Struct AppState 

pub struct AppState {

    pub db: Database,
    pub config: Arc<RwLock<RoboticusConfig>>,
    pub llm: Arc<RwLock<LlmService>>,
    pub wallet: Arc<WalletService>,
    pub a2a: Arc<RwLock<A2aProtocol>>,
    pub personality: Arc<RwLock<PersonalityState>>,
    pub hmac_secret: Arc<Vec<u8>>,
    pub interviews: Arc<RwLock<HashMap<String, InterviewSession>>>,
    pub plugins: Arc<PluginRegistry>,
    pub policy_engine: Arc<PolicyEngine>,
    pub browser: Arc<Browser>,
    pub registry: Arc<SubagentRegistry>,
    pub event_bus: EventBus,
    pub channel_router: Arc<ChannelRouter>,
    pub telegram: Option<Arc<TelegramAdapter>>,
    pub whatsapp: Option<Arc<WhatsAppAdapter>>,
    pub retriever: Arc<MemoryRetriever>,
    pub ann_index: AnnIndex,
    pub tools: Arc<ToolRegistry>,
    pub capabilities: Arc<CapabilityRegistry>,
    pub approvals: Arc<ApprovalManager>,
    pub discord: Option<Arc<DiscordAdapter>>,
    pub signal: Option<Arc<SignalAdapter>>,
    pub email: Option<Arc<EmailAdapter>>,
    pub voice: Option<Arc<RwLock<VoicePipeline>>>,
    pub media_service: Option<Arc<MediaService>>,
    pub discovery: Arc<RwLock<DiscoveryRegistry>>,
    pub devices: Arc<RwLock<DeviceManager>>,
    pub mcp_clients: Arc<RwLock<McpClientManager>>,
    pub mcp_server: Arc<RwLock<McpServerRegistry>>,
    pub live_mcp: Arc<McpConnectionManager>,
    pub oauth: Arc<OAuthManager>,
    pub keystore: Arc<Keystore>,
    pub obsidian: Option<Arc<RwLock<ObsidianVault>>>,
    pub started_at: Instant,
    pub config_path: Arc<PathBuf>,
    pub config_apply_status: Arc<RwLock<ConfigApplyStatus>>,
    pub pending_specialist_proposals: Arc<RwLock<HashMap<String, Value>>>,
    pub ws_tickets: TicketStore,
    pub rate_limiter: GlobalRateLimitLayer,
    pub semantic_classifier: Arc<SemanticClassifier>,
}

Fields

db: Database

config: Arc<RwLock<RoboticusConfig>>

llm: Arc<RwLock<LlmService>>

wallet: Arc<WalletService>

a2a: Arc<RwLock<A2aProtocol>>

personality: Arc<RwLock<PersonalityState>>

hmac_secret: Arc<Vec<u8>>

interviews: Arc<RwLock<HashMap<String, InterviewSession>>>

plugins: Arc<PluginRegistry>

policy_engine: Arc<PolicyEngine>

browser: Arc<Browser>

registry: Arc<SubagentRegistry>

event_bus: EventBus

channel_router: Arc<ChannelRouter>

telegram: Option<Arc<TelegramAdapter>>

whatsapp: Option<Arc<WhatsAppAdapter>>

retriever: Arc<MemoryRetriever>

ann_index: AnnIndex

tools: Arc<ToolRegistry>

capabilities: Arc<CapabilityRegistry>

Mirror of tools for LLM catalog and capability-aware execution paths.

approvals: Arc<ApprovalManager>

discord: Option<Arc<DiscordAdapter>>

signal: Option<Arc<SignalAdapter>>

email: Option<Arc<EmailAdapter>>

voice: Option<Arc<RwLock<VoicePipeline>>>

media_service: Option<Arc<MediaService>>

discovery: Arc<RwLock<DiscoveryRegistry>>

devices: Arc<RwLock<DeviceManager>>

mcp_clients: Arc<RwLock<McpClientManager>>

mcp_server: Arc<RwLock<McpServerRegistry>>

live_mcp: Arc<McpConnectionManager>

oauth: Arc<OAuthManager>

keystore: Arc<Keystore>

obsidian: Option<Arc<RwLock<ObsidianVault>>>

started_at: Instant

config_path: Arc<PathBuf>

config_apply_status: Arc<RwLock<ConfigApplyStatus>>

pending_specialist_proposals: Arc<RwLock<HashMap<String, Value>>>

ws_tickets: TicketStore

rate_limiter: GlobalRateLimitLayer

semantic_classifier: Arc<SemanticClassifier>

Shared semantic classifier backed by the embedding client. Used for guard pre-computation and specialist workflow detection.

Implementations

impl AppState

