Struct WebPushRouter

pub struct WebPushRouter {
    pub db: Box<dyn DbClient>,
    pub metrics: Arc<StatsdClient>,
    pub http: Client,
    pub endpoint_url: Url,
}

The router for desktop user agents.

These agents are connected via an Autopush connection server. The correct server is located via the database routing table. If the server is busy or not available, the notification is stored in the database.

Fields

db: Box<dyn DbClient>

metrics: Arc<StatsdClient>

http: Client

endpoint_url: Url

Implementations

impl WebPushRouter

fn handle_error( &self, error: ApiErrorKind, vapid: Option<VapidHeaderWithKey>, ) -> ApiError

Use the same sort of error chokepoint that all the mobile clients use.

async fn send_notification( &self, notification: &Notification, node_id: &str, ) -> Result<Response, ApiError>

Send the notification to the node

async fn trigger_notification_check( &self, uaid: &Uuid, node_id: &str, ) -> Result<Response, Error>

Notify the node to check for notifications for the user

async fn store_notification( &self, notification: &Notification, ) -> Result<(), ApiError>

Store a notification in the database

async fn remove_node_id( &self, user: &User, node_id: &str, ) -> Result<(), ApiError>

Remove the node ID from a user. This is done if the user is no longer connected to the node.

fn make_delivered_response(&self, notification: &Notification) -> RouterResponse

Update metrics and create a response for when a notification has been directly forwarded to an autopush server.

fn make_stored_response(&self, notification: &Notification) -> RouterResponse

Update metrics and create a response for when a notification has been stored in the database for future transmission.

fn make_response( &self, notification: &Notification, destination_tag: &str, status: StatusCode, ) -> RouterResponse

Update metrics and create a response after routing a notification

Trait Implementations

impl Router for WebPushRouter

fn register( &self, _router_input: &RouterDataInput, _app_id: &str, ) -> Result<HashMap<String, Value, RandomState>, RouterError>

Validate that the user can use this router, and return data to be stored in the user’s router_data field.

fn route_notification<'life0, 'life1, 'async_trait>( &'life0 self, notification: &'life1 Notification, ) -> Pin<Box<dyn Future<Output = Result<RouterResponse, ApiError>> + 'async_trait>>

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

Route a notification to the user