fix: generate payments for topcrowd challenges

Signed-off-by: Rakib Ansary <[email protected]>

Author: rakibansary

.circleci/config.yml

@@ -1,19 +1,15 @@
 version: 2
 defaults: &defaults
   docker:
-  - image: cimg/python:3.11.0-browsers
+  - image: cimg/python:3.12.1-browsers
 install_dependency: &install_dependency
   name: Installation of build and deployment dependencies.
   command: |
-    sudo apt update
-    sudo apt install jq
-    sudo apt install python3-pip
-    sudo pip3 install awscli --upgrade
-    sudo pip3 install docker-compose
+    pip3 install awscli --upgrade
 install_deploysuite: &install_deploysuite
   name: Installation of install_deploysuite.
   command: |
-    git clone --branch v1.4.15 https://github.com/topcoder-platform/tc-deploy-scripts ../buildscript
+    git clone --branch v1.4.17 https://github.com/topcoder-platform/tc-deploy-scripts ../buildscript
     cp ./../buildscript/master_deploy.sh .
     cp ./../buildscript/buildenv.sh .
     cp ./../buildscript/awsconfiguration.sh .
@@ -23,38 +19,38 @@ restore_cache_settings_for_build: &restore_cache_settings_for_build
 save_cache_settings: &save_cache_settings
   key: docker-node-modules-{{ checksum "package-lock.json" }}
   paths:
-    - node_modules
+  - node_modules
 
 builddeploy_steps: &builddeploy_steps
-      - checkout
-      - setup_remote_docker
-      - run: *install_dependency
-      - run: *install_deploysuite
-      - restore_cache: *restore_cache_settings_for_build
-      - run: ./build.sh ${APPNAME}
-      - save_cache: *save_cache_settings
-      - deploy:
-          name: Running MasterScript.
-          command: |
-            ./awsconfiguration.sh $DEPLOY_ENV
-            source awsenvconf
-            ./buildenv.sh -e $DEPLOY_ENV -b ${LOGICAL_ENV}-${APPNAME}-deployvar
-            source buildenvvar
-            ./master_deploy.sh -d ECS -e $DEPLOY_ENV -t latest -s ${LOGICAL_ENV}-global-appvar,${LOGICAL_ENV}-global-informix-appvar,${LOGICAL_ENV}-${APPNAME}-appvar -i ${APPNAME}
+- checkout
+- setup_remote_docker
+- run: *install_dependency
+- run: *install_deploysuite
+- restore_cache: *restore_cache_settings_for_build
+- run: ./build.sh ${APPNAME}
+- save_cache: *save_cache_settings
+- deploy:
+    name: Running MasterScript.
+    command: |
+      ./awsconfiguration.sh $DEPLOY_ENV
+      source awsenvconf
+      ./buildenv.sh -e $DEPLOY_ENV -b ${LOGICAL_ENV}-${APPNAME}-deployvar
+      source buildenvvar
+      ./master_deploy.sh -d ECS -e $DEPLOY_ENV -t latest -s ${LOGICAL_ENV}-global-appvar,${LOGICAL_ENV}-global-informix-appvar,${LOGICAL_ENV}-${APPNAME}-appvar -i ${APPNAME}
 
 
 jobs:
   # Build & Deploy against development backend
   "build-dev":
-    <<: *defaults
+    !!merge <<: *defaults
     environment:
       DEPLOY_ENV: "DEV"
       LOGICAL_ENV: "dev"
       APPNAME: "legacy-payment-processor"
     steps: *builddeploy_steps
 
   "build-prod":
-    <<: *defaults
+    !!merge <<: *defaults
     environment:
       DEPLOY_ENV: "PROD"
       LOGICAL_ENV: "prod"
@@ -65,18 +61,19 @@ workflows:
   version: 2
   build:
     jobs:
-      # Development builds are executed on "develop" branch only.
-      - "build-dev":
-          context : org-global
-          filters:
-            branches:
-              only:
-                - develop
+    # Development builds are executed on "develop" branch only.
+    - "build-dev":
+        context: org-global
+        filters:
+          branches:
+            only:
+            - develop
+            - TOPCROWD-PAYMENTS-FIX
 
-      # Production builds are exectuted only on tagged commits to the
-      # master branch.
-      - "build-prod":
-          context : org-global
-          filters:
-            branches:
-              only: master
+    # Production builds are exectuted only on tagged commits to the
+    # master branch.
+    - "build-prod":
+        context: org-global
+        filters:
+          branches:
+            only: master

