let providerInitGate: Promise<void> | null = null;

let providerCalls: Array<{ provider?: string; model?: string; outputDimensionality?: number }> = [];

let forceNoProvider = false;

const originalMemoryIndexStateDir = process.env.OPENCLAW_STATE_DIR;

const identityAliasFixture = vi.hoisted(() => ({

provider: "identity-alias-test",

});

}

function setMemoryIndexStateDir(stateDir: string): void {

Reflect.set(process.env, "OPENCLAW_STATE_DIR", stateDir);

}

function restoreMemoryIndexStateDir(): void {

if (originalMemoryIndexStateDir === undefined) {

Reflect.deleteProperty(process.env, "OPENCLAW_STATE_DIR");

} else {

Reflect.set(process.env, "OPENCLAW_STATE_DIR", originalMemoryIndexStateDir);

}

}

vi.mock("./embeddings.js", () => {

const embedText = (text: string) => {

const lower = text.toLowerCase();

closeOpenClawStateDatabaseForTest();

clearRegistry();

managersForCleanup.clear();

vi.unstubAllEnvs();

restoreMemoryIndexStateDir();

});

beforeEach(async () => {

rmSync(workspaceDir, { recursive: true, force: true });

mkdirSync(memoryDir, { recursive: true });

vi.stubEnv("OPENCLAW_STATE_DIR", path.join(workspaceDir, ".state-memory-index"));

setMemoryIndexStateDir(path.join(workspaceDir, ".state-memory-index"));

await fs.writeFile(

path.join(memoryDir, "2026-01-12.md"),

"# Log\nAlpha memory line.\nZebra memory line.",

stateDirName: string;

}): Promise<MemoryIndexManager | null> {

forceNoProvider = true;

vi.stubEnv("OPENCLAW_STATE_DIR", path.join(workspaceDir, params.stateDirName));

setMemoryIndexStateDir(path.join(workspaceDir, params.stateDirName));

const cfg = createCfg({

sources: ["memory", "sessions"],

sessionMemory: true,

it("reindexes memory tables in place without deleting unrelated agent rows", async () => {

const stateDir = path.join(workspaceDir, "managed-memory-state");

vi.stubEnv("OPENCLAW_STATE_DIR", stateDir);

setMemoryIndexStateDir(stateDir);

const agentDbPath = resolveOpenClawAgentSqlitePath({ agentId: "main" });

const agentDb = openOpenClawAgentDatabase({ agentId: "main" });

agentDb.db

it("clears dirty after sessions-only identity reindex", async () => {

try {

vi.stubEnv("OPENCLAW_STATE_DIR", path.join(workspaceDir, ".state-sessions-only-reindex"));

setMemoryIndexStateDir(path.join(workspaceDir, ".state-sessions-only-reindex"));

const sessionsDir = resolveSessionTranscriptsDirForAgent("main");

await fs.mkdir(sessionsDir, { recursive: true });

await fs.writeFile(

await nextManager.close?.();

}

} finally {

vi.unstubAllEnvs();

restoreMemoryIndexStateDir();

}

});

it("marks sessions-only indexes dirty when metadata is missing but chunks exist", async () => {

try {

vi.stubEnv("OPENCLAW_STATE_DIR", path.join(workspaceDir, ".state-sessions-missing-meta"));

setMemoryIndexStateDir(path.join(workspaceDir, ".state-sessions-missing-meta"));

const sessionsDir = resolveSessionTranscriptsDirForAgent("main");

await fs.mkdir(sessionsDir, { recursive: true });

await fs.writeFile(

await nextManager.close?.();

}

} finally {

vi.unstubAllEnvs();

restoreMemoryIndexStateDir();

}

});

it("keeps provider cutover vector search paused during targeted session sync", async () => {

try {

vi.stubEnv("OPENCLAW_STATE_DIR", path.join(workspaceDir, ".state-targeted-cutover"));

setMemoryIndexStateDir(path.join(workspaceDir, ".state-targeted-cutover"));

const sessionsDir = resolveSessionTranscriptsDirForAgent("main");

await fs.mkdir(sessionsDir, { recursive: true });

const sessionFile = path.join(sessionsDir, "session-targeted-cutover.jsonl");

await nextManager.close?.();

}

} finally {

vi.unstubAllEnvs();

restoreMemoryIndexStateDir();

}

});

it("preserves memory dirty events raised during session identity reindex", async () => {

try {

vi.stubEnv("OPENCLAW_STATE_DIR", path.join(workspaceDir, ".state-dirty-during-session"));

setMemoryIndexStateDir(path.join(workspaceDir, ".state-dirty-during-session"));

const sessionsDir = resolveSessionTranscriptsDirForAgent("main");

await fs.mkdir(sessionsDir, { recursive: true });

await fs.writeFile(

await nextManager.close?.();

}

} finally {

vi.unstubAllEnvs();

restoreMemoryIndexStateDir();

}

});

expect(results[0]?.source).toBe("sessions");

expect(results[0]?.snippet).toContain("ORBIT-10");

} finally {

vi.unstubAllEnvs();

restoreMemoryIndexStateDir();

}

});

expect(results[0]?.source).toBe("sessions");

expect(results[0]?.snippet).toContain("ORBIT-10");

} finally {

vi.unstubAllEnvs();

restoreMemoryIndexStateDir();

}

});

});