Struct IOBridge 

pub struct IOBridge { /* private fields */ }

IO Bridge - Pure bridge between View and Model layers.

Converts between IO types (IOInput/IOOutput) and internal events (Signal). This is a stateless transformation layer.

Note: IOBridge does not hold a Principal. The Principal is provided by the owning ClientRunner when converting input to Signals.

The parser can be injected for testing or customization.

Implementations

impl IOBridge

pub fn new(io_port: IOPort) -> Self

Creates a new IOBridge with default parser.

Arguments

• io_port - IO port for View communication

pub fn with_parser(io_port: IOPort, parser: InputParser) -> Self

Creates a new IOBridge with a custom parser.

This allows injecting a custom parser for testing or customization.

pub fn channel_id(&self) -> ChannelId

Returns the channel ID.

pub fn command_to_signal( &self, cmd: &InputCommand, principal: &Principal, default_approval_id: Option<&str>, ) -> Option<Signal>

Converts an InputCommand to a Signal.

Arguments

• cmd - The parsed input command
• principal - Principal to use for the signal
• default_approval_id - Fallback approval ID if command has none

pub fn parse_line_to_signal( &self, line: &str, principal: &Principal, default_approval_id: Option<&str>, ) -> Option<Signal>

Parses a line of input and converts to Signal.

Arguments

• line - Raw input line
• principal - Principal to use for the signal
• default_approval_id - Fallback approval ID for HIL responses

pub fn drain_input_to_signals( &mut self, principal: &Principal, ) -> (Vec<Signal>, Vec<InputCommand>)

Drains all available input and converts to Signals.

Returns a vector of Signals ready to be dispatched to EventBus. Also returns any InputCommands that couldn’t be converted (e.g., Quit, Unknown) for the caller to handle.

Approval IDs are extracted from the input context provided by View layer.

Arguments

• principal - Principal to use for signals

pub async fn recv_input( &mut self, principal: &Principal, ) -> Option<Result<Signal, InputCommand>>

Receives a single input and processes it.

Async version - waits for input.

Approval IDs are extracted from the input context provided by View layer.

Arguments

• principal - Principal to use for signals

Returns

• Some(Ok(signal)) - Input converted to signal
• Some(Err(cmd)) - Input is a command that doesn’t map to signal
• None - IO port closed

pub async fn send_output( &self, output: IOOutput, ) -> Result<(), SendError<IOOutput>>

Sends an output to the View layer.

Errors

Returns error if the output handle has been dropped.

pub async fn show_processing( &self, component: &str, operation: &str, ) -> Result<(), SendError<IOOutput>>

Displays a processing notification.

pub async fn show_approval_request( &self, request: &ApprovalRequest, ) -> Result<(), SendError<IOOutput>>

Displays an approval request.

pub async fn show_approved( &self, approval_id: &str, ) -> Result<(), SendError<IOOutput>>

Displays approval confirmation.

pub async fn show_rejected( &self, approval_id: &str, reason: Option<&str>, ) -> Result<(), SendError<IOOutput>>

Displays rejection confirmation.

pub async fn info(&self, message: &str) -> Result<(), SendError<IOOutput>>

Displays an info message.

pub async fn warn(&self, message: &str) -> Result<(), SendError<IOOutput>>

Displays a warning message.

pub async fn error(&self, message: &str) -> Result<(), SendError<IOOutput>>

Displays an error message.

pub async fn prompt(&self, message: &str) -> Result<(), SendError<IOOutput>>

Displays a prompt message.

pub fn is_output_closed(&self) -> bool

Returns true if the output channel is closed.

Trait Implementations

impl Debug for IOBridge

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.