Struct AppState 

pub struct AppState {

    pub store: Arc<HashtreeStore>,
    pub auth: Option<AuthCredentials>,
    pub daemon_started_at: u64,
    pub peer_mode: ServerMode,
    pub hash_get_enabled: bool,
    pub http_webrtc_fetch: bool,
    pub webrtc_peers: Option<Arc<WebRTCState>>,
    pub fips_transport: Option<Arc<DaemonFipsTransport>>,
    pub fetch_from_fips_peers: bool,
    pub ws_relay: Arc<WsRelayState>,
    pub max_upload_bytes: usize,
    pub public_writes: bool,
    pub public_plaintext_reads: bool,
    pub require_random_untrusted_ingest: bool,
    pub optimistic_blossom_uploads: bool,
    pub optimistic_upload_queue_bytes: usize,
    pub optimistic_upload_queue: Arc<Semaphore>,
    pub allowed_pubkeys: HashSet<String>,
    pub upstream_blossom: Vec<String>,
    pub social_graph: Option<Arc<SocialGraphAccessControl>>,
    pub social_graph_store: Option<Arc<dyn SocialGraphBackend>>,
    pub social_graph_root: Option<[u8; 32]>,
    pub socialgraph_snapshot_public: bool,
    pub nostr_relay: Option<Arc<NostrRelay>>,
    pub nostr_relay_urls: Vec<String>,
    pub tree_root_cache: Arc<Mutex<HashMap<String, CachedTreeRootEntry>>>,
    pub inflight_blob_fetches: Arc<Mutex<HashMap<String, Shared<BoxFuture<'static, bool>>>>>,
    pub inflight_blob_reads: Arc<Mutex<HashMap<String, Shared<BoxFuture<'static, Result<Option<Vec<u8>>, String>>>>>>,
    pub directory_listing_cache: Arc<Mutex<TimedLruCache<String, LookupResult<Vec<TreeEntry>>>>>,
    pub resolved_path_cache: Arc<Mutex<TimedLruCache<String, LookupResult<CachedResolvedPathEntry>>>>,
    pub thumbnail_path_cache: Arc<Mutex<TimedLruCache<String, LookupResult<String>>>>,
    pub cid_size_cache: Arc<Mutex<TimedLruCache<String, LookupResult<u64>>>>,
    /* private fields */
}

Fields

store: Arc<HashtreeStore>

auth: Option<AuthCredentials>

daemon_started_at: u64

Unix timestamp when this daemon state was created.

peer_mode: ServerMode

hash_get_enabled: bool

http_webrtc_fetch: bool

Whether HTTP cache misses should ask connected WebRTC peers before falling back to upstream Blossom.

webrtc_peers: Option<Arc<WebRTCState>>

WebRTC peer state for forwarding requests to connected P2P peers

fips_transport: Option<Arc<DaemonFipsTransport>>

FIPS-backed Hashtree blob transport for peer fetches and responses.

fetch_from_fips_peers: bool

ws_relay: Arc<WsRelayState>

WebSocket relay state for /ws clients

max_upload_bytes: usize

Maximum upload size in bytes for Blossom uploads (default: 5 MB)

public_writes: bool

Allow anyone with valid Nostr auth to write (default: true) When false, only allowed_pubkeys can write

public_plaintext_reads: bool

Allow public plaintext reads from mutable npub routes (default: true) When false, only allowed_pubkeys or social graph approved pubkeys can read.

require_random_untrusted_ingest: bool

Require untrusted cached blob ingress to look like encrypted CHK blobs.

optimistic_blossom_uploads: bool

Return from Blossom upload after validation while storage writes finish in a bounded background queue.

optimistic_upload_queue_bytes: usize

Background upload queue byte budget. Each queued body holds one permit per byte until the storage write completes.

optimistic_upload_queue: Arc<Semaphore>

allowed_pubkeys: HashSet<String>

Pubkeys allowed to write (hex format, from config allowed_npubs)

upstream_blossom: Vec<String>

Upstream Blossom servers for cascade fetching

social_graph: Option<Arc<SocialGraphAccessControl>>

Social graph access control

social_graph_store: Option<Arc<dyn SocialGraphBackend>>

Social graph store handle for snapshot export

social_graph_root: Option<[u8; 32]>

Social graph root pubkey bytes for snapshot export

socialgraph_snapshot_public: bool

Allow public access to social graph snapshot endpoint

nostr_relay: Option<Arc<NostrRelay>>

Nostr relay state for /ws and WebRTC Nostr messages

nostr_relay_urls: Vec<String>

Active upstream Nostr relays for HTTP resolver operations.

tree_root_cache: Arc<Mutex<HashMap<String, CachedTreeRootEntry>>>

In-process cache for resolved mutable tree roots, keyed by npub/tree(+key)

inflight_blob_fetches: Arc<Mutex<HashMap<String, Shared<BoxFuture<'static, bool>>>>>

Shared in-flight blob fetches so concurrent misses only hit upstream once per hash

inflight_blob_reads: Arc<Mutex<HashMap<String, Shared<BoxFuture<'static, Result<Option<Vec<u8>>, String>>>>>>

Shared in-flight local blob reads so request bursts for the same hash only spend one blocking storage read.

directory_listing_cache: Arc<Mutex<TimedLruCache<String, LookupResult<Vec<TreeEntry>>>>>

Immutable directory listings keyed by CID

resolved_path_cache: Arc<Mutex<TimedLruCache<String, LookupResult<CachedResolvedPathEntry>>>>

Immutable resolved paths keyed by root CID + path

thumbnail_path_cache: Arc<Mutex<TimedLruCache<String, LookupResult<String>>>>

Immutable thumbnail alias resolutions keyed by root CID + alias path

cid_size_cache: Arc<Mutex<TimedLruCache<String, LookupResult<u64>>>>

Immutable file sizes keyed by CID

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.