Process all pureV5 and pureV5Task challenges of any type

Author: ThomasKranitsas

src/app.js

@@ -51,8 +51,8 @@ const dataHandler = (messageSet, topic, partition) => Promise.each(messageSet, a
     return
   }
 
-  if (_.toUpper(_.get(messageJSON.payload, 'type')) !== 'TASK' || _.toUpper(_.get(messageJSON.payload, 'status')) !== 'COMPLETED') {
-    logger.info(`The message type ${_.get(messageJSON.payload, 'type')}, status ${_.get(messageJSON.payload, 'status')} doesn't match {type: 'Task', status: 'Completed'}.`)
+  if (_.toUpper(_.get(messageJSON.payload, 'status')) !== 'COMPLETED') {
+    logger.info(`The message type ${_.get(messageJSON.payload, 'type')}, status ${_.get(messageJSON.payload, 'status')} doesn't match {status: 'Completed'}.`)
 
     // commit the message and ignore it
     await consumer.commitOffset({ topic, partition, offset: m.offset })

src/services/processorService.js

@@ -82,7 +82,7 @@ async function processUpdate(message) {
           const payment = _.assign({
             memberId: checkpointWinnerMembers[i - 1].userId,
             amount: checkpointPrizes[i - 1].value,
-            desc: `Payment - ${message.payload.name} - ${i} Place`,
+            desc: `Checkpoint payment - ${message.payload.name} - ${i} Place`,
             typeId: config.CHECKPOINT_WINNER_PAYMENT_TYPE_ID
           }, basePayment)
 
@@ -113,7 +113,7 @@ async function processUpdate(message) {
         const copilotPayment = _.assign({
           memberId: copilotId,
           amount: copilotAmount,
-          desc: (copilotPaymentDesc ? copilotPaymentDesc : `Task - ${message.payload.name} - Copilot`),
+          desc: (copilotPaymentDesc ? copilotPaymentDesc : `${message.payload.name} - Copilot`),
           typeId: config.COPILOT_PAYMENT_TYPE_ID
         }, basePayment)
         const paymentExists = await paymentService.paymentExists(copilotPayment)