From 6581c018c36edc6c9f04f457130c6cb596bac7c4 Mon Sep 17 00:00:00 2001
From: Ulf Gebhardt <ulf.gebhardt@webcraft-media.de>
Date: Wed, 2 Apr 2025 17:31:12 +0200
Subject: [PATCH] chat notification logic

---
 .../notifications/notificationsMiddleware.ts  | 49 +++++++++++++++++++
 1 file changed, 49 insertions(+)

diff --git a/backend/src/middleware/notifications/notificationsMiddleware.ts b/backend/src/middleware/notifications/notificationsMiddleware.ts
index 706e46c51..aaca7df78 100644
--- a/backend/src/middleware/notifications/notificationsMiddleware.ts
+++ b/backend/src/middleware/notifications/notificationsMiddleware.ts
@@ -303,6 +303,54 @@ const notifyUsersOfComment = async (label, commentId, postAuthorId, reason, cont
   }
 }
 
+const handleCreateMessage = async (resolve, root, args, context, resolveInfo) => {
+  const { roomId } = args
+  const {
+    user: { id: currentUserId },
+  } = context
+
+  // Find Recipient
+  const session = context.driver.session()
+  const messageRecipient = await session.readTransaction(async (transaction) => {
+    const messageRecipientCypher = `
+      MATCH (currentUser:User { id: $currentUserId })-[:CHATS_IN]->(room:Room { id: $roomId })
+      MATCH (room)<-[:CHATS_IN]-(recipientUser:User)
+        WHERE NOT recipientUser.id = $currentUserId
+      RETURN recipientUser
+    `
+    const messageRecipientTxResponse = await transaction.run(messageRecipientCypher, {
+      currentUserId,
+      roomId,
+    })
+
+    const [recipientUser] = await messageRecipientTxResponse.records.map((record) =>
+      record.get('recipientUser'),
+    )
+    return recipientUser
+  })
+
+  session.close()
+
+  // Is Recipient online
+  const lastActive = new Date(messageRecipient.properties.lastActiveAt).getTime()
+  const awaySince = new Date(messageRecipient.properties.awaySince).getTime()
+  const now = new Date().getTime()
+  const status = messageRecipient.properties.lastOnlineStatus
+  // online & last active less than 1.5min -> no action
+  if (status === 'online' && now - lastActive < 90000) {
+    return resolve(root, args, context, resolveInfo)
+  }
+  // away for less then 3min -> no action
+  if (status === 'away' && now - awaySince < 180000) {
+    return resolve(root, args, context, resolveInfo)
+  }
+
+  // TODO
+  console.log('do notify via email', messageRecipient)
+
+  return resolve(root, args, context, resolveInfo)
+}
+
 export default {
   Mutation: {
     CreatePost: handleContentDataOfPost,
@@ -313,5 +361,6 @@ export default {
     LeaveGroup: handleLeaveGroup,
     ChangeGroupMemberRole: handleChangeGroupMemberRole,
     RemoveUserFromGroup: handleRemoveUserFromGroup,
+    CreateMessage: handleCreateMessage,
   },
 }