mirror/Compass
1
0
Fork 0
mirror of https://github.com/CompassConnections/Compass.git synced 2026-02-28 04:48:49 -05:00
Code Issues Packages Projects Releases Wiki Activity

Remove expired subscriptions

Browse Source
This commit is contained in:
MartinBraquet
2025-10-22 14:28:59 +02:00
parent 6884a91eb8
commit e3fa4efa95
1 changed files with 17 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
backend/api/src/junk-drawer/private-messages.ts
View File

@@ -180,9 +180,20 @@ const notifyOtherUserInChannelIfInactive = async (
})
console.log('Sending notification to:', subscription.endpoint, payload);
await webPush.sendNotification(subscription, payload);
} catch (err) {
console.error('Failed to send notification', err);
// optionally remove invalid subscription from DB
} catch (err: any) {
console.log('Failed to send notification', err);
if (err.statusCode === 410 || err.statusCode === 404) {
console.warn('Removing expired subscription', subscription.endpoint);
await pg.none(
`DELETE
FROM push_subscriptions
WHERE endpoint = $1
AND user_id = $2`,
[subscription.endpoint, otherUser.id]
);
} else {
console.error('Push failed', err);
}
}
}
@@ -223,8 +234,9 @@ export async function getSubscriptionsFromDB(
) {
try {
const subscriptions = await pg.manyOrNone(`
select endpoint, keys from push_subscriptions
where user_id = $1
select endpoint, keys
from push_subscriptions
where user_id = $1
`, [userId]
);