refactor: regenerate services using CLI injection

Author: GAndanje

microservices/cart-service/.dockerignore

@@ -0,0 +1,5 @@
+
+#These files wont be sent to the docker builder during the COPY . . command
+
+node_modules
+bar

microservices/cart-service/.env

@@ -1,11 +1,12 @@
+
 FROM node:18-alpine3.18
 
 WORKDIR /app
 
-COPY package.json ./
+COPY package.json .
 
 RUN yarn install
 
 COPY . .
 
-CMD [ "yarn", "dev" ]
+CMD [ "yarn","dev" ]

microservices/cart-service/.env.dev

@@ -0,0 +1,26 @@
+
+module.exports = {
+    apps : [{
+      name   : cart,
+      autorestart: true,
+      watch: true,
+      time: true,
+      script : "./index.js",
+      instances:4,
+      env_production: {
+        NODE_ENV: "prod",
+        DATABASE_URL="mongodb://mongodb:27017/microservices-suite_cart_proddb",
+        EXCHANGE="@monorepo",
+        AMQP_HOST="amqp://rabbitmq:5672",
+        PORT:9010
+     },
+     env_development: {
+      NODE_ENV: "dev",
+      DATABASE_URL="mongodb://mongodb:27017/microservices-suite_cart_devdb",
+      EXCHANGE="@monorepo",
+      AMQP_HOST="amqp://rabbitmq:5672",
+      PORT:9010
+   }
+    }]
+  }
+

microservices/cart-service/ecosystem.config.js

@@ -0,0 +1,65 @@
+
+const http = require('http');
+const express = require('express');
+const mongoose = require('mongoose');
+const { config, morgan, logger } = require('@microservices-suite/config');
+const { errorHandler } = require('@microservices-suite/errors');
+const { validate, APIError } = require('@microservices-suite/utilities');
+const { getUsers } = require('./src/services');
+const { router } = require('./src/routes');
+const { subscriber } = require('./src/subscriber');
+const rabbitmq = require('@microservices-suite/broker/rabbitmq');
+// const app = require('./src/app');
+
+mongoose.connect(config.db).then(() => {
+    logger.info(`📀 successfully connected to db: ${config.db}`);
+}).catch(err => {
+    logger.error(`failed to connect to db. Exiting... ${err.message}`);
+    process.exit(0);
+});
+
+const app = express();
+
+app.use(express.json());
+
+app.get('/', (req, res) => {
+    res.json({ message: 'hello from @microservices-suite/cart' });
+});
+
+const server = http.createServer(app);
+
+server.on('error', (err) => {
+    logger.error(err);
+    if (err.code === 'EADDRINUSE') {
+        logger.error('Address already in use, retrying...');
+        setTimeout(() => {
+            server.close();
+            server.listen(config.port, 'localhost');
+        }, 1000);
+        errorHandler(err);
+    }
+});
+
+server.listen(config.port, async() => {
+    logger.info(`🚀 @microservices-suite/cart listening at: http://localhost:${config.port}`);
+    const channel = await rabbitmq.workerQueue.amqpInitializeQueue({ config });
+    await rabbitmq.workerQueue.consumeFromQueue({
+        channel,
+        queue: 'cart',
+        subscriberHandler: subscriber.subscriberHandler
+    });
+});
+
+app.use(morgan.errorHandler);
+
+app.use(morgan.successHandler);
+
+app.use('/api/v1', router);
+
+// Global error handler should come after all other middlewares
+app.all('*', (req, res, next) => {
+    const err = new APIError(404, `requested resource not found on server: ${req.originalUrl}`);
+    next(err);
+});
+
+app.use(errorHandler);

microservices/cart-service/package.json

@@ -0,0 +1,46 @@
+{
+  "name": "@microservices-suite/cart",
+  "version": "1.0.0",
+  "description": "This is the cart service. TODO: update this description",
+  "main": "index.js",
+  "author": "Gilbert",
+  "license": "MIT",
+  "dependencies": {
+    "@microservices-suite/config": "1.0.0",
+    "@microservices-suite/errors": "1.0.0",
+    "@microservices-suite/utilities": "1.0.0",
+    "@microservices-suite/broker": "1.0.0",
+    "dotenv": "^16.4.5",
+    "express": "^4.18.3",
+    "helmet": "^7.1.0",
+    "mongodb": "^6.5.0",
+    "mongoose": "^8.2.1",
+    "morgan": "^1.10.0",
+    "pm2": "^5.3.1",
+    "winston": "^3.12.0"
+  },
+  "devDependencies": {
+    "nodemon": "^3.1.0"
+  },
+  "workspaces": {
+    "nohoist": [
+      "**/@microservices-suite/utilities/",
+      "**/@microservices-suite/utilities/**",
+      "**/@microservices-suite/errors/",
+      "**/@microservices-suite/errors/**",
+      "**/@microservices-suite/config/",
+      "**/@microservices-suite/config/**",
+      "**/@microservices-suite/broker/",
+      "**/@microservices-suite/broker/**"
+    ]
+  },
+  "scripts": {
+    "release": "npx bumpp-version@latest && npm publish",
+    "dev": "NODE_ENV=dev nodemon --legacy-watch -q index.js",
+    "start": "pm2-runtime start ecosystem.config.js --env production",
+    "stoprod": "pm2 stop ecosystem.config.js",
+    "deletprod": "pm2 delete ecosystem.config.js",
+    "test": "jest"
+  },
+  "private": true
+}