fix(memory): rebuild migrated search indexes

vincentkoc · vincentkoc · commit 6e6bd5633f1c · 2026-06-19T01:20:06.000+08:00
diff --git a/extensions/memory-core/src/memory/index.test.ts b/extensions/memory-core/src/memory/index.test.ts
@@ -1716,7 +1716,7 @@ describe("memory index", () => {
     expect(status.vector?.available).toBe(available);
   });
 
-  it("drops the shipped legacy vector table after loading sqlite-vec", async () => {
+  it("drops the shipped legacy vector table and schedules a full reindex", async () => {
     const cfg = createCfg({ vectorEnabled: true });
     const manager = await getPersistentManager(cfg);
     const db = Reflect.get(manager, "db") as DatabaseSync;
@@ -1732,6 +1732,7 @@ describe("memory index", () => {
         .prepare("SELECT name FROM sqlite_master WHERE type = 'table' AND name = 'chunks_vec'")
         .get(),
     ).toBeUndefined();
+    expect(Reflect.get(manager, "memoryFullRetryDirty")).toBe(true);
   });
 
   it("probes sqlite vector store availability without initializing embeddings", async () => {
diff --git a/extensions/memory-core/src/memory/manager-sync-ops.ts b/extensions/memory-core/src/memory/manager-sync-ops.ts
@@ -650,7 +650,10 @@ export abstract class MemoryManagerSyncOps {
       this.vector.extensionPath = loaded.extensionPath;
       this.vector.available = true;
       if (this.dropLegacyVectorTable()) {
+        // A broad dirty sync can skip unchanged files whose source hashes were
+        // migrated. Force the next sync to republish the derived vector rows.
         this.dirty = true;
+        this.memoryFullRetryDirty = true;
       }
       return true;
     } catch (err) {
diff --git a/packages/memory-host-sdk/src/host/memory-schema.test.ts b/packages/memory-host-sdk/src/host/memory-schema.test.ts
@@ -69,6 +69,9 @@ describe("memory index schema", () => {
       expect(db.prepare("SELECT id, text FROM memory_index_chunks").all()).toEqual([
         { id: "chunk-1", text: "remember this" },
       ]);
+      expect(db.prepare("SELECT id, text FROM memory_index_chunks_fts").all()).toEqual([
+        { id: "chunk-1", text: "remember this" },
+      ]);
       expect(db.prepare("SELECT provider, hash FROM memory_embedding_cache").all()).toEqual([
         { provider: "openai", hash: "chunk-hash" },
       ]);
diff --git a/packages/memory-host-sdk/src/host/memory-schema.ts b/packages/memory-host-sdk/src/host/memory-schema.ts
@@ -367,6 +367,16 @@ export function ensureMemoryIndexSchema(params: {
           `  end_line UNINDEXED\n` +
           `${tokenizeClause});`,
       );
+      // The shipped generic-table migration and a later FTS enablement both
+      // create an empty derived table beside already-canonical chunk rows.
+      params.db.exec(`
+        INSERT INTO ${MEMORY_INDEX_FTS_TABLE} (
+          text, id, path, source, model, start_line, end_line
+        )
+        SELECT text, id, path, source, model, start_line, end_line
+        FROM ${MEMORY_INDEX_CHUNKS_TABLE}
+        WHERE NOT EXISTS (SELECT 1 FROM ${MEMORY_INDEX_FTS_TABLE} LIMIT 1);
+      `);
       ftsAvailable = true;
     } catch (err) {
       const message = formatErrorMessage(err);