config/default.js

@@ -51,5 +51,6 @@ module.exports = {
   PAYMENT_METHOD_ID: process.env.PAYMENT_METHOD_ID || 1,
   CHARITY_IND: process.env.CHARITY_IND || 0,
   INSTALLMENT_NUMBER: process.env.INSTALLMENT_NUMBER || 1,
-  COPILOT_ROLE_ID: process.env.COPILOT_ROLE_ID || 'cfe12b3f-2a24-4639-9d8b-ec86726f76bd'
+  COPILOT_ROLE_ID: process.env.COPILOT_ROLE_ID || 'cfe12b3f-2a24-4639-9d8b-ec86726f76bd',
+  TOPCROWD_CHALLENGE_TEMPLATE_ID: "517e76b0-8824-4e72-9b48-a1ebde1793a8"
 }

src/app.js

@@ -44,9 +44,11 @@ const dataHandler = (messageSet, topic, partition) => Promise.each(messageSet, a
     return
   }
 
+  const timelineTemplateId = _.get(messageJSON.payload, 'timelineTemplateId');
+
   // Currently only process payments for challenges with `legacy.pureV5Task: true` or `legacy.pureV5: true`
-  if (!_.get(messageJSON.payload, 'legacy.pureV5Task', false) && !_.get(messageJSON.payload, 'legacy.pureV5', false)) {
-    logger.info(`Challenge Legacy Object ${JSON.stringify(_.get(messageJSON.payload, 'legacy'))} does not have legacy.pureV5Task: true or legacy.pureV5: true`)
+  if (!_.get(messageJSON.payload, 'legacy.pureV5Task', false) && !_.get(messageJSON.payload, 'legacy.pureV5', false) && timelineTemplateId != config.get('TOPCROWD_CHALLENGE_TEMPLATE_ID')) {
+    logger.info(`Challenge Legacy Object ${JSON.stringify(_.get(messageJSON.payload, 'legacy'))} does not have legacy.pureV5Task: true or legacy.pureV5: true or timelineTemplateId: ${timelineTemplateId}.`)
     await consumer.commitOffset({ topic, partition, offset: m.offset })
     return
   }

src/services/processorService.js

@@ -18,6 +18,7 @@ async function processUpdate(message) {
   const createUserId = await helper.getUserId(message.payload.createdBy)
   const legacyId = _.get(message, 'payload.legacyId', null)
   const v5ChallengeId = _.get(message, 'payload.id', null)
+  const timelineTemplateId = _.get(message.payload, 'timelineTemplateId')
 
   if (!v5ChallengeId || v5ChallengeId === '') {
     logger.error('Payload of challenge does not contain a v5 Challenge UUID')
@@ -47,7 +48,23 @@ async function processUpdate(message) {
     const checkpointWinnerMembers = _.sortBy(_.filter(_.get(message.payload, 'winners', []), w => w.type === 'checkpoint'), ['placement'])
     if (_.isEmpty(winnerPrizes)) {
       logger.warn(`For challenge ${v5ChallengeId}, no winner payment avaiable`)
-    } else if (winnerPrizes.length !== winnerMembers.length) {
+    } else if (timelineTemplateId == config.get('TOPCROWD_CHALLENGE_TEMPLATE_ID')) {
+      try {
+        for (let i = 0; i < winnerMembers.length; i++) {
+          const payment = _.assign({
+            memberId: winnerMembers[i].userId,
+            amount: winnerPrizes[i].value,
+            desc: `Payment - ${message.payload.name} - ${winnerMembers[i].placement} Place`,
+            typeId: config.WINNER_PAYMENT_TYPE_ID
+          }, basePayment)
+
+          logger.info(`TopCrowd Challenge winner ${payment.memberId} payment object details: ` + JSON.stringify(payment))
+          await paymentService.createPayment(payment)
+        }
+      } catch (error) {
+        logger.error(`For challenge ${v5ChallengeId}, add winner payments error: ${error}`)
+      }
+    }else if (winnerPrizes.length !== winnerMembers.length) {
       logger.error(`For challenge ${v5ChallengeId}, there is ${winnerPrizes.length} user prizes but ${winnerMembers.length} winners`)
     } else {
       try {