Struct FcmRouter

pub struct FcmRouter {
    settings: FcmSettings,
    endpoint_url: Url,
    metrics: Arc<StatsdClient>,
    db: Box<dyn DbClient>,
    clients: HashMap<String, FcmClient>,
}

Firebase Cloud Messaging router

Fields

settings: FcmSettings

endpoint_url: Url

metrics: Arc<StatsdClient>

db: Box<dyn DbClient>

clients: HashMap<String, FcmClient>

A map from application ID to an authenticated FCM client

Implementations

impl FcmRouter

pub async fn new( settings: FcmSettings, endpoint_url: Url, http: Client, metrics: Arc<StatsdClient>, db: Box<dyn DbClient>, ) -> Result<Self, FcmError>

Create a new FcmRouter

async fn create_clients( settings: &FcmSettings, server_credentials: HashMap<String, FcmServerCredential>, http: Client, ) -> Result<HashMap<String, FcmClient>>

Create FCM clients for each application

pub fn active(&self) -> bool

if we have any clients defined, this connection is “active”

fn routing_info( &self, router_data: &HashMap<String, Value>, uaid: &Uuid, ) -> Result<(String, String), ApiError>

Do the gauntlet check to get the routing credentials, these are the sender/project ID, and the subscription specific user routing token. FCM stores the values in the top hash as token & app_id, GCM stores them in a sub-hash as creds.auth and creds.senderID. If any of these error out, it’s probably because of a corrupted key.

Trait Implementations

impl Router for FcmRouter

fn register( &self, router_data_input: &RouterDataInput, app_id: &str, ) -> Result<HashMap<String, Value>, 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