format changes only [skip ci]

Author: Gunasekar-K

src/consumer-slacknotify.js

@@ -1,19 +1,16 @@
 const Kafka = require('no-kafka');
 const Promise = require('bluebird');
 const config = require('config');
-const { 
-    postMessage,
-    validateMsgPosted
-  } = require('./api/postslackinfo')
+const slack = require('./api/postslackinfo')
 const consumer = new Kafka.GroupConsumer();
 
 const dataHandler = function (messageSet, topic, partition) {
     return Promise.each(messageSet, async function (m) {
       const payload = JSON.parse(m.message.value)
       if(config.SLACK.SLACKNOTIFY === 'true') {
         console.log(payload)
-        await postMessage(Object.values(payload), async (response) => {
-            await validateMsgPosted(response.statusCode, response.statusMessage)
+        await slack.postMessage(Object.values(payload), async (response) => {
+            await slack.validateMsgPosted(response.statusCode, response.statusMessage)
         });
         }
 

src/node-server-without-kafka.js

@@ -15,8 +15,6 @@ app.get('/', function (req, res) {
 
 app.post('/fileevents', async function (req, res) {
   const payload = req.body
-  // const topic = payload.topic
-  const topic = 'test-topic';
   console.log({
     topic: config.topic.NAME,
     partition: config.topic.PARTITION,
@@ -27,22 +25,7 @@ app.post('/fileevents', async function (req, res) {
   await pushToDynamoDb(payload);
     res.send('done');
 
-  // send response to client 
-  //res.send('ok')
-
 })
 
-// const producer = new Kafka.Producer()
-
-// producer.init().then(function () {
-//   console.log('connected to local kafka server on port 9092 ...');
-
-//   // start the server
-//   app.listen(port);
-//   console.log('Server started! At http://localhost:' + port);
-
-// } //end producer init
-// ).catch(e => { console.log('Error : ', e) });
-
 app.listen(port);
 console.log('Server started! At http://localhost:' + port);

src/nodeserver.js

@@ -3,17 +3,9 @@ require('express-async-errors');
 const Kafka = require('no-kafka')
 const config = require('config')
 const bodyParser = require('body-parser')
-const {
-  create_producer_app_log,
-  producerpost_success_log,
-  producerpost_failure_log
-} = require('./common/app_log')
+const app_log = require('./common/app_log')
 const pushToKafka = require('./api/pushToKafka')
-const { 
-  postMessage,
-  validateMsgPosted
-} = require('./api/postslackinfo')
-
+const slack = require('./api/postslackinfo')
 const app = express()
 app.use(bodyParser.json()); // to support JSON-encoded bodies
 app.use(bodyParser.urlencoded({ // to support URL-encoded bodies
@@ -22,21 +14,14 @@ app.use(bodyParser.urlencoded({ // to support URL-encoded bodies
 app.get('/', function (req, res) {
   res.send('hello world')
 })
-
-
 app.post('/kafkaevents', async (req, res, next) => {
   const payload = req.body
   let seqID = payload.TIME + "_" + payload.TABLENAME
-  //retry_count  = payload['RETRY_COUNT'] ? payload['RETRY_COUNT'] : 0
-  //let reconcile_flag = payload['RECONCILE_STATUS'] ? payload['RECONCILE_STATUS'] : 0
-  let producer_retry_count
-
   try {
-    await create_producer_app_log(payload,"PayloadReceived")
+    await app_log.create_producer_app_log(payload, "PayloadReceived")
   } catch (error) {
     console.log(error)
   }
-
   //send kafka message
   let kafka_error
   let msgValue = {
@@ -46,14 +31,12 @@ app.post('/kafkaevents', async (req, res, next) => {
   kafka_error = await pushToKafka(producer, config.topic.NAME, msgValue)
   //add auditlog
   if (!kafka_error) {
-    await producerpost_success_log(payload, "PayloadPosted")
+    await app_log.producerpost_success_log(payload, "PayloadPosted")
     res.send('done')
     return
   }
-
   //add auditlog
-  await producerpost_failure_log(payload,kafka_error,'PayloadPostFailed')
-  
+  await app_log.producerpost_failure_log(payload, kafka_error, 'PayloadPostFailed')
   msgValue = {
     ...kafka_error,
     SEQ_ID: seqID,
@@ -66,26 +49,20 @@ app.post('/kafkaevents', async (req, res, next) => {
     console.log("Kafka Message posted successfully to the topic : " + config.topic_error.NAME)
   } else {
     if (config.SLACK.SLACKNOTIFY === 'true') {
-       await postMessage("producer post meesage failed- But usable to post the error in kafka error topic due to errors",  async (response) => {
-           await validateMsgPosted(response.statusCode,response.statusMessage)
+      await slack.postMessage("producer post meesage failed- But usable to post the error in kafka error topic due to errors", async (response) => {
+        await slack.validateMsgPosted(response.statusCode, response.statusMessage)
       });
     }
   }
-
   res.send('error')
-
 })
 
-
 const producer = new Kafka.Producer()
-
 producer.init().then(function () {
     console.log('connected to local kafka server on port 9092 ...');
-
     // start the server
     app.listen(config.PORT);
     console.log('Server started! At http://localhost:' + config.PORT);
-
   } //end producer init
 ).catch(e => {
   console.log('Error : ', e)