autoendpoint/routers/apns/
error.rsuse crate::error::ApiErrorKind;
use crate::routers::RouterError;
use actix_web::http::StatusCode;
use autopush_common::errors::ReportableError;
use std::io;
#[derive(thiserror::Error, Debug)]
pub enum ApnsError {
#[error("Failed to decode the channel settings")]
ChannelSettingsDecode(#[from] serde_json::Error),
#[error("IO Error: {0}")]
Io(#[from] io::Error),
#[error("Error while setting up APNS clients: {0}")]
ApnsClient(#[source] a2::Error),
#[error("Error while checking the message size limit: {0}")]
SizeLimit(#[source] a2::Error),
#[error("APNS error, {0}")]
ApnsUpstream(#[source] a2::Error),
#[error("APNS config, {0}:{1}")]
Config(String, String),
#[error("No device token found for user")]
NoDeviceToken,
#[error("No release channel found for user")]
NoReleaseChannel,
#[error("Release channel is invalid")]
InvalidReleaseChannel,
#[error("Invalid APS data")]
InvalidApsData,
#[error("APNS recipient no longer available")]
Unregistered,
}
impl ApnsError {
pub fn status(&self) -> StatusCode {
match self {
ApnsError::InvalidReleaseChannel
| ApnsError::InvalidApsData
| ApnsError::SizeLimit(_) => StatusCode::BAD_REQUEST,
ApnsError::NoDeviceToken | ApnsError::NoReleaseChannel | ApnsError::Unregistered => {
StatusCode::GONE
}
ApnsError::ChannelSettingsDecode(_)
| ApnsError::Io(_)
| ApnsError::ApnsClient(_)
| ApnsError::Config(..) => StatusCode::INTERNAL_SERVER_ERROR,
ApnsError::ApnsUpstream(_) => StatusCode::BAD_GATEWAY,
}
}
pub fn errno(&self) -> Option<usize> {
match self {
ApnsError::NoDeviceToken | ApnsError::NoReleaseChannel | ApnsError::Unregistered => {
Some(106)
}
ApnsError::ChannelSettingsDecode(_)
| ApnsError::Io(_)
| ApnsError::ApnsClient(_)
| ApnsError::ApnsUpstream(_)
| ApnsError::InvalidReleaseChannel
| ApnsError::InvalidApsData
| ApnsError::Config(..)
| ApnsError::SizeLimit(_) => None,
}
}
}
impl From<ApnsError> for ApiErrorKind {
fn from(e: ApnsError) -> Self {
ApiErrorKind::Router(RouterError::Apns(e))
}
}
impl ReportableError for ApnsError {
fn is_sentry_event(&self) -> bool {
!matches!(self, ApnsError::SizeLimit(_) | ApnsError::Unregistered)
}
fn metric_label(&self) -> Option<&'static str> {
match &self {
ApnsError::SizeLimit(_) => Some("notification.bridge.error.apns.oversized"),
ApnsError::ApnsUpstream(_) => Some("notification.bridge.error.apns.upstream"),
_ => None,
}
}
fn extras(&self) -> Vec<(&str, String)> {
match self {
ApnsError::ApnsUpstream(e) => vec![("error", e.to_string())],
_ => vec![],
}
}
}