Struct EventProcessor 

pub struct EventProcessor { /* private fields */ }

Simplified event processor that delegates to sonos-api event framework

Implementations

impl EventProcessor

pub fn new( subscription_manager: Arc<SubscriptionManager>, event_sender: UnboundedSender<EnrichedEvent>, firewall_coordinator: Option<Arc<FirewallDetectionCoordinator>>, ) -> Self

Create a new event processor

pub async fn process_upnp_notification( &self, payload: NotificationPayload, ) -> EventProcessingResult<()>

Process a UPnP notification payload from the callback server

pub async fn process_polling_event( &self, event: EnrichedEvent, ) -> EventProcessingResult<()>

Process a synthetic event from polling (already enriched)

pub async fn process_resync_event( &self, event: EnrichedEvent, ) -> EventProcessingResult<()>

Process a resync event (already enriched)

pub async fn start_upnp_processing( &self, upnp_receiver: UnboundedReceiver<NotificationPayload>, )

Start processing UPnP events from the callback server

pub async fn start_polling_processing( &self, polling_receiver: UnboundedReceiver<EnrichedEvent>, )

Start processing polling events

pub async fn start_resync_processing( &self, resync_receiver: UnboundedReceiver<EnrichedEvent>, )

Start processing resync events

pub async fn stats(&self) -> EventProcessorStats

Get event processor statistics

pub fn supported_services(&self) -> Vec<Service>

Get list of supported service types

pub fn is_service_supported(&self, service: &Service) -> bool

Check if a service type is supported