UBERF-5650: do not send mention notification if user already notified (#4821)

Signed-off-by: Kristina Fefelova <kristin.fefelova@gmail.com>

server-plugins/notification-resources/src/index.ts

@@ -98,6 +98,10 @@ export async function OnBacklinkCreate (
     return []
   }
 
+  if (sender === receiver) {
+    return []
+  }
+
   const backlink = TxProcessor.createDoc2Doc(tx.tx as TxCreateDoc<Backlink>)
 
   if (!hierarchy.isDerived(backlink.backlinkClass, activity.class.ActivityMessage)) {
@@ -118,15 +122,9 @@ export async function OnBacklinkCreate (
     return []
   }
 
-  const doc = (await control.findAll(message.attachedToClass, { _id: message.attachedTo }))[0]
+  const res: Tx[] = []
-
-  if (doc === undefined) {
-    return []
-  }
-
-  let res: Tx[] = []
-
   const collabMixin = hierarchy.as(message as Doc, notification.mixin.Collaborators)
+
   if (collabMixin.collaborators === undefined || !collabMixin.collaborators.includes(receiver._id)) {
     const collabTx = control.txFactory.createTxMixin(
       message._id,
@@ -142,18 +140,45 @@ export async function OnBacklinkCreate (
     res.push(collabTx)
   }
 
-  const messageTx = (
+  return res
-    await control.findAll(core.class.TxCollectionCUD, {
+}
-      'tx.objectId': message._id,
-      'tx._class': core.class.TxCreateDoc
-    })
-  )[0]
 
-  res = res.concat(
+async function isBacklinkNotified (tx: TxCollectionCUD<Doc, Backlink>, control: TriggerControl): Promise<boolean> {
-    await createCollabDocInfo([receiver._id], control, messageTx.tx, messageTx, doc, [message as ActivityMessage], true)
+  const receiver = await getPersonAccount(tx.objectId as Ref<Employee>, control)
+
+  if (receiver === undefined) {
+    return false
+  }
+
+  const { hierarchy } = control
+  const backlink = TxProcessor.createDoc2Doc(tx.tx as TxCreateDoc<Backlink>)
+
+  if (!hierarchy.isDerived(backlink.backlinkClass, activity.class.ActivityMessage)) {
+    return false
+  }
+
+  const exists = await control.findAll(
+    notification.class.ActivityInboxNotification,
+    { attachedTo: backlink.backlinkId as Ref<ActivityMessage>, user: receiver._id },
+    { limit: 1 }
   )
 
-  return res
+  return exists.length > 0
+}
+
+async function isAlreadyNotified (originTx: TxCUD<Doc>, control: TriggerControl): Promise<boolean> {
+  if (originTx._class !== core.class.TxCollectionCUD) {
+    return false
+  }
+
+  const hierarchy = control.hierarchy
+  const isBacklink = await isBacklinkCreated(originTx as TxCollectionCUD<Doc, AttachedDoc>, hierarchy, control)
+
+  if (!isBacklink) {
+    return false
+  }
+
+  return await isBacklinkNotified(originTx as TxCollectionCUD<Doc, Backlink>, control)
 }
 
 async function isBacklinkCreated (
@@ -983,6 +1008,14 @@ export async function createCollaboratorNotifications (
     return []
   }
 
+  if (activityMessages.length === 0) {
+    return []
+  }
+
+  if (await isAlreadyNotified(originTx ?? tx, control)) {
+    return []
+  }
+
   switch (tx._class) {
     case core.class.TxCreateDoc:
       return await createCollaboratorDoc(tx as TxCreateDoc<Doc>, control, activityMessages, originTx ?? tx)