yume/paricafe
1
0
Fork 0
mirror of https://github.com/paricafe/misskey.git synced 2024-11-24 07:06:44 -06:00
Code Issues Projects Releases Packages Wiki Activity

sw: lint

Browse source
This commit is contained in:
fly_mc 2024-11-21 23:06:10 +08:00
parent a0fe3feb48
commit 67d8393724
1 changed files with 286 additions and 275 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

561
packages/sw/src/sw.ts
View file

@ -18,338 +18,349 @@ const STORAGE_QUOTA = 2 * 1024 * 1024 * 1024; // 2GB in bytes
const EMOJI_PATH = '/emoji/'; const EMOJI_PATH = '/emoji/';
async function requestStorageQuota() { async function requestStorageQuota() {
try { try {
if (!('storage' in navigator)) { if (!('storage' in navigator)) {
throw new Error('Storage API not supported'); throw new Error('Storage API not supported');
} }
if ('persist' in navigator) { if ('persist' in navigator) {
const isPersisted = await navigator.storage.persist(); const isPersisted = await navigator.storage.persist();
console.log(`Persisted storage granted: ${isPersisted}`); console.log(`Persisted storage granted: ${isPersisted}`);
} }
if ('estimate' in navigator.storage) { if ('estimate' in navigator.storage) {
const estimate = await navigator.storage.estimate(); const estimate = await navigator.storage.estimate();
const currentQuota = estimate.quota || 0; const currentQuota = estimate.quota || 0;
const currentUsage = estimate.usage || 0; const currentUsage = estimate.usage || 0;
console.log(`Current storage: ${currentUsage} of ${currentQuota} bytes used`); console.log(`Current storage: ${currentUsage} of ${currentQuota} bytes used`);
if ('requestQuota' in navigator.storage) { if ('requestQuota' in navigator.storage) {
try { try {
const grantedQuota = await navigator.storage.requestQuota(STORAGE_QUOTA); const grantedQuota = await navigator.storage.requestQuota(STORAGE_QUOTA);
console.log(`Granted quota: ${grantedQuota} bytes`); console.log(`Granted quota: ${grantedQuota} bytes`);
} catch (quotaError) { } catch (quotaError) {
console.warn('Failed to request additional quota:', quotaError); console.warn('Failed to request additional quota:', quotaError);
} }
} }
return { return {
quota: currentQuota, quota: currentQuota,
usage: currentUsage usage: currentUsage,
}; };
} else { } else {
console.warn('Storage estimate API not supported'); console.warn('Storage estimate API not supported');
return { return {
quota: 0, quota: 0,
usage: 0 usage: 0,
}; };
} }
} catch (error) { } catch (error) {
console.error('Failed to request storage quota:', error); console.error('Failed to request storage quota:', error);
return { return {
quota: 0, quota: 0,
usage: 0 usage: 0,
}; };
} }
} }
async function manageStorageSpace(newRequestSize = 0) { async function manageStorageSpace(newRequestSize = 0) {
try { try {
if (!('storage' in navigator)) { if (!('storage' in navigator)) {
console.warn('Storage API not supported'); console.warn('Storage API not supported');
return; return;
} }
const estimate = await navigator.storage.estimate(); const estimate = await navigator.storage.estimate();
const currentUsage = estimate.usage || 0; const currentUsage = estimate.usage || 0;
const currentQuota = estimate.quota || STORAGE_QUOTA; const currentQuota = estimate.quota || STORAGE_QUOTA;
if (currentUsage + newRequestSize > currentQuota) { if (currentUsage + newRequestSize > currentQuota) {
console.log(`Storage space needed. Current usage: ${currentUsage}, Need: ${newRequestSize}, Quota: ${currentQuota}`); console.log(`Storage space needed. Current usage: ${currentUsage}, Need: ${newRequestSize}, Quota: ${currentQuota}`);
const cache = await caches.open(STATIC_CACHE_NAME); const cache = await caches.open(STATIC_CACHE_NAME);
const keys = await cache.keys(); const keys = await cache.keys();
const emojiKeys = keys.filter(request => request.url.includes(EMOJI_PATH)); const emojiKeys = keys.filter(request => request.url.includes(EMOJI_PATH));
console.log(`Found ${emojiKeys.length} emoji caches to manage`); console.log(`Found ${emojiKeys.length} emoji caches to manage`);
if (emojiKeys.length > 0) { if (emojiKeys.length > 0) {
for (const key of emojiKeys) { for (const key of emojiKeys) {
await cache.delete(key); await cache.delete(key);
console.log(`Deleted cache for: ${key.url}`); console.log(`Deleted cache for: ${key.url}`);
const newEstimate = await navigator.storage.estimate(); const newEstimate = await navigator.storage.estimate();
const newUsage = newEstimate.usage || 0; const newUsage = newEstimate.usage || 0;
if (newUsage + newRequestSize <= currentQuota) { if (newUsage + newRequestSize <= currentQuota) {
console.log(`Sufficient space cleared. New usage: ${newUsage}`); console.log(`Sufficient space cleared. New usage: ${newUsage}`);
break; break;
} }
} }
} else { } else {
console.warn('No emoji caches available for cleanup'); console.warn('No emoji caches available for cleanup');
} }
} }
} catch (error) { } catch (error) {
console.error('Failed to manage storage space:', error); console.error('Failed to manage storage space:', error);
} }
} }
async function cacheWithFallback(cache, paths) { async function cacheWithFallback(cache, paths) {
for (const path of paths) { for (const path of paths) {
try { try {
const response = await fetch(new Request(path, { credentials: 'same-origin' })); const response = await fetch(new Request(path, { credentials: 'same-origin' }));
const blob = await response.clone().blob(); const blob = await response.clone().blob();
await manageStorageSpace(blob.size); await manageStorageSpace(blob.size);
await cache.put(new Request(path, { credentials: 'same-origin' }), response); await cache.put(new Request(path, { credentials: 'same-origin' }), response);
} catch (error) { } catch (error) {
console.error(`Failed to cache ${path}:`, error); console.error(`Failed to cache ${path}:`, error);
} }
} }
} }
globalThis.addEventListener('install', (ev) => { globalThis.addEventListener('install', (ev) => {
ev.waitUntil((async () => { ev.waitUntil((async () => {
await requestStorageQuota(); await requestStorageQuota();
const cache = await caches.open(STATIC_CACHE_NAME); const cache = await caches.open(STATIC_CACHE_NAME);
await cacheWithFallback(cache, PATHS_TO_CACHE); await cacheWithFallback(cache, PATHS_TO_CACHE);
await globalThis.skipWaiting(); await globalThis.skipWaiting();
})()); })());
}); });
globalThis.addEventListener('activate', ev => { globalThis.addEventListener('activate', (ev) => {
ev.waitUntil( ev.waitUntil(
caches.keys() caches.keys()
.then(cacheNames => Promise.all( .then(cacheNames => Promise.all(
cacheNames cacheNames
.filter((v) => v !== STATIC_CACHE_NAME && v !== swLang.cacheName) .filter((v) => v !== STATIC_CACHE_NAME && v !== swLang.cacheName)
.map(name => caches.delete(name)), .map(name => caches.delete(name)),
)) ))
.then(() => globalThis.clients.claim()), .then(() => globalThis.clients.claim()),
); );
}); });
async function offlineContentHTML() { async function offlineContentHTML() {
const i18n = await (swLang.i18n ?? swLang.fetchLocale()) as Partial<I18n<Locale>>; const i18n = await (swLang.i18n ?? swLang.fetchLocale()) as Partial<I18n<Locale>>;
const messages = { const messages = {
title: i18n.ts?._offlineScreen.title ?? 'Offline - Could not connect to server', title: i18n.ts?._offlineScreen.title ?? 'Offline - Could not connect to server',
header: i18n.ts?._offlineScreen.header ?? 'Could not connect to server', header: i18n.ts?._offlineScreen.header ?? 'Could not connect to server',
reload: i18n.ts?.reload ?? 'Reload', reload: i18n.ts?.reload ?? 'Reload',
}; };
return `<!DOCTYPE html><html lang="en"><head><meta charset="UTF-8"><meta content="width=device-width,initial-scale=1"name="viewport"><title>${messages.title}</title><style>body{background-color:#0c1210;color:#dee7e4;font-family:Hiragino Maru Gothic Pro,BIZ UDGothic,Roboto,HelveticaNeue,Arial,sans-serif;line-height:1.35;display:flex;flex-direction:column;align-items:center;justify-content:center;min-height:100vh;margin:0;padding:24px;box-sizing:border-box}.icon{max-width:120px;width:100%;height:auto;margin-bottom:20px;}.message{text-align:center;font-size:20px;font-weight:700;margin-bottom:20px}.version{text-align:center;font-size:90%;margin-bottom:20px}button{padding:7px 14px;min-width:100px;font-weight:700;font-family:Hiragino Maru Gothic Pro,BIZ UDGothic,Roboto,HelveticaNeue,Arial,sans-serif;line-height:1.35;border-radius:99rem;background-color:#ff82ab;color:#192320;border:none;cursor:pointer;-webkit-tap-highlight-color:transparent}button:hover{background-color:#fac5eb}</style></head><body><svg class="icon"fill="none"height="24"stroke="currentColor"stroke-linecap="round"stroke-linejoin="round"stroke-width="2"viewBox="0 0 24 24"width="24"xmlns="http://www.w3.org/2000/svg"><path d="M0 0h24v24H0z"fill="none"stroke="none"/><path d="M9.58 5.548c.24 -.11 .492 -.207 .752 -.286c1.88 -.572 3.956 -.193 5.444 1c1.488 1.19 2.162 3.007 1.77 4.769h.99c1.913 0 3.464 1.56 3.464 3.486c0 .957 -.383 1.824 -1.003 2.454m-2.997 1.033h-11.343c-2.572 -.004 -4.657 -2.011 -4.657 -4.487c0 -2.475 2.085 -4.482 4.657 -4.482c.13 -.582 .37 -1.128 .7 -1.62"/><path d="M3 3l18 18"/></svg><div class="message">${messages.header}</div><div class="version">v${_VERSION_}</div><button onclick="reloadPage()">${messages.reload}</button><script>function reloadPage(){location.reload(!0)}</script></body></html>`; return `<!DOCTYPE html><html lang="en"><head><meta charset="UTF-8"><meta content="width=device-width,initial-scale=1" name="viewport"><title>${messages.title}</title><style>body{background-color:#0c1210;color:#dee7e4;font-family:Hiragino Maru Gothic Pro,BIZ UDGothic,Roboto,HelveticaNeue,Arial,sans-serif;line-height:1.35;display:flex;flex-direction:column;align-items:center;justify-content:center;min-height:100vh;margin:0;padding:24px;box-sizing:border-box}.icon{max-width:120px;width:100%;height:auto;margin-bottom:20px;}.message{text-align:center;font-size:20px;font-weight:700;margin-bottom:20px}.version{text-align:center;font-size:90%;margin-bottom:20px}button{padding:7px 14px;min-width:100px;font-weight:700;font-family:Hiragino Maru Gothic Pro,BIZ UDGothic,Roboto,HelveticaNeue,Arial,sans-serif;line-height:1.35;border-radius:99rem;background-color:#ff82ab;color:#192320;border:none;cursor:pointer;-webkit-tap-highlight-color:transparent}button:hover{background-color:#fac5eb}</style></head><body><svg class="icon"fill="none"height="24"stroke="currentColor"stroke-linecap="round"stroke-linejoin="round"stroke-width="2"viewBox="0 0 24 24"width="24"xmlns="http://www.w3.org/2000/svg"><path d="M0 0h24v24H0z"fill="none"stroke="none"/><path d="M9.58 5.548c.24 -.11 .492 -.207 .752 -.286c1.88 -.572 3.956 -.193 5.444 1c1.488 1.19 2.162 3.007 1.77 4.769h.99c1.913 0 3.464 1.56 3.464 3.486c0 .957 -.383 1.824 -1.003 2.454m-2.997 1.033h-11.343c-2.572 -.004 -4.657 -2.011 -4.657 -4.487c0 -2.475 2.085 -4.482 4.657 -4.482c.13 -.582 .37 -1.128 .7 -1.62"/><path d="M3 3l18 18"/></svg><div class="message">${messages.header}</div><div class="version">v${_VERSION_}</div><button onclick="reloadPage()">${messages.reload}</button><script>function reloadPage(){location.reload(!0)}</script></body></html>`;
} }
globalThis.addEventListener('fetch', ev => { globalThis.addEventListener('fetch', (ev) => {
const shouldCache = PATHS_TO_CACHE.some(path => ev.request.url.includes(path)); const shouldCache = PATHS_TO_CACHE.some(path => ev.request.url.includes(path));
if (shouldCache) { if (shouldCache) {
ev.respondWith(
caches.match(ev.request)
.then(async response => {
if (response) return response;
const fetchResponse = await fetch(ev.request);
if (!fetchResponse || fetchResponse.status !== 200 || fetchResponse.type !== 'basic') {
return fetchResponse;
}
const blob = await fetchResponse.clone().blob();
await manageStorageSpace(blob.size);
const responseToCache = fetchResponse.clone();
const cache = await caches.open(STATIC_CACHE_NAME);
await cache.put(ev.request, responseToCache);
return fetchResponse;
})
);
return;
}
let isHTMLRequest = false;
if (ev.request.headers.get('sec-fetch-dest') === 'document') {
isHTMLRequest = true;
} else if (ev.request.headers.get('accept')?.includes('/html')) {
isHTMLRequest = true;
} else if (ev.request.url.endsWith('/')) {
isHTMLRequest = true;
}
if (!isHTMLRequest) return;
ev.respondWith( ev.respondWith(
fetch(ev.request) caches.match(ev.request)
.catch(async () => { .then(async (response) => {
const html = await offlineContentHTML(); if (response) return response;
return new Response(html, {
status: 200, const fetchResponse = await fetch(ev.request);
headers: { if (!fetchResponse || fetchResponse.status !== 200 || fetchResponse.type !== 'basic') {
'content-type': 'text/html', return fetchResponse;
}, }
});
}), const blob = await fetchResponse.clone().blob();
await manageStorageSpace(blob.size);
const responseToCache = fetchResponse.clone();
const cache = await caches.open(STATIC_CACHE_NAME);
await cache.put(ev.request, responseToCache);
return fetchResponse;
}),
); );
return;
}
let isHTMLRequest = false;
if (ev.request.headers.get('sec-fetch-dest') === 'document') {
isHTMLRequest = true;
} else if (ev.request.headers.get('accept')?.includes('/html')) {
isHTMLRequest = true;
} else if (ev.request.url.endsWith('index.html')) {
isHTMLRequest = true;
}
if (isHTMLRequest) {
ev.respondWith(
caches.match(ev.request)
.then(async (response) => {
if (response) return response;
const offlineHTML = await offlineContentHTML();
return new Response(offlineHTML, {
headers: { 'Content-Type': 'text/html' },
});
}),
);
}
}); });
globalThis.addEventListener('push', ev => { globalThis.addEventListener('push', (ev) => {
ev.waitUntil(globalThis.clients.matchAll({ ev.waitUntil(
includeUncontrolled: true, globalThis.clients.matchAll({
type: 'window', includeUncontrolled: true,
type: 'window',
}).then(async () => { }).then(async () => {
const data: PushNotificationDataMap[keyof PushNotificationDataMap] = ev.data?.json(); const data: PushNotificationDataMap[keyof PushNotificationDataMap] = ev.data?.json();
switch (data.type) { switch (data.type) {
case 'notification': case 'notification':
case 'unreadAntennaNote': case 'unreadAntennaNote':
if (Date.now() - data.dateTime > 1000 * 60 * 60 * 24) break; if (Date.now() - data.dateTime > 1000 * 60 * 60 * 24) break;
return createNotification(data); return createNotification(data);
case 'readAllNotifications':
await globalThis.registration.getNotifications()
.then(notifications => notifications.forEach(n => n.tag !== 'read_notification' && n.close()));
break;
}
await createEmptyNotification(); case 'readAllNotifications':
return; await globalThis.registration.getNotifications()
})); .then(notifications => {
notifications.forEach(n => {
if (n.tag !== 'read_notification') n.close();
});
});
break;
}
await createEmptyNotification();
}),
);
}); });
globalThis.addEventListener('notificationclick', (ev: ServiceWorkerGlobalScopeEventMap['notificationclick']) => { globalThis.addEventListener('notificationclick', (ev: ServiceWorkerGlobalScopeEventMap['notificationclick']) => {
ev.waitUntil((async (): Promise<void> => { ev.waitUntil((async (): Promise<void> => {
if (_DEV_) { if (_DEV_) {
console.log('notificationclick', ev.action, ev.notification.data); console.log('notificationclick', ev.action, ev.notification.data);
} }
const { action, notification } = ev; const { action, notification } = ev;
const data: PushNotificationDataMap[keyof PushNotificationDataMap] = notification.data ?? {}; const data: PushNotificationDataMap[keyof PushNotificationDataMap] = notification.data ?? {};
const { userId: loginId } = data; const { userId: loginId } = data;
let client: WindowClient | null = null; let client: WindowClient | null = null;
switch (data.type) { switch (data.type) {
case 'notification': case 'notification':
switch (action) { switch (action) {
case 'follow': case 'follow':
if ('userId' in data.body) await swos.api('following/create', loginId, { userId: data.body.userId }); if ('userId' in data.body) {
break; await swos.api('following/create', loginId, { userId: data.body.userId });
case 'showUser': }
if ('user' in data.body) client = await swos.openUser(Misskey.acct.toString(data.body.user), loginId); break;
break; case 'showUser':
case 'reply': if ('user' in data.body) {
if ('note' in data.body) client = await swos.openPost({ reply: data.body.note }, loginId); client = await swos.openUser(Misskey.acct.toString(data.body.user), loginId);
break; }
case 'renote': break;
if ('note' in data.body) await swos.api('notes/create', loginId, { renoteId: data.body.note.id }); case 'reply':
break; if ('note' in data.body) {
case 'accept': client = await swos.openPost({ reply: data.body.note }, loginId);
switch (data.body.type) { }
case 'receiveFollowRequest': break;
await swos.api('following/requests/accept', loginId, { userId: data.body.userId }); case 'renote':
break; if ('note' in data.body) {
} await swos.api('notes/create', loginId, { renoteId: data.body.note.id });
break; }
case 'reject': break;
switch (data.body.type) { case 'accept':
case 'receiveFollowRequest': if (data.body.type === 'receiveFollowRequest') {
await swos.api('following/requests/reject', loginId, { userId: data.body.userId }); await swos.api('following/requests/accept', loginId, { userId: data.body.userId });
break; }
} break;
break; case 'reject':
case 'showFollowRequests': if (data.body.type === 'receiveFollowRequest') {
client = await swos.openClient('push', '/my/follow-requests', loginId); await swos.api('following/requests/reject', loginId, { userId: data.body.userId });
break; }
default: break;
switch (data.body.type) { case 'showFollowRequests':
case 'receiveFollowRequest': client = await swos.openClient('push', '/my/follow-requests', loginId);
client = await swos.openClient('push', '/my/follow-requests', loginId); break;
break; default:
case 'reaction': if (data.body.type === 'receiveFollowRequest') {
client = await swos.openNote(data.body.note.id, loginId); client = await swos.openClient('push', '/my/follow-requests', loginId);
break; } else if (data.body.type === 'reaction') {
default: client = await swos.openNote(data.body.note.id, loginId);
if ('note' in data.body) { } else if ('note' in data.body) {
client = await swos.openNote(data.body.note.id, loginId); client = await swos.openNote(data.body.note.id, loginId);
} else if ('user' in data.body) { } else if ('user' in data.body) {
client = await swos.openUser(Misskey.acct.toString(data.body.user), loginId); client = await swos.openUser(Misskey.acct.toString(data.body.user), loginId);
} }
break; break;
}
}
break;
case 'unreadAntennaNote':
client = await swos.openAntenna(data.body.antenna.id, loginId);
break;
default:
switch (action) {
case 'markAllAsRead':
await globalThis.registration.getNotifications()
.then(notifications => notifications.forEach(n => n.tag !== 'read_notification' && n.close()));
await get<Pick<Misskey.entities.SignupResponse, 'id' | 'token'>[]>('accounts').then(accounts => {
return Promise.all((accounts ?? []).map(async account => {
await swos.sendMarkAllAsRead(account.id);
}));
});
break;
case 'settings':
client = await swos.openClient('push', '/settings/notifications', loginId);
break;
}
} }
break;
if (client) { case 'unreadAntennaNote':
client.focus(); client = await swos.openAntenna(data.body.antenna.id, loginId);
} break;
if (data.type === 'notification') {
await swos.sendMarkAllAsRead(loginId);
}
notification.close(); default:
})()); switch (action) {
case 'markAllAsRead':
await globalThis.registration.getNotifications()
.then(notifications => notifications.forEach(n => {
if (n.tag !== 'read_notification') n.close();
}));
await get<Pick<Misskey.entities.SignupResponse, 'id' | 'token'>[]>('accounts')
.then(accounts => {
return Promise.all((accounts ?? []).map(async account => {
await swos.sendMarkAllAsRead(account.id);
}));
});
break;
case 'settings':
client = await swos.openClient('push', '/settings/notifications', loginId);
break;
}
}
if (client) {
client.focus();
}
if (data.type === 'notification') {
await swos.sendMarkAllAsRead(loginId);
}
notification.close();
})());
}); });
globalThis.addEventListener('notificationclose', (ev: ServiceWorkerGlobalScopeEventMap['notificationclose']) => { globalThis.addEventListener('notificationclose', (ev: ServiceWorkerGlobalScopeEventMap['notificationclose']) => {
const data: PushNotificationDataMap[keyof PushNotificationDataMap] = ev.notification.data; const data: PushNotificationDataMap[keyof PushNotificationDataMap] = ev.notification.data;
ev.waitUntil((async (): Promise<void> => { ev.waitUntil((async (): Promise<void> => {
if (data.type === 'notification') { if (data.type === 'notification') {
await swos.sendMarkAllAsRead(data.userId); await swos.sendMarkAllAsRead(data.userId);
} }
return; })());
})());
}); });
globalThis.addEventListener('message', (ev: ServiceWorkerGlobalScopeEventMap['message']) => { globalThis.addEventListener('message', (ev: ServiceWorkerGlobalScopeEventMap['message']) => {
ev.waitUntil((async (): Promise<void> => { ev.waitUntil((async (): Promise<void> => {
if (ev.data === 'clear') { if (ev.data === 'clear') {
await caches.keys() await caches.keys()
.then(cacheNames => Promise.all( .then(cacheNames => Promise.all(
cacheNames.map(name => caches.delete(name)), cacheNames.map(name => caches.delete(name)),
)); ));
return; return;
} }
if (typeof ev.data === 'object') { if (typeof ev.data === 'object') {
const otype = Object.prototype.toString.call(ev.data).slice(8, -1).toLowerCase(); const otype = Object.prototype.toString.call(ev.data).slice(8, -1).toLowerCase();
if (otype === 'object') { if (otype === 'object') {
if (ev.data.msg === 'initialize') { if (ev.data.msg === 'initialize') {
swLang.setLang(ev.data.lang); swLang.setLang(ev.data.lang);
}
}
} }
})()); }
}
})());
}); });