Ben tim/testing

.gitignore

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

Main.js

@@ -0,0 +1,154 @@
+const { app, BrowserWindow, ipcMain } = require('electron');
+const fs = require('fs');
+const path = require('path');
+const connectSQL = require('./model/sql-connect');
+const connectMongoose = require('./model/mongoose-connect');
+const CommunicationSchema = require('./model/mongoose-communicatonSchema');
+const HealthInfoSchema = require('./model/mongoose-healthInfoSchema');
+
+let win;
+function createWindow() {
+  win = new BrowserWindow({
+    width: 900,
+    height: 800,
+    icon: path.join(__dirname, 'app/assets/icons/icon.png'),
+    webPreferences: {
+      nodeIntegration: true,
+    },
+  });
+
+  // Development
+  win.loadURL('http://localhost:8080/');
+
+  // Production
+  // win.loadURL(`file://${path.join(__dirname, './dist/index.html')}`);
+
+  win.on('closed', () => {
+    win = null;
+  });
+}
+app.on('ready', createWindow);
+
+app.on('window-all-closed', () => {
+  if (process.platform !== 'darwin') {
+    app.quit();
+  }
+});
+
+app.on('activate', () => {
+  if (win === null) {
+    createWindow();
+  }
+});
+
+// Load settings JSON and returns current setup status back to the render process.
+ipcMain.on('setup', (message) => {
+  const state = JSON.parse(
+    fs.readFileSync(path.resolve(__dirname, './user/settings.json'), {
+      encoding: 'UTF-8',
+    }),
+  );
+  const { setupRequired } = state;
+  message.returnValue = setupRequired;
+});
+
+// Loads existing settings JSON and update settings to include new services entered by the user.
+ipcMain.on('submit', (message, newService) => {
+  const state = JSON.parse(
+    fs.readFileSync(path.resolve(__dirname, './user/settings.json'), {
+      encoding: 'UTF-8',
+    }),
+  );
+  // if statement is used to replace hard coded data. Hard coded data and the michelleWasHere key is needed to avoid a load error caused by Electron querying the database before a user has added or selected a database.
+  if (state.michelleWasHere) {
+    state.setupRequired = false;
+    state.michelleWasHere = false;
+    state.services = [JSON.parse(newService)];
+    fs.writeFileSync(path.resolve(__dirname, './user/settings.json'), JSON.stringify(state));
+  } else {
+    state.setupRequired = false;
+    state.services.push(JSON.parse(newService));
+    fs.writeFileSync(path.resolve(__dirname, './user/settings.json'), JSON.stringify(state));
+  }
+});
+
+// Load settings JSON and returns updated state back to the render process.
+ipcMain.on('dashboard', (message) => {
+  const state = JSON.parse(
+    fs.readFileSync(path.resolve(__dirname, './user/settings.json'), {
+      encoding: 'UTF-8',
+    }),
+  );
+  const { services } = state;
+  const dashboardList = services.reduce((acc, curVal) => {
+    acc.push(curVal[0]);
+    return acc;
+  }, []);
+  message.returnValue = dashboardList;
+});
+
+// Queries the database for communications information and returns it back to the render process.
+ipcMain.on('overviewRequest', (message, index) => {
+  const databaseType = JSON.parse(
+    fs.readFileSync(path.resolve(__dirname, './user/settings.json'), { encoding: 'UTF-8' }),
+  ).services[index][1];
+
+  if (databaseType === 'MongoDB') {
+    connectMongoose(index);
+    CommunicationSchema.find({}, (err, data) => {
+      if (err) {
+        console.log(`An error occured while querying the database: ${err}`);
+        message.sender.send('overviewResponse', JSON.stringify(err));
+      }
+      const queryResults = JSON.stringify(data);
+      // Asynchronous event emitter used to transmit query results back to the render process.
+      message.sender.send('overviewResponse', queryResults);
+    });
+  }
+
+  if (databaseType === 'SQL') {
+    const pool = connectSQL(index);
+    const getCommunications = 'SELECT * FROM communications';
+    pool.query(getCommunications, (err, result) => {
+      if (err) {
+        console.log(err);
+        message.sender.send(JSON.stringify('Database info could not be retreived.'));
+      }
+      const queryResults = JSON.stringify(result.rows);
+      // Asynchronous event emitter used to transmit query results back to the render process.
+      message.sender.send('overviewResponse', queryResults);
+    });
+  }
+});
+
+// Queries the database for computer health information and returns it back to the render process.
+ipcMain.on('detailsRequest', (message, index) => {
+  const databaseType = JSON.parse(
+    fs.readFileSync(path.resolve(__dirname, './user/settings.json'), { encoding: 'UTF-8' }),
+  ).services[index][1];
+
+  if (databaseType === 'MongoDB') {
+    connectMongoose(index);
+    HealthInfoSchema.find({}, (err, data) => {
+      if (err) {
+        message.sender.send('detailsResponse', JSON.stringify(err));
+      }
+      const queryResults = JSON.stringify(data);
+      // Asynchronous event emitter used to transmit query results back to the render process.
+      message.sender.send('detailsResponse', queryResults);
+    });
+  }
+
+  if (databaseType === 'SQL') {
+    const pool = connectSQL(index);
+    const getHealth = 'SELECT * FROM healthInfo';
+    pool.query(getHealth, (err, result) => {
+      if (err) {
+        message.sender.send('detailsResponse', JSON.stringify('Database info could not be retreived.'));
+      }
+      const queryResults = JSON.stringify(result.rows);
+      // Asynchronous event emitter used to transmit query results back to the render process.
+      message.sender.send('detailsResponse', queryResults);
+    });
+  }
+});

