Fix Room Schema Mapping

Author: Nephelite

backend/matching-service/models/RoomSchema.ts

@@ -12,7 +12,7 @@ export interface Room extends mongoose.Document {
 
 
 const roomSchema: Schema<Room> = new mongoose.Schema<Room>({
-    participants: [{ userId: String }],
+    participants: [{ type: String }],
     category: { type: String, default: 'Any' },
     difficulty: { type: String, default: 'Any' },
     roomId: { type: String, required: true },

backend/matching-service/workers/matchWorker.ts

@@ -244,7 +244,7 @@ async function handleMatch(user1: any, user2: any) {
             matchId: savedEvent._id.toString(),
         };
 
-        await producer.send({
+        await producer.send({ 
             topic: MATCH_TOPIC,
             messages: [
                 {
@@ -395,18 +395,23 @@ export async function emitMatchEvent(matchId: string) {
     }
 
     const roomObject = JSON.parse(data);
+    console.log(roomObject);
 
     if (roomObject.questionId && roomObject.roomId) {
         const newRoom = new Room({
             participants: [
-                { userId: roomObject.user1.userId },
-                { userId: roomObject.user2.userId },
+                JSON.parse(roomObject.user1).userId,
+                JSON.parse(roomObject.user2).userId,
             ],
             category: roomObject.category,
             difficulty: roomObject.difficulty,
             roomId: roomObject.roomId,
             questionId: roomObject.questionId,
         });
+        console.log(newRoom);
+        console.log(
+            JSON.parse(roomObject.user1).userId,
+            JSON.parse(roomObject.user2).userId);
 
         await newRoom.save();
 

frontend/src/domain/entities/Room.ts

@@ -1,7 +1,7 @@
 export interface Room {
     roomId: string;
     attemptStartedAt: string;
-    userIdOne: { _id: string };
-    userIdTwo: { _id: string };
+    userIdOne: string;
+    userIdTwo: string;
     questionId: string;
 }

frontend/src/domain/usecases/HistoryUseCases.ts

@@ -25,7 +25,7 @@ export class HistoryUseCases {
         || !attemptStartedAt || attemptStartedAt.trim() === "" 
         || !attemptCompletedAt || attemptCompletedAt.trim() === "" 
         || !collaboratorId || collaboratorId.trim() === "") {
-            throw new Error("Missing Attempt Details");
+            throw new Error(`Missing Attempt Details, ${questionId} ${roomId} ${attemptStartedAt} ${attemptCompletedAt} ${collaboratorId} ${attemptCode}`);
         }
         await this.historyRepository.createOrUpdateUserHistory(questionId, roomId, attemptStartedAt, attemptCompletedAt, collaboratorId, attemptCode, true);
     }
@@ -42,7 +42,7 @@ export class HistoryUseCases {
         || !attemptStartedAt || attemptStartedAt.trim() === "" 
         || !attemptCompletedAt || attemptCompletedAt.trim() === "" 
         || !collaboratorId || collaboratorId.trim() === "") {
-            throw new Error("Missing Attempt Details");
+            throw new Error(`Missing Attempt Details, ${questionId} ${roomId} ${attemptStartedAt} ${attemptCompletedAt} ${collaboratorId} ${attemptCode}`);
         }
         await this.historyRepository.createOrUpdateUserHistory(questionId, roomId, attemptStartedAt, attemptCompletedAt, collaboratorId, attemptCode, false);
     }

frontend/src/presentation/pages/room/CollaborationRoomPage.tsx

@@ -44,16 +44,17 @@ const CollaborationRoomPage: React.FC = () => {
                     setRoom({
                         roomId: roomId,
                         attemptStartedAt: attemptStartedAt,
-                        userIdOne: { _id: user!._id },
-                        userIdTwo: { _id: matchUserId },
+                        userIdOne: user!._id,
+                        userIdTwo: matchUserId,
                         questionId: questionId
                     });
                 } else {
                     if (!urlRoomId) return;
                     // Fetch room details from API
                     const fetchedRoom = await roomUseCases.getRoomDetails(urlRoomId);
+                    console.log("Fetched Room", fetchedRoom)
                     // Ensure the current user is userIdOne
-                    if (fetchedRoom.userIdOne._id !== user?._id) {
+                    if (fetchedRoom.userIdOne !== user!._id) {
                         const temp = fetchedRoom.userIdOne;
                         fetchedRoom.userIdOne = fetchedRoom.userIdTwo;
                         fetchedRoom.userIdTwo = temp;
@@ -132,14 +133,16 @@ const CollaborationRoomPage: React.FC = () => {
                     <div className={styles.verticalSeparator} {...verticalSeparatorProps} />
 
                     <div className={styles.editorAndOutputContainer}>
-                        <div className={styles.editorContainer}>
-                            <CodeEditor
-                                questionId={room.questionId}
-                                roomId={room.roomId}
-                                attemptStartedAt={new Date(room.attemptStartedAt)}
-                                collaboratorId={room.userIdTwo?._id}
-                            />
-                        </div>
+                        {room.questionId && room.roomId && room.attemptStartedAt && room.userIdTwo &&
+                            <div className={styles.editorContainer}>
+                                <CodeEditor
+                                    questionId={room.questionId}
+                                    roomId={room.roomId}
+                                    attemptStartedAt={new Date(room.attemptStartedAt)}
+                                    collaboratorId={room.userIdTwo}
+                                />
+                            </div>
+                        }
 
                         <div className={styles.horizontalSeparator} {...horizontalSeparatorProps} />