Allow finding chats by member's id or username

Author: hussein-m-kandil

src/api/v1/chats/chats.router.ts

@@ -33,7 +33,7 @@ chatsRouter.get('/', Middlewares.authValidator, async (req, res) => {
 
 chatsRouter.get('/members/:profileId', Middlewares.authValidator, async (req, res) => {
   const userId = Utils.getCurrentUserIdFromReq(req)!;
-  const chats = await Service.getUserChatsByMemberProfileId(userId, req.params.profileId);
+  const chats = await Service.getUserChatsByMember(userId, req.params.profileId);
   res.json(chats);
 });
 

src/api/v1/chats/chats.service.ts

@@ -241,15 +241,20 @@ export const getUserChatById = async (userId: User['id'], chatId: Chat['id']) =>
   );
 };
 
-export const getUserChatsByMemberProfileId = async (
-  userId: User['id'],
-  profileId: Profile['id'],
-) => {
+export const getUserChatsByMember = async (userId: User['id'], memberIdOrUsername: string) => {
   return await Utils.handleDBKnownErrors(
     db.$transaction(async (tx) => {
+      let profileId: Profile['id'];
       try {
-        const memberProfile = await tx.profile.findUnique({ where: { id: profileId } });
+        const memberUser = await tx.user.findUnique({
+          where: { username: memberIdOrUsername },
+          include: { profile: true },
+        });
+        const memberProfile =
+          memberUser?.profile ??
+          (await tx.profile.findUnique({ where: { id: memberIdOrUsername } }));
         if (!memberProfile) throw new AppNotFoundError('Chat member profile not found');
+        profileId = memberProfile.id;
       } catch {
         throw new AppNotFoundError('Chat member profile not found');
       }

src/tests/api/v1/chats.int.test.ts

@@ -322,6 +322,37 @@ describe('Chats endpoints', async () => {
         }
         assertReceivedDateUpdated(resChat1, dbChat1, userOneData.username);
         assertReceivedDateUpdated(resChat2, dbChat2, userOneData.username);
+        await db.chat.delete({ where: { id: dbChat2.id } });
+      });
+
+      it('should respond all the current user chats that include the given member`s', async () => {
+        const memberUsername = dbUserTwo.username;
+        const dbChatId1 = dbChats.find((c) =>
+          c.profiles.some((p) => p.profileName === memberUsername),
+        )!.id;
+        const dbChat1 = (await db.chat.findUnique({
+          where: { id: dbChatId1 },
+          include: { profiles: true },
+        }))!;
+        const dbChat2 = await createChat('Hello #2', [dbUserOne, dbUserTwo, dbXUser]);
+        const { authorizedApi } = await prepForAuthorizedTest(userOneData);
+        const res = await authorizedApi.get(`${CHATS_URL}/members/${memberUsername}`);
+        const resBody = res.body as ChatFullData[];
+        const resChat1 = resBody.find((c) => c.id === dbChat1.id)!;
+        const resChat2 = resBody.find((c) => c.id === dbChat2.id)!;
+        expect(res.statusCode).toBe(200);
+        expect(res.type).toMatch(/json/);
+        expect(resBody).toBeInstanceOf(Array);
+        expect(resBody).toHaveLength(2);
+        expect(resBody.every((c) => c.id === dbChat1.id || c.id === dbChat2.id)).toBe(true);
+        for (const c of resBody) {
+          if (c.id === dbChat2.id) assertChat(c, c.id, 1, 3);
+          else assertChat(c, c.id);
+          assertChatMembersTangibility(c);
+        }
+        assertReceivedDateUpdated(resChat1, dbChat1, userOneData.username);
+        assertReceivedDateUpdated(resChat2, dbChat2, userOneData.username);
+        await db.chat.delete({ where: { id: dbChat2.id } });
       });
     });