textbee/textbee
1
0
Fork 0
mirror of https://github.com/vernu/textbee.git synced 2026-09-03 03:29:58 +03:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #194 from vernu/dev

Browse Source 
mark undelivered webhook notifications older than one month as aborted to prevent further retries
This commit is contained in:
Israel Abebe
2026-03-05 19:53:03 +03:00
committed by GitHub
parent 3061bd8d66 540bb9068b
commit 14fd2f9b03
1 changed files with 15 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
api/src/webhook/webhook.service.ts
+15
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)