style: cargo fmt

Author: superstructor

src/cli/loop_cmd.rs

@@ -317,10 +317,7 @@ fn migrate_legacy_install(claude_dir: &std::path::Path) -> Result<MigrationResul
         remove_hooks_from_settings(&settings_path)?;
     }
 
-    output::success(&format!(
-        "Removed {} legacy files/directories",
-        removed
-    ));
+    output::success(&format!("Removed {} legacy files/directories", removed));
 
     Ok(MigrationResult {
         migrated: true,
@@ -334,8 +331,8 @@ fn remove_hooks_from_settings(settings_path: &std::path::Path) -> Result<bool> {
         return Ok(false);
     }
 
-    let contents = std::fs::read_to_string(settings_path)
-        .context("failed to read settings.json")?;
+    let contents =
+        std::fs::read_to_string(settings_path).context("failed to read settings.json")?;
     let mut val: serde_json::Value = match serde_json::from_str(&contents) {
         Ok(v) => v,
         Err(_) => return Ok(false),
@@ -381,10 +378,9 @@ fn remove_hooks_from_settings(settings_path: &std::path::Path) -> Result<bool> {
         }
 
         if modified {
-            let formatted = serde_json::to_string_pretty(&val)
-                .context("failed to serialize settings.json")?;
-            std::fs::write(settings_path, formatted)
-                .context("failed to write settings.json")?;
+            let formatted =
+                serde_json::to_string_pretty(&val).context("failed to serialize settings.json")?;
+            std::fs::write(settings_path, formatted).context("failed to write settings.json")?;
         }
     }
 
@@ -398,8 +394,8 @@ fn migrate_claude_md(claude_dir: &std::path::Path) -> Result<()> {
         return Ok(());
     }
 
-    let contents = std::fs::read_to_string(&claude_md_path)
-        .context("failed to read ~/.claude/CLAUDE.md")?;
+    let contents =
+        std::fs::read_to_string(&claude_md_path).context("failed to read ~/.claude/CLAUDE.md")?;
 
     if contents.trim() == LEGACY_CLAUDE_MD.trim() {
         std::fs::remove_file(&claude_md_path)
@@ -440,10 +436,7 @@ fn collect_existing_paths(claude_dir: &std::path::Path) -> Vec<std::path::PathBu
 
     // Check skill files in plugin dir
     for skill in SKILLS {
-        let path = plugin_dir
-            .join("skills")
-            .join(skill.name)
-            .join("SKILL.md");
+        let path = plugin_dir.join("skills").join(skill.name).join("SKILL.md");
         if path.exists() {
             existing.push(path);
         }
@@ -587,8 +580,7 @@ fn run_install(project: bool, force: bool, non_interactive: bool) -> Result<()>
 
     // Write plugin manifest
     let manifest_path = plugin_manifest_dir.join("plugin.json");
-    std::fs::write(&manifest_path, PLUGIN_MANIFEST)
-        .context("failed to write plugin.json")?;
+    std::fs::write(&manifest_path, PLUGIN_MANIFEST).context("failed to write plugin.json")?;
     output::success("Plugin manifest -> ~/.claude/plugins/great/.claude-plugin/plugin.json");
 
     // Write agent files
@@ -604,10 +596,7 @@ fn run_install(project: bool, force: bool, non_interactive: bool) -> Result<()>
 
     // Write skill files
     for skill in SKILLS {
-        let path = plugin_dir
-            .join("skills")
-            .join(skill.name)
-            .join("SKILL.md");
+        let path = plugin_dir.join("skills").join(skill.name).join("SKILL.md");
         std::fs::write(&path, skill.content)
             .with_context(|| format!("failed to write skill file: {}", path.display()))?;
     }
@@ -618,14 +607,12 @@ fn run_install(project: bool, force: bool, non_interactive: bool) -> Result<()>
 
     // Write hooks.json
     let hooks_json_path = plugin_hooks_dir.join("hooks.json");
-    std::fs::write(&hooks_json_path, HOOKS_JSON)
-        .context("failed to write hooks.json")?;
+    std::fs::write(&hooks_json_path, HOOKS_JSON).context("failed to write hooks.json")?;
     output::success("Hooks config -> ~/.claude/plugins/great/hooks/hooks.json");
 
     // Write hook handler script
     let hook_script_path = plugin_scripts_dir.join("update-state.sh");
-    std::fs::write(&hook_script_path, HOOK_UPDATE_STATE)
-        .context("failed to write hook script")?;
+    std::fs::write(&hook_script_path, HOOK_UPDATE_STATE).context("failed to write hook script")?;
 
     // Make executable (Unix only)
     #[cfg(unix)]
@@ -646,8 +633,7 @@ fn run_install(project: bool, force: bool, non_interactive: bool) -> Result<()>
         .context("failed to write observer-template.md")?;
 
     let teams_cfg_path = plugin_dir.join("teams-config.json");
-    std::fs::write(&teams_cfg_path, TEAMS_CONFIG)
-        .context("failed to write teams-config.json")?;
+    std::fs::write(&teams_cfg_path, TEAMS_CONFIG).context("failed to write teams-config.json")?;
 
     // --- Phase 3: Side-effects outside plugin ---
 
@@ -762,9 +748,7 @@ fn run_install(project: bool, force: bool, non_interactive: bool) -> Result<()>
                         // No hooks key at all — just handle statusLine
                         let needs_statusline = if !obj.contains_key("statusLine") {
                             true
-                        } else if let Some(sl) =
-                            obj.get("statusLine").and_then(|v| v.as_object())
-                        {
+                        } else if let Some(sl) = obj.get("statusLine").and_then(|v| v.as_object()) {
                             !sl.contains_key("type")
                         } else {
                             false
@@ -818,9 +802,7 @@ fn run_install(project: bool, force: bool, non_interactive: bool) -> Result<()>
             .context("failed to serialize default settings")?;
         std::fs::write(&settings_path, formatted)
             .context("failed to write ~/.claude/settings.json")?;
-        output::success(
-            "Settings with Agent Teams and statusLine -> ~/.claude/settings.json",
-        );
+        output::success("Settings with Agent Teams and statusLine -> ~/.claude/settings.json");
     }
 
     // Project working state
@@ -891,7 +873,10 @@ fn run_status() -> Result<()> {
     println!();
 
     // Check plugin manifest
-    let plugin_ok = plugin_dir.join(".claude-plugin").join("plugin.json").exists();
+    let plugin_ok = plugin_dir
+        .join(".claude-plugin")
+        .join("plugin.json")
+        .exists();
     if plugin_ok {
         output::success("Plugin manifest: installed");
     } else {
@@ -907,7 +892,11 @@ fn run_status() -> Result<()> {
     }
 
     // Check key skill file in plugin dir
-    let skills_ok = plugin_dir.join("skills").join("loop").join("SKILL.md").exists();
+    let skills_ok = plugin_dir
+        .join("skills")
+        .join("loop")
+        .join("SKILL.md")
+        .exists();
     if skills_ok {
         output::success("Plugin skills: installed");
     } else {
@@ -1059,8 +1048,8 @@ fn run_uninstall() -> Result<()> {
     // Clean settings.json (remove env var, statusLine, and any leftover hooks)
     let settings_path = claude_dir.join("settings.json");
     if settings_path.exists() {
-        let contents = std::fs::read_to_string(&settings_path)
-            .context("failed to read settings.json")?;
+        let contents =
+            std::fs::read_to_string(&settings_path).context("failed to read settings.json")?;
         if let Ok(mut val) = serde_json::from_str::<serde_json::Value>(&contents) {
             if let Some(obj) = val.as_object_mut() {
                 let mut modified = false;
@@ -1467,8 +1456,7 @@ mod tests {
 
     #[test]
     fn test_hooks_json_has_all_events() {
-        let parsed: serde_json::Value =
-            serde_json::from_str(HOOKS_JSON).expect("valid JSON");
+        let parsed: serde_json::Value = serde_json::from_str(HOOKS_JSON).expect("valid JSON");
         let obj = parsed.as_object().expect("hooks.json must be an object");
         let expected = [
             "SubagentStart",

src/cli/statusline.rs

@@ -290,19 +290,13 @@ fn parse_session_info_bytes(input: &[u8]) -> SessionInfo {
         .or_else(|| root.get("cost_usd").and_then(json_f64));
 
     // total_duration_ms: /cost/total_duration_ms
-    let total_duration_ms = root
-        .pointer("/cost/total_duration_ms")
-        .and_then(json_u64);
+    let total_duration_ms = root.pointer("/cost/total_duration_ms").and_then(json_u64);
 
     // lines_added: /cost/total_lines_added
-    let lines_added = root
-        .pointer("/cost/total_lines_added")
-        .and_then(json_u64);
+    let lines_added = root.pointer("/cost/total_lines_added").and_then(json_u64);
 
     // lines_removed: /cost/total_lines_removed
-    let lines_removed = root
-        .pointer("/cost/total_lines_removed")
-        .and_then(json_u64);
+    let lines_removed = root.pointer("/cost/total_lines_removed").and_then(json_u64);
 
     // context_tokens: sum /context_window/total_input_tokens + total_output_tokens
     //   -> /context_tokens (flat)
@@ -321,7 +315,10 @@ fn parse_session_info_bytes(input: &[u8]) -> SessionInfo {
             (None, None) => root
                 .get("context_tokens")
                 .and_then(json_u64)
-                .or_else(|| root.pointer("/context_window/used_tokens").and_then(json_u64))
+                .or_else(|| {
+                    root.pointer("/context_window/used_tokens")
+                        .and_then(json_u64)
+                })
                 .or_else(|| root.pointer("/context_window/used").and_then(json_u64)),
         }
     };
@@ -334,7 +331,10 @@ fn parse_session_info_bytes(input: &[u8]) -> SessionInfo {
         .pointer("/context_window/context_window_size")
         .and_then(json_u64)
         .or_else(|| root.get("context_window").and_then(json_u64))
-        .or_else(|| root.pointer("/context_window/max_tokens").and_then(json_u64))
+        .or_else(|| {
+            root.pointer("/context_window/max_tokens")
+                .and_then(json_u64)
+        })
         .or_else(|| root.pointer("/context_window/max").and_then(json_u64));
 
     // used_percentage: /context_window/used_percentage
@@ -343,9 +343,7 @@ fn parse_session_info_bytes(input: &[u8]) -> SessionInfo {
         .and_then(json_f64);
 
     // exceeds_200k: /exceeds_200k_tokens
-    let exceeds_200k = root
-        .get("exceeds_200k_tokens")
-        .and_then(|v| v.as_bool());
+    let exceeds_200k = root.get("exceeds_200k_tokens").and_then(|v| v.as_bool());
 
     // session_id: /session_id
     let session_id = root.get("session_id").and_then(json_string);
@@ -616,16 +614,14 @@ fn render_cost(session: &SessionInfo) -> Option<String> {
 /// Medium/narrow: 42%
 fn render_context_bar(session: &SessionInfo, width: u16, use_unicode: bool) -> Option<String> {
     // Get percentage: prefer used_percentage, fallback to calculation
-    let pct = session
-        .used_percentage
-        .or_else(|| {
-            let tokens = session.context_tokens? as f64;
-            let window = session.context_window? as f64;
-            if window == 0.0 {
-                return None;
-            }
-            Some((tokens / window) * 100.0)
-        })?;
+    let pct = session.used_percentage.or_else(|| {
+        let tokens = session.context_tokens? as f64;
+        let window = session.context_window? as f64;
+        if window == 0.0 {
+            return None;
+        }
+        Some((tokens / window) * 100.0)
+    })?;
 
     let pct_clamped = pct.clamp(0.0, 100.0);
 
@@ -665,10 +661,7 @@ fn render_context_bar(session: &SessionInfo, width: u16, use_unicode: bool) -> O
 
 /// Render the model display name, dimmed.
 fn render_model(session: &SessionInfo) -> Option<String> {
-    session
-        .model_name
-        .as_ref()
-        .map(|m| m.dimmed().to_string())
+    session.model_name.as_ref().map(|m| m.dimmed().to_string())
 }
 
 /// Render lines changed segment (e.g. "+12 -3").
@@ -837,9 +830,12 @@ fn has_loop(state: &LoopState) -> bool {
 
 /// Returns true if any agent is in an active state (Running, Queued, or Error).
 fn is_loop_active(agents: &[AgentState]) -> bool {
-    agents
-        .iter()
-        .any(|a| matches!(a.status, AgentStatus::Running | AgentStatus::Queued | AgentStatus::Error))
+    agents.iter().any(|a| {
+        matches!(
+            a.status,
+            AgentStatus::Running | AgentStatus::Queued | AgentStatus::Error
+        )
+    })
 }
 
 // ---------------------------------------------------------------------------
@@ -1386,7 +1382,11 @@ session_timeout_secs = 60
         };
         let config = StatuslineConfig::default();
         let line = render(&session, &state, &config, 150, true, false, false);
-        assert!(line.contains("loop"), "active loop should show 'loop': {}", line);
+        assert!(
+            line.contains("loop"),
+            "active loop should show 'loop': {}",
+            line
+        );
         assert!(line.contains("$0.14"), "should show cost: {}", line);
         assert!(line.contains("22%"), "should show context %: {}", line);
     }
@@ -1571,14 +1571,12 @@ session_timeout_secs = 60
         };
         let state = LoopState {
             started_at: Some(0),
-            agents: vec![
-                AgentState {
-                    id: 1,
-                    name: "a".into(),
-                    status: AgentStatus::Running,
-                    updated_at: 0,
-                },
-            ],
+            agents: vec![AgentState {
+                id: 1,
+                name: "a".into(),
+                status: AgentStatus::Running,
+                updated_at: 0,
+            }],
             ..Default::default()
         };
         let config = StatuslineConfig::default();
@@ -1788,11 +1786,7 @@ session_timeout_secs = 60
         assert!(result.is_some());
         let r = result.unwrap();
         assert!(r.contains("30%"), "should contain 30%: {}", r);
-        assert!(
-            r.contains('\u{2588}'),
-            "wide mode should have bar: {}",
-            r
-        );
+        assert!(r.contains('\u{2588}'), "wide mode should have bar: {}", r);
     }
 
     #[test]
@@ -1827,11 +1821,7 @@ session_timeout_secs = 60
         let result = render_context_bar(&session, 150, false);
         let r = result.unwrap();
         assert!(r.contains('#'), "ASCII mode should use # for filled: {}", r);
-        assert!(
-            r.contains('-'),
-            "ASCII mode should use - for empty: {}",
-            r
-        );
+        assert!(r.contains('-'), "ASCII mode should use - for empty: {}", r);
     }
 
     #[test]
@@ -1899,11 +1889,7 @@ session_timeout_secs = 60
             "State A should not contain 'loop': {}",
             line
         );
-        assert!(
-            line.contains("$0.14"),
-            "State A should show cost: {}",
-            line
-        );
+        assert!(line.contains("$0.14"), "State A should show cost: {}", line);
         assert!(
             line.contains("42%"),
             "State A should show context %: {}",
@@ -2009,17 +1995,12 @@ session_timeout_secs = 60
             "State C should contain 'loop': {}",
             line
         );
-        assert!(
-            line.contains("$0.14"),
-            "State C should show cost: {}",
-            line
-        );
+        assert!(line.contains("$0.14"), "State C should show cost: {}", line);
     }
 
     #[test]
     fn test_used_percentage_direct() {
-        let json =
-            r#"{"context_window":{"used_percentage":42.5,"context_window_size":200000}}"#;
+        let json = r#"{"context_window":{"used_percentage":42.5,"context_window_size":200000}}"#;
         let info = parse_session_info_bytes(json.as_bytes());
         assert!((info.used_percentage.unwrap() - 42.5).abs() < f64::EPSILON);
         assert_eq!(info.context_window, Some(200000));