feat(people): contact resolution + scoring + CNContactStore (A5)

Cargo.toml

@@ -67,6 +67,9 @@ tokio-util = { version = "0.7", features = ["rt"] }
 tokio-tungstenite = { version = "0.24", features = ["rustls-tls-webpki-roots"] }
 futures = "0.3"
 rusqlite = { version = "0.37", features = ["bundled"] }
+r2d2 = "0.8"
+r2d2_sqlite = "0.31"
+sqlite-vec = "0.1"
 chrono = { version = "0.4", features = ["serde"] }
 iana-time-zone = "0.1"
 cron = "0.12"
@@ -142,12 +145,19 @@ wacore = { version = "0.5", optional = true, default-features = false }
 
 [target.'cfg(target_os = "macos")'.dependencies]
 whisper-rs = { version = "0.16", features = ["metal"] }
+# Contacts framework bindings for address book seeding (A5).
+# Version matched to objc2-event-kit = "0.3.2" used by A7.
+objc2 = "0.6"
+objc2-foundation = { version = "0.3", features = ["NSArray", "NSError", "NSObject", "NSString", "NSPredicate"] }
+objc2-contacts = { version = "0.3.2", features = ["CNContact", "CNContactFetchRequest", "CNContactStore", "CNLabeledValue", "CNPhoneNumber"] }
+block2 = "0.6"
 
 [target.'cfg(target_os = "linux")'.dependencies]
 landlock = { version = "0.4", optional = true }
 rppal = { version = "0.22", optional = true }
 
 [dev-dependencies]
+httpmock = "0.7"
 
 [features]
 sandbox-landlock = ["dep:landlock"]

app/src-tauri/src/imessage_scanner/mod.rs

@@ -417,23 +417,26 @@ async fn ingest_group(account_id: &str, key: &str, transcript: String) -> anyhow
     let (chat_id, day) = key.split_once(':').unwrap_or((key, ""));
     let url = crate::core_rpc::core_rpc_url_value();
 
+    // Use anchor timestamp = start of the chat-day in UTC so re-ingests for the
+    // same day map to a stable `ts` field. Scanner's cursor + PersonalIndex's
+    // upsert-by-(source, external_id) together guarantee no duplicates.
+    let ts = parse_day_to_unix(day).unwrap_or_else(|| chrono::Utc::now().timestamp());
+
     let body = json!({
         "jsonrpc": "2.0",
         "id": 1,
-        "method": "openhuman.memory_doc_ingest",
+        "method": "openhuman.life_capture_ingest",
         "params": {
-            "namespace": format!("imessage:{}", account_id),
-            "key": key,
-            "title": format!("Messages — {} — {}", chat_id, day),
-            "content": transcript,
-            "source_type": "imessage",
-            "tags": ["chat", "imessage"],
+            "source": "imessage",
+            "external_id": key,
+            "ts": ts,
+            "subject": format!("Messages — {} — {}", chat_id, day),
+            "text": transcript,
             "metadata": {
                 "chat_identifier": chat_id,
                 "day": day,
-                "source": "imessage"
-            },
-            "category": "chat"
+                "account_id": account_id
+            }
         }
     });
 
@@ -444,10 +447,18 @@ async fn ingest_group(account_id: &str, key: &str, transcript: String) -> anyhow
         anyhow::bail!("core rpc {}: {}", res.status(), res.text().await?);
     }
 
-    log::info!("[imessage] memory upsert ok key={}", key);
+    log::info!("[imessage] life_capture ingest ok key={}", key);
     Ok(())
 }
 
+/// Parse a "YYYY-MM-DD" day string to a unix-seconds timestamp at 00:00 UTC.
+/// Returns None for malformed input; caller falls back to wall-clock time.
+#[cfg(target_os = "macos")]
+fn parse_day_to_unix(day: &str) -> Option<i64> {
+    let d = chrono::NaiveDate::parse_from_str(day, "%Y-%m-%d").ok()?;
+    Some(d.and_hms_opt(0, 0, 0)?.and_utc().timestamp())
+}
+
 // Non-macOS stub so the rest of the app compiles unchanged.
 #[cfg(not(target_os = "macos"))]
 pub struct ScannerRegistry;

docs/superpowers/plans/2026-04-21-imessage-live-harness.md

@@ -56,7 +56,16 @@ Prod path wraps: `HttpDeps { base_url }` implements `TickDeps` with existing JSO
 - [ ] Step 3: Move tick body 129-209 into `run_single_tick`. Green.
 - [ ] Step 4: Write `HttpDeps` wrapping existing gate+ingest fns. Use in `run_scanner`.
 - [ ] Step 5: Existing 9 unit tests + 2 ignored still green.
-- [ ] Step 6: Write ignored live-sidecar test. Needs sidecar binary staged; use `cargo build --bin openhuman` at root first.
+- [x] Step 6: Ingest bridge + ignored e2e test. Scanner now POSTs to
+      `openhuman.life_capture_ingest` (bridging into `PersonalIndex` via
+      `IndexWriter::upsert` — idempotent by `(source, external_id)`) instead
+      of `openhuman.memory_doc_ingest`. Verification surface is
+      `openhuman.life_capture_search`, not a raw `memory.db` query. Test at
+      `tests/imessage_ingest_e2e.rs` boots `build_core_http_router` in-process
+      with a deterministic embedder and asserts: (a) first ingest inserts,
+      (b) search surfaces the item with `source=="imessage"`, (c) re-ingest
+      with same external_id sets `replaced=true` and leaves
+      `get_stats.total_items` unchanged (process-once guarantee).
 - [ ] Step 7: Update `docs/superpowers/runbooks/imessage-verification.md` with harness commands.
 - [ ] Step 8: Run `cargo check` + `cargo fmt` in app/src-tauri.