Struct BrainEngine 

pub struct BrainEngine {
    pub pending: HashMap<u32, BrainSuggestion>,
    /* private fields */
}

The brain inference engine. Manages async inference threads and collects results.

Fields

pending: HashMap<u32, BrainSuggestion>

Pending suggestions waiting for user confirmation (advisory mode).

Implementations

impl BrainEngine

pub fn new(config: BrainConfig) -> Self

pub fn tick( &mut self, sessions: &[ClaudeSession], deny_rules: &[AutoRule], ) -> Vec<(u32, String)>

Run one tick of the brain engine. Call this from app.tick() after refresh().

1. Collect results from completed inference threads
2. Spawn new inference threads for eligible sessions

Returns a list of (pid, status_message) for actions taken this tick.

pub fn accept(&mut self, pid: u32, session: &ClaudeSession) -> Option<String>

Accept a pending brain suggestion (user pressed ‘b’).

pub fn reject(&mut self, pid: u32) -> Option<BrainSuggestion>

Reject a pending brain suggestion (user pressed ‘B’).

pub fn maybe_restart_saturated( &mut self, sessions: &[ClaudeSession], lifecycle: &LifecycleConfig, is_idle: bool, ) -> Vec<(u32, String)>

Check for sessions with saturated context and auto-restart them. Saves a checkpoint and spawns a fresh session with the summary as prompt.

pub fn cleanup(&mut self, sessions: &[ClaudeSession])

Clear pending suggestions for PIDs that are no longer in NeedsInput/WaitingInput.

pub fn maybe_orchestrate( &mut self, sessions: &[ClaudeSession], ) -> Vec<(u32, String)>

Run orchestration evaluation: ask the brain if any cross-session actions should be taken (spawn, route, terminate). Runs less frequently than per-session advisory (every orchestrate_interval_secs).

pub fn handle_orchestration_result( &mut self, suggestion: &BrainSuggestion, sessions: &[ClaudeSession], ) -> Vec<(u32, String)>

Check if a result is an orchestration response (pid == 0).