style: rustfmt this session's T1-T4a files

Line-length/wrapping-only reflow from cargo fmt -- no behavior change,
full test suite already re-verified green (calm-core 1050/1050,
calm-server 364/364, calm-cli, clippy clean in both default and
--features index-bundles) after applying it.

Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>

Author: Your Name

crates/calm-cli/src/main.rs

@@ -1150,7 +1150,10 @@ async fn main() -> Result<()> {
         }
         #[cfg(feature = "index-bundles")]
         Commands::Bundle { action } => match action {
-            BundleAction::Export { project_root, output } => {
+            BundleAction::Export {
+                project_root,
+                output,
+            } => {
                 let root = std::fs::canonicalize(&project_root)?;
                 let db_path = calm_server::default_db_path(&root);
                 let config = calm_core::config::load_config_or_warn(&root);
@@ -1168,7 +1171,10 @@ async fn main() -> Result<()> {
                 let manifest = calm_core::bundle::inspect_bundle(&archive)?;
                 println!("{}", serde_json::to_string_pretty(&manifest)?);
             }
-            BundleAction::Import { archive, project_root } => {
+            BundleAction::Import {
+                archive,
+                project_root,
+            } => {
                 let root = std::fs::canonicalize(&project_root)?;
                 let db_path = calm_server::default_db_path(&root);
                 let config = calm_core::config::load_config_or_warn(&root);
@@ -1187,7 +1193,9 @@ async fn main() -> Result<()> {
                     );
                 }
                 if !report.commit_matches {
-                    println!("  (imported as a seed, not an exact match for this repo's current HEAD)");
+                    println!(
+                        "  (imported as a seed, not an exact match for this repo's current HEAD)"
+                    );
                 }
             }
         },

crates/calm-core/src/bundle.rs

@@ -173,10 +173,7 @@ pub fn export_bundle(
 
     {
         let src = Connection::open_with_flags(db_path, OpenFlags::SQLITE_OPEN_READ_ONLY)?;
-        src.execute(
-            "VACUUM INTO ?1",
-            [snapshot_path.to_string_lossy().as_ref()],
-        )?;
+        src.execute("VACUUM INTO ?1", [snapshot_path.to_string_lossy().as_ref()])?;
     }
 
     // Re-open the FRESH snapshot for integrity_check and stats -- verifies
@@ -236,10 +233,7 @@ pub fn export_bundle(
         MANIFEST_FILE_NAME,
         manifest_json.as_slice(),
     )?;
-    tar_builder
-        .into_inner()?
-        .finish()?
-        .flush()?;
+    tar_builder.into_inner()?.finish()?.flush()?;
 
     Ok(manifest)
 }
@@ -304,7 +298,8 @@ pub fn import_bundle(
     }
 
     {
-        let snap = Connection::open_with_flags(&extracted_db_path, OpenFlags::SQLITE_OPEN_READ_ONLY)?;
+        let snap =
+            Connection::open_with_flags(&extracted_db_path, OpenFlags::SQLITE_OPEN_READ_ONLY)?;
         check_integrity(&snap)?;
     }
 
@@ -437,21 +432,19 @@ mod tests {
 
         let config = Config::default();
         let archive_path = src_dir.path().join("bundle.tar.gz");
-        let manifest =
-            export_bundle(&db_path, src_dir.path(), &config, &archive_path).unwrap();
+        let manifest = export_bundle(&db_path, src_dir.path(), &config, &archive_path).unwrap();
         assert_eq!(manifest.symbol_count, 1);
         assert_eq!(manifest.file_count, 1);
         assert!(archive_path.exists());
 
         let dest_dir = tempfile::tempdir().unwrap();
         let dest_db_path = dest_dir.path().join("index.db");
-        let report =
-            import_bundle(&archive_path, dest_dir.path(), &dest_db_path, &config).unwrap();
+        let report = import_bundle(&archive_path, dest_dir.path(), &dest_db_path, &config).unwrap();
         assert_eq!(report.manifest.symbol_count, 1);
         assert!(dest_db_path.exists());
 
-        let conn = Connection::open_with_flags(&dest_db_path, OpenFlags::SQLITE_OPEN_READ_ONLY)
-            .unwrap();
+        let conn =
+            Connection::open_with_flags(&dest_db_path, OpenFlags::SQLITE_OPEN_READ_ONLY).unwrap();
         let count: i64 = conn
             .query_row("SELECT COUNT(*) FROM symbols", [], |r| r.get(0))
             .unwrap();
@@ -501,17 +494,33 @@ mod tests {
             manifest_header.set_mode(0o644);
             manifest_header.set_cksum();
             builder
-                .append_data(&mut manifest_header, MANIFEST_FILE_NAME, manifest_json.as_slice())
+                .append_data(
+                    &mut manifest_header,
+                    MANIFEST_FILE_NAME,
+                    manifest_json.as_slice(),
+                )
+                .unwrap();
+            builder
+                .into_inner()
+                .unwrap()
+                .finish()
+                .unwrap()
+                .flush()
                 .unwrap();
-            builder.into_inner().unwrap().finish().unwrap().flush().unwrap();
         }
 
         let dest_dir = tempfile::tempdir().unwrap();
         let dest_db_path = dest_dir.path().join("index.db");
-        let err = import_bundle(&tampered_path, dest_dir.path(), &dest_db_path, &config)
-            .unwrap_err();
-        assert!(matches!(err, BundleError::ChecksumMismatch { .. }), "{err:?}");
-        assert!(!dest_db_path.exists(), "a failed import must not touch the destination at all");
+        let err =
+            import_bundle(&tampered_path, dest_dir.path(), &dest_db_path, &config).unwrap_err();
+        assert!(
+            matches!(err, BundleError::ChecksumMismatch { .. }),
+            "{err:?}"
+        );
+        assert!(
+            !dest_db_path.exists(),
+            "a failed import must not touch the destination at all"
+        );
     }
 
     #[test]
@@ -546,15 +555,24 @@ mod tests {
             manifest_header.set_mode(0o644);
             manifest_header.set_cksum();
             builder
-                .append_data(&mut manifest_header, MANIFEST_FILE_NAME, manifest_json.as_slice())
+                .append_data(
+                    &mut manifest_header,
+                    MANIFEST_FILE_NAME,
+                    manifest_json.as_slice(),
+                )
+                .unwrap();
+            builder
+                .into_inner()
+                .unwrap()
+                .finish()
+                .unwrap()
+                .flush()
                 .unwrap();
-            builder.into_inner().unwrap().finish().unwrap().flush().unwrap();
         }
 
         let dest_dir = tempfile::tempdir().unwrap();
         let dest_db_path = dest_dir.path().join("index.db");
-        let err = import_bundle(&bumped_path, dest_dir.path(), &dest_db_path, &config)
-            .unwrap_err();
+        let err = import_bundle(&bumped_path, dest_dir.path(), &dest_db_path, &config).unwrap_err();
         assert!(matches!(err, BundleError::SchemaTooNew { .. }), "{err:?}");
     }
 
@@ -618,16 +636,29 @@ mod tests {
             manifest_header.set_mode(0o644);
             manifest_header.set_cksum();
             builder
-                .append_data(&mut manifest_header, MANIFEST_FILE_NAME, manifest_json.as_slice())
+                .append_data(
+                    &mut manifest_header,
+                    MANIFEST_FILE_NAME,
+                    manifest_json.as_slice(),
+                )
+                .unwrap();
+            builder
+                .into_inner()
+                .unwrap()
+                .finish()
+                .unwrap()
+                .flush()
                 .unwrap();
-            builder.into_inner().unwrap().finish().unwrap().flush().unwrap();
         }
 
         let dest_dir = tempfile::tempdir().unwrap();
         let dest_db_path = dest_dir.path().join("index.db");
-        let err = import_bundle(&archive_path, dest_dir.path(), &dest_db_path, &config)
-            .unwrap_err();
-        assert!(matches!(err, BundleError::IntegrityCheckFailed(_)), "{err:?}");
+        let err =
+            import_bundle(&archive_path, dest_dir.path(), &dest_db_path, &config).unwrap_err();
+        assert!(
+            matches!(err, BundleError::IntegrityCheckFailed(_)),
+            "{err:?}"
+        );
         assert!(!dest_db_path.exists());
     }
 
