const webpush = require("web-push");
if (config.vapid) {
webpush.setVapidDetails(
config.vapid.url,
config.vapid.publicKey,
config.vapid.privateKey
);
}
notify = (user, payload) => {
let { subscriptions } = user;
if (subscriptions) {
subscriptions.map(async (subscription, i) => {
try {
await webpush.sendNotification(subscription, payload);
} catch (e) {
if (e.body && (e.body.includes('expired') || e.body.includes('No such'))) {
user.subscriptions.splice(i, 1);
await user.save();
} else {
l.error("problem sending notification", e);
}
}
});
}
};
x : coinos-server.git
blob: 40906dcdb7d799489f7707bff6e23b23ca74e09b (
plain) (
tree)