feat: update specs

Author: bimawa

.kiro/specs/ci-multi-platform/spec.json

@@ -5,5 +5,5 @@
   "phase": "implementation",
   "language": "ru",
   "created": "2026-07-14",
-  "updated": "2026-07-14"
-}
+  "updated": "2026-07-15"
+}

.kiro/specs/code-anchors-cross-repo/spec.json

@@ -6,8 +6,10 @@
   "language": "ru",
   "priority": "P0",
   "effort": "XL",
-  "depends_on": ["trace-graph-db"],
+  "depends_on": [
+    "trace-graph-db"
+  ],
   "wave": 2,
   "created": "2026-07-11",
-  "updated": "2026-07-14"
-}
+  "updated": "2026-07-15"
+}

.kiro/specs/kq-dual-mode/spec.json

@@ -5,9 +5,15 @@
   "phase": "implementation",
   "language": "ru",
   "approvals": {
-    "requirements": { "generated": true, "approved": true },
-    "design": { "generated": true, "approved": true }
+    "requirements": {
+      "generated": true,
+      "approved": true
+    },
+    "design": {
+      "generated": true,
+      "approved": true
+    }
   },
   "created": "2026-07-14",
   "updated": "2026-07-15"
-}
+}

.kiro/specs/trace-graph-db/spec.json

@@ -9,5 +9,5 @@
   "depends_on": [],
   "wave": 1,
   "created": "2026-07-11",
-  "updated": "2026-07-11"
-}
+  "updated": "2026-07-15"
+}

kq-core/src/vector.rs

@@ -2,16 +2,17 @@ use std::collections::HashMap;
 use std::sync::Once;
 
 use anyhow::{Context, Result};
-use rusqlite::Connection;
 use sqlite_vec::sqlite3_vec_init;
+use rusqlite::Connection;
+use rusqlite::ffi as sqlite_ffi;
 
 const EMBEDDING_DIM: usize = 384;
 static REGISTER_VEC_GLOBAL: Once = Once::new();
 
 /// Register vec0 globally (for future connections) and directly on this connection.
 pub fn register_vec_on_connection(db: &Connection) -> Result<()> {
     REGISTER_VEC_GLOBAL.call_once(|| unsafe {
-        rusqlite::ffi::sqlite3_auto_extension(Some(std::mem::transmute::<*const (), _>(
+        sqlite_ffi::sqlite3_auto_extension(Some(std::mem::transmute::<*const (), _>(
             sqlite3_vec_init as *const (),
         )));
     });
@@ -105,6 +106,7 @@ pub fn reindex_embeddings(conn: &Connection) -> Result<usize> {
     Ok(changed.len())
 }
 
+
 #[cfg(test)]
 mod tests {
     use super::*;

kq-core/src/vector_add.rs

@@ -0,0 +1,26 @@
+pub fn register_vec_on_connection(db: &Connection) -> Result<()> {
+    REGISTER_VEC.call_once(|| unsafe {
+        rusqlite::ffi::sqlite3_auto_extension(Some(std::mem::transmute::<*const (), _>(
+            sqlite3_vec_init as *const (),
+        )));
+    });
+    unsafe {
+        type F = unsafe extern "C" fn(*mut rusqlite::ffi::sqlite3, *mut *mut std::os::raw::c_char, *const std::ffi::c_void) -> i32;
+        let ptr: *const () = sqlite3_vec_init as *const ();
+        let f: F = std::mem::transmute(ptr);
+        let rc = f(db.handle(), std::ptr::null_mut(), std::ptr::null());
+        if rc != 0 { anyhow::bail!("vec0 init failed: {}", rc); }
+    }
+    Ok(())
+}
+
+pub fn reindex_embeddings(conn: &Connection) -> Result<usize> {
+    let changed: Vec<(i64, String, String)> = conn.prepare(
+        "SELECT f.id, f.path, f.content_hash FROM files f
+         LEFT JOIN vec_chunks vc ON vc.file_id = f.id AND vc.content_hash = f.content_hash
+         WHERE vc.rowid IS NULL"
+    )?.query_map([], |row| Ok((row.get(0)?, row.get(1)?, row.get(2)?)))?.filter_map(|r| r.ok()).collect();
+    if changed.is_empty() { return Ok(0); }
+    for (fid, _, _) in &changed { conn.execute("DELETE FROM vec_chunks WHERE file_id = ?1", rusqlite::params![fid])?; }
+    Ok(changed.len())
+}