feat: add DELETE /admin/backfill endpoint to clear backfill table

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: eabdelmoneim

src/server/routes/admin/backfill.ts

@@ -4,17 +4,20 @@ import { StatusCodes } from "http-status-codes";
 import { TransactionDB } from "../../../shared/db/transactions/db";
 import { standardResponseSchema } from "../../schemas/shared-api-schemas";
 
-const requestBodySchema = Type.Object({
+const loadRequestBodySchema = Type.Object({
   entries: Type.Array(
     Type.Object({
       queueId: Type.String({ description: "Queue ID (UUID)" }),
       transactionHash: Type.String({ description: "Transaction hash (0x...)" }),
     }),
-    { description: "Array of queueId to transactionHash mappings", maxItems: 10000 },
+    {
+      description: "Array of queueId to transactionHash mappings",
+      maxItems: 10000,
+    },
   ),
 });
 
-const responseBodySchema = Type.Object({
+const loadResponseBodySchema = Type.Object({
   result: Type.Object({
     inserted: Type.Integer({ description: "Number of entries inserted" }),
     skipped: Type.Integer({
@@ -23,10 +26,16 @@ const responseBodySchema = Type.Object({
   }),
 });
 
+const clearResponseBodySchema = Type.Object({
+  result: Type.Object({
+    deleted: Type.Integer({ description: "Number of entries deleted" }),
+  }),
+});
+
 export async function loadBackfillRoute(fastify: FastifyInstance) {
   fastify.route<{
-    Body: Static<typeof requestBodySchema>;
-    Reply: Static<typeof responseBodySchema>;
+    Body: Static<typeof loadRequestBodySchema>;
+    Reply: Static<typeof loadResponseBodySchema>;
   }>({
     method: "POST",
     url: "/admin/backfill",
@@ -36,10 +45,10 @@ export async function loadBackfillRoute(fastify: FastifyInstance) {
         "Load queueId to transactionHash mappings into the backfill table. Uses SETNX to never overwrite existing entries.",
       tags: ["Admin"],
       operationId: "loadBackfill",
-      body: requestBodySchema,
+      body: loadRequestBodySchema,
       response: {
         ...standardResponseSchema,
-        [StatusCodes.OK]: responseBodySchema,
+        [StatusCodes.OK]: loadResponseBodySchema,
       },
       hide: true,
     },
@@ -55,3 +64,31 @@ export async function loadBackfillRoute(fastify: FastifyInstance) {
     },
   });
 }
+
+export async function clearBackfillRoute(fastify: FastifyInstance) {
+  fastify.route<{
+    Reply: Static<typeof clearResponseBodySchema>;
+  }>({
+    method: "DELETE",
+    url: "/admin/backfill",
+    schema: {
+      summary: "Clear backfill table",
+      description:
+        "Delete all entries from the backfill table. This action cannot be undone.",
+      tags: ["Admin"],
+      operationId: "clearBackfill",
+      response: {
+        ...standardResponseSchema,
+        [StatusCodes.OK]: clearResponseBodySchema,
+      },
+      hide: true,
+    },
+    handler: async (_request, reply) => {
+      const deleted = await TransactionDB.clearBackfill();
+
+      reply.status(StatusCodes.OK).send({
+        result: { deleted },
+      });
+    },
+  });
+}

src/server/routes/index.ts

@@ -1,5 +1,5 @@
 import type { FastifyInstance } from "fastify";
-import { loadBackfillRoute } from "./admin/backfill";
+import { clearBackfillRoute, loadBackfillRoute } from "./admin/backfill";
 import { getNonceDetailsRoute } from "./admin/nonces";
 import { getTransactionDetails } from "./admin/transaction";
 import { createAccessToken } from "./auth/access-tokens/create";
@@ -299,4 +299,5 @@ export async function withRoutes(fastify: FastifyInstance) {
   await fastify.register(getTransactionDetails);
   await fastify.register(getNonceDetailsRoute);
   await fastify.register(loadBackfillRoute);
+  await fastify.register(clearBackfillRoute);
 }

src/shared/db/transactions/db.ts

@@ -258,6 +258,33 @@ export class TransactionDB {
 
     return { inserted, skipped };
   };
+
+  /**
+   * Clears all backfill entries.
+   * @returns number - The number of entries deleted.
+   */
+  static clearBackfill = async (): Promise<number> => {
+    let totalDeleted = 0;
+    let cursor = "0";
+
+    do {
+      const [nextCursor, keys] = await redis.scan(
+        cursor,
+        "MATCH",
+        "backfill:*",
+        "COUNT",
+        1000,
+      );
+      cursor = nextCursor;
+
+      if (keys.length > 0) {
+        const deleted = await redis.unlink(...keys);
+        totalDeleted += deleted;
+      }
+    } while (cursor !== "0");
+
+    return totalDeleted;
+  };
 }
 
 const toSeconds = (timestamp: Date) => timestamp.getTime() / 1000;