mirror/textbee
1
0
Fork 0
mirror of https://github.com/vernu/textbee.git synced 2026-05-18 21:35:12 -04:00
Code Issues Packages Projects Releases Wiki Activity

feat(api): mark notifications older than one month as aborted to prevent retries

Browse Source
This commit is contained in:
isra el
2026-03-05 19:50:48 +03:00
parent 338fb665bc
commit 540bb9068b
1 changed files with 15 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
api/src/webhook/webhook.service.ts
View File

@@ -570,12 +570,27 @@ export class WebhookService {
async checkForNotificationsToDeliver() {
const now = new Date()
const fiveMinutesAgo = new Date(now.getTime() - 5 * 60 * 1000)
const oneMonthAgo = new Date(now.getTime() - 30 * 24 * 60 * 60 * 1000)
// Mark notifications older than one month as aborted so they are no longer retried
await this.webhookNotificationModel.updateMany(
{
nextDeliveryAttemptAt: { $lte: fiveMinutesAgo },
deliveredAt: null,
deliveryAttemptCount: { $lt: 10 },
deliveryAttemptAbortedAt: null,
createdAt: { $lt: oneMonthAgo },
},
{ $set: { deliveryAttemptAbortedAt: now } },
)
const notifications = await this.webhookNotificationModel
.find({
nextDeliveryAttemptAt: { $lte: fiveMinutesAgo },
deliveredAt: null,
deliveryAttemptCount: { $lt: 10 },
deliveryAttemptAbortedAt: null,
createdAt: { $gte: oneMonthAgo },
})
.sort({ nextDeliveryAttemptAt: 1 })
.limit(200)