Notification method change

Author: Gunasekar-K

.circleci/config.yml

@@ -44,15 +44,15 @@ builddeploy_steps: &builddeploy_steps
             # # notify deployment
             # rm -rf buildenvvar
             # ./unsetenv.sh            
-            ./buildenv.sh -e $DEPLOY_ENV -b ${LOGICAL_ENV}-${APPNAME}-notify-deployvar
-            source buildenvvar            
-            ./master_deploy.sh -d ECS -e $DEPLOY_ENV -t latest -s ${LOGICAL_ENV}-global-appvar,${LOGICAL_ENV}-${APPNAME}-notify-appvar -i ${APPNAME}            
+            # ./buildenv.sh -e $DEPLOY_ENV -b ${LOGICAL_ENV}-${APPNAME}-notify-deployvar
+            # source buildenvvar            
+            # ./master_deploy.sh -d ECS -e $DEPLOY_ENV -t latest -s ${LOGICAL_ENV}-global-appvar,${LOGICAL_ENV}-${APPNAME}-notify-appvar -i ${APPNAME}            
             # # consumer deployment
             # rm -rf buildenvvar
             # ./unsetenv.sh
-            # ./buildenv.sh -e $DEPLOY_ENV -b ${LOGICAL_ENV}-${APPNAME}-consumer-deployvar
-            # source buildenvvar            
-            # ./master_deploy.sh -d ECS -e $DEPLOY_ENV -t latest -s ${LOGICAL_ENV}-global-appvar,${LOGICAL_ENV}-${APPNAME}-appvar -i ${APPNAME}
+            ./buildenv.sh -e $DEPLOY_ENV -b ${LOGICAL_ENV}-${APPNAME}-consumer-deployvar
+            source buildenvvar            
+            ./master_deploy.sh -d ECS -e $DEPLOY_ENV -t latest -s ${LOGICAL_ENV}-global-appvar,${LOGICAL_ENV}-${APPNAME}-appvar -i ${APPNAME}
             # # without kafka dynamodb
             # rm -rf buildenvvar
             # ./unsetenv.sh

src/consumer.js

@@ -112,7 +112,8 @@ async function dataHandler(messageSet, topic, partition) {
       if (reconcile_flag != 0) {
         msgValue.msginfo = `Reconcile failed. \n` +
           `DB Operation: ${payload.OPERATION} \n ` +
-          `Error code : ${msgValue.code}`
+          `Error code : ${msgValue.code} \n` +
+          `Error Detail : ${msgValue.detail}`
         logger.debug('Reconcile failed, sending it to error queue: ', config.topic_error.NAME);
         kafka_error = await pushToKafka(producer, config.topic_error.NAME, msgValue)
         if (!kafka_error) {
@@ -122,7 +123,8 @@ async function dataHandler(messageSet, topic, partition) {
           `SequnceId : ${payload.SEQ_ID} \n` +
           `Status : Reconcile failed. Also unable to post the info in kafka error topic channel due to errors \n` +
           `DB Operation: ${payload.OPERATION} \n ` +
-          `Error code : ${msgValue.code}`
+          `Error code : ${msgValue.code} \n` +
+          `Error Detail : ${msgValue.detail}`
           notify_msg = "consumer_reconcile post fails - unable to post the error in kafka failure topic due to some errors"
           await slack.send_msg_to_slack(notify_msg);
         }
@@ -141,7 +143,8 @@ async function dataHandler(messageSet, topic, partition) {
         logger.debug('Reached at max retry counter, sending it to error queue: ', config.topic_error.NAME);
         msgValue.msginfo = `Max Retry Reached. \n` +
           `DB Operation: ${payload.OPERATION} \n ` +
-          `Error code : ${msgValue.code}`        
+          `Error code : ${msgValue.code} \n` +
+          `Error Detail : ${msgValue.detail}`       
         kafka_error = await pushToKafka(producer, config.topic_error.NAME, msgValue)
         if (!kafka_error) {
           logger.info("Kafka Message posted successfully to the topic : " + config.topic_error.NAME)
@@ -150,7 +153,8 @@ async function dataHandler(messageSet, topic, partition) {
           `SequnceId : ${payload.SEQ_ID} \n` +
           `Status : Max Retry Reached. Also unable to post the info in kafka error topic channel due to errors \n` +
           `DB Operation: ${payload.OPERATION} \n ` +
-          `Error code : ${msgValue.code}`
+          `Error code : ${msgValue.code} \n` +
+          `Error Detail : ${msgValue.detail}`
           await slack.send_msg_to_slack(notify_msg);
         }
       } else {