Struct ProdGotifyFacade 

pub(crate) struct ProdGotifyFacade {
    workspace: Weak<Workspace>,
}

Production facade over Weak<Workspace> (weak to avoid a cycle with the MCP server the workspace owns).

Fields

workspace: Weak<Workspace>

Implementations

impl ProdGotifyFacade

pub(crate) fn from_arc(workspace: &Arc<Workspace>) -> Arc<dyn GotifyFacade>

Trait Implementations

impl GotifyFacade for ProdGotifyFacade

fn subscribe<'life0, 'life1, 'async_trait>( &'life0 self, caller: &'life1 SessionSlot, applications: Vec<String>, min_priority: Option<u8>, ) -> Pin<Box<dyn Future<Output = Result<SubscribeOutcome, GotifySubscribeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Subscribe the caller’s durable identity to the configured server, optionally filtered by application names and/or minimum priority. An empty applications matches any app. Persists when the identity is durable. Async because a filter that names applications refreshes the app index before returning.

fn list(&self, caller: &SessionSlot) -> Vec<GotifySubscription>

The caller’s own subscriptions in its project - a lead’s, or one worker’s, never another owner’s.

fn unsubscribe( &self, caller: &SessionSlot, id: Uuid, ) -> Result<GotifySubscription, GotifyUnsubscribeError>

Remove one of the caller’s OWN subscriptions by id within its project, returning the row as it stood. A refusal says which case it is: GotifyUnsubscribeError::NoSuchSubscription when the project has no such id, GotifyUnsubscribeError::NotOwnedByCaller when it has one under another owner.

fn apps<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, GotifyReadError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

The application NAMEs on the configured server (GET /application) so a session can self-discover what it may subscribe to.

fn recent<'life0, 'async_trait>( &'life0 self, applications: Vec<String>, min_priority: Option<u8>, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<GotifyRecent>, GotifyReadError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

The most recent notifications, newest first, filtered by application NAME (empty = any) and min_priority (None = any), capped at limit. A catch-up read for a woken or live session.