feat(orchestrator): wire todo pipeline via Bus event + auto-poke

Completes the Codebuff-style orchestrator pipeline:
* BusEvent::TodoOrchestratorToggle { session_id, enabled } added
* activate_auto_poke / deactivate_auto_poke publish the toggle
* Server client_lifecycle.rs subscribes and sets
  agent.set_todo_orchestrator_enabled(enabled)

With orchestrator.rs (Agent::poll_todo_pipeline) + run_once_capture
hook, the end-to-end flow is:
  1. User creates todos via TodoTool
  2. /poke activates auto-poke (publishes BusEvent)
  3. Server flips agent.todo_orchestrator_enabled = true
  4. After each turn, poll_todo_pipeline spawns sub-agents
     (planner/file-picker/editor/reviewer/basher) for incomplete todos
  5. BusEvent::TodoUpdated broadcasts after each save

Author: quangdang46

crates/jcode-app-core/src/server/client_lifecycle.rs

@@ -789,6 +789,17 @@ pub(super) async fn handle_client(
                             });
                         }
                     }
+                    Ok(BusEvent::TodoOrchestratorToggle { session_id, enabled }) => {
+                        if session_id == client_session_id {
+                            let mut guard = agent.lock().await;
+                            guard.set_todo_orchestrator_enabled(enabled);
+                            crate::logging::info(&format!(
+                                "[orchestrator] toggled {} for session {}",
+                                if enabled { "ON" } else { "OFF" },
+                                session_id,
+                            ));
+                        }
+                    }
                     Ok(BusEvent::CompactionFinished) => {
                         let agent = Arc::clone(&agent);
                         let tx = client_event_tx.clone();

crates/jcode-base/src/bus.rs

@@ -360,6 +360,8 @@ pub enum SessionUpdateStatus {
 pub enum BusEvent {
     ToolUpdated(ToolEvent),
     TodoUpdated(TodoEvent),
+    /// Toggle orchestrator pipeline on/off for a session.
+    TodoOrchestratorToggle { session_id: String, enabled: bool },
     SubagentStatus(SubagentStatus),
     ManualToolCompleted(ManualToolCompleted),
     BatchProgress(BatchProgress),

crates/jcode-tui/src/tui/app/commands.rs

@@ -104,6 +104,10 @@ pub(super) fn clear_queued_poke_messages(app: &mut App) -> usize {
 pub(super) fn disable_auto_poke(app: &mut App) -> usize {
     let cleared = clear_queued_poke_messages(app);
     app.auto_poke_incomplete_todos = false;
+    crate::bus::Bus::global().publish(crate::bus::BusEvent::TodoOrchestratorToggle {
+        session_id: app.session.id.clone(),
+        enabled: false,
+    });
     cleared
 }
 
@@ -252,6 +256,11 @@ pub(super) fn activate_auto_poke(app: &mut App) -> PokeActivation {
     let incomplete = incomplete_poke_todos(app);
     app.auto_poke_incomplete_todos = true;
     app.set_status_notice("Poke: ON");
+    // Broadcast orchestrator enable so the Agent spawns sub-agents.
+    crate::bus::Bus::global().publish(crate::bus::BusEvent::TodoOrchestratorToggle {
+        session_id: app.session.id.clone(),
+        enabled: true,
+    });
 
     if incomplete.is_empty() {
         return PokeActivation::EnabledNoIncomplete;