Temporary disabling the pausing feature as there is chance of losing message during unsubscribe/posing due to using simple Kafka consumer. Also adding linting support.

Author: Sachin Maheshwari

.eslintrc

@@ -0,0 +1,3 @@
+"parserOptions": {
+   "ecmaVersion": 6
+ }

Dockerfile

@@ -9,5 +9,5 @@ WORKDIR /opt/app
 COPY . .
 RUN npm install
 RUN npm install dotenv --save
-#RUN npm test
+RUN npm run lint
 CMD ["npm", "start"]

config/default.js

@@ -33,8 +33,11 @@ module.exports = {
   TEMPLATE_MAP: process.env.TEMPLATE_MAP,
   SENDGRID_API_KEY: process.env.SENDGRID_API_KEY || '',
   EMAIL_FROM: process.env.EMAIL_FROM || 'no-reply@topcoder.com',
+  
+  // temporary not in use feature
   EMAIL_MAX_ERRORS: process.env.EMAIL_MAX_ERRORS || 2,
   EMAIL_PAUSE_TIME: process.env.EMAIL_PAUSE_TIME || 30,
+
   //in every 2 minutes will retry for failed status
   EMAIL_RETRY_SCHEDULE: process.env.EMAIL_RETRY_SCHEDULE || '0 */2 * * * *',
 };

src/app.js

@@ -76,9 +76,14 @@ function configureKafkaConsumer(handlers) {
         emailModel.status = 'SUCCESS';
         return emailModel.save();
       } else {
-        emailTries[topicName] += 1;
+        // emailTries[topicName] += 1; //temporary disabling this feature 
         emailModel.status = 'FAILED';
         return emailModel.save().then(() => {
+	 /* 
+	  * temporary disabling this feature as there is chance of losing message during
+	  * unsubscribe/pausing due to simple kafka consumer
+         */ 	
+	  /*	
           const currentTries = emailTries[topicName];
           if (currentTries > maxErrors) {
             logger.debug(`Failed to send email. Will sleep for ${pauseTime}s`);
@@ -94,7 +99,7 @@ function configureKafkaConsumer(handlers) {
           } else {
             logger.debug(`Failed to send email (retries left ${maxErrors - currentTries})`);
             throw result.error;
-          }
+          }*/ 
         });
       }
     }).then(() => consumer.commitOffset({ topic, partition, offset: m.offset })) // commit offset