Merge branch 'develop' of github.com:rj76/fcm-rust into develop

src/android/mod.rs

@@ -36,7 +36,7 @@ pub struct AndroidConfig {
 
     // If set to true, messages will be allowed to be delivered to the app while the device is in direct boot mode.
     #[serde(skip_serializing_if = "Option::is_none")]
-    direct_boot_ok: Option<bool>
+    direct_boot_ok: Option<bool>,
 }
 
 #[derive(Serialize, Debug)]
@@ -52,7 +52,7 @@ pub struct Color {
     blue: f32,
 
     // The fraction of this color that should be applied to the pixel.
-    alpha: f32
+    alpha: f32,
 }
 
 #[derive(Serialize, Debug)]
@@ -184,7 +184,7 @@ pub struct AndroidNotification {
 //https://firebase.google.com/docs/reference/fcm/rest/v1/projects.messages?authuser=0#androidconfig
 pub struct AndroidFcmOptions {
     // Label associated with the message's analytics data.
-    analytics_label: String
+    analytics_label: String,
 }
 
 #[allow(dead_code)]
@@ -206,7 +206,7 @@ pub enum NotificationPriority {
     PriorityLow,
     PriorityDefault,
     PriorityHigh,
-    PriorityMax
+    PriorityMax,
 }
 
 #[allow(dead_code)]
@@ -217,5 +217,5 @@ pub enum Visibility {
     VisibilityUnspecified,
     Private,
     Public,
-    Secret
+    Secret,
 }

src/apns/mod.rs

@@ -24,5 +24,5 @@ pub struct ApnsFcmOptions {
     analytics_label: String,
 
     // Contains the URL of an image that is going to be displayed in a notification.
-    image: String
+    image: String,
 }

src/client/mod.rs

@@ -1,11 +1,10 @@
 pub(crate) mod response;
 
-use gauth::serv_account::ServiceAccount;
-use reqwest::{Body, StatusCode};
-use reqwest::header::RETRY_AFTER;
 use crate::client::response::{ErrorReason, FcmError, FcmResponse, RetryAfter};
 use crate::Message;
-
+use gauth::serv_account::ServiceAccount;
+use reqwest::header::RETRY_AFTER;
+use reqwest::{Body, StatusCode};
 
 /// An async client for sending the notification payload.
 pub struct Client {
@@ -115,10 +114,7 @@ impl Client {
         };
 
         // https://firebase.google.com/docs/reference/fcm/rest/v1/projects.messages/send
-        let url = format!(
-            "https://fcm.googleapis.com/v1/projects/{}/messages:send",
-            project_id
-        );
+        let url = format!("https://fcm.googleapis.com/v1/projects/{}/messages:send", project_id);
 
         let request = self
             .http_client

src/client/response.rs

@@ -148,7 +148,6 @@ pub enum FcmError {
     ProjectIdError(String),
 
     AuthToken(String),
-
 }
 
 impl Error for FcmError {}

src/lib.rs

@@ -64,10 +64,10 @@ mod message;
 pub use crate::message::*;
 mod notification;
 pub use crate::notification::*;
-mod client;
 mod android;
-mod web;
 mod apns;
+mod client;
+mod web;
 
 pub use crate::client::*;
 

src/message/mod.rs

@@ -1,9 +1,9 @@
-use serde::{Serialize, Serializer};
-use serde_json::Value;
 use crate::android::AndroidConfig;
 use crate::apns::ApnsConfig;
-use crate::Notification;
 use crate::web::WebpushConfig;
+use crate::Notification;
+use serde::{Serialize, Serializer};
+use serde_json::Value;
 
 #[cfg(test)]
 mod tests;
@@ -13,23 +13,17 @@ mod tests;
 pub enum Target {
     Token(String),
     Topic(String),
-    Condition(String)
+    Condition(String),
 }
 
 fn output_target<S>(target: &Target, s: S) -> Result<S::Ok, S::Error>
-    where
-        S: Serializer
+where
+    S: Serializer,
 {
     match target {
-        Target::Token(token) => {
-            s.serialize_newtype_struct("token", token.as_str())
-        },
-        Target::Topic(topic) => {
-            s.serialize_newtype_struct("topic", topic.as_str())
-        },
-        Target::Condition(condition) => {
-            s.serialize_newtype_struct("condition", condition.as_str())
-        },
+        Target::Token(token) => s.serialize_newtype_struct("token", token.as_str()),
+        Target::Topic(topic) => s.serialize_newtype_struct("topic", topic.as_str()),
+        Target::Condition(condition) => s.serialize_newtype_struct("condition", condition.as_str()),
     }
 }
 
@@ -62,7 +56,7 @@ pub struct Message {
 
     // Target to send a message to.
     #[serde(serialize_with = "output_target")]
-    target: Target
+    target: Target,
 }
 
 #[derive(Serialize, Debug)]
@@ -88,7 +82,7 @@ pub struct FcmOptions {
 pub struct MessageBuilder {
     data: Option<Value>,
     notification: Option<Notification>,
-    target: Target
+    target: Target,
 }
 
 impl MessageBuilder {
@@ -150,7 +144,7 @@ impl MessageBuilder {
             webpush: None,
             apns: None,
             fcm_options: None,
-            target: self.target
+            target: self.target,
         }
     }
 }

src/message/tests.rs

@@ -12,8 +12,7 @@ struct CustomData {
 #[test]
 fn should_create_new_message() {
     let target = Target::Token("token".to_string());
-    let msg = MessageBuilder::new(target.clone())
-        .finalize();
+    let msg = MessageBuilder::new(target.clone()).finalize();
 
     assert_eq!(msg.target, target);
 }
@@ -61,8 +60,7 @@ fn should_be_able_to_render_a_full_message_to_json() {
     let target = Target::Token("token".to_string());
     let mut builder = MessageBuilder::new(target);
 
-    builder
-        .notification(NotificationBuilder::new().finalize());
+    builder.notification(NotificationBuilder::new().finalize());
 
     let payload = serde_json::to_string(&builder.finalize()).unwrap();
 

src/notification/mod.rs

@@ -70,7 +70,7 @@ impl NotificationBuilder {
         Notification {
             title: self.title,
             body: self.body,
-            image: self.image
+            image: self.image,
         }
     }
 }

src/web/mod.rs

@@ -29,5 +29,5 @@ pub struct WebpushFcmOptions {
     link: String,
 
     // Label associated with the message's analytics data.
-    analytics_label: String
+    analytics_label: String,
 }