This commit is contained in:
fly_mc 2024-10-23 22:49:53 +08:00
parent a3515d7d5a
commit 938b9d5896

View file

@ -1,8 +1,3 @@
/*
* SPDX-FileCopyrightText: syuilo and misskey-project
* SPDX-License-Identifier: AGPL-3.0-only
*/
import { get } from 'idb-keyval'; import { get } from 'idb-keyval';
import * as Misskey from 'misskey-js'; import * as Misskey from 'misskey-js';
import type { PushNotificationDataMap } from '@/types.js'; import type { PushNotificationDataMap } from '@/types.js';
@ -12,99 +7,37 @@ import { createEmptyNotification, createNotification } from '@/scripts/create-no
import { swLang } from '@/scripts/lang.js'; import { swLang } from '@/scripts/lang.js';
import * as swos from '@/scripts/operations.js'; import * as swos from '@/scripts/operations.js';
const CACHE_NAME = 'pari-cache-${_VERSION_}'; const STATIC_ASSETS = [
const urlsToCache = [
'/manifest.json',
'/assets', '/assets',
'/emoji', '/emoji',
'/twemoji', '/twemoji',
'/fluent-emoji', '/fluent-emoji',
'/vite', '/vite',
'/identicon',
'/proxy'
]; ];
globalThis.addEventListener('install', (event) => { const STATIC_CACHE_NAME = `static-cache-${_VERSION_}`;
event.waitUntil( const LANG_CACHE_NAME = swLang.cacheName;
caches.open(CACHE_NAME)
.then((cache) => cache.addAll(urlsToCache)) globalThis.addEventListener('install', (ev) => {
ev.waitUntil(
(async () => {
const cache = await caches.open(STATIC_CACHE_NAME);
await cache.addAll(STATIC_ASSETS);
})(),
); );
}); });
globalThis.addEventListener('activate', (event) => { globalThis.addEventListener('activate', ev => {
const cacheWhitelist = [CACHE_NAME, swLang.cacheName]; ev.waitUntil(
event.waitUntil( (async () => {
caches.keys().then((cacheNames) => { const cacheNames = await caches.keys();
return Promise.all( const deletePromises = cacheNames
cacheNames.map((cacheName) => { .filter(name => name !== STATIC_CACHE_NAME && name !== LANG_CACHE_NAME)
if (cacheWhitelist.indexOf(cacheName) === -1) { .map(name => caches.delete(name));
return caches.delete(cacheName);
} await Promise.all(deletePromises);
}) await globalThis.clients.claim();
); })(),
}).then(() => globalThis.clients.claim())
);
});
globalThis.addEventListener('fetch', (event) => {
let isHTMLRequest = false;
if (event.request.headers.get('sec-fetch-dest') === 'document' ||
event.request.headers.get('accept')?.includes('/html') ||
event.request.url.endsWith('/')) {
isHTMLRequest = true;
}
if (isHTMLRequest) {
event.respondWith(
fetch(event.request)
.catch(async () => {
const html = await offlineContentHTML();
return new Response(html, {
status: 200,
headers: {
'content-type': 'text/html',
},
});
})
);
return;
}
event.respondWith(
caches.match(event.request)
.then((response) => {
if (response) {
return response;
}
return fetch(event.request).then(
(response) => {
if (!response || response.status !== 200 || response.type !== 'basic') {
return response;
}
const responseToCache = response.clone();
caches.open(CACHE_NAME)
.then((cache) => {
cache.put(event.request, responseToCache);
});
return response;
}
).catch(async () => {
if (isHTMLRequest) {
const html = await offlineContentHTML();
return new Response(html, {
status: 200,
headers: {
'content-type': 'text/html',
},
});
}
throw new Error('Failed to fetch');
});
})
); );
}); });
@ -119,6 +52,70 @@ async function offlineContentHTML() {
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 => {
const url = new URL(ev.request.url);
const isStaticAsset = STATIC_ASSETS.some(path => url.pathname.startsWith(path));
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 (isStaticAsset) {
ev.respondWith(
caches.match(ev.request)
.then(response => {
if (response) {
return response;
}
return fetch(ev.request).then(response => {
if (response.status === 200) {
const responseClone = response.clone();
caches.open(STATIC_CACHE_NAME).then(cache => {
cache.put(ev.request, responseClone);
});
}
return response;
});
})
.catch(() => {
if (isHTMLRequest) {
return offlineContentHTML().then(html => {
return new Response(html, {
status: 200,
headers: {
'content-type': 'text/html',
},
});
});
}
}),
);
return;
}
if (isHTMLRequest) {
ev.respondWith(
fetch(ev.request)
.catch(async () => {
const html = await offlineContentHTML();
return new Response(html, {
status: 200,
headers: {
'content-type': 'text/html',
},
});
}),
);
return;
}
});
globalThis.addEventListener('push', ev => { globalThis.addEventListener('push', ev => {
ev.waitUntil(globalThis.clients.matchAll({ ev.waitUntil(globalThis.clients.matchAll({
includeUncontrolled: true, includeUncontrolled: true,
@ -144,6 +141,10 @@ globalThis.addEventListener('push', ev => {
globalThis.addEventListener('notificationclick', (ev: ServiceWorkerGlobalScopeEventMap['notificationclick']) => { globalThis.addEventListener('notificationclick', (ev: ServiceWorkerGlobalScopeEventMap['notificationclick']) => {
ev.waitUntil((async (): Promise<void> => { ev.waitUntil((async (): Promise<void> => {
if (_DEV_) {
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;
@ -165,45 +166,57 @@ globalThis.addEventListener('notificationclick', (ev: ServiceWorkerGlobalScopeEv
if ('note' in data.body) await swos.api('notes/create', loginId, { renoteId: data.body.note.id }); if ('note' in data.body) await swos.api('notes/create', loginId, { renoteId: data.body.note.id });
break; break;
case 'accept': case 'accept':
if (data.body.type === 'receiveFollowRequest') { switch (data.body.type) {
await swos.api('following/requests/accept', loginId, { userId: data.body.userId }); case 'receiveFollowRequest':
await swos.api('following/requests/accept', loginId, { userId: data.body.userId });
break;
} }
break; break;
case 'reject': case 'reject':
if (data.body.type === 'receiveFollowRequest') { switch (data.body.type) {
await swos.api('following/requests/reject', loginId, { userId: data.body.userId }); case 'receiveFollowRequest':
await swos.api('following/requests/reject', loginId, { userId: data.body.userId });
break;
} }
break; break;
case 'showFollowRequests': case 'showFollowRequests':
client = await swos.openClient('push', '/my/follow-requests', loginId); client = await swos.openClient('push', '/my/follow-requests', loginId);
break; break;
default: default:
if (data.body.type === 'receiveFollowRequest') { switch (data.body.type) {
client = await swos.openClient('push', '/my/follow-requests', loginId); case 'receiveFollowRequest':
} else if (data.body.type === 'reaction') { client = await swos.openClient('push', '/my/follow-requests', loginId);
client = await swos.openNote(data.body.note.id, loginId); break;
} else if ('note' in data.body) { case 'reaction':
client = await swos.openNote(data.body.note.id, loginId); client = await swos.openNote(data.body.note.id, loginId);
} else if ('user' in data.body) { break;
client = await swos.openUser(Misskey.acct.toString(data.body.user), loginId); default:
if ('note' in data.body) {
client = await swos.openNote(data.body.note.id, loginId);
} else if ('user' in data.body) {
client = await swos.openUser(Misskey.acct.toString(data.body.user), loginId);
}
break;
} }
break;
} }
break; break;
case 'unreadAntennaNote': case 'unreadAntennaNote':
client = await swos.openAntenna(data.body.antenna.id, loginId); client = await swos.openAntenna(data.body.antenna.id, loginId);
break; break;
default: default:
if (action === 'markAllAsRead') { switch (action) {
await globalThis.registration.getNotifications() case 'markAllAsRead':
.then(notifications => notifications.forEach(n => n.tag !== 'read_notification' && n.close())); await globalThis.registration.getNotifications()
await get<Pick<Misskey.entities.SignupResponse, 'id' | 'token'>[]>('accounts').then(accounts => { .then(notifications => notifications.forEach(n => n.tag !== 'read_notification' && n.close()));
return Promise.all((accounts ?? []).map(async account => { await get<Pick<Misskey.entities.SignupResponse, 'id' | 'token'>[]>('accounts').then(accounts => {
await swos.sendMarkAllAsRead(account.id); return Promise.all((accounts ?? []).map(async account => {
})); await swos.sendMarkAllAsRead(account.id);
}); }));
} else if (action === 'settings') { });
client = await swos.openClient('push', '/settings/notifications', loginId); break;
case 'settings':
client = await swos.openClient('push', '/settings/notifications', loginId);
break;
} }
} }
@ -231,12 +244,13 @@ globalThis.addEventListener('notificationclose', (ev: ServiceWorkerGlobalScopeEv
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') { switch (ev.data) {
await caches.keys() case 'clear':
.then(cacheNames => Promise.all( await caches.keys()
cacheNames.map(name => caches.delete(name)), .then(cacheNames => Promise.all(
)); cacheNames.map(name => caches.delete(name)),
return; ));
return;
} }
if (typeof ev.data === 'object') { if (typeof ev.data === 'object') {