Struct AppState 

pub struct AppState {
    pub credential_source: CredentialSource,
    pub policy: Arc<Policy>,
    pub database_url: Option<String>,
    /* private fields */
}

Shared application state

Fields

credential_source: CredentialSource

Credential source configuration

policy: Arc<Policy>

Resolved policy for granular tool access control

database_url: Option<String>

Optional Redis database URL for direct connections

Implementations

impl AppState

pub fn new( credential_source: CredentialSource, policy: Arc<Policy>, database_url: Option<String>, ) -> Result<Self>

Create new application state

pub fn available_profiles(&self) -> &[String]

Get the list of configured profiles

pub async fn cloud_client_for_profile( &self, profile: Option<&str>, ) -> Result<CloudClient>

Get or create Cloud API client for a specific profile

If profile is None, uses the first configured profile or default from config

pub async fn cloud_client(&self) -> Result<CloudClient>

Get or create Cloud API client (uses default profile)

pub async fn enterprise_client_for_profile( &self, profile: Option<&str>, ) -> Result<EnterpriseClient>

Get or create Enterprise API client for a specific profile

If profile is None, uses the first configured profile or default from config

pub async fn enterprise_client(&self) -> Result<EnterpriseClient>

Get or create Enterprise API client (uses default profile)

pub fn database_url_for_profile(&self, profile: Option<&str>) -> Result<String>

Resolve a Redis database URL from a profile

If profile is None, uses the first configured profile or default from config

pub async fn redis_connection_for_url( &self, url: &str, ) -> Result<MultiplexedConnection>

Get or create a cached Redis connection for a resolved URL.

Connections are cached by URL. If a cached connection fails a PING health check, it is evicted and a fresh connection is created.

pub fn is_write_allowed(&self) -> bool

Check if write operations are allowed by the global policy tier.

Returns true for ReadWrite and Full tiers. Used for defense-in-depth in non-destructive write tool handlers.

pub fn is_destructive_allowed(&self) -> bool

Check if destructive operations are allowed by the global policy tier.

Returns true only for Full tier. Used for defense-in-depth in destructive tool handlers.

pub async fn set_alias(&self, name: String, commands: Vec<Vec<String>>)

Store a named command alias (session-scoped, in-memory only).

pub async fn get_alias(&self, name: &str) -> Option<Vec<Vec<String>>>

Retrieve a named command alias.

pub async fn list_aliases(&self) -> Vec<(String, usize)>

List all aliases with their command counts.

pub async fn delete_alias(&self, name: &str) -> bool

Delete a named alias. Returns true if it existed.

impl AppState

Test helpers for creating AppState with pre-configured clients

pub fn test_policy() -> Arc<Policy>

Create a default read-only policy for tests

pub fn with_cloud_client(client: CloudClient) -> Self

Create test state with a pre-configured Cloud client

pub fn with_enterprise_client(client: EnterpriseClient) -> Self

Create test state with a pre-configured Enterprise client

pub fn with_clients(cloud: CloudClient, enterprise: EnterpriseClient) -> Self

Create test state with both Cloud and Enterprise clients

Trait Implementations

impl Clone for AppState

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.