Struct AppState 

pub struct AppState {

    pub db: DbPool,
    pub config_path: PathBuf,
    pub data_dir: PathBuf,
    pub event_tx: Sender<AccountWsEvent>,
    pub api_token: String,
    pub passphrase_hash: RwLock<Option<String>>,
    pub passphrase_hash_mtime: RwLock<Option<SystemTime>>,
    pub bind_host: String,
    pub bind_port: u16,
    pub login_attempts: Mutex<HashMap<IpAddr, (u32, Instant)>>,
    pub runtimes: Mutex<HashMap<String, Runtime>>,
    pub content_generators: Mutex<HashMap<String, Arc<ContentGenerator>>>,
    pub circuit_breaker: Option<Arc<CircuitBreaker>>,
    pub scraper_health: Option<ScraperHealth>,
    pub watchtower_cancel: RwLock<Option<CancellationToken>>,
    pub content_sources: RwLock<ContentSourcesConfig>,
    pub connector_config: ConnectorConfig,
    pub deployment_mode: DeploymentMode,
    pub pending_oauth: Mutex<HashMap<String, PendingOAuth>>,
    pub token_managers: Mutex<HashMap<String, Arc<TokenManager>>>,
    pub x_client_id: String,
    pub semantic_index: Option<Arc<RwLock<SemanticIndex>>>,
    pub embedding_provider: Option<Arc<dyn EmbeddingProvider>>,
}

Shared application state accessible by all route handlers.

Fields

db: DbPool

SQLite connection pool.

config_path: PathBuf

Path to the configuration file.

data_dir: PathBuf

Data directory for media storage (parent of config file).

event_tx: Sender<AccountWsEvent>

Broadcast channel sender for real-time WebSocket events.

api_token: String

Local bearer token for API authentication.

passphrase_hash: RwLock<Option<String>>

Bcrypt hash of the web login passphrase (None if not configured).

passphrase_hash_mtime: RwLock<Option<SystemTime>>

Last-observed mtime of the passphrase_hash file (for detecting out-of-band resets).

bind_host: String

Host address the server is bound to.

bind_port: u16

Port the server is listening on.

login_attempts: Mutex<HashMap<IpAddr, (u32, Instant)>>

Per-IP login attempt tracking for rate limiting: (count, window_start).

runtimes: Mutex<HashMap<String, Runtime>>

Per-account automation runtimes (keyed by account_id).

content_generators: Mutex<HashMap<String, Arc<ContentGenerator>>>

Per-account content generators for AI assist endpoints.

circuit_breaker: Option<Arc<CircuitBreaker>>

Optional circuit breaker for X API rate-limit protection.

scraper_health: Option<ScraperHealth>

Optional scraper health tracker (populated when provider_backend = “scraper”).

watchtower_cancel: RwLock<Option<CancellationToken>>

Cancellation token for the Watchtower filesystem watcher (None if not running).

content_sources: RwLock<ContentSourcesConfig>

Content sources configuration for the Watchtower.

connector_config: ConnectorConfig

Connector configuration for remote source OAuth flows.

deployment_mode: DeploymentMode

Deployment mode (desktop, self_host, or cloud).

pending_oauth: Mutex<HashMap<String, PendingOAuth>>

Pending OAuth PKCE challenges keyed by state parameter.

token_managers: Mutex<HashMap<String, Arc<TokenManager>>>

Per-account X API token managers for automatic token refresh.

x_client_id: String

X API client ID from config (needed to create token managers).

semantic_index: Option<Arc<RwLock<SemanticIndex>>>

In-memory semantic search index (None if embedding not configured).

embedding_provider: Option<Arc<dyn EmbeddingProvider>>

Embedding provider for semantic indexing (None if not configured).

Implementations

impl AppState

pub async fn get_x_access_token( &self, token_path: &Path, account_id: &str, ) -> Result<String, XApiError>

Get a fresh X API access token for the given account.

Lazily creates a TokenManager on first use (loading tokens from disk), then returns a token that is automatically refreshed before expiry.

pub async fn load_effective_config( &self, account_id: &str, ) -> Result<Config, String>

Load the effective config for a given account.

Default account: reads config.toml directly (backward compat). Non-default: merges config.toml base with account’s config_overrides from DB.

pub async fn get_or_create_content_generator( &self, account_id: &str, ) -> Result<Arc<ContentGenerator>, String>

Lazily create or return a cached ContentGenerator for the given account.

Loads effective config, creates the LLM provider, and caches the generator.

pub fn is_local_first(&self) -> bool

Returns true if the current deployment mode is local-first (Desktop).

pub async fn restart_watchtower(&self)

Cancel the running Watchtower (if any), reload config from disk, and spawn a new Watchtower loop with the updated sources.

Called after PATCH /api/settings modifies content_sources or deployment_mode.