import * as push from 'web-push'; import * as mongo from 'mongodb'; import Subscription from './models/sw-subscription'; import config from './config'; import fetchMeta from './misc/fetch-meta'; import { IMeta } from './models/meta'; let meta: IMeta = null; setInterval(() => { fetchMeta().then(m => { meta = m; if (meta.enableServiceWorker) { // アプリケーションの連絡先と、サーバーサイドの鍵ペアの情報を登録 push.setVapidDetails(config.url, meta.swPublicKey, meta.swPrivateKey); } }); }, 3000); export default async function(userId: mongo.ObjectID | string, type: string, body?: any) { if (!meta.enableServiceWorker) return; if (typeof userId === 'string') { userId = new mongo.ObjectID(userId); } // Fetch const subscriptions = await Subscription.find({ userId: userId }); for (const subscription of subscriptions) { const pushSubscription = { endpoint: subscription.endpoint, keys: { auth: subscription.auth, p256dh: subscription.publickey } }; push.sendNotification(pushSubscription, JSON.stringify({ type, body })).catch((err: any) => { //swLogger.info(err.statusCode); //swLogger.info(err.headers); //swLogger.info(err.body); if (err.statusCode == 410) { Subscription.remove({ userId: userId, endpoint: subscription.endpoint, auth: subscription.auth, publickey: subscription.publickey }); } }); } }