Feedback

.gitignore

@@ -0,0 +1,6 @@
+.env
+.history
+
+node_modules/
+
+kubernetes/secrets.env

README.md

@@ -1,7 +1,109 @@
+[![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: Gxx
+## Group: G19
 
-### 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. 
+### Quickstart:
+There are two ways to run our application:
+1. Using Docker
+2. Using `npm`
+
+Fisrt download or `git clone` our code.
+
+#### Using Docker:
+1. Make sure Docker is running
+2. Add a file named `.env` to current directory (i.e., project root directory), with the following content:
+
+    ```
+    JWT_SECRET=
+    DB_CLOUD_URI=
+    DB_LOCAL_URI=
+    MONGO_URL=
+    ```
+    Fill in it with your own environment variable values.
+3. 
+- If you are using running on MacOS or Linux, run the bash script:
+    `./run_all_containerized_services.sh`
+
+    If an error 
+
+    `permission denied: ./run_all_containerized_services.sh` 
+
+    occurs, please run 
+
+    `chmod a+x run_all_containerized_services.sh` 
+
+    before running the script.
+
+- If you are using running on Windows, run:
+    ```
+    docker-compose build --no-cache
+    docker-compose up -d
+    ```
+4. To stop all services, run:
+
+    `docker compose down` or `docker-compose down`(for Windows)
+
+#### Using `npm`:
+1. Add a file named `.env` to user_service directory (i.e., `./backend/user-service`), with the following content:
+
+    ```
+    DB_CLOUD_URI=
+    DB_LOCAL_URI=
+    PORT=8000
+    ENV=PROD
+    JWT_SECRET=
+    ```
+    Fill in it with your own environment variable values.
+2. Add a file named `.env` to questions_service directory (i.e., `./backend/questions_service`), with the following content:
+
+    ```
+    PORT=8001
+    MONGO_URL=
+    ```
+    Fill in it with your own environment variable values.
+3. Add a file named `.env` to matching-service directory (i.e., `./backend/matching-service`), with the following content:
+
+    ```
+    PORT=8002
+    ```
+    Fill in it with your own environment variable values.
+4. Add a file named `.env` to collaboration-service directory (i.e., `./backend/collaboration-service`), with the following content:
+
+    ```
+    PORT=8003
+    ```
+    Fill in it with your own environment variable values.
+5. **Make sure RabbitMQ is running on port `5672`.**
+6.
+- If you are running on MacOS or Linux, change back to the project root directory and run the script: 
+
+    `./run_all_services.sh`
+
+    If an error 
+
+    `permission denied: ./run_all_services.sh` 
+
+    occurs, please run 
+
+    `chmod a+x run_all_services.sh` 
+
+    before running the script.
+
+    To stop all services, press `Ctrl + C`.
+
+- If you are running on Windows:
+    1. run `npm install` for all backend services.
+
+    2. Change to the `/backend` directory, and run:
+    `npm start`.
+
+    3. Then change to the `/frontend` directory and run:
+
+    ```
+    npm install
+    npm start
+    ```
+    4. To stop all services, press `Ctrl + C` in all service directories.
+
+
+**Now the frontend can be viewed at `http://localhost:3000`.**

backend/.gitignore

@@ -0,0 +1,3 @@
+.env
+node_modules
+*.rest

backend/collaboration-service/.dockerignore

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

backend/collaboration-service/Dockerfile

@@ -0,0 +1,13 @@
+FROM node:20-alpine
+
+WORKDIR /app
+
+COPY package*.json ./
+
+RUN npm install
+
+COPY . .
+
+EXPOSE 8003
+
+CMD ["npm", "start"]

backend/collaboration-service/consumer.js

@@ -0,0 +1,140 @@
+const { Mistral } = require('@mistralai/mistralai');
+
+const amqp = require('amqplib/callback_api');
+const { sendWsMessage, broadcastToRoom } = require('./ws');
+const axios = require('axios');
+const dotenv = require('dotenv');
+dotenv.config();
+
+const CLOUDAMQP_URL = process.env.CLOUDAMQP_URL;
+const LOCAL_RABBITMQ_URL = process.env.LOCAL_RABBITMQ_URL || "amqp://localhost:5672";
+const COLLAB_SERVICE_URL = process.env.COLLAB_SERVICE_URL || "http://localhost:8003";
+
+function arrayEquals(a, b) {
+  return Array.isArray(a) &&
+    Array.isArray(b) &&
+    a.length === b.length &&
+    a.every((val, index) => val === b[index]);
+}
+
+function checkSubset(parentArray, subsetArray) {
+  return subsetArray.every((el) => {
+    return parentArray.includes(el)
+  });
+}
+
+// In-memory store to track unmatched users
+let unmatchedUsers = [];
+
+// Function to set up RabbitMQ consumer
+const setupConsumer = () => {
+  amqp.connect(LOCAL_RABBITMQ_URL, (err, conn) => {
+    if (err) {
+      console.error('Connection error in consumer.js:', err);
+      return;
+    }
+
+    conn.createChannel((err, ch) => {
+      if (err) throw err;
+      const queue = 'collab_queue';
+      ch.assertQueue(queue, { durable: false });
+
+      console.log('Listening for messages in RabbitMQ queue for collab...');
+      ch.consume(queue, async (msg) => {
+        const userRequest = JSON.parse(msg.content.toString());
+        console.log('Received user request:', userRequest);
+        console.log('User request type:', userRequest.type);
+        if (userRequest.status === 'cancel') {
+          // Handle cancel request
+          const userIndex = unmatchedUsers.findIndex(u => u.userId === userRequest.userId);
+          if (userIndex !== -1) {
+            console.log(`Cancelling request for user ${userRequest.userId}`);
+            clearTimeout(unmatchedUsers[userIndex].timeoutId); // Clear any pending timeout
+            unmatchedUsers.splice(userIndex, 1); // Remove user from unmatched list
+            sendWsMessage(userRequest.userId, { status: 'CANCELLED' });
+            console.log(`Cancelled matching request for user ${userRequest.userId}`);
+          } else {
+            console.log(`No unmatched request found for user ${userRequest.userId}`);
+          }
+          sendWsMessage(userRequest.userId, { status: 'CANCELLED' });
+          console.log(`Cancelled matching request for user ${userRequest.userId}`);
+        } else if (userRequest.type === 'ASK_COPILOT') {
+          // Function to make the API call with retry logic
+
+          try {
+            const apiKey = process.env.MISTRAL_API_KEY;
+            const client = new Mistral({ apiKey: apiKey });
+            prompt = userRequest.prompt;
+            currentCode = userRequest.code;
+
+            const chatResponse = await client.chat.complete({
+              model: 'mistral-large-latest',
+              messages: [{ role: 'user', content: currentCode + '\n' + prompt }],
+            });
+            console.log('Asking Copilot:', chatResponse);
+
+            broadcastToRoom(userRequest.roomId, { type: 'ASK_COPILOT', response: chatResponse.choices[0].message.content });
+          } catch (error) {
+            console.error("Failed to fetch chat response:", error);
+            broadcastToRoom(userRequest.roomId, { type: 'ASK_COPILOT', response: "Error fetching response from assistant." });
+          }
+        }
+        else {
+          // Handle match request
+          const match = unmatchedUsers.find(u =>
+            checkSubset(u.category, userRequest.category) ||
+            checkSubset(userRequest.category, u.category)
+          ) || unmatchedUsers.find(u => u.difficulty === userRequest.difficulty);
+
+          if (match) {
+            try {
+              console.log(`Matched user ${userRequest.userId} with user ${match.userId}`);
+
+              // Create room in collaboration service
+              const response = await axios.post(`${COLLAB_SERVICE_URL}/rooms/create`, {
+                users: [userRequest.userId, match.userId],
+                difficulty: userRequest.difficulty,
+                category: userRequest.category
+              });
+              console.log(response.data);
+              const { roomId } = response.data;
+
+              // Notify both users
+              [userRequest, match].forEach(user => {
+                sendWsMessage(user.userId, {
+                  status: 'MATCH_FOUND',
+                  roomId,
+                  matchedUserId: user === userRequest ? match.userId : userRequest.userId,
+                  difficulty: userRequest.difficulty,
+                  category: userRequest.category
+                });
+              });
+
+              // Clear the timeouts for both users
+              clearTimeout(match.timeoutId);
+
+              // Remove matched user from unmatchedUsers
+              unmatchedUsers = unmatchedUsers.filter(u => u.userId !== match.userId);
+            } catch (error) {
+              console.error('Error creating room:', error);
+            }
+          } else {
+            // Set a timeout to remove unmatched users after 30 seconds
+            const timeoutId = setTimeout(() => {
+              unmatchedUsers = unmatchedUsers.filter(u => u.userId !== userRequest.userId);
+              sendWsMessage(userRequest.userId, { status: 'timeout' });
+            }, 30000);  // 30 seconds timeout
+
+            // Add the new user with their timeout ID
+            unmatchedUsers.push({ ...userRequest, timeoutId });
+          }
+        }
+
+        ch.ack(msg);  // Acknowledge message processing
+      });
+    });
+  });
+};
+
+
+module.exports = { setupConsumer };

backend/collaboration-service/controllers/copilotControllers.js

@@ -0,0 +1,16 @@
+const { sendToQueue } = require("../mq");
+
+const askCopilot = async (req, res) => {
+
+    const { code, prompt, type, roomId } = req.body;
+    console.log(`Received request to ask Copilot for prompt: ${prompt}`);
+
+    sendToQueue({ code, prompt, type, roomId });
+
+    res.status(200).send({ status: 'Request received. Waiting for Copilot response.' });
+
+};
+
+module.exports = {
+    askCopilot,
+};