chore: abort app on connection to queue problem (#252)

* chore: abort app on connection to queue problem

* chore: update

* chore: update

Author: hmbanan666

apps/atrium-telegram/server/plugins/02.queue.ts

@@ -5,9 +5,24 @@ import { queue } from '@roll-stack/queue'
  * Queue init
  */
 export default defineNitroPlugin(async () => {
+  const logger = useLogger('plugin:start-queue')
+
+  if (process.env.NODE_ENV !== 'production' && !process.env.QUEUE_URL) {
+    logger.info('Skipping in non-production environment')
+    return
+  }
+
   if (!process.env.QUEUE_URL) {
     throw new Error('QUEUE_URL is not defined')
   }
 
-  await queue.connect(process.env.QUEUE_URL)
+  try {
+    await queue.connect(process.env.QUEUE_URL, 10)
+  } catch (error) {
+    // Have a problem
+    logger.error(error)
+
+    // System
+    process.exit(1)
+  }
 })

apps/core-telegram/server/plugins/02.queue.ts

@@ -9,15 +9,23 @@ export default defineNitroPlugin(async () => {
   const logger = useLogger('plugin:start-queue')
 
   if (process.env.NODE_ENV !== 'production' && !process.env.QUEUE_URL) {
-    logger.info('Skipping Queue in non-production environment')
+    logger.info('Skipping in non-production environment')
     return
   }
 
   if (!process.env.QUEUE_URL) {
     throw new Error('QUEUE_URL is not defined')
   }
 
-  await queue.connect(process.env.QUEUE_URL)
+  try {
+    await queue.connect(process.env.QUEUE_URL, 10)
+  } catch (error) {
+    // Have a problem
+    logger.error(error)
+
+    // System
+    process.exit(1)
+  }
 
   await setupConsumers()
 })

apps/web-app/server/plugins/02.queue.ts

@@ -8,13 +8,21 @@ export default defineNitroPlugin(async () => {
   const logger = useLogger('plugin:start-queue')
 
   if (process.env.NODE_ENV !== 'production' && !process.env.QUEUE_URL) {
-    logger.info('Skipping Queue in non-production environment')
+    logger.info('Skipping in non-production environment')
     return
   }
 
   if (!process.env.QUEUE_URL) {
     throw new Error('QUEUE_URL is not defined')
   }
 
-  await queue.connect(process.env.QUEUE_URL)
+  try {
+    await queue.connect(process.env.QUEUE_URL, 10)
+  } catch (error) {
+    // Have a problem
+    logger.error(error)
+
+    // System
+    process.exit(1)
+  }
 })

pnpm-lock.yaml

@@ -33,7 +33,7 @@ catalogs:
     '@date-fns/tz': ^1.4.1
     '@internationalized/date': ^3.10.0
     '@neoconfetti/vue': ^2.2.1
-    '@nextorders/queue': ^0.4.0
+    '@nextorders/queue': ^0.4.2
     '@nuxt/ui': ^4.1.0
     '@openai/agents': ^0.2.1
     '@paralleldrive/cuid2': 2.2.2