54e0a7f8a8
* feat: 凍結された場合のダイアログを実装 * Update CHANGELOG.md * Update basic.js * improve error handling * cypressなんもわからん * Update basic.js
138 lines
3.4 KiB
TypeScript
138 lines
3.4 KiB
TypeScript
import { del, get, set } from '@client/scripts/idb-proxy';
|
|
import { reactive } from 'vue';
|
|
import { apiUrl } from '@client/config';
|
|
import { waiting } from '@client/os';
|
|
import { unisonReload, reloadChannel } from '@client/scripts/unison-reload';
|
|
import { showSuspendedDialog } from './scripts/show-suspended-dialog';
|
|
|
|
// TODO: 他のタブと永続化されたstateを同期
|
|
|
|
type Account = {
|
|
id: string;
|
|
token: string;
|
|
isModerator: boolean;
|
|
isAdmin: boolean;
|
|
isDeleted: boolean;
|
|
};
|
|
|
|
const data = localStorage.getItem('account');
|
|
|
|
// TODO: 外部からはreadonlyに
|
|
export const $i = data ? reactive(JSON.parse(data) as Account) : null;
|
|
|
|
export async function signout() {
|
|
waiting();
|
|
localStorage.removeItem('account');
|
|
|
|
//#region Remove account
|
|
const accounts = await getAccounts();
|
|
accounts.splice(accounts.findIndex(x => x.id === $i.id), 1);
|
|
|
|
if (accounts.length > 0) await set('accounts', accounts);
|
|
else await del('accounts');
|
|
//#endregion
|
|
|
|
//#region Remove service worker registration
|
|
try {
|
|
if (navigator.serviceWorker.controller) {
|
|
const registration = await navigator.serviceWorker.ready;
|
|
const push = await registration.pushManager.getSubscription();
|
|
if (push) {
|
|
await fetch(`${apiUrl}/sw/unregister`, {
|
|
method: 'POST',
|
|
body: JSON.stringify({
|
|
i: $i.token,
|
|
endpoint: push.endpoint,
|
|
}),
|
|
});
|
|
}
|
|
}
|
|
|
|
if (accounts.length === 0) {
|
|
await navigator.serviceWorker.getRegistrations()
|
|
.then(registrations => {
|
|
return Promise.all(registrations.map(registration => registration.unregister()));
|
|
});
|
|
}
|
|
} catch (e) {}
|
|
//#endregion
|
|
|
|
document.cookie = `igi=; path=/`;
|
|
|
|
if (accounts.length > 0) login(accounts[0].token);
|
|
else unisonReload();
|
|
}
|
|
|
|
export async function getAccounts(): Promise<{ id: Account['id'], token: Account['token'] }[]> {
|
|
return (await get('accounts')) || [];
|
|
}
|
|
|
|
export async function addAccount(id: Account['id'], token: Account['token']) {
|
|
const accounts = await getAccounts();
|
|
if (!accounts.some(x => x.id === id)) {
|
|
await set('accounts', accounts.concat([{ id, token }]));
|
|
}
|
|
}
|
|
|
|
function fetchAccount(token): Promise<Account> {
|
|
return new Promise((done, fail) => {
|
|
// Fetch user
|
|
fetch(`${apiUrl}/i`, {
|
|
method: 'POST',
|
|
body: JSON.stringify({
|
|
i: token
|
|
})
|
|
})
|
|
.then(res => res.json())
|
|
.then(res => {
|
|
if (res.error) {
|
|
if (res.error.id === 'a8c724b3-6e9c-4b46-b1a8-bc3ed6258370') {
|
|
showSuspendedDialog().then(() => {
|
|
signout();
|
|
});
|
|
} else {
|
|
signout();
|
|
}
|
|
} else {
|
|
res.token = token;
|
|
done(res);
|
|
}
|
|
})
|
|
.catch(fail);
|
|
});
|
|
}
|
|
|
|
export function updateAccount(data) {
|
|
for (const [key, value] of Object.entries(data)) {
|
|
$i[key] = value;
|
|
}
|
|
localStorage.setItem('account', JSON.stringify($i));
|
|
}
|
|
|
|
export function refreshAccount() {
|
|
return fetchAccount($i.token).then(updateAccount);
|
|
}
|
|
|
|
export async function login(token: Account['token'], redirect?: string) {
|
|
waiting();
|
|
if (_DEV_) console.log('logging as token ', token);
|
|
const me = await fetchAccount(token);
|
|
localStorage.setItem('account', JSON.stringify(me));
|
|
await addAccount(me.id, token);
|
|
|
|
if (redirect) {
|
|
reloadChannel.postMessage('reload');
|
|
location.href = redirect;
|
|
return;
|
|
}
|
|
|
|
unisonReload();
|
|
}
|
|
|
|
// このファイルに書きたくないけどここに書かないと何故かVeturが認識しない
|
|
declare module '@vue/runtime-core' {
|
|
interface ComponentCustomProperties {
|
|
$i: typeof $i;
|
|
}
|
|
}
|