Function buildSqliteIndex

src/context/sqlite-index.ts:105–154

(
  projectRoot: string,
  embeddingModel: string,
  chunks: Chunk[],
)

 * index at the path. Returns false if better-sqlite3 can't be loaded.
 */
export async function buildSqliteIndex(
  projectRoot: string,
  embeddingModel: string,
  chunks: Chunk[],
): Promise<boolean> {
  const Database = await loadSqlite();
  if (!Database) return false;

  const p = sqliteIndexPath(projectRoot, embeddingModel);
  await fs.mkdir(path.dirname(p), { recursive: true });
  // Remove stale file so we never half-overwrite.
  try { await fs.unlink(p); } catch { /* none */ }

  const db = new Database(p);
  db.pragma('journal_mode = WAL');
  db.exec(`
    CREATE TABLE meta (key TEXT PRIMARY KEY, value TEXT);
    CREATE TABLE chunks (
      id INTEGER PRIMARY KEY,
      file TEXT, start_line INTEGER, end_line INTEGER,
      symbol TEXT, text TEXT, hash TEXT,
      scale REAL, vec BLOB
    );
  `);

  const dims = chunks.find(c => c.embedding)?.embedding?.length ?? 0;
  const insertMeta = db.prepare('INSERT INTO meta(key,value) VALUES (?,?)');
  insertMeta.run('projectRoot', projectRoot);
  insertMeta.run('embeddingModel', embeddingModel);
  insertMeta.run('dims', String(dims));
  insertMeta.run('builtAt', String(Date.now()));

  const insertChunk = db.prepare(
    'INSERT INTO chunks(id,file,start_line,end_line,symbol,text,hash,scale,vec) VALUES (?,?,?,?,?,?,?,?,?)',
  );
  const tx = db.transaction((rows: Chunk[]) => {
    let id = 0;
    for (const c of rows) {
      if (!c.embedding || c.embedding.length === 0) continue;
      const q = quantize(c.embedding);
      insertChunk.run(
        id++, c.file, c.startLine, c.endLine, c.symbol ?? null,
        c.text, c.hash, q.scale, Buffer.from(q.bytes.buffer),
      );
    }
  });
  tx(chunks);
  db.close();
  return true;
}

export async function openSqliteIndex(
  projectRoot: string,