Merge remote-tracking branch 'origin/main' into staging

# Conflicts: # docs/BUG_HISTORY.md # frontend/src/app/admin/codes/page.tsx # frontend/src/app/admin/layout.tsx # frontend/src/app/api/admin/codes/route.ts # frontend/src/app/api/admin/users/route.ts # frontend/src/lib/supabase/admin.ts # frontend/tests/staging-backend-workflows.test.ts
2026-07-29 09:32:29 +08:00
parent f430ebd2c8 2da848a1d9
commit f7fd3e6a60
166 changed files with 16226 additions and 2786 deletions
@@ -0,0 +1,23 @@
+import { setTimeout as sleep } from "node:timers/promises";
+import { createRectificationV4CandidateEngine } from "../src/lib/rectification-v4/candidate-engine.ts";
+import { createRectificationV4SupabaseStore } from "../src/lib/rectification-v4/supabase-store.ts";
+import { createRectificationV4Worker } from "../src/lib/rectification-v4/worker.ts";
+import { createAdminSupabaseClient } from "../src/lib/supabase/admin-client-core.ts";
+
+const intervalMs = Number(process.env.RECTIFICATION_V4_WORKER_POLL_MS ?? "1000");
+const once = process.argv.includes("--once");
+let stopped = false;
+for (const signal of ["SIGINT", "SIGTERM"] as const) process.once(signal, () => { stopped = true; });
+
+const worker = createRectificationV4Worker({
+  store: createRectificationV4SupabaseStore(createAdminSupabaseClient()),
+  engine: createRectificationV4CandidateEngine({
+    apiBase: process.env.JYOTISH_API_BASE ?? "http://127.0.0.1:5200",
+  }),
+});
+
+do {
+  const worked = await worker.runOnce();
+  if (once) break;
+  if (!worked) await sleep(Number.isFinite(intervalMs) && intervalMs >= 100 ? intervalMs : 1000);
+} while (!stopped);