Struct AppState 

pub struct AppState {
    pub config: Arc<HttpServerConfig>,
    pub pipelines: Arc<dyn PipelineRunRegistry>,
    pub lib: Option<Arc<ComponentHandles>>,
    pub auth_resolver: Option<Arc<dyn AuthResolver>>,
    pub health: Option<Arc<dyn HealthChecker>>,
    pub spans: Arc<SpanBuffer>,
    pub sync: Arc<SyncRegistry>,
    pub telemetry_guard: Option<Arc<TelemetryGuard>>,
}

Per-server dependency container shared across all handlers.

Fields that depend on closed-side features (auth chain, mailer, etc.) are kept as injection seams (Option<Arc<dyn ...>>) so the closed cognee-http-cloud crate can populate them via the RouterBuilder.

Fields

config: Arc<HttpServerConfig>

HTTP server config (host, port, CORS, JWT, …).

pipelines: Arc<dyn PipelineRunRegistry>

Background pipeline-run lifecycle registry.

The inner Arc<dyn PipelineRunRegistry> is Clone-able cheaply.

lib: Option<Arc<ComponentHandles>>

Pre-built component handles (database, storage, delete_service, ontology_manager). None until AppState::build fully initialises the backends — most tests leave this None and stub out the relevant functionality directly.

auth_resolver: Option<Arc<dyn AuthResolver>>

Closed-side authentication chain. None in pure-OSS builds; closed embedders install one via RouterBuilder::with_auth_resolver(...) or RouterBuilder::with_extra_validator(...). When None, the AuthenticatedUser extractor falls through to either a synthetic default user (require_authentication=false) or a 401 (require_authentication=true).

health: Option<Arc<dyn HealthChecker>>

Health checker for /health endpoints. None falls back to a synthetic MockHealthChecker. Embedders populate by calling AppState::install_real_health_checker after wiring lib.

spans: Arc<SpanBuffer>

In-memory span buffer feeding GET /api/v1/activity/spans. Always populated — BufferConfig::from_env() reads the cap. To effectively disable the buffer pass BufferConfig { max_traces: 0, .. }.

sync: Arc<SyncRegistry>

In-memory registry tracking one running cloud sync per user. Always populated; the registry itself starts empty.

telemetry_guard: Option<Arc<TelemetryGuard>>

Flush-on-drop guard for the OpenTelemetry exporter (decision 9). Held only for its Drop side effect: the last Arc released calls provider.force_flush() + provider.shutdown(). None when built without explicit telemetry init (test paths, library embedders).

Implementations

impl AppState

pub fn noop_pipelines() -> Arc<dyn PipelineRunRegistry>

Build a no-op Arc<dyn PipelineRunRegistry> backed by a NoopPipelineRunRepository. Useful in tests that construct AppState directly without a real database.

pub async fn build(config: HttpServerConfig) -> Result<Self, ServerError>

Construct an AppState with the given config; all optional components default to None. Later phases call this and then set individual fields.

Builds DefaultPipelineRunRegistry from the config’s registry knobs and runs the startup orphan-reset per pipelines.md §12 — any INITIATED / STARTED rows left over from a previous unclean shutdown are rewritten to ERRORED with reason = "server_restart_orphan".

pub fn components(&self) -> Option<&ComponentHandles>

Convenience accessor for the component handles.

Returns None when the server is running in test mode without backends wired. Most integration tests build their own ComponentHandles directly.

pub fn install_real_health_checker(&mut self)

Replace the health field with a RealHealthChecker built from the currently-wired ComponentHandles. No-op when lib is None.

impl AppState

pub async fn build_with_db( config: HttpServerConfig, db: Arc<DatabaseConnection>, ) -> Result<Self, ServerError>

Build AppState with a real DatabaseConnection wired into the pipeline registry. Used by the server startup path when backend env vars are present.

Runs the orphan-reset once on startup per pipelines.md §12.

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 FromRequestParts<AppState> for AuthenticatedUser

type Rejection = ApiError

If the extractor fails it’ll use this “rejection” type. A rejection is a kind of error that can be converted into a response.

async fn from_request_parts( parts: &mut Parts, state: &AppState, ) -> Result<Self, Self::Rejection>

Perform the extraction.

impl FromRequestParts<AppState> for OptionalAuthenticatedUser

type Rejection = !

If the extractor fails it’ll use this “rejection” type. A rejection is a kind of error that can be converted into a response.

async fn from_request_parts( parts: &mut Parts, state: &AppState, ) -> Result<Self, Self::Rejection>

Perform the extraction.