fmt

hive-ag3nt/src/bin/hive-ag3nt.rs

@@ -52,8 +52,7 @@ async fn main() -> Result<()> {
             check(&resp)
         }
         Cmd::Recv => {
-            let resp: AgentResponse =
+            let resp: AgentResponse = client::request(&cli.socket, &AgentRequest::Recv).await?;
-                client::request(&cli.socket, &AgentRequest::Recv).await?;
             render(&resp)?;
             check(&resp)
         }

hive-c0re/src/coordinator.rs

@@ -38,8 +38,7 @@ impl Coordinator {
         std::fs::create_dir_all(&agent_dir)
             .with_context(|| format!("create agent dir {}", agent_dir.display()))?;
         let socket_path = Self::socket_path(name);
-        let socket =
+        let socket = agent_server::start(name.to_owned(), socket_path, self.broker.clone()).await?;
-            agent_server::start(name.to_owned(), socket_path, self.broker.clone()).await?;
         self.agents.lock().unwrap().insert(name.to_owned(), socket);
         Ok(agent_dir)
     }

hive-sh4re/src/lib.rs

@@ -108,12 +108,19 @@ pub const MANAGER_AGENT: &str = "manager";
 #[derive(Debug, Clone, Serialize, Deserialize)]
 #[serde(tag = "cmd", rename_all = "snake_case")]
 pub enum ManagerRequest {
-    Send { to: String, body: String },
+    Send {
+        to: String,
+        body: String,
+    },
     Recv,
     /// Spawn a sub-agent. Phase 5 will gate this on user approval.
-    Spawn { name: String },
+    Spawn {
+        name: String,
+    },
     /// Stop a sub-agent (graceful).
-    Kill { name: String },
+    Kill {
+        name: String,
+    },
 }
 
 #[derive(Debug, Clone, Serialize, Deserialize)]