summaryrefslogtreecommitdiff
path: root/packages/sw/src/scripts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/sw/src/scripts')
-rw-r--r--packages/sw/src/scripts/create-notification.ts237
-rw-r--r--packages/sw/src/scripts/get-account-from-id.ts7
-rw-r--r--packages/sw/src/scripts/get-user-name.ts3
-rw-r--r--packages/sw/src/scripts/i18n.ts29
-rw-r--r--packages/sw/src/scripts/lang.ts47
-rw-r--r--packages/sw/src/scripts/login-id.ts11
-rw-r--r--packages/sw/src/scripts/notification-read.ts50
-rw-r--r--packages/sw/src/scripts/operations.ts70
8 files changed, 454 insertions, 0 deletions
diff --git a/packages/sw/src/scripts/create-notification.ts b/packages/sw/src/scripts/create-notification.ts
new file mode 100644
index 0000000000..6d7ba7d524
--- /dev/null
+++ b/packages/sw/src/scripts/create-notification.ts
@@ -0,0 +1,237 @@
+/*
+ * Notification manager for SW
+ */
+declare var self: ServiceWorkerGlobalScope;
+
+import { swLang } from '@/scripts/lang';
+import { cli } from '@/scripts/operations';
+import { pushNotificationDataMap } from '@/types';
+import getUserName from '@/scripts/get-user-name';
+import { I18n } from '@/scripts/i18n';
+import { getAccountFromId } from '@/scripts/get-account-from-id';
+
+export async function createNotification<K extends keyof pushNotificationDataMap>(data: pushNotificationDataMap[K]) {
+ const n = await composeNotification(data);
+
+ if (n) {
+ return self.registration.showNotification(...n);
+ } else {
+ console.error('Could not compose notification', data);
+ return createEmptyNotification();
+ }
+}
+
+async function composeNotification<K extends keyof pushNotificationDataMap>(data: pushNotificationDataMap[K]): Promise<[string, NotificationOptions] | null> {
+ if (!swLang.i18n) swLang.fetchLocale();
+ const i18n = await swLang.i18n as I18n<any>;
+ const { t } = i18n;
+ switch (data.type) {
+ /*
+ case 'driveFileCreated': // TODO (Server Side)
+ return [t('_notification.fileUploaded'), {
+ body: body.name,
+ icon: body.url,
+ data
+ }];
+ */
+ case 'notification':
+ switch (data.body.type) {
+ case 'follow':
+ // users/showの型定義をswos.apiへ当てはめるのが困難なのでapiFetch.requestを直接使用
+ const account = await getAccountFromId(data.userId);
+ if (!account) return null;
+ const userDetail = await cli.request('users/show', { userId: data.body.userId }, account.token);
+ return [t('_notification.youWereFollowed'), {
+ body: getUserName(data.body.user),
+ icon: data.body.user.avatarUrl,
+ data,
+ actions: userDetail.isFollowing ? [] : [
+ {
+ action: 'follow',
+ title: t('_notification._actions.followBack')
+ }
+ ],
+ }];
+
+ case 'mention':
+ return [t('_notification.youGotMention', { name: getUserName(data.body.user) }), {
+ body: data.body.note.text || '',
+ icon: data.body.user.avatarUrl,
+ data,
+ actions: [
+ {
+ action: 'reply',
+ title: t('_notification._actions.reply')
+ }
+ ],
+ }];
+
+ case 'reply':
+ return [t('_notification.youGotReply', { name: getUserName(data.body.user) }), {
+ body: data.body.note.text || '',
+ icon: data.body.user.avatarUrl,
+ data,
+ actions: [
+ {
+ action: 'reply',
+ title: t('_notification._actions.reply')
+ }
+ ],
+ }];
+
+ case 'renote':
+ return [t('_notification.youRenoted', { name: getUserName(data.body.user) }), {
+ body: data.body.note.text || '',
+ icon: data.body.user.avatarUrl,
+ data,
+ actions: [
+ {
+ action: 'showUser',
+ title: getUserName(data.body.user)
+ }
+ ],
+ }];
+
+ case 'quote':
+ return [t('_notification.youGotQuote', { name: getUserName(data.body.user) }), {
+ body: data.body.note.text || '',
+ icon: data.body.user.avatarUrl,
+ data,
+ actions: [
+ {
+ action: 'reply',
+ title: t('_notification._actions.reply')
+ },
+ ...((data.body.note.visibility === 'public' || data.body.note.visibility === 'home') ? [
+ {
+ action: 'renote',
+ title: t('_notification._actions.renote')
+ }
+ ] : [])
+ ],
+ }];
+
+ case 'reaction':
+ return [`${data.body.reaction} ${getUserName(data.body.user)}`, {
+ body: data.body.note.text || '',
+ icon: data.body.user.avatarUrl,
+ data,
+ actions: [
+ {
+ action: 'showUser',
+ title: getUserName(data.body.user)
+ }
+ ],
+ }];
+
+ case 'pollVote':
+ return [t('_notification.youGotPoll', { name: getUserName(data.body.user) }), {
+ body: data.body.note.text || '',
+ icon: data.body.user.avatarUrl,
+ data,
+ }];
+
+ case 'pollEnded':
+ return [t('_notification.pollEnded'), {
+ body: data.body.note.text || '',
+ data,
+ }];
+
+ case 'receiveFollowRequest':
+ return [t('_notification.youReceivedFollowRequest'), {
+ body: getUserName(data.body.user),
+ icon: data.body.user.avatarUrl,
+ data,
+ actions: [
+ {
+ action: 'accept',
+ title: t('accept')
+ },
+ {
+ action: 'reject',
+ title: t('reject')
+ }
+ ],
+ }];
+
+ case 'followRequestAccepted':
+ return [t('_notification.yourFollowRequestAccepted'), {
+ body: getUserName(data.body.user),
+ icon: data.body.user.avatarUrl,
+ data,
+ }];
+
+ case 'groupInvited':
+ return [t('_notification.youWereInvitedToGroup', { userName: getUserName(data.body.user) }), {
+ body: data.body.invitation.group.name,
+ data,
+ actions: [
+ {
+ action: 'accept',
+ title: t('accept')
+ },
+ {
+ action: 'reject',
+ title: t('reject')
+ }
+ ],
+ }];
+
+ case 'app':
+ return [data.body.header || data.body.body, {
+ body: data.body.header && data.body.body,
+ icon: data.body.icon,
+ data
+ }];
+
+ default:
+ return null;
+ }
+ case 'unreadMessagingMessage':
+ if (data.body.groupId === null) {
+ return [t('_notification.youGotMessagingMessageFromUser', { name: getUserName(data.body.user) }), {
+ icon: data.body.user.avatarUrl,
+ tag: `messaging:user:${data.body.userId}`,
+ data,
+ renotify: true,
+ }];
+ }
+ return [t('_notification.youGotMessagingMessageFromGroup', { name: data.body.group.name }), {
+ icon: data.body.user.avatarUrl,
+ tag: `messaging:group:${data.body.groupId}`,
+ data,
+ renotify: true,
+ }];
+ default:
+ return null;
+ }
+}
+
+export async function createEmptyNotification() {
+ return new Promise<void>(async res => {
+ if (!swLang.i18n) swLang.fetchLocale();
+ const i18n = await swLang.i18n as I18n<any>;
+ const { t } = i18n;
+
+ await self.registration.showNotification(
+ t('_notification.emptyPushNotificationMessage'),
+ {
+ silent: true,
+ tag: 'read_notification',
+ }
+ );
+
+ res();
+
+ setTimeout(async () => {
+ for (const n of
+ [
+ ...(await self.registration.getNotifications({ tag: 'user_visible_auto_notification' })),
+ ...(await self.registration.getNotifications({ tag: 'read_notification' }))
+ ]
+ ) {
+ n.close();
+ }
+ }, 1000);
+ });
+}
diff --git a/packages/sw/src/scripts/get-account-from-id.ts b/packages/sw/src/scripts/get-account-from-id.ts
new file mode 100644
index 0000000000..be4cfaeba4
--- /dev/null
+++ b/packages/sw/src/scripts/get-account-from-id.ts
@@ -0,0 +1,7 @@
+import { get } from 'idb-keyval';
+
+export async function getAccountFromId(id: string) {
+ const accounts = await get('accounts') as { token: string; id: string; }[];
+ if (!accounts) console.log('Accounts are not recorded');
+ return accounts.find(e => e.id === id);
+}
diff --git a/packages/sw/src/scripts/get-user-name.ts b/packages/sw/src/scripts/get-user-name.ts
new file mode 100644
index 0000000000..d499ea0203
--- /dev/null
+++ b/packages/sw/src/scripts/get-user-name.ts
@@ -0,0 +1,3 @@
+export default function(user: { name?: string | null, username: string }): string {
+ return user.name || user.username;
+}
diff --git a/packages/sw/src/scripts/i18n.ts b/packages/sw/src/scripts/i18n.ts
new file mode 100644
index 0000000000..3fe88e5514
--- /dev/null
+++ b/packages/sw/src/scripts/i18n.ts
@@ -0,0 +1,29 @@
+export class I18n<T extends Record<string, any>> {
+ public ts: T;
+
+ constructor(locale: T) {
+ this.ts = locale;
+
+ //#region BIND
+ this.t = this.t.bind(this);
+ //#endregion
+ }
+
+ // string にしているのは、ドット区切りでのパス指定を許可するため
+ // なるべくこのメソッド使うよりもlocale直接参照の方がvueのキャッシュ効いてパフォーマンスが良いかも
+ public t(key: string, args?: Record<string, string>): string {
+ try {
+ let str = key.split('.').reduce((o, i) => o[i], this.ts) as unknown as string;
+
+ if (args) {
+ for (const [k, v] of Object.entries(args)) {
+ str = str.replace(`{${k}}`, v);
+ }
+ }
+ return str;
+ } catch (err) {
+ console.warn(`missing localization '${key}'`);
+ return key;
+ }
+ }
+}
diff --git a/packages/sw/src/scripts/lang.ts b/packages/sw/src/scripts/lang.ts
new file mode 100644
index 0000000000..2d05404ef9
--- /dev/null
+++ b/packages/sw/src/scripts/lang.ts
@@ -0,0 +1,47 @@
+/*
+ * Language manager for SW
+ */
+declare var self: ServiceWorkerGlobalScope;
+
+import { get, set } from 'idb-keyval';
+import { I18n } from '@/scripts/i18n';
+
+class SwLang {
+ public cacheName = `mk-cache-${_VERSION_}`;
+
+ public lang: Promise<string> = get('lang').then(async prelang => {
+ if (!prelang) return 'en-US';
+ return prelang;
+ });
+
+ public setLang(newLang: string) {
+ this.lang = Promise.resolve(newLang);
+ set('lang', newLang);
+ return this.fetchLocale();
+ }
+
+ public i18n: Promise<I18n<any>> | null = null;
+
+ public fetchLocale() {
+ return this.i18n = this._fetch();
+ }
+
+ private async _fetch() {
+ // Service Workerは何度も起動しそのたびにlocaleを読み込むので、CacheStorageを使う
+ const localeUrl = `/assets/locales/${await this.lang}.${_VERSION_}.json`;
+ let localeRes = await caches.match(localeUrl);
+
+ // _DEV_がtrueの場合は常に最新化
+ if (!localeRes || _DEV_) {
+ localeRes = await fetch(localeUrl);
+ const clone = localeRes?.clone();
+ if (!clone?.clone().ok) Error('locale fetching error');
+
+ caches.open(this.cacheName).then(cache => cache.put(localeUrl, clone));
+ }
+
+ return new I18n(await localeRes.json());
+ }
+}
+
+export const swLang = new SwLang();
diff --git a/packages/sw/src/scripts/login-id.ts b/packages/sw/src/scripts/login-id.ts
new file mode 100644
index 0000000000..0f9c6be4a9
--- /dev/null
+++ b/packages/sw/src/scripts/login-id.ts
@@ -0,0 +1,11 @@
+export function getUrlWithLoginId(url: string, loginId: string) {
+ const u = new URL(url, origin);
+ u.searchParams.append('loginId', loginId);
+ return u.toString();
+}
+
+export function getUrlWithoutLoginId(url: string) {
+ const u = new URL(url);
+ u.searchParams.delete('loginId');
+ return u.toString();
+}
diff --git a/packages/sw/src/scripts/notification-read.ts b/packages/sw/src/scripts/notification-read.ts
new file mode 100644
index 0000000000..8433f902b4
--- /dev/null
+++ b/packages/sw/src/scripts/notification-read.ts
@@ -0,0 +1,50 @@
+declare var self: ServiceWorkerGlobalScope;
+
+import { get } from 'idb-keyval';
+import { pushNotificationDataMap } from '@/types';
+import { api } from '@/scripts/operations';
+
+type Accounts = {
+ [x: string]: {
+ queue: string[],
+ timeout: number | null
+ }
+};
+
+class SwNotificationReadManager {
+ private accounts: Accounts = {};
+
+ public async construct() {
+ const accounts = await get('accounts');
+ if (!accounts) Error('Accounts are not recorded');
+
+ this.accounts = accounts.reduce((acc, e) => {
+ acc[e.id] = {
+ queue: [],
+ timeout: null
+ };
+ return acc;
+ }, {} as Accounts);
+
+ return this;
+ }
+
+ // プッシュ通知の既読をサーバーに送信
+ public async read<K extends keyof pushNotificationDataMap>(data: pushNotificationDataMap[K]) {
+ if (data.type !== 'notification' || !(data.userId in this.accounts)) return;
+
+ const account = this.accounts[data.userId];
+
+ account.queue.push(data.body.id as string);
+
+ // 最後の呼び出しから200ms待ってまとめて処理する
+ if (account.timeout) clearTimeout(account.timeout);
+ account.timeout = setTimeout(() => {
+ account.timeout = null;
+
+ api('notifications/read', data.userId, { notificationIds: account.queue });
+ }, 200);
+ }
+}
+
+export const swNotificationRead = (new SwNotificationReadManager()).construct();
diff --git a/packages/sw/src/scripts/operations.ts b/packages/sw/src/scripts/operations.ts
new file mode 100644
index 0000000000..02cf0d96cf
--- /dev/null
+++ b/packages/sw/src/scripts/operations.ts
@@ -0,0 +1,70 @@
+/*
+ * Operations
+ * 各種操作
+ */
+declare var self: ServiceWorkerGlobalScope;
+
+import * as Misskey from 'misskey-js';
+import { SwMessage, swMessageOrderType } from '@/types';
+import { acct as getAcct } from '@/filters/user';
+import { getAccountFromId } from '@/scripts/get-account-from-id';
+import { getUrlWithLoginId } from '@/scripts/login-id';
+
+export const cli = new Misskey.api.APIClient({ origin, fetch: (...args) => fetch(...args) });
+
+export async function api<E extends keyof Misskey.Endpoints>(endpoint: E, userId: string, options?: Misskey.Endpoints[E]['req']) {
+ const account = await getAccountFromId(userId);
+ if (!account) return;
+
+ return cli.request(endpoint, options, account.token);
+}
+
+// rendered acctからユーザーを開く
+export function openUser(acct: string, loginId: string) {
+ return openClient('push', `/@${acct}`, loginId, { acct });
+}
+
+// noteIdからノートを開く
+export function openNote(noteId: string, loginId: string) {
+ return openClient('push', `/notes/${noteId}`, loginId, { noteId });
+}
+
+export async function openChat(body: any, loginId: string) {
+ if (body.groupId === null) {
+ return openClient('push', `/my/messaging/${getAcct(body.user)}`, loginId, { body });
+ } else {
+ return openClient('push', `/my/messaging/group/${body.groupId}`, loginId, { body });
+ }
+}
+
+// post-formのオプションから投稿フォームを開く
+export async function openPost(options: any, loginId: string) {
+ // クエリを作成しておく
+ let url = `/share?`;
+ if (options.initialText) url += `text=${options.initialText}&`;
+ if (options.reply) url += `replyId=${options.reply.id}&`;
+ if (options.renote) url += `renoteId=${options.renote.id}&`;
+
+ return openClient('post', url, loginId, { options });
+}
+
+export async function openClient(order: swMessageOrderType, url: string, loginId: string, query: any = {}) {
+ const client = await findClient();
+
+ if (client) {
+ client.postMessage({ type: 'order', ...query, order, loginId, url } as SwMessage);
+ return client;
+ }
+
+ return self.clients.openWindow(getUrlWithLoginId(url, loginId));
+}
+
+export async function findClient() {
+ const clients = await self.clients.matchAll({
+ type: 'window'
+ });
+ for (const c of clients) {
+ if (c.url.indexOf('?zen') < 0) return c;
+ }
+ return null;
+}
generated by cgit v1.2.3-freya (git 2.53.0.84.g453e7b744a) at 2026-03-04 00:35:29 +0000