Feedback

.gitignore

@@ -0,0 +1,2 @@
+node_modules
+.env

LICENSE

@@ -1,21 +1,21 @@
-MIT License
-
-Copyright (c) 2024 CS3219-AY2425S1
-
-Permission is hereby granted, free of charge, to any person obtaining a copy
-of this software and associated documentation files (the "Software"), to deal
-in the Software without restriction, including without limitation the rights
-to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
-copies of the Software, and to permit persons to whom the Software is
-furnished to do so, subject to the following conditions:
-
-The above copyright notice and this permission notice shall be included in all
-copies or substantial portions of the Software.
-
-THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
-IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
-FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
-AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
-LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
-OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
-SOFTWARE.
+MIT License
+
+Copyright (c) 2024 CS3219-AY2425S1
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

README.md

@@ -1,7 +1,7 @@
-# CS3219 Project (PeerPrep) - AY2425S1
-## Group: Gxx
-
-### Note: 
-- You can choose to develop individual microservices within separate folders within this repository **OR** use individual repositories (all public) for each microservice. 
-- In the latter scenario, you should enable sub-modules on this GitHub classroom repository to manage the development/deployment **AND** add your mentor to the individual repositories as a collaborator. 
-- The teaching team should be given access to the repositories as we may require viewing the history of the repository in case of any disputes or disagreements. 
+[![Review Assignment Due Date](https://classroom.github.com/assets/deadline-readme-button-22041afd0340ce965d47ae6ef1cefeee28c7c493a6346c4f15d667ab976d596c.svg)](https://classroom.github.com/a/bzPrOe11)
+# CS3219 Project (PeerPrep) - AY2425S1
+## Group: G13
+
+### Welcome to Peerprep!
+
+Checkout our project here: http://34.128.119.63:3000/login

collaboration-service/Dockerfile

@@ -0,0 +1,23 @@
+# backend/Dockerfile
+
+# Use a Node.js base image
+FROM node:18-alpine
+
+# Set working directory
+WORKDIR /usr/src/app/collaboration-service
+
+# Copy package.json and install dependencies
+COPY package*.json ./
+# Ensure clean dependency install
+RUN rm -rf node_modules
+RUN npm install -g nodemon
+RUN npm install
+
+# Copy the rest of the app's source code
+COPY . .
+
+# Expose the backend port
+EXPOSE 4444
+
+# Command to run nodemon
+CMD ["npm", "start"]

collaboration-service/index.js

@@ -0,0 +1,130 @@
+// server.js
+
+const express = require('express');
+const { createServer } = require('http');
+const cors = require('cors');
+const { WebSocketServer } = require('ws');
+const Y = require('yjs');
+const { setupWSConnection } = require('y-websocket/bin/utils');
+const { createChannel, sendDeleteRoomRequest } = require('./rabbit/rabbit.js')
+
+const app = express();
+app.use(cors());
+app.options('*', cors());
+app.use(express.json());
+
+const httpServer = createServer(app);
+const wss = new WebSocketServer({ server: httpServer });
+
+const docs = new Map();
+const rooms = new Map();
+
+wss.on('connection', (ws, req) => {
+  const urlParams = new URL(req.url, `http://${req.headers.host}`).searchParams;
+  const roomId = urlParams.get('room');
+  const isCustom = urlParams.get('custom') === 'true';
+
+  if (isCustom) {
+    // Handle custom WebSocket connection
+    if (!rooms.has(roomId)) {
+      rooms.set(roomId, { sockets: new Set(), question: null });
+    }
+    const room = rooms.get(roomId);
+    room.sockets.add(ws);
+
+    console.log(`Custom WebSocket client connected to room ${roomId}. Room size: ${room.sockets.size}`);
+
+    ws.on('message', (message) => {
+      try {
+        const messageString = message.toString('utf8');
+        const parsedMessage = JSON.parse(messageString);
+        console.log('Parsed custom message:', parsedMessage);
+
+        if (parsedMessage.type === 'SEND_QUESTION') {
+          room.question = parsedMessage.question;
+        } else if (parsedMessage.type === 'REQUEST_QUESTION') {
+          console.log('Request question received');
+          if (room.question) {
+            ws.send(
+              JSON.stringify({ type: 'RECEIVE_QUESTION', question: room.question })
+            );
+          }
+        }
+      } catch (error) {
+        console.error('Error parsing custom message:', error);
+      }
+    });
+
+    ws.on('close', async () => {
+      room.sockets.delete(ws);
+      console.log(`Custom WebSocket client disconnected from room ${roomId}. Room size: ${room.sockets.size}`);
+
+      if (room.sockets.size === 0) {
+        const channel = await createChannel();
+
+        const payload = { roomId: roomId }
+        sendDeleteRoomRequest(channel, Buffer.from(JSON.stringify(payload)));
+        await channel.close();
+        rooms.delete(roomId);
+        console.log(`Custom room ${roomId} removed`);
+      }
+    });
+
+    return;
+  }
+
+  // Yjs synchronization connection
+  if (!docs.has(roomId)) {
+    const doc = new Y.Doc();
+    docs.set(roomId, doc);
+
+    // Initialize shared types
+    doc.getText('monaco');
+    doc.getArray('chatMessages');
+    console.log(`Created new Yjs document for room ${roomId}`);
+  }
+
+  setupWSConnection(ws, req, {
+    docName: roomId,
+    doc: docs.get(roomId),
+    gc: true, // Enable garbage collection
+  });
+
+  ws.on('close', () => {
+    // Yjs WebSocket does not need to manage room sockets; handled internally
+    const doc = docs.get(roomId);
+
+    if (wss.clients.size === 0) {
+      // No clients connected to the server at all
+
+
+      docs.delete(roomId);
+      console.log(`Yjs document destroyed for room ${roomId}`);
+    }
+  });
+});
+
+httpServer.on('error', (error) => {
+  console.error('Server error:', error);
+});
+
+httpServer.on('listening', () => {
+  console.log(`Listening on port 4444`);
+});
+
+process.on('SIGINT', () => {
+  console.log('Server shutting down...');
+
+  docs.forEach((doc, roomId) => {
+    doc.destroy();
+    console.log(`Cleaned up Yjs document for room ${roomId}`);
+  });
+
+  docs.clear();
+  rooms.clear();
+
+  process.exit(0);
+});
+
+const PORT = process.env.PORT || 4444;
+httpServer.listen(PORT);