added .env file for RabbitMQ

luminosityleds · Nov 2, 2023 · 99228f4 · 99228f4
1 parent f4e1763
commit 99228f4
Show file tree

Hide file tree

Showing 51 changed files with 51 additions and 11 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,7 @@
 {
   "dependencies": {
     "amqplib": "^0.10.3",
+    "dotenv": "^16.3.1",
     "typescript-coverage-report": "^0.7.0"
   },
   "scripts": {

diff --git a/src/notification/connection.js b/src/notification/connection.js
@@ -38,14 +38,20 @@ var __generator = (this && this.__generator) || function (thisArg, body) {
 Object.defineProperty(exports, "__esModule", { value: true });
 // Import the necessary modules
 var amqplib = require("amqplib");
+var dotenv = require("dotenv");
+// Load environment variables from the .env file
+dotenv.config();
+// Access the environment variables
+var rabbitMqUsername = process.env.RABBITMQ_USERNAME;
+var rabbitMqPassword = process.env.RABBITMQ_PASSWORD;
 function connectToRabbitMQ() {
     return __awaiter(this, void 0, void 0, function () {
         var connection, channel, queueName, message, sendMessages, consumer, error_1;
         return __generator(this, function (_a) {
             switch (_a.label) {
                 case 0:
                     _a.trys.push([0, 6, , 7]);
-                    return [4 /*yield*/, amqplib.connect('amqp://luminosityleds:Lumi-123@localhost:5672', {
+                    return [4 /*yield*/, amqplib.connect("amqp://".concat(rabbitMqUsername, ":").concat(rabbitMqPassword, "@localhost:5672"), {
                             heartbeat: 10,
                         })];
                 case 1:

diff --git a/src/notification/connection.ts b/src/notification/connection.ts
@@ -1,12 +1,20 @@
 // Import the necessary modules
 import * as amqplib from 'amqplib';
+import * as dotenv from 'dotenv';
+
+// Load environment variables from the .env file
+dotenv.config();
+
+// Access the environment variables
+const rabbitMqUsername = process.env.RABBITMQ_USERNAME;
+const rabbitMqPassword = process.env.RABBITMQ_PASSWORD;
 
 async function connectToRabbitMQ() {
   try {
 
     // Replace 'username' and 'password' with your RabbitMQ credentials
     const connection: amqplib.Connection = await amqplib.connect(
-      'amqp://luminosityleds:Lumi-123@localhost:5672',
+      `amqp://${rabbitMqUsername}:${rabbitMqPassword}@localhost:5672`,
       {
         heartbeat: 10,
       }

diff --git a/src/notification/docker-compose.yaml b/src/notification/docker-compose.yaml
@@ -4,9 +4,7 @@ services:
     image: rabbitmq:3.9.13-management-alpine
     container_name: 'rabbitmq'
     restart: always
-    environment:
-      - "RABBITMQ_DEFAULT_PASS=Lumi-123"
-      - "RABBITMQ_DEFAULT_USER=luminosityleds"
+    env_file: ".env"
     ports:
       - "15672:15672"
       - "5672:5672"
@@ -15,7 +13,6 @@ services:
     volumes:
       - ./rabbitmq-data:/var/lib/rabbitmq
 
-
 networks:
   rabbitmq_go_net:
-    driver: bridge
+    driver: bridge
diff --git a/src/notification/rabbitmq-data/mnesia/[email protected] b/src/notification/rabbitmq-data/mnesia/[email protected]
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/DECISION_TAB.LOG b/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/DECISION_TAB.LOG
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/LATEST.LOG b/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/LATEST.LOG
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/cluster_nodes.config b/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/cluster_nodes.config
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/nodes_running_at_shutdown b/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/nodes_running_at_shutdown
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/rabbit_durable_exchange.DCD b/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/rabbit_durable_exchange.DCD
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/rabbit_durable_queue.DCD b/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/rabbit_durable_queue.DCD
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/rabbit_durable_queue.DCL b/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/rabbit_durable_queue.DCL
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/rabbit_runtime_parameters.DCD b/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/rabbit_runtime_parameters.DCD
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/rabbit_serial b/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/rabbit_serial
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/rabbit_user.DCD b/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/rabbit_user.DCD
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/rabbit_user_permission.DCD b/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/rabbit_user_permission.DCD
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/rabbit_vhost.DCD b/src/notification/rabbitmq-data/mnesia/rabbit@63b686beb86d/rabbit_vhost.DCD
diff --git a/.../mnesia/rabbit@63b686beb86d-feature_flags → .../mnesia/rabbit@91a39ef9d71d-feature_flags b/.../mnesia/rabbit@63b686beb86d-feature_flags → .../mnesia/rabbit@91a39ef9d71d-feature_flags
diff --git a/src/notification/rabbitmq-data/mnesia/[email protected] b/src/notification/rabbitmq-data/mnesia/[email protected]
@@ -0,0 +1 @@
+15
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef-feature_flags b/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef-feature_flags
@@ -0,0 +1,3 @@
+[drop_unroutable_metric,empty_basic_get_metric,implicit_default_bindings,
+ maintenance_mode_status,quorum_queue,stream_queue,user_limits,
+ virtual_host_metadata].
diff --git a/src/notification/rabbitmq-data/mnesia/[email protected] b/src/notification/rabbitmq-data/mnesia/[email protected]
@@ -0,0 +1 @@
+15
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/DECISION_TAB.LOG b/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/DECISION_TAB.LOG
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/LATEST.LOG b/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/LATEST.LOG
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/cluster_nodes.config b/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/cluster_nodes.config
@@ -0,0 +1 @@
+{[rabbit@e62134c482ef],[rabbit@e62134c482ef]}.
diff --git a/...dination/rabbit@63b686beb86d/00000002.wal → ...dination/rabbit@e62134c482ef/00000001.wal b/...dination/rabbit@63b686beb86d/00000002.wal → ...dination/rabbit@e62134c482ef/00000001.wal
diff --git a/...oordination/rabbit@63b686beb86d/meta.dets → ...oordination/rabbit@e62134c482ef/meta.dets b/...oordination/rabbit@63b686beb86d/meta.dets → ...oordination/rabbit@e62134c482ef/meta.dets
diff --git a/...ordination/rabbit@63b686beb86d/names.dets → ...ordination/rabbit@e62134c482ef/names.dets b/...ordination/rabbit@63b686beb86d/names.dets → ...ordination/rabbit@e62134c482ef/names.dets
diff --git a/.../vhosts/628WB79CIFDYO9LJI6DKMI09L/.config → .../vhosts/628WB79CIFDYO9LJI6DKMI09L/.config b/.../vhosts/628WB79CIFDYO9LJI6DKMI09L/.config → .../vhosts/628WB79CIFDYO9LJI6DKMI09L/.config
diff --git a/...s/vhosts/628WB79CIFDYO9LJI6DKMI09L/.vhost → ...s/vhosts/628WB79CIFDYO9LJI6DKMI09L/.vhost b/...s/vhosts/628WB79CIFDYO9LJI6DKMI09L/.vhost → ...s/vhosts/628WB79CIFDYO9LJI6DKMI09L/.vhost
diff --git a/...YO9LJI6DKMI09L/msg_store_persistent/0.rdq → ...YO9LJI6DKMI09L/msg_store_persistent/0.rdq b/...YO9LJI6DKMI09L/msg_store_persistent/0.rdq → ...YO9LJI6DKMI09L/msg_store_persistent/0.rdq
diff --git a/...DYO9LJI6DKMI09L/msg_store_transient/0.rdq → ...DYO9LJI6DKMI09L/msg_store_transient/0.rdq b/...DYO9LJI6DKMI09L/msg_store_transient/0.rdq → ...DYO9LJI6DKMI09L/msg_store_transient/0.rdq
diff --git a/...s/628WB79CIFDYO9LJI6DKMI09L/recovery.dets → ...s/628WB79CIFDYO9LJI6DKMI09L/recovery.dets b/...s/628WB79CIFDYO9LJI6DKMI09L/recovery.dets → ...s/628WB79CIFDYO9LJI6DKMI09L/recovery.dets
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/nodes_running_at_shutdown b/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/nodes_running_at_shutdown
@@ -0,0 +1 @@
+[rabbit@e62134c482ef].
diff --git a/...d/quorum/rabbit@63b686beb86d/00000002.wal → ...f/quorum/rabbit@e62134c482ef/00000001.wal b/...d/quorum/rabbit@63b686beb86d/00000002.wal → ...f/quorum/rabbit@e62134c482ef/00000001.wal
diff --git a/...b86d/quorum/rabbit@63b686beb86d/meta.dets → ...82ef/quorum/rabbit@e62134c482ef/meta.dets b/...b86d/quorum/rabbit@63b686beb86d/meta.dets → ...82ef/quorum/rabbit@e62134c482ef/meta.dets
diff --git a/...86d/quorum/rabbit@63b686beb86d/names.dets → ...2ef/quorum/rabbit@e62134c482ef/names.dets b/...86d/quorum/rabbit@63b686beb86d/names.dets → ...2ef/quorum/rabbit@e62134c482ef/names.dets
diff --git a/...bit@63b686beb86d/rabbit_durable_route.DCD → ...@e62134c482ef/rabbit_durable_exchange.DCD b/...bit@63b686beb86d/rabbit_durable_route.DCD → ...@e62134c482ef/rabbit_durable_exchange.DCD
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/rabbit_durable_exchange.DCL b/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/rabbit_durable_exchange.DCL
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/rabbit_durable_queue.DCD b/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/rabbit_durable_queue.DCD
diff --git a/...@63b686beb86d/rabbit_topic_permission.DCD → ...bit@e62134c482ef/rabbit_durable_route.DCD b/...@63b686beb86d/rabbit_topic_permission.DCD → ...bit@e62134c482ef/rabbit_durable_route.DCD
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/rabbit_runtime_parameters.DCD b/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/rabbit_runtime_parameters.DCD
@@ -0,0 +1 @@
+cXM
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/rabbit_runtime_parameters.DCL b/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/rabbit_runtime_parameters.DCL
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/rabbit_serial b/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/rabbit_serial
@@ -0,0 +1 @@
+1.
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/rabbit_topic_permission.DCD b/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/rabbit_topic_permission.DCD
@@ -0,0 +1 @@
+cXM
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/rabbit_user.DCD b/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/rabbit_user.DCD
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/rabbit_user_permission.DCD b/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/rabbit_user_permission.DCD
diff --git a/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/rabbit_vhost.DCD b/src/notification/rabbitmq-data/mnesia/rabbit@e62134c482ef/rabbit_vhost.DCD
diff --git a/...ata/mnesia/rabbit@63b686beb86d/schema.DAT → ...ata/mnesia/rabbit@e62134c482ef/schema.DAT b/...ata/mnesia/rabbit@63b686beb86d/schema.DAT → ...ata/mnesia/rabbit@e62134c482ef/schema.DAT
diff --git a/...mnesia/rabbit@63b686beb86d/schema_version → ...mnesia/rabbit@e62134c482ef/schema_version b/...mnesia/rabbit@63b686beb86d/schema_version → ...mnesia/rabbit@e62134c482ef/schema_version
diff --git a/yarn.lock b/yarn.lock
@@ -239,6 +239,11 @@ define-properties@^1.1.3, define-properties@^1.2.0:
     has-property-descriptors "^1.0.0"
     object-keys "^1.1.1"
 
+dotenv@^16.3.1:
+  version "16.3.1"
+  resolved "https://registry.npmjs.org/dotenv/-/dotenv-16.3.1.tgz"
+  integrity sha512-IPzF4w4/Rd94bA9imS68tZBaYyBWSCE47V1RGuMrB94iyTOIEwRmVL2x/4An+6mETpLrKJ5hQkB8W4kFAadeIQ==
+
 emoji-regex@^8.0.0:
   version "8.0.0"
   resolved "https://registry.npmjs.org/emoji-regex/-/emoji-regex-8.0.0.tgz"