Struct AppState 

pub struct AppState { /* private fields */ }

Shared application state injected into every route handler.

Why: Connectors, the poller cache, metrics caches, and HTTP client are created once at startup and reused for every request so there is no per- request allocation. A separate MetricsCache is maintained for each stdio-MCP-polled service (analyze, memory, search, review) so they can be updated independently and served without coupling. analyze_handle is held in Arc so the on-demand visualize/index routes can call the analyze stdio MCP without going through the /proxy path. mcp_handles maps each service id to its McpServiceHandle so the services route can overlay the connector-reported status with the actual tools/list probe result (Degraded when console_metrics is absent). What: Wraps the connector list, poller cache, per-service metrics caches, reqwest client, the analyze MCP handle, and the full handle map in Arcs for cheap cloning. Test: Constructed in build_router; exercised by the integration tests.

Implementations

impl AppState

Resolve trusty-search’s socket for the routes and the connector alike.

Why on AppState rather than a free call: the integration tests bind their own stub socket and need the router to dial it, and the alternative — TRUSTY_DATA_DIR_OVERRIDE — is process-global in a test binary that runs six connectors in parallel. The same argument detect::AnalyzeConnector records for taking a socket override. Test: tests/search_uds_bridge.rs drives every case through it.

pub fn with_search_socket(self, socket: PathBuf) -> Self

Dial socket for trusty-search instead of the resolved path.

Why: see the AppState::search_socket field doc — the alternative is a process-global env var this crate’s test binary cannot use safely. Test: tests/search_uds_bridge.rs sets it on every case.

impl AppState

pub fn new(connectors: Vec<Box<dyn ServiceConnector>>) -> Self

Create a new AppState from a list of connectors.

Why: Lets tests inject a custom connector list and fresh caches. What: Wraps connectors in Arc; initialises empty PollerCache, three MetricsCache instances (analyze / memory / search), and a reqwest::Client with idle-connection pooling disabled (#1984 — see the builder comment below). Creates the analyze stdio MCP handle that is shared between the background metrics poller and on-demand routes. Populates mcp_handles with all three per-service handles so the services route can read their degraded state. Test: Used in build_router and directly in tests.

pub fn mcp_handles(&self) -> Arc<HashMap<String, Arc<McpServiceHandle>>>

Access the per-service MCP handle map.

Why: The services route reads handles from this map to overlay connector statuses with the tools/list probe result. What: Returns a clone of the Arc<HashMap> (cheap). Test: Used by apply_handle_overrides and the services handler.

pub fn analyze_handle(&self) -> Arc<McpServiceHandle>

Access the shared analyze MCP handle.

Why: On-demand routes (/api/console/metrics/analyze/indexes, /api/console/metrics/analyze/visualize) call the analyze stdio MCP without touching the analyze daemon HTTP directly (architecture: console is a stdio MCP client only, per #1104). What: Returns a clone of the Arc<McpServiceHandle> (cheap). Test: Exercised by the analyze index and visualize route tests.

pub fn connectors(&self) -> Arc<Vec<Box<dyn ServiceConnector>>>

Access the shared connector list.

Why: The background poller and the fallback spawn_blocking path both need the connector list. What: Returns a clone of the Arc (cheap). Test: Used by run_serve in main.rs.

pub fn poller_cache(&self) -> &PollerCache

Access the background poll cache.

Why: Routes read from the cache; the background task writes to it. What: Returns a clone of the PollerCache handle (cheap — it’s an Arc). Test: Used by services_handler and proxy_handler.

pub fn metrics_cache(&self) -> &MetricsCache

Access the metrics cache for the trusty-analyze stdio MCP poller.

Why: The metrics poller writes ConsoleMetricsReports here; the /api/console/metrics/analyze route reads from it. What: Returns a reference to the MetricsCache handle. Test: test_metrics_analyze_route_cold_cache_returns_503.

pub fn memory_metrics_cache(&self) -> &MetricsCache

Access the metrics cache for the trusty-memory stdio MCP poller.

Why: Separate cache per service so memory and analyze reports can be updated and served independently. What: Returns a reference to the MetricsCache handle for memory. Test: test_metrics_memory_route_cold_cache_returns_503.

pub fn search_metrics_cache(&self) -> &MetricsCache

Access the metrics cache for the trusty-search stdio MCP poller.

Why: Separate cache per service so search and analyze reports can be updated and served independently. What: Returns a reference to the MetricsCache handle for search. Test: test_metrics_search_route_cold_cache_returns_503.

pub fn review_metrics_cache(&self) -> &MetricsCache

Access the metrics cache for the trusty-review stdio MCP poller.

Why: Separate cache per service so review reports can be updated and served independently from the other service caches. What: Returns a reference to the MetricsCache handle for review. Test: test_metrics_review_route_cold_cache_returns_503.

pub fn mpm_metrics_cache(&self) -> &MetricsCache

Access the metrics cache for the trusty-mpm stdio MCP poller (#1222).

Why: separate cache per service so the mpm session/supervisor report can be updated and served independently from the other service caches. What: returns a reference to the MetricsCache handle for mpm. Test: test_metrics_mpm_route_cold_cache_returns_503.

pub fn host_metrics_cache(&self) -> &HostMetricsCache

Access the whole-machine host-metrics cache (#6517).

Why: the background host sampler writes here; the machine-status route reads it. run_serve clones it to start the sampler. What: returns a reference to the HostMetricsCache handle. Test: machine_status_route_cold_cache_returns_503.

pub async fn collect_service_reports(&self) -> Vec<ConsoleMetricsReport>

Gather whichever per-service ConsoleMetricsReports are currently cached (#6517).

Why: the machine-status rollup counts and lists every service that has a warm report. A service whose cache is still None (binary absent or not yet polled) is simply omitted — the rollup describes what is reachable. What: reads all five per-service metrics caches and collects the Some reports into a Vec in a stable service order. Test: machine_status_route_warm_cache_returns_json.

pub fn http_client(&self) -> Arc<Client>

Access the shared reqwest::Client.

Why: Re-using one client enables connection pooling across proxy requests. What: Returns a clone of the Arc<reqwest::Client> (cheap). Test: Used by proxy_handler.

pub fn stream_client(&self) -> Arc<Client>

The client to proxy a Server-Sent Events request with (#6155).

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.