From 1bca8cf9dc4cfecbae8e852295e88bc873f2f4e4 Mon Sep 17 00:00:00 2001
From: Martin Dimitrov <martin3dimitrov@gmail.com>
Date: Wed, 8 Oct 2025 14:01:53 -0700
Subject: [PATCH] implement best efforts cleanup

---
 packages/doorman-api/src/functions/api/door/logCall.ts | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/packages/doorman-api/src/functions/api/door/logCall.ts b/packages/doorman-api/src/functions/api/door/logCall.ts
index 30764d4..a3ccc40 100644
--- a/packages/doorman-api/src/functions/api/door/logCall.ts
+++ b/packages/doorman-api/src/functions/api/door/logCall.ts
@@ -12,6 +12,7 @@ import { z } from "zod";
 import { UserAgentHeader } from "../../../utils/blockUserAgent";
 import { setResponseJson } from "../../../utils/responseUtils";
 import { LOG_CALL_SK, LogCallSchema } from "../../../schema/LogCall";
+import { isTTLInFuture } from "../../../common/TTLHelper";
 
 export const LogCallRequestSchema = z.object({
   caller: z.string(),
@@ -46,6 +47,15 @@ export const handler: ServerlessFunctionSignature<TwilioContext, LogCallRequestT
       msg: "Onboarding is not open",
     });
   } else {
+    // best efforts cleanup
+    // TODO: make this use an INDEX instead of scan
+    console.log("Attempting best efforts cleanup of logged calls")
+    const logs = await db.entities.logCall.findAll();
+    const toRemove = logs.filter(log => !isTTLInFuture(log));
+    console.log(`There are ${toRemove.length} old call logs to remove`);
+    await db.entities.logCall.deleteBatch(toRemove);
+    console.log("done cleaning up logged calls");
+
     // log this caller
     const otp = getCode();
     const logCall = LogCallSchema.parse({