fix: exit app if not connection on rabbitmq

Vitruveo · Apr 17, 2024 · 467ccdf · 467ccdf
1 parent b3ebf84
commit 467ccdf
Show file tree

Hide file tree

Showing 5 changed files with 13 additions and 3 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
     "name": "vtru-studio-websocket",
-    "version": "1.1.32",
+    "version": "1.1.33",
     "description": "",
     "main": "index.js",
     "scripts": {

diff --git a/src/controllers/notify/index.ts b/src/controllers/notify/index.ts
@@ -10,6 +10,10 @@ const uniqueId = nanoid();
 export const start = async () => {
     const channel = await getChannel();
 
+    channel?.on('close', () => {
+        process.exit(1);
+    })
+
     const notificationQueue = `${RABBITMQ_EXCHANGE_CREATORS}.notifications.${uniqueId}`;
 
     channel?.assertExchange(RABBITMQ_EXCHANGE_CREATORS, 'topic', {

diff --git a/src/controllers/preSignedURL/index.ts b/src/controllers/preSignedURL/index.ts
@@ -11,6 +11,10 @@ const uniqueId = nanoid();
 export const start = async () => {
     const channel = await getChannel();
 
+    channel?.on('close', () => {
+        process.exit(1);
+    });
+
     const logQueue = `${RABBITMQ_EXCHANGE_CREATORS}.assets.${uniqueId}`;
 
     channel?.assertExchange(RABBITMQ_EXCHANGE_CREATORS, 'topic', {

diff --git a/src/services/rabbitmq/index.ts b/src/services/rabbitmq/index.ts
@@ -60,6 +60,8 @@ export const getChannel = async () => {
         process.exit(1);
     } catch (error) {
         captureException(error, { tags: { scope: 'rabbitmq' } });
+
+        process.exit(1);
     }
     return null;
 };