Module control_dispatch 

Inbound control_request dispatch: ControlDispatchHandle routes permission checks, MCP JSON-RPC, and hook callbacks to the appropriate handler and writes the matching control_response via a clonable SharedWriter.

Internal: built once during Client::spawn, cloned and moved into a tokio::spawn’d task per inbound control_request by the reader task in crate::client::runtime. The clonable writer + the tokio::spawn mean a slow callback cannot block the read loop, and cancellation of the actor’s select! cannot drop a control_response write mid-flight.

Used the same way during the synchronous init handshake - the init loop calls ControlDispatchHandle::dispatch directly for interleaved control_requests, since no concurrent reader exists yet.

Re-exports

use std::collections::HashMap; 🔒

use std::sync::Arc; 🔒

use crate::Error; 🔒

use crate::control::AllowBehavior; 🔒

use crate::control::ControlRequest; 🔒

use crate::control::ControlRequestKind; 🔒

use crate::control::ControlResponse; 🔒

use crate::control::ControlResponseKind; 🔒

use crate::control::ControlResponseType; 🔒

use crate::hooks::callback::ErasedHookCallback; 🔒

use crate::hooks::HookContext; 🔒

use crate::hooks::HookDecision; 🔒

use crate::hooks::HookKind; 🔒

use crate::mcp::orchestration::Dispatched; 🔒

use crate::mcp::orchestration::McpHosts; 🔒

use crate::mcp::protocol::JsonRpcRequest; 🔒

use crate::permissions::CanUseToolCallback; 🔒

use crate::transport::process::SharedWriter; 🔒

use forge_primitives::hooks::outputs::encode_updated_input_wrapper; 🔒

use forge_primitives::PermissionDecision; 🔒

use forge_primitives::ToolPermissionContext; 🔒

Structs

ControlDispatchHandle 🔒

Clonable bundle of state + writer that dispatches a single control_request. Internal - built once during Client::spawn and cloned by the reader task per inbound request.

Functions

control_subtype 🔒

The subtype a request crossed as, for a failure record that has to say which kind of control request went unanswered.