fix: resolve clippy warnings in orchestrator module

- Add #[allow(dead_code)] to task_handle field (intentionally unused, keeps task alive)
- Remove unused publish_event() and event_sender() methods
- Events are published directly via event_tx.send() throughout the codebase

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

Author: hikejs

Cargo.lock

@@ -102,14 +102,10 @@ pub enum SubAgentActivity {
     },
 
     /// 正在请求 LLM
-    RequestingLlm {
-        message_count: usize,
-    },
+    RequestingLlm { message_count: usize },
 
     /// 正在等待控制信号
-    WaitingForControl {
-        reason: String,
-    },
+    WaitingForControl { reason: String },
 }
 
 impl SubAgentConfig {

core/src/orchestrator/config.rs

@@ -24,9 +24,7 @@ pub enum ControlSignal {
     },
 
     /// 注入新提示词
-    InjectPrompt {
-        prompt: String,
-    },
+    InjectPrompt { prompt: String },
 }
 
 impl std::fmt::Display for ControlSignal {

core/src/orchestrator/control.rs

@@ -53,16 +53,10 @@ pub enum OrchestratorEvent {
     },
 
     /// 规划开始
-    PlanningStarted {
-        id: String,
-        goal: String,
-    },
+    PlanningStarted { id: String, goal: String },
 
     /// 规划完成
-    PlanningCompleted {
-        id: String,
-        plan: ExecutionPlan,
-    },
+    PlanningCompleted { id: String, plan: ExecutionPlan },
 
     /// 工具执行开始
     ToolExecutionStarted {
@@ -83,10 +77,7 @@ pub enum OrchestratorEvent {
     },
 
     /// 控制信号接收
-    ControlSignalReceived {
-        id: String,
-        signal: ControlSignal,
-    },
+    ControlSignalReceived { id: String, signal: ControlSignal },
 
     /// 控制信号应用
     ControlSignalApplied {

core/src/orchestrator/events.rs

@@ -28,7 +28,8 @@ pub struct SubAgentHandle {
     /// 当前活动
     pub(crate) activity: Arc<RwLock<SubAgentActivity>>,
 
-    /// 任务句柄
+    /// 任务句柄（保持任务存活，不直接访问）
+    #[allow(dead_code)]
     task_handle: Arc<tokio::task::JoinHandle<Result<String>>>,
 }
 

core/src/orchestrator/handle.rs

@@ -135,7 +135,10 @@ impl AgentOrchestrator {
         );
 
         // 注册到 orchestrator
-        self.subagents.write().await.insert(id.clone(), handle.clone());
+        self.subagents
+            .write()
+            .await
+            .insert(id.clone(), handle.clone());
 
         Ok(handle)
     }
@@ -150,10 +153,12 @@ impl AgentOrchestrator {
         handle.send_control(signal.clone()).await?;
 
         // 发布控制信号接收事件
-        let _ = self.event_tx.send(OrchestratorEvent::ControlSignalReceived {
-            id: id.to_string(),
-            signal,
-        });
+        let _ = self
+            .event_tx
+            .send(OrchestratorEvent::ControlSignalReceived {
+                id: id.to_string(),
+                signal,
+            });
 
         Ok(())
     }
@@ -298,23 +303,16 @@ impl AgentOrchestrator {
         let subagents = self.subagents.read().await;
         subagents.get(id).cloned()
     }
-
-    /// 发布事件（内部使用）
-    pub(crate) fn publish_event(&self, event: OrchestratorEvent) {
-        let _ = self.event_tx.send(event);
-    }
-
-    /// 获取事件发送器（用于 SubAgentWrapper）
-    pub(crate) fn event_sender(&self) -> broadcast::Sender<OrchestratorEvent> {
-        self.event_tx.clone()
-    }
 }
 
 impl std::fmt::Debug for AgentOrchestrator {
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
         f.debug_struct("AgentOrchestrator")
             .field("event_buffer_size", &self.config.event_buffer_size)
-            .field("max_concurrent_subagents", &self.config.max_concurrent_subagents)
+            .field(
+                "max_concurrent_subagents",
+                &self.config.max_concurrent_subagents,
+            )
             .finish()
     }
 }

core/src/orchestrator/orchestrator.rs

@@ -15,18 +15,13 @@ pub enum SubAgentState {
     Paused,
 
     /// 已完成
-    Completed {
-        success: bool,
-        output: String,
-    },
+    Completed { success: bool, output: String },
 
     /// 已取消
     Cancelled,
 
     /// 错误
-    Error {
-        message: String,
-    },
+    Error { message: String },
 }
 
 impl SubAgentState {

core/src/orchestrator/state.rs

@@ -190,4 +190,3 @@ async fn test_max_concurrent_subagents() {
     let result: Result<SubAgentHandle> = orchestrator.spawn_subagent(agent_config).await;
     assert!(result.is_err());
 }
-

core/src/orchestrator/tests.rs

@@ -210,14 +210,12 @@ impl SubAgentWrapper {
         };
 
         // 发布控制信号应用事件
-        let _ = self
-            .event_tx
-            .send(OrchestratorEvent::ControlSignalApplied {
-                id: self.id.clone(),
-                signal,
-                success: result.is_ok(),
-                error: result.as_ref().err().map(|e| format!("{}", e)),
-            });
+        let _ = self.event_tx.send(OrchestratorEvent::ControlSignalApplied {
+            id: self.id.clone(),
+            signal,
+            success: result.is_ok(),
+            error: result.as_ref().err().map(|e| format!("{}", e)),
+        });
 
         result
     }