Method close

core/src/agent_api/session_close.rs:67–108

Perform the full session close sequence. Idempotent: subsequent calls are no-ops and are guaranteed not to panic. Sequence (see [`AgentSession::close`](super::AgentSession::close) for the public-facing contract): 1. Flip the `closed` flag so further `send`/`stream` fast-fail; 2. Fire the session-level cancellation token so every derived run and subagent task token fires; 3. Mark the active run as

(&self)

    /// 5. Cancel pending HITL tool confirmations so blocked tool callers
    ///    receive a rejection instead of hanging.
    pub(crate) async fn close(&self) {
        if self.closed.swap(true, Ordering::AcqRel) {
            return;
        }

        // 1. Fire the session-level token so children cascade.
        self.session_cancel.cancel();

        // 2. Mark the active run cancelled and fire AHP hook bookkeeping.
        //    The per-run token has already fired via step 1; this loop
        //    just updates the run store and emits the hook event.
        let had_active_token = self.cancel_token.lock().await.is_some();
        if had_active_token {
            if let Some(run_id) = self.current_run_id.lock().await.clone() {
                let _ = self.run_store.mark_cancelled(&run_id).await;
                if let Some(hook) = &self.hook_executor {
                    hook.record_run_cancelled(&run_id, &self.session_id, Some("cancelled by host"))
                        .await;
                }
            }
        }

        // 3. Mark every still-running subagent task cancelled.
        let pending: Vec<String> = self
            .subagent_tasks
            .list_for_parent(&self.session_id)
            .await
            .into_iter()
            .filter(|task| task.status == SubagentStatus::Running)
            .map(|task| task.task_id)
            .collect();
        for task_id in pending {
            let _ = self.subagent_tasks.cancel(&task_id).await;
        }

        // 4. Cancel pending HITL confirmations.
        if let Some(manager) = &self.confirmation_manager {
            let _ = manager.cancel_all().await;
        }

        tracing::info!(session_id = %self.session_id, "AgentSession closed");
    }
}