martin/doorman
1
0
Fork 0
Code Issues 5 Pull Requests Actions Packages Projects Releases Wiki Activity

implement best efforts cleanup

Browse Source
This commit is contained in:
Martin Dimitrov 2025-10-08 14:01:53 -07:00
parent 29786f5780
commit 1bca8cf9dc
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
packages/doorman-api/src/functions/api/door/logCall.ts
View File

@ -12,6 +12,7 @@ import { z } from "zod";
import { UserAgentHeader } from "../../../utils/blockUserAgent"; import { UserAgentHeader } from "../../../utils/blockUserAgent";
import { setResponseJson } from "../../../utils/responseUtils"; import { setResponseJson } from "../../../utils/responseUtils";
import { LOG_CALL_SK, LogCallSchema } from "../../../schema/LogCall"; import { LOG_CALL_SK, LogCallSchema } from "../../../schema/LogCall";
import { isTTLInFuture } from "../../../common/TTLHelper";
export const LogCallRequestSchema = z.object({ export const LogCallRequestSchema = z.object({
caller: z.string(), caller: z.string(),
@ -46,6 +47,15 @@ export const handler: ServerlessFunctionSignature<TwilioContext, LogCallRequestT
msg: "Onboarding is not open", msg: "Onboarding is not open",
}); });
} else { } 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 // log this caller
const otp = getCode(); const otp = getCode();
const logCall = LogCallSchema.parse({ const logCall = LogCallSchema.parse({