141 lines
4.3 KiB
TypeScript
141 lines
4.3 KiB
TypeScript
import { Inject, Injectable } from '@nestjs/common';
|
|
import push from 'web-push';
|
|
import { DI } from '@/di-symbols.js';
|
|
import type { Config } from '@/config.js';
|
|
import type { Packed } from '@/misc/schema';
|
|
import { getNoteSummary } from '@/misc/get-note-summary.js';
|
|
import type { SwSubscriptionsRepository } from '@/models/index.js';
|
|
import { MetaService } from '@/core/MetaService.js';
|
|
import { bindThis } from '@/decorators.js';
|
|
|
|
// Defined also packages/sw/types.ts#L13
|
|
type pushNotificationsTypes = {
|
|
'notification': Packed<'Notification'>;
|
|
'unreadMessagingMessage': Packed<'MessagingMessage'>;
|
|
'unreadAntennaNote': {
|
|
antenna: { id: string, name: string };
|
|
note: Packed<'Note'>;
|
|
};
|
|
'readNotifications': { notificationIds: string[] };
|
|
'readAllNotifications': undefined;
|
|
'readAllMessagingMessages': undefined;
|
|
'readAllMessagingMessagesOfARoom': { userId: string } | { groupId: string };
|
|
'readAntenna': { antennaId: string };
|
|
'readAllAntennas': undefined;
|
|
};
|
|
|
|
// Reduce length because push message servers have character limits
|
|
function truncateBody<T extends keyof pushNotificationsTypes>(type: T, body: pushNotificationsTypes[T]): pushNotificationsTypes[T] {
|
|
if (body === undefined) return body;
|
|
|
|
return {
|
|
...body,
|
|
...(('note' in body && body.note) ? {
|
|
note: {
|
|
...body.note,
|
|
// textをgetNoteSummaryしたものに置き換える
|
|
text: getNoteSummary(('type' in body && body.type === 'renote') ? body.note.renote as Packed<'Note'> : body.note),
|
|
|
|
cw: undefined,
|
|
reply: undefined,
|
|
renote: undefined,
|
|
user: type === 'notification' ? undefined as any : body.note.user,
|
|
}
|
|
} : {}),
|
|
};
|
|
|
|
return body;
|
|
}
|
|
|
|
function truncateUnreadAntennaNote(notification: pushNotificationsTypes['unreadAntennaNote']): pushNotificationsTypes['unreadAntennaNote'] {
|
|
if (notification.note) {
|
|
return {
|
|
...notification,
|
|
note: {
|
|
...notification.note,
|
|
// textをgetNoteSummaryしたものに置き換える
|
|
text: getNoteSummary(('type' in notification && notification.type === 'renote') ? notification.note.renote as Packed<'Note'> : notification.note),
|
|
|
|
cw: undefined,
|
|
reply: undefined,
|
|
renote: undefined,
|
|
user: undefined as any, // 通知を受け取ったユーザーである場合が多いのでこれも捨てる アンテナの場合も不要なのでいらない
|
|
},
|
|
};
|
|
}
|
|
|
|
return notification;
|
|
}
|
|
|
|
@Injectable()
|
|
export class PushNotificationService {
|
|
constructor(
|
|
@Inject(DI.config)
|
|
private config: Config,
|
|
|
|
@Inject(DI.swSubscriptionsRepository)
|
|
private swSubscriptionsRepository: SwSubscriptionsRepository,
|
|
|
|
private metaService: MetaService,
|
|
) {
|
|
}
|
|
|
|
@bindThis
|
|
public async pushNotification<T extends keyof pushNotificationsTypes>(userId: string, type: T, body: pushNotificationsTypes[T]) {
|
|
const meta = await this.metaService.fetch();
|
|
|
|
if (!meta.enableServiceWorker || meta.swPublicKey == null || meta.swPrivateKey == null) return;
|
|
|
|
// アプリケーションの連絡先と、サーバーサイドの鍵ペアの情報を登録
|
|
push.setVapidDetails(this.config.url,
|
|
meta.swPublicKey,
|
|
meta.swPrivateKey);
|
|
|
|
// Fetch
|
|
const subscriptions = await this.swSubscriptionsRepository.findBy({
|
|
userId: userId,
|
|
});
|
|
|
|
for (const subscription of subscriptions) {
|
|
// Continue if sendReadMessage is false
|
|
if ([
|
|
'readNotifications',
|
|
'readAllNotifications',
|
|
'readAllMessagingMessages',
|
|
'readAllMessagingMessagesOfARoom',
|
|
'readAntenna',
|
|
'readAllAntennas',
|
|
].includes(type) && !subscription.sendReadMessage) continue;
|
|
|
|
const pushSubscription = {
|
|
endpoint: subscription.endpoint,
|
|
keys: {
|
|
auth: subscription.auth,
|
|
p256dh: subscription.publickey,
|
|
},
|
|
};
|
|
|
|
push.sendNotification(pushSubscription, JSON.stringify({
|
|
type,
|
|
body: (type === 'notification' || type === 'unreadAntennaNote') ? truncateBody(type, body) : body,
|
|
userId,
|
|
dateTime: (new Date()).getTime(),
|
|
}), {
|
|
proxy: this.config.proxy,
|
|
}).catch((err: any) => {
|
|
//swLogger.info(err.statusCode);
|
|
//swLogger.info(err.headers);
|
|
//swLogger.info(err.body);
|
|
|
|
if (err.statusCode === 410) {
|
|
this.swSubscriptionsRepository.delete({
|
|
userId: userId,
|
|
endpoint: subscription.endpoint,
|
|
auth: subscription.auth,
|
|
publickey: subscription.publickey,
|
|
});
|
|
}
|
|
});
|
|
}
|
|
}
|
|
}
|