v0.6.0 - hardening: restore daemon rustfmt

Apply rustfmt to daemon admin, compaction, and embedding code that drifted during earlier v0.6.0 work.

Validation: rtk cargo fmt --manifest-path daemon-rs/Cargo.toml -- --check; rtk cargo check --manifest-path daemon-rs/Cargo.toml --tests.

Author: AdityaVG13

daemon-rs/src/admin.rs

@@ -267,26 +267,39 @@ mod tests {
         // Older memory predating the session — must not be touched.
         seed_memory(&conn, "claude", "old", "2026-04-23T23:59:00Z", "active");
         // Another agent's memory in the same time window — must not be touched.
-        seed_memory(&conn, "codex", "other-agent", "2026-04-24T00:05:00Z", "active");
+        seed_memory(
+            &conn,
+            "codex",
+            "other-agent",
+            "2026-04-24T00:05:00Z",
+            "active",
+        );
         // In-session memories + one already-rolled-back row to confirm we only
         // touch active rows.
         seed_memory(&conn, "claude", "m1", "2026-04-24T00:05:00Z", "active");
         seed_memory(&conn, "claude", "m2", "2026-04-24T00:10:00Z", "active");
-        seed_memory(&conn, "claude", "pre-rolled", "2026-04-24T00:07:00Z", ROLLED_BACK_STATUS);
+        seed_memory(
+            &conn,
+            "claude",
+            "pre-rolled",
+            "2026-04-24T00:07:00Z",
+            ROLLED_BACK_STATUS,
+        );
         seed_decision(&conn, "claude", "d1", "2026-04-24T00:06:00Z");
 
         let stats = rollback_session_by_id(&conn, "sess-1", true).unwrap();
-        assert_eq!(stats.memories_affected, 2, "only the 2 active in-session memories");
+        assert_eq!(
+            stats.memories_affected, 2,
+            "only the 2 active in-session memories"
+        );
         assert_eq!(stats.decisions_affected, 1);
         assert!(stats.applied);
 
         // Pre-existing rows preserved
         let old_status: String = conn
-            .query_row(
-                "SELECT status FROM memories WHERE text = 'old'",
-                [],
-                |r| r.get(0),
-            )
+            .query_row("SELECT status FROM memories WHERE text = 'old'", [], |r| {
+                r.get(0)
+            })
             .unwrap();
         assert_eq!(old_status, "active");
         let other_status: String = conn

daemon-rs/src/compaction.rs

@@ -404,9 +404,7 @@ fn run_compaction_with_options(conn: &Connection, allow_vacuum: bool) -> Compact
         + result.stale_embeddings_pruned
         + result.co_occurrence_pruned
         + result.legacy_embeddings_migrated;
-    if allow_vacuum
-        && (freelist_pages > VACUUM_FREELIST_THRESHOLD_PAGES || result.fts_optimized)
-    {
+    if allow_vacuum && (freelist_pages > VACUUM_FREELIST_THRESHOLD_PAGES || result.fts_optimized) {
         let _ = conn.execute_batch("VACUUM;");
     }
 
@@ -556,9 +554,7 @@ fn migrate_legacy_blob_column_to_pq8(
     let mut stmt = match conn.prepare(&select_sql) {
         Ok(stmt) => stmt,
         Err(err) => {
-            eprintln!(
-                "[compaction] PQ8 migration prepare failed for {table}.{column}: {err}"
-            );
+            eprintln!("[compaction] PQ8 migration prepare failed for {table}.{column}: {err}");
             return 0;
         }
     };
@@ -1804,10 +1800,7 @@ mod tests {
             .collect();
         assert_eq!(rows.len(), 2);
         for (label, blob) in &rows {
-            assert!(
-                blob.len() >= 2,
-                "{label} centroid too short to carry magic"
-            );
+            assert!(blob.len() >= 2, "{label} centroid too short to carry magic");
             assert_eq!(
                 blob[0],
                 crate::embeddings::PQ8_MAGIC_BYTE,
@@ -1923,8 +1916,7 @@ mod tests {
         // Recall fidelity: re-reading via blob_to_vector should match the
         // original within the per-vector quantization scale.
         let recovered = crate::embeddings::blob_to_vector(&new_blob);
-        let scale =
-            f32::from_le_bytes([new_blob[2], new_blob[3], new_blob[4], new_blob[5]]);
+        let scale = f32::from_le_bytes([new_blob[2], new_blob[3], new_blob[4], new_blob[5]]);
         let max_err = legacy_vec
             .iter()
             .zip(recovered.iter())

daemon-rs/src/embeddings.rs

@@ -674,9 +674,7 @@ pub fn vector_to_pq8_blob(vec: &[f32]) -> Vec<u8> {
 
 /// True iff the blob is a PQ8-encoded vector (magic + version match).
 pub fn is_pq8_blob(blob: &[u8]) -> bool {
-    blob.len() >= PQ8_HEADER_BYTES
-        && blob[0] == PQ8_MAGIC_BYTE
-        && blob[1] == PQ8_FORMAT_VERSION
+    blob.len() >= PQ8_HEADER_BYTES && blob[0] == PQ8_MAGIC_BYTE && blob[1] == PQ8_FORMAT_VERSION
 }
 
 /// Decode a PQ8 blob back to Vec<f32>. Returns None if the blob is not a
@@ -1193,6 +1191,9 @@ mod tests {
         );
         // Top-3 may permute slightly; require at least 2/3 overlap.
         let overlap = raw_top.iter().filter(|i| q_top.contains(i)).count();
-        assert!(overlap >= 2, "top-3 overlap < 2: raw={raw_top:?}, q={q_top:?}");
+        assert!(
+            overlap >= 2,
+            "top-3 overlap < 2: raw={raw_top:?}, q={q_top:?}"
+        );
     }
 }