pub async fn resync_capabilities_from_tools(&self)

Rebuild CapabilityRegistry from the current ToolRegistry (e.g. after plugin hot-load).

pub async fn reload_personality(&self)

Trait Implementations

impl Clone for AppState

fn clone(&self) -> AppState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl HasAgent for AppState

fn tools(&self) -> &Arc<ToolRegistry>

fn capabilities(&self) -> &Arc<CapabilityRegistry>

fn policy_engine(&self) -> &Arc<PolicyEngine>

fn approvals(&self) -> &Arc<ApprovalManager>

fn registry(&self) -> &Arc<SubagentRegistry>

fn plugins(&self) -> &Arc<PluginRegistry>

impl HasChannels for AppState

fn channel_router(&self) -> &Arc<ChannelRouter>

impl HasCore for AppState

fn db(&self) -> &Database

fn config(&self) -> &Arc<RwLock<RoboticusConfig>>

fn hmac_secret(&self) -> &[u8]

impl HasInference for AppState

fn llm(&self) -> &Arc<RwLock<LlmService>>

fn semantic_classifier(&self) -> &Arc<SemanticClassifier>

impl HasMemory for AppState

fn retriever(&self) -> &Arc<MemoryRetriever>

fn ann_index(&self) -> &AnnIndex

impl HasWallet for AppState

fn wallet(&self) -> &Arc<WalletService>

impl InferenceRunner for AppState

fn select_and_audit_model<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, user_content: &'life1 str, session_id: &'life2 str, turn_id: &'life3 str, channel_label: &'life4 str, complexity: Option<&'life5 str>, ) -> Pin<Box<dyn Future<Output = String> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait,

Select the best model for a request and persist the audit trail.

fn infer_with_fallback<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, request: &'life1 UnifiedRequest, initial_model: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<InferenceResult, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Run inference with fallback chain. Routes to the best available provider, escalates on low confidence, falls back on provider errors.

fn infer_stream_with_fallback<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, request: &'life1 UnifiedRequest, initial_model: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<StreamResolvedInference, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Resolve a streaming provider and return a ready-to-consume SSE stream with provider metadata for post-stream bookkeeping.

impl PipelineCoordination for AppState

fn channel_router(&self) -> &Arc<ChannelRouter>

fn event_bus(&self) -> &EventBus

impl PipelineCore for AppState

fn db(&self) -> &Database

fn config(&self) -> &Arc<RwLock<RoboticusConfig>>

impl PipelineExecution for AppState

fn keystore(&self) -> &Arc<Keystore>

fn oauth(&self) -> &Arc<OAuthManager>

fn live_mcp(&self) -> &Arc<McpConnectionManager>

fn mcp_clients(&self) -> &Arc<RwLock<McpClientManager>>

fn browser(&self) -> &Arc<Browser>

impl PipelinePersonality for AppState

fn personality(&self) -> &Arc<RwLock<PersonalityState>>

impl PipelineReasoning for AppState

fn llm(&self) -> &Arc<RwLock<LlmService>>

fn semantic_classifier(&self) -> &Arc<SemanticClassifier>

impl PipelineRetrieval for AppState

fn retriever(&self) -> &Arc<MemoryRetriever>

fn ann_index(&self) -> &AnnIndex

impl PipelineSecurity for AppState

fn hmac_secret(&self) -> &[u8]

impl PipelineTooling for AppState

fn tools(&self) -> &Arc<ToolRegistry>

fn capabilities(&self) -> &Arc<CapabilityRegistry>

fn policy_engine(&self) -> &Arc<PolicyEngine>

fn approvals(&self) -> &Arc<ApprovalManager>

fn registry(&self) -> &Arc<SubagentRegistry>

fn plugins(&self) -> &Arc<PluginRegistry>

fn mcp_server(&self) -> &Arc<RwLock<McpServerRegistry>>

fn pending_specialist_proposals(&self) -> &Arc<RwLock<HashMap<String, Value>>>

Pending specialist proposals awaiting user approval. Used by the decomposition gate to track in-flight specialist creation.

impl ToolExecutor for AppState

fn execute_tool<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tool_name: &'life1 str, params: &'life2 Value, turn_id: &'life3 str, authority: InputAuthority, channel: Option<&'life4 str>, ) -> Pin<Box<dyn Future<Output = Result<String, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Execute a tool by name, returning the output text.

fn execute_tool_detailed<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tool_name: &'life1 str, params: &'life2 Value, turn_id: &'life3 str, authority: InputAuthority, channel: Option<&'life4 str>, ) -> Pin<Box<dyn Future<Output = Result<ToolExecutionDetails, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Execute a tool and return detailed metadata (output + source).