feat(indexer): add gap detection and ledger event replay on startup

backend/.env.example

@@ -36,6 +36,10 @@ LOG_LEVEL=info
 # ── Indexer ───────────────────────────────────────────────────
 GENESIS_LEDGER=100000
 POLL_INTERVAL_MS=5000
+# Ledgers replayed per batch when recovering a startup gap (max 1 batch/sec)
+INDEXER_REPLAY_BATCH_SIZE=50
+# Ledger gap above which replay is skipped (Sentry warning emitted instead)
+INDEXER_MAX_REPLAY_LEDGERS=10000
 
 # ── External Boxing Data API ──────────────────────────────────
 BOXING_API_URL=https://api.example-boxing-data.com/v1

backend/db/schema.sql

@@ -16,6 +16,7 @@ CREATE TABLE IF NOT EXISTS markets (
   pool_draw        NUMERIC     NOT NULL DEFAULT 0,
   total_pool       NUMERIC     NOT NULL DEFAULT 0,
   fee_bps          INTEGER     NOT NULL DEFAULT 200,
+  lock_before_secs INTEGER     NOT NULL DEFAULT 3600,
   resolved_at      TIMESTAMPTZ,
   oracle_used      TEXT,
   created_at       TIMESTAMPTZ NOT NULL DEFAULT NOW(),

backend/src/config/env.ts

@@ -20,6 +20,8 @@ const envSchema = z.object({
   ENABLE_SWAGGER: z.coerce.boolean().default(false),
   GENESIS_LEDGER: z.coerce.number().int().positive().default(100000),
   POLL_INTERVAL_MS: z.coerce.number().int().positive().default(5000),
+  INDEXER_REPLAY_BATCH_SIZE: z.coerce.number().int().positive().default(50),
+  INDEXER_MAX_REPLAY_LEDGERS: z.coerce.number().int().positive().default(10000),
   BOXING_API_URL: z.string().url().optional(),
   SENTRY_DSN: z.string().url().optional(),
   WS_BUFFER_THRESHOLD_BYTES: z.coerce.number().int().positive().default(16384),

backend/src/index.ts

@@ -14,7 +14,6 @@ import adminRouter from "./routes/admin.routes";
 import disputesRouter from "./routes/disputes.routes";
 import { getPortfolio, getPlatformStats, getLeaderboard } from "./api/controllers/MarketController";
 import governanceRouter from "./routes/governance.routes";
-import { getPortfolio, getPlatformStats } from "./api/controllers/MarketController";
 import claimsRouter from "./routes/bet.routes";
 import { startAutoResolutionCron, startAutoLockCron } from "./cron/autoResolution.cron";
 import { startCleanupCron } from "./cron/cleanup.cron";