chore(notifications): pass overrides when triggering a workflow

core/notifications/src/executor/mod.rs

@@ -45,13 +45,15 @@ impl Executor {
 
         let user_id = event.user_id().to_string();
         let payload = event.into_payload();
+        let overrides = <T as NotificationEvent>::into_overrides();
 
         let id = self
             .config
             .workflows
             .for_name(<T as NotificationEvent>::workflow_name());
 
-        self.trigger_workflow(user_id, id, payload).await?;
+        self.trigger_workflow(user_id, id, payload, overrides)
+            .await?;
 
         Ok(())
     }
@@ -61,12 +63,14 @@ impl Executor {
         user_id: String,
         trigger_name: String,
         payload_data: HashMap<String, AllowedPayloadValues>,
+        overrides: Option<HashMap<String, serde_json::Value>>,
     ) -> Result<(), ExecutorError> {
         self.client
             .trigger(TriggerPayload {
                 name: trigger_name,
                 payload: payload_data,
                 to: TriggerRecipientsType::Single(TriggerRecipientBuilder::new(user_id).build()),
+                overrides,
             })
             .await?;
 
@@ -122,6 +126,7 @@ impl Executor {
                         .email(recipient_email)
                         .build(),
                 ),
+                overrides: None,
             })
             .await?;
         Ok(())

core/notifications/src/executor/novu/events.rs

@@ -104,6 +104,7 @@ pub struct TriggerPayload {
     pub payload: ITriggerPayload,
     pub to: TriggerRecipientsType,
     pub name: String,
+    pub overrides: Option<HashMap<String, serde_json::Value>>,
 }
 
 #[derive(Debug, Serialize, Deserialize)]

core/notifications/src/notification_event.rs

@@ -1,3 +1,4 @@
+use serde_json::Value;
 use std::collections::HashMap;
 
 use crate::{executor::AllowedPayloadValues, primitives::*};
@@ -6,6 +7,7 @@ pub trait NotificationEvent {
     fn workflow_name() -> &'static str;
     fn user_id(&self) -> &GaloyUserId;
     fn into_payload(self) -> HashMap<String, AllowedPayloadValues>;
+    fn into_overrides() -> Option<HashMap<String, Value>>;
 }
 
 #[derive(Debug)]
@@ -39,6 +41,31 @@ impl NotificationEvent for CircleGrew {
         .into_iter()
         .collect()
     }
+
+    fn into_overrides() -> Option<HashMap<String, Value>> {
+        Some(
+            [(
+                "fcm".to_string(),
+                Value::Object(
+                    [(
+                        "data".to_string(),
+                        Value::Object(
+                            [(
+                                "linkTo".to_string(),
+                                Value::String("/people/circles".to_string()),
+                            )]
+                            .into_iter()
+                            .collect(),
+                        ),
+                    )]
+                    .into_iter()
+                    .collect(),
+                ),
+            )]
+            .into_iter()
+            .collect(),
+        )
+    }
 }
 
 #[derive(Debug)]
@@ -76,4 +103,29 @@ impl NotificationEvent for CircleThresholdReached {
         .into_iter()
         .collect()
     }
+
+    fn into_overrides() -> Option<HashMap<String, Value>> {
+        Some(
+            [(
+                "fcm".to_string(),
+                Value::Object(
+                    [(
+                        "data".to_string(),
+                        Value::Object(
+                            [(
+                                "linkTo".to_string(),
+                                Value::String("/people/circles".to_string()),
+                            )]
+                            .into_iter()
+                            .collect(),
+                        ),
+                    )]
+                    .into_iter()
+                    .collect(),
+                ),
+            )]
+            .into_iter()
+            .collect(),
+        )
+    }
 }