Struct SubscriptionManager 

pub struct SubscriptionManager { /* private fields */ }

Manages subscriptions for registered speaker/service pairs

Implementations

impl SubscriptionManager

pub fn new(callback_url: String) -> Self

Create a new SubscriptionManager

pub async fn set_firewall_status(&self, status: FirewallStatus)

Set the firewall status (called by firewall detection system)

pub async fn firewall_status(&self) -> FirewallStatus

Get the current firewall status

pub async fn create_subscription( &self, registration_id: RegistrationId, pair: SpeakerServicePair, ) -> SubscriptionResult<Arc<ManagedSubscriptionWrapper>>

Create a subscription for a speaker/service pair

pub async fn remove_subscription( &self, registration_id: RegistrationId, ) -> SubscriptionResult<()>

Remove a subscription

pub async fn get_subscription( &self, registration_id: RegistrationId, ) -> Option<Arc<ManagedSubscriptionWrapper>>

Get a subscription by registration ID

pub async fn get_subscription_by_sid( &self, subscription_id: &str, ) -> Option<Arc<ManagedSubscriptionWrapper>>

Get subscription by UPnP subscription ID (for event routing)

pub async fn list_subscriptions(&self) -> Vec<Arc<ManagedSubscriptionWrapper>>

List all active subscriptions

pub async fn check_renewals(&self) -> SubscriptionResult<usize>

Check for subscriptions that need renewal and renew them

pub async fn record_event_received(&self, subscription_id: &str)

Record that an event was received for a subscription

pub async fn stats(&self) -> SubscriptionStats

Get statistics about managed subscriptions

pub async fn shutdown(&self) -> SubscriptionResult<()>

Shutdown all subscriptions