tested

Author: gKushagra

Consumer.js

@@ -7,7 +7,7 @@ class Consumer {
     constructor(id, clientSecret, queue) {
         this.id = id;
         this.clientSecret = clientSecret;
-        this.queues = queue;
+        this.queue = queue;
     }
 }
 

MessageQueue.js

@@ -7,24 +7,27 @@ class MessageQueue {
 
     constructor(name) {
         this.name = name;
+        this.root = null;
     }
 
     Enqueue(message) {
-        var node = new QueueNode(message);
-        node.next = null;
-        if (this.root == null) {
-            this.root = node;
-        } else {
-            var curr = this.root;
-            while (curr != null) {
-                curr = curr.next;
-            }
-            curr = node;
+        if (this.root === null) {
+            this.root = new QueueNode(message);
+            return;
+        }
+        if (this.root.next === null) {
+            this.root.next = new QueueNode(message);
+            return;
+        }
+        var currNode = this.root;
+        while(currNode.next !== null) {
+            currNode = currNode.next;
         }
+        currNode.next = new QueueNode(message);
     }
 
     Dequeue() {
-        if (this.root !== null) {
+        if (this.root != null) {
             var node = this.root;
             this.root = this.root.next;
             return node.message;

QueueNode.js

@@ -3,9 +3,9 @@ class QueueNode {
     message;
     next;
 
-    constructor(message, next) {
+    constructor(message) {
         this.message = message;
-        this.next = next;
+        this.next = null;
     }
 }
 

app.js

@@ -68,15 +68,16 @@ app.post('/queues/:queue/consumers', function (req, res, next) {
 // publish
 app.post('/queues/:queue/messages', function (req, res, next) {
     try {
-        var queues = consumers.findAll(c => c.queue.name === req.params.queue);
-        if (queues.length > 0) {
-            for (var q in queues) {
-                q.Enqueue(req.body.message);
+        var activeConsumers = consumers.filter(c => c.queue.name === req.params.queue);
+        if (activeConsumers.length > 0) {
+            for (let i = 0; i < activeConsumers.length; i++) {
+                console.log(activeConsumers[i]);
+                activeConsumers[i].queue.Enqueue(req.body.message);
             }
         }
         var queue = queues.find(q => q.name === req.params.queue);
         if (!queue) {
-            queues.push(req.params.queue);
+            queue.Enqueue(req.params.queue);
         }
         res.sendStatus(200);
     } catch (error) {
@@ -92,7 +93,7 @@ app.get('/queues/:queue/consumers/:id/messages', function (req, res, next) {
         var queue = queues.find(q => q.name === req.params.queue);
         var consumer = consumers.find(c => c.id === req.params.id && c.queue.name === req.params.queue);
         if (queue && consumer) {
-            var message = queue.Dequeue();
+            var message = consumer.queue.Dequeue();
             message ? res.status(200).json(message) : res.sendStatus(204);
         } else {
             res.sendStatus(204);