//! In-process event bus: nudges the webhook worker and streams proposal
//! updates to open pages over server-sent events (hub spec §13.1).

use hub_api::ProposalEvent;
use tokio::sync::broadcast;

pub struct Events {
    pub deliveries: broadcast::Sender<()>,
    pub proposals: broadcast::Sender<(i64, ProposalEvent)>,
}

impl Default for Events {
    fn default() -> Self {
        Events { deliveries: broadcast::channel(16).0, proposals: broadcast::channel(256).0 }
    }
}

impl Events {
    pub fn notify_deliveries(&self) {
        let _ = self.deliveries.send(());
    }

    /// Announce something about a proposal of a repository.
    pub fn proposal(&self, repo_id: i64, event: ProposalEvent) {
        let _ = self.proposals.send((repo_id, event));
    }
}