[WIP]feat: added core logic for handling resend for transactions and reports

.dockerignore

@@ -9,3 +9,6 @@ logs
 *.db
 ./prisma/db/*
 ./prisma/generated
+prisma/dev.db
+*.sqlite
+*.sqlite-journal

bun.lock

@@ -4,7 +4,7 @@
     "": {
       "name": "concero-v2-operators",
       "dependencies": {
-        "@concero/operator-utils": "https://github.com/concero/operator-utils.git#feature/add-block-checkpoints",
+        "@concero/operator-utils": "https://github.com/concero/operator-utils.git#feature/restart-failed-transaction",
         "@prisma/client": "6.16.2",
         "@slack/web-api": "7.9.1",
         "@types/jest": "29.5.14",

docker/Dockerfile

@@ -33,5 +33,6 @@ COPY --from=builder --chown=bunuser:bunuser /app/prisma         /app/prisma
 COPY --chown=bunuser:bunuser ./rpc.extensions.json /app/
 COPY --chown=bunuser:bunuser ./rpc.overrides.json /app/
 
-ENV NODE_ENV=production
+ENV NODE_ENV=production \
+    DATABASE_URL=file:/app/data/concero.sqlite
 ENTRYPOINT ["/app/entrypoint.sh"]

package.json

@@ -45,7 +45,7 @@
         "typescript": "5.0.0"
     },
     "dependencies": {
-        "@concero/operator-utils": "https://github.com/concero/operator-utils.git#feature/add-block-checkpoints",
+        "@concero/operator-utils": "https://github.com/concero/operator-utils.git#feature/restart-failed-transaction",
         "@prisma/client": "6.16.2",
         "@slack/web-api": "7.9.1",
         "@types/jest": "29.5.14",

prisma/migrations/20251016181328_init/migration.sql

@@ -0,0 +1,16 @@
+-- CreateTable
+CREATE TABLE "RelayerJob" (
+    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "jobType" TEXT NOT NULL DEFAULT 'tx-submit',
+    "txHash" TEXT,
+    "chainName" TEXT NOT NULL,
+    "payload" TEXT NOT NULL,
+    "status" TEXT NOT NULL DEFAULT 'pending',
+    "attempts" INTEGER NOT NULL DEFAULT 0,
+    "nextRetryAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "updatedAt" DATETIME NOT NULL
+);
+
+-- CreateIndex
+CREATE INDEX "RelayerJob_status_nextRetryAt_idx" ON "RelayerJob"("status", "nextRetryAt");

prisma/migrations/20251020165731_add_compound_unique_relayerjob/migration.sql

@@ -0,0 +1,8 @@
+/*
+  Warnings:
+
+  - A unique constraint covering the columns `[jobType,txHash]` on the table `RelayerJob` will be added. If there are existing duplicate values, this will fail.
+
+*/
+-- CreateIndex
+CREATE UNIQUE INDEX "RelayerJob_jobType_txHash_key" ON "RelayerJob"("jobType", "txHash");

prisma/schema.prisma

@@ -21,3 +21,19 @@ model LogsListenerBlockCheckpoints {
   @@index([chainSelector, contractAddress])
   @@map("logsListener_blockCheckpoints")
 }
+
+model RelayerJob {
+  id            Int      @id @default(autoincrement())
+  jobType       String   @default("tx-submit") // tx-submit | report-request
+  chainName     String
+  txHash        String?
+  payload       String   
+  status        String   @default("pending") // pending | processing | done | failed
+  attempts      Int      @default(0)
+  nextRetryAt   DateTime @default(now())
+  createdAt     DateTime @default(now())
+  updatedAt     DateTime @updatedAt
+
+  @@index([status, nextRetryAt])
+  @@unique([jobType, txHash])
+}