return openMemoryDatabaseAtPath(dbPath, this.settings.store.vector.enabled);

}

private seedEmbeddingCache(sourceDb: DatabaseSync): void {

private async seedEmbeddingCache(sourceDb: DatabaseSync): Promise<void> {

if (!this.cache.enabled) {

return;

}

let transactionStarted = false;

try {

const rows = sourceDb

.prepare(

`SELECT provider, model, provider_key, hash, embedding, dims, updated_at FROM ${EMBEDDING_CACHE_TABLE}`,

)

.all() as Array<{

.iterate() as IterableIterator<{

provider: string;

model: string;

provider_key: string;

dims: number | null;

updated_at: number;

}>;

if (!rows.length) {

return;

}

const insert = this.db.prepare(

`INSERT INTO ${EMBEDDING_CACHE_TABLE} (provider, model, provider_key, hash, embedding, dims, updated_at)

VALUES (?, ?, ?, ?, ?, ?, ?)

ON CONFLICT(provider, model, provider_key, hash) DO UPDATE SET

embedding=excluded.embedding,

dims=excluded.dims,

updated_at=excluded.updated_at`,

);

this.db.exec("BEGIN");

// Keep gateway health probes responsive while rebuilding large caches.

const SEED_EMBEDDING_YIELD_EVERY = 1000;

let rowCount = 0;

let insert: ReturnType<DatabaseSync["prepare"]> | null = null;

for (const row of rows) {

if (!insert) {

insert = this.db.prepare(

`INSERT INTO ${EMBEDDING_CACHE_TABLE} (provider, model, provider_key, hash, embedding, dims, updated_at)

VALUES (?, ?, ?, ?, ?, ?, ?)

ON CONFLICT(provider, model, provider_key, hash) DO UPDATE SET

embedding=excluded.embedding,

dims=excluded.dims,

updated_at=excluded.updated_at`,

);

this.db.exec("BEGIN");

transactionStarted = true;

}

insert.run(

row.provider,

row.model,

row.dims,

row.updated_at,

);

rowCount += 1;

if (rowCount % SEED_EMBEDDING_YIELD_EVERY === 0) {

await new Promise<void>((resolve) => {

setImmediate(resolve);

});

}

}

if (transactionStarted) {

this.db.exec("COMMIT");

}

this.db.exec("COMMIT");

} catch (err) {

try {

this.db.exec("ROLLBACK");

} catch {}

if (transactionStarted) {

try {

this.db.exec("ROLLBACK");

} catch {}

}

throw err;

}

}

targetPath: dbPath,

tempPath: tempDbPath,

build: async () => {

this.seedEmbeddingCache(originalDb);

await this.seedEmbeddingCache(originalDb);

const shouldSyncMemory = this.sources.has("memory");

const shouldSyncSessions = this.shouldSyncSessions(

{ reason: params.reason, force: params.force },