fix: retry broker and db connections at start

Author: GAndanje

.suite-cli/cli/scripts/assets/serverContent.asset.js

@@ -5,32 +5,45 @@ const mongoose = require('mongoose');
 const { config, morgan, logger } = require('${answers.project_base}/config');
 const { errorHandler } = require('${answers.project_base}/errors');
 const { validate, APIError } = require('${answers.project_base}/utilities');
-const { getUsers } = require('./src/services');
 const { router } = require('./src/routes');
 const { subscriber } = require('./src/subscriber');
 const ${answers.default_broker} = require('${answers.project_base}/broker/${answers.default_broker}');
-// const app = require('./src/app');
 
-const connectWithRetry = () => {
+const connectDbWithRetry = () => {
     mongoose.connect(config.db)
-    .then(() => {
+        .then(() => {
             logger.info(\`📀 successfully connected to db: \${config.db}\`);
         })
         .catch((err) => {
             logger.error(\`Failed to connect to db. Exiting... \${err.message}\`);
-            logger.info('Retrying connection in 5 seconds...');
-            setTimeout(connectWithRetry, 5000); // Retry after 5 seconds
+            logger.info('Retrying connection in 2 seconds...');
+            setTimeout(connectDbWithRetry, 2000); // Retry after 2 seconds
         });
 };
 
-connectWithRetry();
+const connectBrokerWithRetry = async () => {
+    try {
+        const channel = await ${answers.default_broker}.workerQueue.amqpInitializeQueue({ config });
+        await ${answers.default_broker}.workerQueue.consumeFromQueue({
+            channel,
+            queue: '${answers.service_name}',
+            subscriberHandler: subscriber.subscriberHandler,
+        });
+    } catch (error) {
+        logger.error(error);
+        logger.info('Retrying broker connection in 2 seconds...');
+        setTimeout(connectBrokerWithRetry, 2000); // Retry after 2 seconds
+    }
+};
+
+connectDbWithRetry();
 
 const app = express();
 
 app.use(express.json());
 
 app.get('/', (req, res) => {
-    res.json({ message: 'hello from ${answers.project_base}/${answers.service_name}' });
+    res.json({ message: \`hello from ${answers.project_base}/${answers.service_name}\` });
 });
 
 const server = http.createServer(app);
@@ -47,14 +60,9 @@ server.on('error', (err) => {
     }
 });
 
-server.listen(config.port, async() => {
+server.listen(config.port, () => {
     logger.info(\`🚀 ${answers.project_base}/${answers.service_name} listening at: http://localhost:\${config.port}\`);
-    const channel = await ${answers.default_broker}.workerQueue.amqpInitializeQueue({ config });
-    await ${answers.default_broker}.workerQueue.consumeFromQueue({
-        channel,
-        queue: '${answers.service_name}',
-        subscriberHandler: subscriber.subscriberHandler
-    });
+    connectBrokerWithRetry();
 });
 
 app.use(morgan.errorHandler);