README.md

@@ -1,88 +1,34 @@
-# Chronos
-Chronos consists of an NPM package to be required into a user’s microservices that intercepts all http and gRPC microservice communications, as well as monitors the health of each microservice over time. This information is written to a user-owned database (PostgreSQL or NoSQL) where it is queried and rendered by the frontend utilizing Node in conjunction with a native, cross-platform Electron desktop application with React components to ensure agreement between the frontend and database.
+##Chronos Microservice Debugger
+Chronos Microservice Debugger consists of an npm package with an optional Electron front end to visualize and monitor your microservices.
 
-## Why was Chronos created?
-As companies grow larger and begin to scale, they have a tendency to move from a monolithic code architecture and microservices and distributed systems architecture in order to build faster, more maintainable code.
-
-The process of modularizing a code bases and breaking a monolith into individual services can be a daunting task. How do you break apart and re-connect these services? There is often a transitional period where valuable time is spent debugging these connections between services.
-
-Chronos is deigned to meet the needs of companies and developers working to break down their monoliths into distributed systems by combining an NPM package together with an Electron application to monitor and assist in the debugging of their services.
-
-## How to Install Chronos
-The Chronos-Microservice-Debugger Express Middleware can be found on npm: https://www.npmjs.com/package/chronos-microservice-debugger
-
-To install the NPM package:
+## Install
 ```javascript
 npm install chronos-microservice-debugger
 ```
 
-The Chronos Electron application is in progress and will soon be availble for public download for all platforms. Please stay tuned.
-
-## How to Use Chronos
+## Usage
 There are two main aspects to Chronos-Microservice-Debugger
-1. Communication Monitor: Listens in on all microservice-microservice and microservice-client communication and monitors the response statuses and messages to ensure communications are making it to the correct destination successfully.
-2. Health Monitor: The health monitor checks the status of your microservice every second and sends this health information to an optional electron frontend where it is visualized for easier use.
-
-To use the npm package, there are three required parameters and an optional fourth parameter. You can enter the items as individual strings or as an array containing the three required parameters and one optional parameter.
+*Communication Monitor: Listens in on all microservice-microservice and microservice-client communication and monitors the response statuses and messages to ensure communications are making it to the correct destination successfully.
+*Health Monitor: The health monitor checks the status of your microservice every second and sends this health information to an optional electron frontend where it is visualized for easier use.
 
-The parameters are:
-1. microserviceName: What do you want to name the current microservice
-2. databaseType: We currently support PostgreSQL and Mongo. Enter "mongo" or "sql"
-3. databaseURL: Where would you like to store your information? Enter the URL to your database
-4. queryFrequency: How often do you want microHealth to monitor the health of your database? It defaults to every second, but you can choose:
-  * "s" : The default, monitors every second
-  * "m" : Monitors every minute
-  * "h" : Monitors every hour
-  * "d" : Monitors once per day
-  * "w" : Monitors once per week
 
-String parameter example:
 ```javascript
-// How to use chronos-microservice-debugger
-app.use('/', chronos-microservice-debgugger.microCom('microserviceName', 'databaseType', 'databaseURL'))
-
-chronos-microservice-debugger.microHealth('microserviceName', 'databaseType', 'databaseURL', 'queryFrequency'))
-
-// Example using string parameters
-app.use('/', chronos-microservice-debugger.microCom('books', 'sql', 'thisIsMyURL'))
-// Note: microCom does not utilize queryFreq because it logs all communication when an endpoint is hit
-
-chronos-microservice-debugger.microHealth('books', 'sql', 'thisIsMyURL', 'h')
+app.use('/', chronos-microservice-debugger.microCom('microserviceName', 'databaseType', 'databaseURL'))
+chronos-microservice-debugger.microHealth('microserviceName', databaseType, databaseURL))
 ```
+Chronos uses a user-owned and provided database to ensure that your private data stays private. We currently support MongoDB and SQL/PostgreSQL databases.
 
