Struct WebSubHub 

pub struct WebSubHub {
    pub hub_url: String,
    pub subscriptions: Vec<Subscription>,
}

A WebSub hub that stores subscriptions and tracks which topics have been updated. A production hub would also drive HTTP callbacks; this implementation focuses on the subscription registry.

Fields

hub_url: String

The publicly reachable URL of this hub.

subscriptions: Vec<Subscription>

All subscriptions held by this hub.

Implementations

impl WebSubHub

pub fn new(hub_url: impl Into<String>) -> Self

Create a new hub with the given public URL.

pub fn add_subscription(&mut self, sub: Subscription) -> usize

Register a new subscription. Returns the index of the new entry.

pub fn activate(&mut self, index: usize) -> Result<()>

Activate a subscription by index (after intent verification succeeds).

pub fn active_subscriptions_for(&self, topic_url: &str) -> Vec<&Subscription>

Return all active, non-expired subscriptions for the given topic.

pub fn purge_expired(&mut self) -> usize

Remove expired subscriptions and return the count removed.

Trait Implementations

impl Debug for WebSubHub

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for WebSubHub

fn default() -> WebSubHub

Returns the “default value” for a type.