Struct SubsystemHost 

pub(crate) struct SubsystemHost(Weak<Workspace>);

The GotifyHost the forge-connectors pump drives: a Weak<Workspace> behind the port. The pump holds the host strongly, so the wrapper stays the weak boundary - the workspace can drop while the subsystem runs, and every port call degrades to a no-op then, exactly like the per-event upgrade the pump did when it lived here.

Tuple Fields

0: Weak<Workspace>

Implementations

impl SubsystemHost

pub(crate) fn new(workspace: &Arc<Workspace>) -> Self

Trait Implementations

impl GotifyHost for SubsystemHost

fn app_name(&self, appid: u64) -> Option<String>

The application NAME for appid via the reverse of the app index, or None when the id isn’t known (index not yet fetched, or a new app the server added after the last refresh).

fn deliver( &self, subscription: &GotifySubscription, app: &str, message: &GotifyMessage, )

Wrap the matched message into the notification wire shape and dispatch it to the subscriber. This is the only place a forge-connectors match becomes a GotifyNotification, so the prose shape stays workspace-owned (forge_server::envelope::detect_inbound keys on it).

fn http_client(&self, timeout: Duration) -> Result<Client, String>

A reqwest client with the NODE_EXTRA_CA_CERTS roots applied and the caller’s timeout baked in.

fn subscriptions(&self) -> Vec<GotifySubscription>

The active subscriptions to match inbound messages against.

fn store_app_index(&self, index: HashMap<String, u64>)

Replace the fetched name->appid index.

fn set_connected(&self, connected: bool)

Record stream liveness for the Inspector’s GOTIFY status line.