update payment-scheduler-step optional

Author: xxcxy

migrations/2021-06-18-make-payment-scheduler-step-optional.js

@@ -0,0 +1,15 @@
+const config = require('config')
+const _ = require('lodash')
+const { PaymentSchedulerStatus } = require('../app-constants')
+/*
+ * Make Job payment_schedulers step optional.
+ */
+
+module.exports = {
+  up: async (queryInterface, Sequelize) => {
+    await queryInterface.sequelize.query(`ALTER TABLE ${config.DB_SCHEMA_NAME}.payment_schedulers ALTER COLUMN step DROP NOT NULL`)
+  },
+  down: async (queryInterface, Sequelize) => {
+    await queryInterface.sequelize.query(`ALTER TABLE ${config.DB_SCHEMA_NAME}.payment_schedulers ALTER COLUMN step SET NOT NULL`)
+  }
+}

src/models/PaymentScheduler.js

@@ -50,8 +50,7 @@ module.exports = (sequelize) => {
         allowNull: false
       },
       step: {
-        type: Sequelize.ENUM(_.values(PaymentSchedulerStatus)),
-        allowNull: false
+        type: Sequelize.ENUM(_.values(PaymentSchedulerStatus))
       },
       status: {
         type: Sequelize.ENUM(

src/services/PaymentSchedulerService.js

@@ -131,7 +131,7 @@ async function processPayment (workPeriodPayment) {
     await postEvent(config.TAAS_WORK_PERIOD_PAYMENT_UPDATE_TOPIC, updated.toJSON(), { oldValue })
 
     if (paymentScheduler) {
-      await paymentScheduler.update({ step: _.get(err, 'step', PaymentSchedulerStatus.CLOSE_CHALLENGE), userId: paymentScheduler.userId, status: 'failed' })
+      await paymentScheduler.update({ step: _.get(err, 'step'), userId: paymentScheduler.userId, status: 'failed' })
     }
     localLogger.error(`Processed workPeriodPayment ${workPeriodPayment.id} failed`, 'processPayment')
     return processResult.FAIL