Question Service tests

Author: LimZiJia

services/question/package-lock.json

@@ -17,6 +17,7 @@
     "amqplib": "^0.10.4",
     "body-parser": "^1.20.3",
     "cors": "^2.8.5",
+    "dotenv": "^16.4.5",
     "express": "^4.21.0",
     "jsonwebtoken": "^9.0.2",
     "mongoose": "^8.6.2",

services/question/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> {
@@ -32,7 +32,11 @@ class MessageBroker {
                 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;
@@ -45,15 +49,23 @@ 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');
+            }
 
             this.channel.consume(
                 queue,
                 msg => {
                     if (!msg) return console.error('Invalid message from queue', queue);
 
                     onMessage(JSON.parse(msg.content.toString()) as T);
-                    this.channel.ack(msg);
+                    if (this.channel) {
+                        this.channel.ack(msg);
+                    } else {
+                        console.error('Channel is not initialized');
+                    }
                 },
                 { noAck: false },
             );

services/question/src/events/broker.ts

@@ -4,7 +4,7 @@ import messageBroker from './broker';
 import { produceMatchFailedEvent, produceQuestionFoundEvent } from './producer';
 import { Queues } from './queues';
 
-async function consumeMatchFound(msg: MatchFoundEvent) {
+export async function consumeMatchFound(msg: MatchFoundEvent) {
     console.log('Attempting to find questions:', msg);
 
     const { user1, user2, topics, difficulty } = msg;