feat: add logs

Author: rakibansary

src/app.js

@@ -12,6 +12,7 @@ const helper = require('./common/helper')
 const ProcessorService = require('./services/ProcessorService')
 
 const AWSXRay = require('aws-xray-sdk')
+const segment = new AWSXRay.Segment('legacy-challenge-processor');
 
 // Start kafka consumer
 logger.info('Starting kafka consumer')
@@ -57,7 +58,12 @@ const dataHandler = (messageSet, topic, partition) => Promise.each(messageSet, a
   }
 
   const ns = AWSXRay.getNamespace();
+  console.log('Running within context', ns);
   ns.run(async () => {
+    console.log('creating segment');
+    console.log('created segment');
+    AWSXRay.setSegment(segment);
+    console.log('set segment');
 
     const { traceInformation: {
       traceId,
@@ -69,18 +75,16 @@ const dataHandler = (messageSet, topic, partition) => Promise.each(messageSet, a
 
     console.log('tracing information', traceId, parentSegmentId);
 
-    const segment = new AWSXRay.Segment('legacy-challenge-processor');
-
     if (traceId) {
       segment.trace_id = traceId;
       segment.id = parentSegmentId;
     }
 
-    AWSXRay.setSegment(segment);
 
     // do not trust the message payload
     // the message.payload will be replaced with the data from the API
     try {
+      console.log('Fetch challenge details');
       const challengeUuid = _.get(messageJSON, 'payload.id')
       if (_.isEmpty(challengeUuid)) {
         segment.close();
@@ -98,6 +102,7 @@ const dataHandler = (messageSet, topic, partition) => Promise.each(messageSet, a
     }
 
     try {
+      console.log('Process challenge')
       await ProcessorService.processMessage(messageJSON)
 
       // logger.debug('Successfully processed message')