Struct Handler 

pub struct Handler {
    agent_to_block: HashMap<String, String>,
    block_to_agent: HashMap<String, String>,
    agent_info: HashMap<String, AgentRegistration>,
    input_sender: Option<Arc<dyn Fn(&str, &[u8]) -> Result<(), String> + Send + Sync>>,
    message_sender: Option<Arc<dyn Fn(&str, &str) -> Result<bool, String> + Send + Sync>>,
    audit_log: Vec<AuditLogEntry>,
    rate_limiter: RateLimiter,
    include_source_in_message: bool,
}

Core reactive messaging handler.

Manages agent registrations, rate limiting, message injection, and audit logging.

Fields

agent_to_block: HashMap<String, String>

block_to_agent: HashMap<String, String>

agent_info: HashMap<String, AgentRegistration>

input_sender: Option<Arc<dyn Fn(&str, &[u8]) -> Result<(), String> + Send + Sync>>

message_sender: Option<Arc<dyn Fn(&str, &str) -> Result<bool, String> + Send + Sync>>

Controller-aware delivery for non-PTY agents (persistent stream-json / ACP). When set, it is tried before the PTY keystroke path so messages reach (and steer) agents that have no terminal. See set_message_sender.

audit_log: Vec<AuditLogEntry>

rate_limiter: RateLimiter

include_source_in_message: bool

Implementations

impl Handler

pub fn new() -> Self

Create a new handler without an input sender. Call set_input_sender before injecting messages.

pub fn set_input_sender( &mut self, sender: Arc<dyn Fn(&str, &[u8]) -> Result<(), String> + Send + Sync>, )

Set the input sender function for message injection.

pub fn set_message_sender( &mut self, sender: Arc<dyn Fn(&str, &str) -> Result<bool, String> + Send + Sync>, )

Set the controller-aware message sender. When present, inject_message tries it first: persistent stream-json and ACP agents receive a structured message on their live channel (mid-turn steering); PTY-based agents report back so injection falls through to the keystroke path.

pub fn set_include_source(&mut self, include: bool)

Set whether to include source agent prefix in injected messages.

pub fn register_agent( &mut self, agent_id: &str, block_id: &str, tab_id: Option<&str>, ) -> Result<(), String>

Register an agent with a block.

pub fn unregister_agent(&mut self, agent_id: &str)

Unregister an agent.

pub fn unregister_block(&mut self, block_id: &str)

Unregister by block ID.

pub fn update_last_seen(&mut self, agent_id: &str)

Update the last_seen timestamp for an agent.

pub fn get_agent(&self, agent_id: &str) -> Option<&AgentRegistration>

Get agent registration by agent ID.

pub fn get_agent_by_block(&self, block_id: &str) -> Option<&AgentRegistration>

Get agent registration by block ID.

pub fn list_agents(&self) -> Vec<AgentRegistration>

List all registered agents.

pub fn list_active_blocks(&self) -> Vec<String>

List all block IDs that have a registered agent.

pub fn inject_message(&mut self, req: InjectionRequest) -> InjectionResponse

Inject a message into an agent’s terminal.

Sends message\r as a single payload (required for text display), then spawns 3 delayed \r sends at 200ms intervals as separate PTY writes to ensure submission. See specs/jekt-inject-timing.md.

pub fn get_audit_log(&self, limit: usize) -> Vec<AuditLogEntry>

Get audit log entries, most recent first.

pub(super) fn log_audit( &mut self, source_agent: Option<&str>, target_agent: &str, block_id: &str, message: &str, success: bool, error_message: Option<&str>, request_id: &str, )

Add an entry to the audit ring buffer.

Trait Implementations

impl Default for Handler

fn default() -> Self

Returns the “default value” for a type.