cleanup webhook logs

Author: dcodesdev

apps/backend/src/cron/cleanupWebhookLogs.ts

@@ -0,0 +1,54 @@
+import { cronJob } from "./cron.utils"
+import { prisma } from "../utils/prisma"
+import dayjs from "dayjs"
+
+export const cleanupWebhookLogsCron = cronJob(
+  "cleanup-webhook-logs",
+  async () => {
+    const organizations = await prisma.organization.findMany({
+      include: {
+        GeneralSettings: true,
+      },
+    })
+
+    let totalDeletedLogs = 0
+
+    for (const org of organizations) {
+      const cleanupIntervalDays = org.GeneralSettings?.cleanupInterval ?? 90
+      const cleanupOlderThanDate = dayjs()
+        .subtract(cleanupIntervalDays, "days")
+        .toDate()
+
+      try {
+        const deletedResult = await prisma.webhookLog.deleteMany({
+          where: {
+            Webhook: {
+              organizationId: org.id,
+            },
+            createdAt: {
+              lt: cleanupOlderThanDate,
+            },
+          },
+        })
+
+        if (deletedResult.count > 0) {
+          console.log(
+            `Webhook logs cleanup for org ${org.id}: Deleted ${deletedResult.count} logs older than ${cleanupIntervalDays} days.`
+          )
+          totalDeletedLogs += deletedResult.count
+        }
+      } catch (error) {
+        console.error(`Error deleting webhook logs for org ${org.id}: ${error}`)
+        continue
+      }
+    }
+
+    if (totalDeletedLogs > 0) {
+      console.log(
+        `Webhook logs cleanup job finished. Total deleted logs: ${totalDeletedLogs}.`
+      )
+    } else {
+      console.log("Webhook logs cleanup job finished. No logs to delete.")
+    }
+  }
+)

apps/backend/src/cron/cron.ts

@@ -2,6 +2,7 @@ import cron from "node-cron"
 import { sendMessagesCron } from "./sendMessages"
 import { dailyMaintenanceCron } from "./dailyMaintenance"
 import { processQueuedCampaigns } from "./processQueuedCampaigns"
+import { cleanupWebhookLogsCron } from "./cleanupWebhookLogs"
 
 type CronJob = {
   name: string
@@ -31,10 +32,18 @@ const processQueuedCampaignsJob: CronJob = {
   enabled: true,
 }
 
+const cleanupWebhookLogsJob: CronJob = {
+  name: "cleanup-webhook-logs",
+  schedule: "0 1 * * *", // Runs daily at 1 AM
+  job: cleanupWebhookLogsCron,
+  enabled: true,
+}
+
 const cronJobs: CronJob[] = [
   sendMessagesJob,
   dailyMaintenanceJob,
   processQueuedCampaignsJob,
+  cleanupWebhookLogsJob,
 ]
 
 export const initializeCronJobs = () => {

package.json

@@ -1,5 +1,5 @@
 {
-  "version": "0.9.20-beta.4",
+  "version": "0.9.20-beta.5",
   "name": "letterspace",
   "private": true,
   "scripts": {