From 985116c6f29f87d5c054843c88d58f9749b5ad05 Mon Sep 17 00:00:00 2001
From: Daniel Hougaard <62331820+DanielHougaard@users.noreply.github.com>
Date: Tue, 11 Jun 2024 04:04:42 +0200
Subject: [PATCH] Update user-service.ts

---
 backend/src/services/user/user-service.ts | 61 ++++++++++++++++++++---
 1 file changed, 53 insertions(+), 8 deletions(-)

diff --git a/backend/src/services/user/user-service.ts b/backend/src/services/user/user-service.ts
index a82259db6..b2f3910c0 100644
--- a/backend/src/services/user/user-service.ts
+++ b/backend/src/services/user/user-service.ts
@@ -134,14 +134,59 @@ export const userServiceFactory = ({
           );
         }
       } else {
-        // update current user's username to [email]
-        await userDAL.updateById(
-          user.id,
-          {
-            username: email
-          },
-          tx
-        );
+        const existingUserWithUsername = await userDAL.findOne({
+          username: email
+        });
+
+        if (existingUserWithUsername && existingUserWithUsername.id !== user.id) {
+          // merge users
+          const mergeUserOrgMembershipSet = new Set(
+            (await orgMembershipDAL.find({ userId: existingUserWithUsername.id }, { tx })).map((m) => m.orgId)
+          );
+
+          const myOrgMemberships = (await orgMembershipDAL.find({ userId: user.id }, { tx })).filter(
+            (m) => !mergeUserOrgMembershipSet.has(m.orgId)
+          );
+
+          const userAliases = await userAliasDAL.find(
+            {
+              userId: user.id
+            },
+            { tx }
+          );
+
+          // delete current user
+          await userDAL.deleteById(user.id, tx);
+
+          if (myOrgMemberships.length) {
+            await orgMembershipDAL.insertMany(
+              myOrgMemberships.map((orgMembership) => ({
+                ...orgMembership,
+                userId: existingUserWithUsername.id
+              })),
+              tx
+            );
+          }
+
+          if (userAliases.length) {
+            await userAliasDAL.insertMany(
+              userAliases.map((userAlias) => ({
+                ...userAlias,
+                userId: existingUserWithUsername.id
+              })),
+              tx
+            );
+          }
+        } else {
+          // update current user's username to [email]
+          await userDAL.updateById(
+            user.id,
+            {
+              username: email
+            },
+            tx
+          );
+        }
       }
     });
   };