Metrics service Integration for ticker functionality and DB migration Script in Donor service

backend/donor-service/configs/config.js

@@ -32,6 +32,9 @@ const ESIGN_STATUS = Object.freeze({
 const ESIGN_VALIDATION_KAFKA_BROKERS = process.env.ESIGN_VALIDATION_KAFKA_BROKERS || 'localhost:5101';
 let ESIGN_VALIDATION_EXPIRE_TIME = process.env.ESIGN_VALIDATION_EXPIRE_TIME || 2*60;
 const ESIGN_VALIDATION_PREVENT_3RD_PARTY = process.env.ESIGN_VALIDATION_PREVENT_3RD_PARTY === "true" || false;
+const METRICS_URL = process.env.METRICS_URL || 'http://metrics:8070';
+const KAFKA_BROKER_FOR_METRICS_SERVICE = process.env.KAFKA_BROKER_FOR_METRICS_SERVICE || 'kafka:9092';
+const METRICS_TOPIC = process.env.METRICS_TOPIC || 'events';
 const ESIGN_VALIDATION_KAFKA_TOPIC = process.env.ESIGN_VALIDATION_KAFKA_TOPIC || 'esign_topic';
 const ESIGN_VALIDATION_KAFKA_TOPIC_GROUP = process.env.ESIGN_VALIDATION_KAFKA_TOPIC_GROUP || 'dev_esign_group_1';
 const ESIGN_VALIDATION_CLIENT_ID = process.env.ESIGN_VALIDATION_CLIENT_ID || "dev-esign-client";
@@ -75,5 +78,8 @@ module.exports = {
     ESIGN_VALIDATION_PREVENT_3RD_PARTY,
     ESIGN_VALIDATION_KAFKA_TOPIC,
     ESIGN_VALIDATION_KAFKA_TOPIC_GROUP,
-    ESIGN_VALIDATION_CLIENT_ID,
+    METRICS_URL,
+    KAFKA_BROKER_FOR_METRICS_SERVICE,
+    METRICS_TOPIC,
+    ESIGN_VALIDATION_CLIENT_ID
 }

backend/donor-service/main.js

@@ -25,6 +25,8 @@ const {PLEDGE_STATUS, GENDER_MAP, SOCIAL_SHARE_TEMPLATE_MAP} = require('./config
 const app = express();
 const {convertToSocialShareResponse} = require("./utils/utils");
 const consumer = require("./services/esign.consumer");
+const metricsService = require('./services/metrics.service');
+const dataMigrationScript = require('./utils/scriptForDataMigration');
 
 (async() => {
     await redis.initRedis({REDIS_URL: config.REDIS_URL});
@@ -749,4 +751,36 @@ app.use(function(err, req, res, next) {
         message: "Internal server error"
     })
 });
+
+// Metrics Sercvice Integration
+app.get('/getMetrics/:schemaType', (req,res) => metricsService.getMetrics(req,res));
+
+
+// Data Migration Script for NHA PROD
+// 
+// pathParmas ---> entityName ex: /Pledge
+// sample request body : 
+// {
+//     "osIdArray" : ["b6189f8f-9ef3-499f-961b-94bdd540f3cd"]
+// }
+app.post('/pushDataToCH/:entityName', async (req,res) => {
+    let entityName = req.params.entityName;
+    let osidArray = req.body.osIdArray;
+    console.log(osidArray, entityName);
+    let accessToken = await getServiceAccountToken();
+    try {
+        for (let i=0 ; i< osidArray.length; i++) {
+            await dataMigrationScript.migrateDataToCH(entityName,osidArray[i], accessToken);
+            await new Promise(resolve => setTimeout(resolve, 500)); // wait for 500 millisecons
+        }
+        res.status(200).send({
+            message: "Data Migaration Successfull!",
+        })
+    } catch (error) {
+        console.log("error while db migraiton",error);
+        res.status(500).send(error)
+    }
+
+})
+
 app.listen('3000');