@@ -643,8 +674,7 @@ mod tests {
 
         let dest_dir = tempfile::tempdir().unwrap();
         let dest_db_path = dest_dir.path().join("index.db");
-        let report =
-            import_bundle(&archive_path, dest_dir.path(), &dest_db_path, &config).unwrap();
+        let report = import_bundle(&archive_path, dest_dir.path(), &dest_db_path, &config).unwrap();
         // Both sides have no git commit -> commit_matches is conservatively
         // false (never assume equality from two absences), which forces a
         // full reindex recommendation.

crates/calm-core/src/graph/digest.rs

@@ -344,7 +344,10 @@ pub fn compute_digests(conn: &Connection) -> rusqlite::Result<()> {
     {
         let mut stmt = conn.prepare("SELECT qualified_name, name_tokens FROM symbols")?;
         let iter = stmt.query_map([], |r| {
-            Ok((r.get::<_, String>(0)?, r.get::<_, Option<String>>(1)?.unwrap_or_default()))
+            Ok((
+                r.get::<_, String>(0)?,
+                r.get::<_, Option<String>>(1)?.unwrap_or_default(),
+            ))
         })?;
         for row in iter {
             let (qn, tokens) = row?;
@@ -406,8 +409,9 @@ pub fn compute_digests(conn: &Connection) -> rusqlite::Result<()> {
 
     let mut effects_by_symbol: HashMap<String, Vec<EffectFact>> = HashMap::new();
     {
-        let mut stmt =
-            conn.prepare("SELECT symbol_qn, effect_kind, target_text FROM symbol_effects ORDER BY line")?;
+        let mut stmt = conn.prepare(
+            "SELECT symbol_qn, effect_kind, target_text FROM symbol_effects ORDER BY line",
+        )?;
         let iter = stmt.query_map([], |r| {
             Ok((
                 r.get::<_, String>(0)?,
@@ -417,13 +421,10 @@ pub fn compute_digests(conn: &Connection) -> rusqlite::Result<()> {
         })?;
         for row in iter {
             let (qn, kind, target) = row?;
-            effects_by_symbol
-                .entry(qn)
-                .or_default()
-                .push(EffectFact {
-                    effect_kind: kind,
-                    target_text: target,
-                });
+            effects_by_symbol.entry(qn).or_default().push(EffectFact {
+                effect_kind: kind,
+                target_text: target,
+            });
         }
     }
 
@@ -461,7 +462,10 @@ pub fn compute_digests(conn: &Connection) -> rusqlite::Result<()> {
         let possible_truncated = possible.len() > MAX_POSSIBLE_CALLEES_SHOWN;
         possible.truncate(MAX_POSSIBLE_CALLEES_SHOWN);
 
-        let type_relations = type_relations_by_from.get(&row.qn).cloned().unwrap_or_default();
+        let type_relations = type_relations_by_from
+            .get(&row.qn)
+            .cloned()
+            .unwrap_or_default();
 
         let mut effects = effects_by_symbol.get(&row.qn).cloned().unwrap_or_default();
         let effects_truncated = effects.len() > MAX_EFFECTS_SHOWN;
@@ -669,14 +673,32 @@ mod tests {
             signature: "fn refresh_session(token, store) -> User".to_string(),
             complexity: 7,
             confirmed_callees: vec![
-                CalleeFact { name: "verify_token".to_string(), role_tags: vec!["verify".to_string(), "token".to_string()] },
-                CalleeFact { name: "load_session".to_string(), role_tags: vec![] },
+                CalleeFact {
+                    name: "verify_token".to_string(),
+                    role_tags: vec!["verify".to_string(), "token".to_string()],
+                },
+                CalleeFact {
+                    name: "load_session".to_string(),
+                    role_tags: vec![],
+                },
             ],
-            possible_callees: vec![CalleeFact { name: "emit_event".to_string(), role_tags: vec!["emit".to_string()] }],
-            type_relations: vec![TypeRelationFact { relation_kind: "implements".to_string(), target_text: "SessionRefresher".to_string() }],
+            possible_callees: vec![CalleeFact {
+                name: "emit_event".to_string(),
+                role_tags: vec!["emit".to_string()],
+            }],
+            type_relations: vec![TypeRelationFact {
+                relation_kind: "implements".to_string(),
+                target_text: "SessionRefresher".to_string(),
+            }],
             effects: vec![
-                EffectFact { effect_kind: "write_field".to_string(), target_text: "last_refresh".to_string() },
-                EffectFact { effect_kind: "explicit_throw".to_string(), target_text: "ExpiredToken".to_string() },
+                EffectFact {
+                    effect_kind: "write_field".to_string(),
+                    target_text: "last_refresh".to_string(),
+                },
+                EffectFact {
+                    effect_kind: "explicit_throw".to_string(),
+                    target_text: "ExpiredToken".to_string(),
+                },
             ],
             recursive_component: false,
             truncated: false,
@@ -748,7 +770,8 @@ mod tests {
             "INSERT INTO symbol_effects (symbol_qn, effect_kind, target_text, source_path, line) \
              VALUES ('a.py::Foo::m', 'write_field', 'x', 'a.py', 1)",
             [],
-        ).unwrap();
+        )
+        .unwrap();
 
         compute_digests(&conn).unwrap();