Collab Service tests

Author: LimZiJia

services/collaboration/package-lock.json

@@ -8,12 +8,14 @@
     "start": "npm run build && node ./dist/server.js",
     "dev": "nodemon --files ./src/server.ts",
     "lint": "npx eslint .",
-    "lint:fix": "npx eslint . --fix"
+    "lint:fix": "npx eslint . --fix",
+    "test": "mocha --require ts-node/register tests/**/*.spec.ts"
   },
   "dependencies": {
     "amqplib": "^0.10.4",
     "body-parser": "^1.19.0",
     "cors": "^2.8.5",
+    "dotenv": "^16.4.5",
     "express": "^4.21.0",
     "jsonwebtoken": "^9.0.2",
     "mongodb": "^5.9.2",
@@ -28,6 +30,7 @@
   "devDependencies": {
     "@types/amqplib": "^0.10.5",
     "@types/cors": "^2.8.17",
+    "@types/eslint__js": "^8.42.3",
     "@types/express": "^4.17.13",
     "@types/jsonwebtoken": "^9.0.7",
     "@types/mocha": "^10.0.8",

services/collaboration/package.json

@@ -6,8 +6,8 @@ import config from '../config';
  * https://hassanfouad.medium.com/using-rabbitmq-with-nodejs-and-typescript-8b33d56a62cc
  */
 class MessageBroker {
-    connection!: Connection;
-    channel!: Channel;
+    connection: Connection | undefined;
+    channel: Channel | undefined;
     private connected = false;
 
     async connect(): Promise<void> {
@@ -31,7 +31,11 @@ class MessageBroker {
             if (!this.connected) {
                 await this.connect();
             }
-            this.channel.sendToQueue(queue, Buffer.from(JSON.stringify(message)));
+            if (this.channel) {
+                this.channel.sendToQueue(queue, Buffer.from(JSON.stringify(message)));
+            } else {
+                throw new Error('Channel is not initialized');
+            }
         } catch (error) {
             console.error('Failed to produce message:', error);
             throw error;
@@ -44,7 +48,11 @@ class MessageBroker {
                 await this.connect();
             }
 
-            await this.channel.assertQueue(queue, { durable: true });
+            if (this.channel) {
+                await this.channel.assertQueue(queue, { durable: true });
+            } else {
+                throw new Error('Channel is not initialized');
+            }
             await this.channel.consume(
                 queue,
                 msg => {
@@ -53,7 +61,11 @@ class MessageBroker {
                     }
                     const parsedMessage = JSON.parse(msg.content.toString()) as T;
                     onMessage(parsedMessage);
-                    this.channel.ack(msg);
+                    if (this.channel) {
+                        this.channel.ack(msg);
+                    } else {
+                        console.error('Channel is not initialized');
+                    }
                 },
                 { noAck: false },
             );

services/collaboration/src/events/broker.ts

@@ -8,7 +8,7 @@ import { produceCollabCreated, produceCollabCreateFailedEvent, produceCreateHist
  * Consume the question found event and create a room
  * @param message
  */
-async function consumeQuestionFound(message: QuestionFoundEvent) {
+export async function consumeQuestionFound(message: QuestionFoundEvent) {
     console.log('Attempting to create room:', message);
     const { user1, user2, question } = message;
 

services/collaboration/src/events/consumer.ts

@@ -0,0 +1,14 @@
+/* Visit https://aka.ms/tsconfig to read more about this file */
+{
+  "compilerOptions": {
+    "target": "ES6",
+    "module": "CommonJS",
+    "outDir": "../dist",
+    "composite": true,
+    "strict": true,
+    "esModuleInterop": true,
+    "skipLibCheck": true,
+    "forceConsistentCasingInFileNames": true,    
+  },
+  "include": ["**/*.ts"]
+}