-Array parameter example:
-```javascript
-let values = [
-  'microserviceName',
-  'databaseType',
-  'databaseURL',
-  'queryFrequency'
-]
-// How to use chronos-micrservice-debugger with an array parameter
-app.use('/', chronos-microservice-debgugger.microCom(values)
-
-chronos-microservice-debugger.microHealth(values)
-
-// Example using an array parameter
-let values = [
-  'books',
-  'mongo',
-  'thisIsMyNewURL',
-  'w'
-]
+## Things in the Works
+*gRPC support
+*Ability to determine how often your microservice health is monitored (currently every second)
+*'Time Travel' to see how your microservices have changed over time
+*Docker health information for containerized microservices
+*Implement additional unit testing
 
-app.use('/', chronos-microservice-debgugger.microCom(values)
-// Note: microCom does not utilize queryFreq because it logs all communication when an endpoint is hit
-
-chronos-microservice-debugger.microHealth(values)
-
-```
+## Links
+*Chronos Website: http://chronos.ninja
+*Gitub Page: https://github.com/oslabs-beta/Chronos
 
-## How to Contribute to Chronos
-Chronos hopes to inspire an active community of both users and developers. For questions, comments, suggestions, please contact us at teammicronos@gmail.com or submit a pull request.
+## Contact Us
+For questions, requests, or more information, please contact us at teammicronos@gmail.com
 
-## Created By
-* Duane McFarlane
-* Michelle Herrera
-* Mohtasim Chowdhury
-* Natalie Umanzor

__tests__/spec.js

@@ -0,0 +1,28 @@
+const { Application } = require('spectron');
+const assert = require('assert');
+const electronPath = require('electron');
+const path = require('path');
+
+describe('Application launch', function () {
+  this.timeout(10000);
+
+  beforeEach(function () {
+    this.app = new Application({
+      path: electronPath,
+      args: [path.join(__dirname, '..')],
+    });
+    return this.app.start();
+  });
+
+  afterEach(function () {
+    if (this.app && this.app.isRunning()) {
+      return this.app.stop();
+    }
+  });
+
+  it('shows an initial window', function () {
+    return this.app.client.getWindowCount().then(function (count) {
+      assert.equal(count, 1);
+    });
+  });
+});

__tests__/test.js

@@ -0,0 +1,42 @@
+var expect = require('chai').expect;
+var MongoClient = require('mongodb').MongoClient;
+
+describe('middleware', () => {
+  var healthInfo, db;
+
+  beforeAll(function (done) {
+    MongoClient.connect(
+      'mongodb+srv://numanzor:Nu121692.@microservice-tutorial-hq75f.mongodb.net/chronos-access', { useNewUrlParser: true }, function(err, client) {
+        if (err) throw new Error(err);
+        done();
+        db = client.db('chronos-access');
+        healthInfo = db.collection('healthinfos');
+      }
+    );
+  });
+
+  test('should have records in the "healthinfos" collection', done => {
+   healthInfo.countDocuments(function (err, num) {
+      expect(err).to.not.exist;
+      expect(num).to.be.above(0);
+      done();
+    });
+  });
+
+  test('should have the right string and date-time fields', done => {
+    healthInfo.find().toArray(function (err, data) {
+      expect(err).to.not.exist;
+      expect(data).to.be.an('Array');
+      var dataPoint = data[0];
+      expect(dataPoint.currentMicroservice).to.be.a('string').and.not.eql('');
+      expect(dataPoint.targetedEndpoint).to.be.a('string').and.not.eql('');
+      expect(dataPoint.reqType).to.be.a('string').and.not.eql('');
+      expect(dataPoint.timeSent).to.be.a('date').and.not.eql('');
+      done();
+    });
+  });
+
+  afterAll(function () {
+    db.close();
+  });
+});

app/charts/latency-chart.jsx

@@ -0,0 +1,37 @@
+import React, { useContext } from 'react';
+import { Line } from 'react-chartjs-2';
+import HealthContext from '../context/DetailsContext';
+
+const LatencyChart = (props) => {
+  const xAxis = [];
+  const yAxis = [];
+  const healthData = useContext(HealthContext).detailData;
+  for (let i = 0; i < healthData.length; i++) {
+    const element = healthData[i];
+    if (element.currentmicroservice === props.service || element.currentMicroservice === props.service) {
+      xAxis.push(i);
+      yAxis.push(element.latency);
+    }
+  }
+  const chartData = {
+    datasets: [
+      {
+        label: `CPU latency of ${props.service}`,
+        data: yAxis,
+        backgroundColor: ['rgb(254, 255, 0)'],
+      },
+    ],
+    options: {
+      xAxisID: 'TBD',
+      yAxisID: 'TBD',
+    },
+    labels: xAxis,
+  };
+  return (
+    <div>
+      <Line data={chartData} />
+    </div>
+  );
+};
+
+export default LatencyChart;