providerUnavailableReason: "No embeddings provider available.",

})),

);

const originalFtsOnlyStateDir = process.env.OPENCLAW_STATE_DIR;

function setFtsOnlyStateDir(stateDir: string): void {

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

}

function restoreFtsOnlyStateDir(): void {

if (originalFtsOnlyStateDir === undefined) {

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

} else {

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

}

}

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

createEmbeddingProvider: createEmbeddingProviderMock,

workspaceDir = path.join(fixtureRoot, `case-${caseId++}`);

await fs.mkdir(path.join(workspaceDir, "memory"), { recursive: true });

await fs.writeFile(path.join(workspaceDir, "MEMORY.md"), "Alpha topic\n\nKeep this note.");

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

setFtsOnlyStateDir(path.join(workspaceDir, "state"));

indexPath = resolveOpenClawAgentSqlitePath({ agentId: "main" });

});

manager = null;

}

await closeAllMemorySearchManagers();

vi.unstubAllEnvs();

restoreFtsOnlyStateDir();

});

afterAll(async () => {

type SessionDeltaState = { lastSize: number; pendingBytes: number; pendingMessages: number };

type SyncSessionParams = { needsFullReindex: boolean; targetSessionFiles?: string[] };

const originalReindexStateDir = process.env.OPENCLAW_STATE_DIR;

function setReindexStateDir(stateDir: string): void {

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

}

function restoreReindexStateDir(): void {

if (originalReindexStateDir === undefined) {

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

} else {

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

}

}

type ReindexHarness = {

sync: (params: { reason?: string; force?: boolean }) => Promise<void>;

workspaceDir = path.join(fixtureRoot, "workspace");

memoryDir = path.join(workspaceDir, "memory");

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

vi.stubEnv("OPENCLAW_STATE_DIR", path.join(fixtureRoot, "state"));

setReindexStateDir(path.join(fixtureRoot, "state"));

});

afterEach(async () => {

vi.unstubAllEnvs();

restoreReindexStateDir();

vi.restoreAllMocks();

if (manager) {

await manager.close();