Merge pull request #1534 from AppFlowy-IO/email-todo

feat: add block id to page mention notification email url link

Author: khorshuheng

src/application.rs

@@ -315,22 +315,24 @@ pub async fn init_state(config: &Config) -> Result<AppState, Error> {
   ));
 
   let mailer = get_mailer(&config.mailer).await?;
-  info!("Setting up background notification worker...");
-  let email_notification_interval = config.notification.email_notification_interval_secs;
-  let email_notification_grace_period = config.notification.email_notification_grace_period_secs;
-  let task_appflowy_web_url = config.appflowy_web_url.clone();
-  let task_mailer = mailer.clone();
-  let task_pg_pool = pg_pool.clone();
-  tokio::spawn(async move {
-    let email_notification_worker = EmailNotificationWorker::new(
-      task_pg_pool,
-      task_mailer,
-      email_notification_interval,
-      email_notification_grace_period,
-      &task_appflowy_web_url,
-    );
-    email_notification_worker.start_task().await;
-  });
+  if config.notification.enable_email_notification {
+    info!("Setting up background notification worker...");
+    let email_notification_interval = config.notification.email_notification_interval_secs;
+    let email_notification_grace_period = config.notification.email_notification_grace_period_secs;
+    let task_appflowy_web_url = config.appflowy_web_url.clone();
+    let task_mailer = mailer.clone();
+    let task_pg_pool = pg_pool.clone();
+    tokio::spawn(async move {
+      let email_notification_worker = EmailNotificationWorker::new(
+        task_pg_pool,
+        task_mailer,
+        email_notification_interval,
+        email_notification_grace_period,
+        &task_appflowy_web_url,
+      );
+      email_notification_worker.start_task().await;
+    });
+  }
 
   info!("Setting up Indexer scheduler...");
   let (open_ai_config, azure_ai_config) = get_open_ai_config();

src/biz/notification/email.rs

@@ -65,6 +65,14 @@ impl EmailNotificationWorker {
           .collect();
 
         for mention in page_mentions {
+          let mut page_url = format!(
+            "{}/app/{}/{}",
+            self.appflowy_web_url, mention.workspace_id, mention.view_id
+          );
+          if let Some(block_id) = mention.block_id {
+            page_url.push_str(&format!("?blockId={}", block_id));
+          }
+
           let param = PageMentionNotificationMailerParam {
             workspace_name: mention.workspace_name,
             mentioned_page_name: mention.view_name,