From 11387344fa62e8db620159e9fe9de7fe7d2fda47 Mon Sep 17 00:00:00 2001
From: Tobias Herber <22559657+herber@users.noreply.github.com>
Date: Sun, 28 Dec 2025 18:36:04 +0100
Subject: [PATCH] Add log cleanup

---
 service/src/queues/cleanup.ts | 19 +++++++++++++++++++
 service/src/worker.ts         |  3 ++-
 2 files changed, 21 insertions(+), 1 deletion(-)
 create mode 100644 service/src/queues/cleanup.ts

diff --git a/service/src/queues/cleanup.ts b/service/src/queues/cleanup.ts
new file mode 100644
index 0000000..009695e
--- /dev/null
+++ b/service/src/queues/cleanup.ts
@@ -0,0 +1,19 @@
+import { createCron } from '@lowerdeck/cron';
+import { subDays } from 'date-fns';
+import { db } from '../db';
+import { env } from '../env';
+
+export let cleanupProcessor = createCron(
+  {
+    name: 'fbay/cleanup',
+    cron: '0 0 * * *',
+    redisUrl: env.service.REDIS_URL
+  },
+  async () => {
+    let threeDaysAgo = subDays(new Date(), 3);
+
+    await db.functionInvocation.deleteMany({
+      where: { createdAt: { lt: threeDaysAgo } }
+    });
+  }
+);
diff --git a/service/src/worker.ts b/service/src/worker.ts
index 89290a0..1a0be43 100644
--- a/service/src/worker.ts
+++ b/service/src/worker.ts
@@ -1,4 +1,5 @@
 import { runQueueProcessors } from '@lowerdeck/queue';
 import { buildProcessors } from './queues/build';
+import { cleanupProcessor } from './queues/cleanup';
 
-await runQueueProcessors([buildProcessors]);
+await runQueueProcessors([buildProcessors, cleanupProcessor]);