Struct HttpState 

pub struct HttpState(/* private fields */);

Cloneable handle to the channel’s state. Build the server with router; the crate::HttpChannel shares the same state.

Implementations

impl HttpState

pub fn new(config: HttpConfig, deps: HttpDeps) -> Self

Assemble the state from configuration and dependencies.

pub fn config(&self) -> &HttpConfig

The channel configuration.

pub fn lanes(&self) -> &LaneIds

The lane JIDs.

pub async fn register_base_lanes(&self)

Register the chat and investigation lanes (persisted) and capture the template per-user lanes are cloned from.

pub fn set_base_group(&self, group: RegisteredGroup)

Set the template per-user lanes are cloned from (normally captured by Self::register_base_lanes).

pub async fn ensure_user_lane( &self, user_id: Option<&UserId>, user_name: Option<&str>, ) -> Result<String, LaneLimitReached>

Resolve (registering on first use) the lane for a validated CoPilot user id. None maps to the shared base lane.

pub fn user_lane_jids(&self) -> Vec<String>

Every registered per-user lane JID.

pub async fn sweep_idle_lanes(&self) -> Vec<String>

Drop per-user lanes idle for longer than lane_idle. Returns the swept JIDs.

pub async fn sweep_idle_lanes_before(&self, cutoff: Instant) -> Vec<String>

Drop per-user lanes whose last traffic is older than cutoff.

pub async fn seed_digest_task(&self) -> Result<bool>

Seed the paused alert digest task if it does not exist yet.

Trait Implementations

impl Clone for HttpState

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HttpState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.