From 86b9ec9d95ba26d14db786098e96e917448dc449 Mon Sep 17 00:00:00 2001
From: Rishi Ghan <rishi.ghan@gmail.com>
Date: Thu, 14 Oct 2021 18:22:36 -0700
Subject: [PATCH] =?UTF-8?q?=F0=9F=94=91=20Added=20credentials=20for=20rabb?=
 =?UTF-8?q?itMQ=20connection?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/server/index.ts | 61 ++++++++++++++++++++++++++-------------------
 1 file changed, 35 insertions(+), 26 deletions(-)

diff --git a/src/server/index.ts b/src/server/index.ts
index b79b95a..7bb2836 100644
--- a/src/server/index.ts
+++ b/src/server/index.ts
@@ -19,6 +19,9 @@ app.use(bodyParser.urlencoded({ extended: true }));
 const port: number = Number(process.env.PORT) || 8050; // set our port
 // set rabbitMQ host
 const rabbitMQHost = process.env.RABBITMQHOST || "localhost";
+const rabbitMQCredentials =
+  `${process.env.RABBITMQ_USERNAME}:${process.env.RABBITMQ_PASSWORD}` ||
+  `guest:guest`;
 
 // Send index.html on root request
 app.use(express.static("dist"));
@@ -45,34 +48,40 @@ io.on("connection", (socket) => {
   });
 });
 
-amqp.connect(`amqp://${rabbitMQHost}`, (error0, connection) => {
-  if (error0) {
-    throw error0;
-  }
-  connection.createChannel((error1, channel) => {
-    if (error1) {
-      throw error1;
+amqp.connect(
+  `amqp://${rabbitMQCredentials}@${rabbitMQHost}`,
+  (error0, connection) => {
+    if (error0) {
+      throw error0;
     }
-    const queue = "comicBookCovers";
-    channel.assertQueue(queue, {
-      durable: false,
+    connection.createChannel((error1, channel) => {
+      if (error1) {
+        throw error1;
+      }
+      const queue = "comicBookCovers";
+      channel.assertQueue(queue, {
+        durable: false,
+      });
+
+      console.log(`RabbitMQ: Connected to ${queue} queue.`);
+      console.log(`RabbitMQ: Waiting for comic book cover data in ${queue}`);
+
+      channel.consume(
+        queue,
+        (data) => {
+          //Socket Trigger All Clients
+          io.sockets.emit(
+            "coverExtracted",
+            JSON.parse(data.content.toString()),
+          );
+        },
+        {
+          noAck: true,
+        },
+      );
     });
-
-    console.log(`RabbitMQ: Connected to ${queue} queue.`);
-    console.log(`RabbitMQ: Waiting for comic book cover data in ${queue}`);
-
-    channel.consume(
-      queue,
-      (data) => {
-        //Socket Trigger All Clients
-        io.sockets.emit("coverExtracted", JSON.parse(data.content.toString()));
-      },
-      {
-        noAck: true,
-      },
-    );
-  });
-});
+  },
+);
 
 // socket server
 httpServer.listen(8051);