Struct Notification

pub struct Notification {
    pub message_id: String,
    pub subscription: Subscription,
    pub headers: NotificationHeaders,
    pub timestamp: u64,
    pub sort_key_timestamp: u64,
    pub data: Option<String>,
}

Extracts notification data from Subscription and request data

Fields

message_id: String

Unique message_id for this notification

subscription: Subscription

The subscription information block

headers: NotificationHeaders

Set of associated crypto headers

timestamp: u64

UNIX timestamp in seconds

sort_key_timestamp: u64

UNIX timestamp in milliseconds

data: Option<String>

The encrypted notification body

Implementations

impl Notification

fn generate_message_id( fernet: &MultiFernet, uaid: Uuid, channel_id: Uuid, topic: Option<&str>, timestamp: u64, ) -> String

Generate a message-id suitable for accessing the message

For topic messages, a sort_key version of 01 is used, and the topic is included for reference:

Encrypted('01' : uaid.hex : channel_id.hex : topic)

For non-topic messages, a sort_key version of 02 is used:

Encrypted('02' : uaid.hex : channel_id.hex : timestamp)

pub fn has_topic(&self) -> bool

pub fn serialize_for_delivery( &self, ) -> Result<HashMap<&'static str, Value>, ApiError>

Serialize the notification for delivery to the connection server. Some fields in autopush_common’s Notification are marked with #[serde(skip_serializing)] so they are not shown to the UA. These fields are still required when delivering to the connection server, so we can’t simply convert this notification type to that one and serialize via serde.

Trait Implementations

impl Clone for Notification

fn clone(&self) -> Notification

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Notification

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

Formats the value using the given formatter.

impl From<Notification> for Notification

fn from(notification: Notification) -> Self

Converts to this type from the input type.

impl FromRequest for Notification

type Error = ApiError

The associated error which can be returned.

type Future = Pin<Box<dyn Future<Output = Result<Notification, <Notification as FromRequest>::Error>>>>

Future that resolves to a Self.

fn from_request(req: &HttpRequest, payload: &mut Payload) -> Self::Future

Create a Self from request parts asynchronously.

fn extract(req: &HttpRequest) -> Self::Future

Create a Self from request head asynchronously.