Docker/microservice

.env.example

@@ -0,0 +1,20 @@
+# In each of the microservices, create an .env file in the root directory.
+# Supply port values for use by the Dockerfile. 
+  # Make sure the values are consistent for all services.
+# Supply your URI for the Chronos db.
+  # This is where the aggregated comm/health/container info are stored.
+# Supply a unique URI for each service that's NOT your Chronos db. 
+  # This is where the entries of books/orders/customers are stored.
+
+# These should be the same for all services.
+FRONTEND_PORT=
+BOOKS_PORT=
+CUSTOMERS_PORT=
+ORDERS_PORT=
+NGINX_PORT=
+CHRONOS_PSQL=
+CHRONOS_MONGO=
+
+# This one will be unique for every service.
+  # Note that the Frontend service will not need this. 
+BOOKS_DB=

.gitignore

@@ -1,3 +1,2 @@
-node_modules
-.eslintrc.js
-package-lock.json
+.env
+node_modules

books/BookController.js

@@ -1,3 +1,4 @@
+require('dotenv').config();
 const fetch = require('node-fetch');
 const BookModel = require('./BookModel');
 
@@ -52,10 +53,11 @@ BookController.deleteBook = (req, res, next) => {
 
 //  This controller gets order info from the order application
 BookController.getorderinfo = (req, res, next) => {
+  console.log('req.headers (in bookController.js):', req.headers);
   //  const { body } = req;
   // since it's a get request, you technically don't need
   //  all the headers but it's more declarative this way
-  fetch('http://localhost:8080/orders/getorders', {
+  fetch(`http://orders:${process.env.ORDERS_PORT}/orders/getorders`, {
     method: 'GET',
     headers: {
       'Content-Type': 'Application/JSON',
@@ -69,7 +71,7 @@ BookController.getorderinfo = (req, res, next) => {
       return next();
     })
     .catch((error) => {
-      console.log(`There was an error in getting customers data ${error}`);
+      console.log(`There was an error in getting orders data ${error}`);
     });
 };
 module.exports = BookController;

books/BookModel.js

@@ -1,16 +1,16 @@
 const mongoose = require('mongoose');
+require('dotenv').config();
 
 //  pull schema from the mongoose object
 const { Schema } = mongoose;
 
-//  database link
-//  can change but woun't advice that because the book application database lives here
-const myURI = 'mongodb+srv://tim:tim@cluster0-khxef.mongodb.net/test?retryWrites=true&w=majority';
+// DB link for books data.
+const book_db_URI = `${process.env.BOOKS_DB}`;
 
-const URI = process.env.MONGO_URI || myURI;
+// const URI = process.env.MONGO_URI || myURI;
 
 // connect the database, if error, log will be sent to the terminal
-mongoose.connect(URI, { useNewUrlParser: true, useUnifiedTopology: true })
+mongoose.connect(book_db_URI, { useNewUrlParser: true, useUnifiedTopology: true })
   .then(() => console.log('Connected!!!********* Books Database is live!!!'))
   .catch((err) => console.log('Connection Error ', err));
 

books/BookServer.js

@@ -1,39 +1,45 @@
-const cmd = require('chronos-microservice-debugger3');
-
-cmd.propagate();
-const PORT = 4545;
 const express = require('express');
 const path = require('path');
 const cors = require('cors');
-
-const app = express();
-const bodyParser = require('body-parser');
+const cmd = require('chronos-microservice-debugger4');
 const controller = require('./BookController.js');
+require('dotenv').config();
 
-//  we're using the chronos debugger tool here to intercept
-//  request and propagate our context onto said request as it travels
-
-// app.use('/', cmd.microCom('books_microservice', 'sql', 'postgres://tsfcbdjo:l8AWzEJEyhxtR-ERoj7HNjIqBuRCqm9f@rajje.db.elephantsql.com:5432/tsfcbdjo'));
-// cmd.microHealth('books_microservice', 'sql', 'postgres://tsfcbdjo:l8AWzEJEyhxtR-ERoj7HNjIqBuRCqm9f@rajje.db.elephantsql.com:5432/tsfcbdjo', 'h');
-
-app.use('/', cmd.microCom('books_microservice', 'sql', 'postgres://kpbljbrv:Ry1hO5KPIU-jvVyGnHHne-yplDr2Yk3H@rajje.db.elephantsql.com:5432/kpbljbrv', 'yes', 'm'));
+// Places a unique header on every req in order to trace the path in the req's life cycle.
+cmd.propagate();
 
+const app = express();
 
-app.use(bodyParser.urlencoded({ extended: true }));
-app.use(bodyParser.json());
+app.use(express.json());
+
+// Invoke .microCom with the 6 params to enable logging of comm and health data to your own db.
+// Params (6): microservice name, db type, db URI, want health data?, query freq, is service Dockerized?
+  // If running a svc in a Docker container, please give container the same name as the microservice...
+  // ... to ensure proper logging of container stats.
+app.use('/', cmd.microCom(
+  'books',
+  // PostgreSQL
+  'sql',
+  `${process.env.CHRONOS_PSQL}`,
+  // MongoDB
+  // 'mongo',
+  // `${process.env.CHRONOS_MONGO}`,
+  'no',
+  'm',
+  'yes' // <-- Is the service Dockerized?
+));
 
 app.use(cors());
 app.use('/', express.static(path.resolve(__dirname, '../frontend')));
 
-// ********** I PROBABLY STILL NEED THIS PART FOR CHRONOS TO WORK AND DEBUG MY MICOSERVICE *************
-
 // CHAOS FLOW - SIMPLY A TEST FOR THE EXPESS SERVER
 app.use((req, res, next) => {
   console.log(
     `***************************************************************************************
-    CHAOS FLOW TEST --- METHOD:${req.method}, PATH: ${
-  req.url
-}, BODY: ${JSON.stringify(req.body)}, ID: ${req.query.id}
+    CHAOS FLOW TEST --- METHOD:${req.method},
+    PATH: ${req.url},
+    BODY: ${JSON.stringify(req.body)},
+    ID: ${req.query.id}
     ***************************************************************************************`,
   );
   next();
@@ -59,9 +65,8 @@ app.get('/books/getordersinfo', controller.getorderinfo, (req, res) => {
   res.status(200).json(res.locals.getorderinfo);
 });
 
-
-//  This is my global error handler - isn't being used right now and it's not breaking anything so...
-function errorHandler(error, req, res, next) {
+// Global error handler
+app.use((error, req, res, next) => {
   //  console.log(err.stack);
   const defaultErr = {
     log: 'Express error handler caught unknown middleware error',
@@ -72,9 +77,8 @@ function errorHandler(error, req, res, next) {
   console.log(`Here is the error object's response: ${errorObj.log}`);
 
   res.status(errorObj.status).json(errorObj.message);
-}
+});
 
-// Open and listen to server on said port
-app.listen(PORT, () => {
-  console.log(`Book server running on port ${PORT} ...`);
+app.listen(process.env.BOOKS_PORT, () => {
+  console.log(`Book server running on port ${process.env.BOOKS_PORT} ...`);
 });