Update oih libs version and refactor code

Mars-2030 · Jan 25, 2021 · 474f6bd · 474f6bd
1 parent 3ef80d9
commit 474f6bd
Show file tree

Hide file tree

Showing 3 changed files with 528 additions and 443 deletions.
diff --git a/services/reports-analytics/package.json b/services/reports-analytics/package.json
@@ -7,7 +7,7 @@
   "license": "Apache-2.0",
   "scripts": {
     "start": "node src/index.js",
-    "start:container": "nodemon src/index.js --watch src/",
+    "start:container": "nodemon src/index.js --watch src/ --watch ../../lib/event-bus/src",
     "test": "jest",
     "watch": "nodemon src/index.js",
     "coverage": "yarn test --coverage",
@@ -22,8 +22,8 @@
     "stop-dev": "yarn stop-dev-ts && yarn stop-dev-mongo && yarn stop-dev-rabbitmq"
   },
   "dependencies": {
-    "@basaas/node-logger": "1.1.5",
-    "@openintegrationhub/event-bus": "1.2.0",
+    "@basaas/node-logger": "*",
+    "@openintegrationhub/event-bus": "*",
     "dotenv": "8.2.0",
     "express": "4.17.1",
     "influx": "5.6.3",

diff --git a/services/reports-analytics/src/server/index.js b/services/reports-analytics/src/server/index.js
@@ -41,7 +41,7 @@ module.exports = class Server {
     async setupExpress() {
         this.app = express();
         this.app.disable('x-powered-by');
-        this.app.use('/healthcheck', require('./../route/healthcheck'));
+        this.app.use('/healthcheck', require('../route/healthcheck'));
         this.app.use('/grafana-proxy', require('../route/grafana-proxy'));
     }
 
@@ -108,13 +108,15 @@ module.exports = class Server {
                     timestamp: `${event.createdAt}000000`,
                 });
             }
+            console.log(payload);
             await this.influx.writePoints(payload);
         } catch (err) {
             logger.error(err);
         }
     }
 
     async handleEvent(event) {
+        console.log(event.name);
         this.writeTs(event, this.eventMap.get(event.name));
     }