test(memory): cover live manager after CLI reindex

849261680 · 849261680 · commit 541917a3fd90 · 2026-06-23T19:52:18.000+08:00
diff --git a/extensions/memory-core/src/memory/manager.self-heal-missing-identity.test.ts b/extensions/memory-core/src/memory/manager.self-heal-missing-identity.test.ts
@@ -31,7 +31,7 @@ describe("memory manager self-heal missing identity with FTS-only chunks", () =>
   let caseId = 0;
   let workspaceDir = "";
   let indexPath = "";
-  let manager: MemoryIndexManager | null = null;
+  let managers: MemoryIndexManager[] = [];
 
   function indexIdentityStatus(memoryManager: MemoryIndexManager): string | undefined {
     const identity = memoryManager.status().custom?.indexIdentity as
@@ -54,10 +54,10 @@ describe("memory manager self-heal missing identity with FTS-only chunks", () =>
   });
 
   afterEach(async () => {
-    if (manager) {
-      await manager.close();
-      manager = null;
+    for (const activeManager of managers.toReversed()) {
+      await activeManager.close();
     }
+    managers = [];
     await closeAllMemorySearchManagers();
     vi.unstubAllEnvs();
   });
@@ -70,7 +70,11 @@ describe("memory manager self-heal missing identity with FTS-only chunks", () =>
   });
 
   async function createManager(
-    params: { provider?: string; vectorEnabled?: boolean } = {},
+    params: {
+      provider?: string;
+      vectorEnabled?: boolean;
+      purpose?: "default" | "status" | "cli";
+    } = {},
   ): Promise<MemoryIndexManager> {
     const store =
       params.vectorEnabled === undefined
@@ -92,12 +96,17 @@ describe("memory manager self-heal missing identity with FTS-only chunks", () =>
         list: [{ id: "main", default: true }],
       },
     } as OpenClawConfig;
-    const result = await getMemorySearchManager({ cfg, agentId: "main" });
+    const result = await getMemorySearchManager({
+      cfg,
+      agentId: "main",
+      purpose: params.purpose,
+    });
     if (!result.manager) {
       throw new Error(result.error ?? "manager missing");
     }
-    manager = result.manager as unknown as MemoryIndexManager;
-    return manager;
+    const activeManager = result.manager as unknown as MemoryIndexManager;
+    managers.push(activeManager);
+    return activeManager;
   }
 
   async function seedChunksWithNoMeta(model = "fts-only"): Promise<void> {
@@ -159,4 +168,30 @@ describe("memory manager self-heal missing identity with FTS-only chunks", () =>
     expect(statusAfter.chunks).toBe(1);
     expect(statusAfter.dirty).toBe(true);
   });
+
+  it("observes a separate CLI reindex without reopening the live gateway manager", async () => {
+    const liveManager = await createManager({ provider: "none", vectorEnabled: false });
+    await liveManager.sync({ reason: "test", force: true });
+    (
+      liveManager as unknown as {
+        db: { exec: (sql: string) => void };
+      }
+    ).db.exec(`DELETE FROM memory_index_meta WHERE key = 'memory_index_meta_v1'`);
+    expect(indexIdentityStatus(liveManager)).toBe("missing");
+
+    await fs.writeFile(
+      path.join(workspaceDir, "MEMORY.md"),
+      "Beta topic\n\nKeep this repaired note.",
+    );
+    const cliManager = await createManager({
+      provider: "none",
+      vectorEnabled: false,
+      purpose: "cli",
+    });
+    await cliManager.sync({ reason: "cli", force: true });
+
+    expect(indexIdentityStatus(liveManager)).toBe("valid");
+    const results = await liveManager.search("beta repaired");
+    expect(results.some((result) => result.snippet.includes("Beta topic"))).toBe(true);
+  });
 });
