From 24ba0b23c0237c3b44aeeb9be60a34b7518ab067 Mon Sep 17 00:00:00 2001
From: BigSimmo <87357024+BigSimmo@users.noreply.github.com>
Date: Thu, 2 Jul 2026 17:27:24 +0800
Subject: [PATCH] Add regression guard for duplicate migration stems

Co-authored-by: Copilot App <223556219+Copilot@users.noreply.github.com>
---
 tests/supabase-schema.test.ts | 28 +++++++++++++++++++++++++++-
 1 file changed, 27 insertions(+), 1 deletion(-)

diff --git a/tests/supabase-schema.test.ts b/tests/supabase-schema.test.ts
index 226b0852b..ca36b1129 100644
--- a/tests/supabase-schema.test.ts
+++ b/tests/supabase-schema.test.ts
@@ -1,4 +1,4 @@
-import { readFileSync } from "node:fs";
+import { readdirSync, readFileSync } from "node:fs";
 import { describe, expect, it } from "vitest";
 
 const schema = readFileSync(new URL("../supabase/schema.sql", import.meta.url), "utf8").replace(/\s+/g, " ");
@@ -50,6 +50,12 @@ const auditLogsServiceRolePolicyMigration = readFileSync(
   new URL("../supabase/migrations/20260630090000_audit_logs_service_role_policy.sql", import.meta.url),
   "utf8",
 ).replace(/\s+/g, " ");
+const migrationDirectoryUrl = new URL("../supabase/migrations/", import.meta.url);
+
+function parseMigrationStem(fileName: string) {
+  const stem = fileName.match(/^\d+_(.+)\.sql$/)?.[1];
+  return stem ?? null;
+}
 
 function extractTextChunkFunction(sql: string) {
   const start = sql.indexOf("function public.match_document_chunks_text");
@@ -313,6 +319,26 @@ describe("Supabase schema Data API grants", () => {
     expect(schema).not.toMatch(/grant [^;]*public\.audit_logs[^;]* to anon;/);
   });
 
+  it("does not introduce new duplicate migration stems", () => {
+    const duplicateStemAllowlist = new Map<string, number>([
+      ["api_rate_limits", 2],
+      ["audit_logs", 2],
+      ["audit_logs_service_role_policy", 2],
+      ["indexing_reliability_recovery", 2],
+      ["rag_queries_retention", 2],
+    ]);
+    const stemCounts = new Map<string, number>();
+
+    for (const fileName of readdirSync(migrationDirectoryUrl)) {
+      const stem = parseMigrationStem(fileName);
+      if (!stem) continue;
+      stemCounts.set(stem, (stemCounts.get(stem) ?? 0) + 1);
+    }
+
+    const duplicateStems = new Map([...stemCounts.entries()].filter(([, count]) => count > 1));
+    expect(duplicateStems).toEqual(duplicateStemAllowlist);
+  });
+
   it("stores deep structured memory privately for source-backed answers", () => {
     expect(schema).toContain("create table if not exists public.document_sections");
     expect(schema).toContain("create table if not exists public.document_memory_cards");