feat: fcm verification

src/error.rs

@@ -162,6 +162,9 @@ pub enum Error {
 
     #[error("failed to load geoip database from s3")]
     GeoIpS3Failed,
+
+    #[error("invalid fcm api key")]
+    BadFcmApiKey,
 }
 
 impl IntoResponse for Error {
@@ -198,6 +201,18 @@ impl IntoResponse for Error {
                     message: e.to_string(),
                 }
             ], vec![]),
+            Error::BadFcmApiKey => crate::handlers::Response::new_failure(StatusCode::BAD_REQUEST, vec![
+                ResponseError {
+                    name: "bad_fcm_api_key".to_string(),
+                    message: "The provided API Key was not valid".to_string(),
+                }
+            ], vec![
+                ErrorField {
+                    field: "api_key".to_string(),
+                    description: "The provided API Key was not valid".to_string(),
+                    location: ErrorLocation::Body,
+                }
+            ]),
             Error::Database(e) => crate::handlers::Response::new_failure(StatusCode::INTERNAL_SERVER_ERROR, vec![
                 ResponseError {
                     name: "sqlx".to_string(),

src/handlers/update_fcm.rs

@@ -1,6 +1,9 @@
 use {
     crate::{
-        error::{Error, Error::InvalidMultipartBody},
+        error::{
+            Error,
+            Error::{BadFcmApiKey, InvalidMultipartBody},
+        },
         increment_counter,
         state::AppState,
         stores::tenant::TenantFcmUpdateParams,
@@ -9,6 +12,7 @@ use {
         extract::{Multipart, Path, State},
         Json,
     },
+    fcm::FcmError,
     serde::Serialize,
     std::sync::Arc,
 };
@@ -50,6 +54,22 @@ pub async fn handler(
         return Err(InvalidMultipartBody);
     }
 
+    // ---- checks
+    let test_notification = fcm::Client::new()
+        .send(
+            fcm::MessageBuilder::new(&body.api_key.clone(), "wc-notification-test")
+                .dry_run(true)
+                .finalize(),
+        )
+        .await;
+    match test_notification {
+        Err(e) => match e {
+            FcmError::Unauthorized => Err(BadFcmApiKey),
+            _ => Ok(()),
+        },
+        Ok(_) => Ok(()),
+    }?;
+
     // ---- handler
     let update_body = TenantFcmUpdateParams {
         fcm_api_key: body.api_key,