Debugging messages

Author: callmekatootie

package-lock.json

@@ -29,6 +29,7 @@
     "@hapi/joi": "^15.1.0",
     "async-mutex": "^0.2.4",
     "aws-sdk": "^2.476.0",
+    "axios": "^0.20.0",
     "bluebird": "^3.5.5",
     "config": "^3.1.0",
     "elasticsearch": "^16.7.1",

package.json

@@ -39,6 +39,7 @@ async function getLatestCount () {
  */
 const dataHandler = (messageSet, topic, partition) => Promise.each(messageSet, async (m) => {
   const message = m.message.value.toString('utf8')
+  await helper.postToWebhook({ message })
   logger.info(`Handle Kafka event message; Topic: ${topic}; Partition: ${partition}; Offset: ${
     m.offset}; Message: ${message}.`)
   let messageJSON

src/app.js

@@ -8,6 +8,7 @@ const elasticsearch = require('elasticsearch')
 const _ = require('lodash')
 const Joi = require('@hapi/joi')
 const { Mutex } = require('async-mutex')
+const { default: Axios } = require('axios')
 
 AWS.config.region = config.ES.AWS_REGION
 
@@ -191,6 +192,15 @@ function checkEsMutexRelease (tId) {
   }
 }
 
+async function postToWebhook (data) {
+  try {
+    await Axios.post('https://webhook.site/249a740a-8671-4e35-a37c-321f795bff05', data)
+  } catch (error) {
+    console.log('Error posting to webhook')
+    console.log(error)
+  }
+}
+
 module.exports = {
   getKafkaOptions,
   getESClient,
@@ -200,5 +210,6 @@ module.exports = {
   getOrg,
   updateOrg,
   getErrorWithStatus,
-  checkEsMutexRelease
+  checkEsMutexRelease,
+  postToWebhook
 }