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>>,
    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>>

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_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 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.