DASH-150 add payments job to check payment statuses from stripe and u…

…pdate order status

package.json

@@ -15,7 +15,7 @@
     "lint": "eslint ./server/src ./client/src --ext js,mjs,ts,tsx",
     "lint:fix": "eslint ./server/src ./client/src --ext js,mjs,ts,tsx --fix",
     "server:prod": "npm run migrate && node --es-module-specifier-resolution=node server/src/index.mjs",
-    "scheduler": "JOB_LIST=emails,orders,txCheck,wrapStatus node --es-module-specifier-resolution=node server/src/scheduler.mjs",
+    "scheduler": "JOB_LIST=emails,orders,txCheck,wrapStatus,payments node --es-module-specifier-resolution=node server/src/scheduler.mjs",
     "scheduler:wallet-data": "JOB_LIST=walletData node --es-module-specifier-resolution=node server/src/scheduler.mjs",
     "scheduler:wrap-status": "JOB_LIST=wrapStatus node --es-module-specifier-resolution=node server/src/scheduler.mjs",
     "migrate": "sequelize db:migrate",

server/src/external/payment-processor/stripe.mjs

@@ -30,10 +30,6 @@ const STRIPE_USER_AGENT = 'Stripe/1.0';
 
 const stripe = new StripeLib(process.env.STRIPE_SECRET);
 class Stripe extends PaymentProcessor {
-  constructor() {
-    super();
-  }
-
   isWebhook(hostname, userAgent) {
     const checkRegex = new RegExp(`${STRIPE_USER_AGENT}`, 'i');
     return checkRegex.exec(userAgent);
@@ -239,6 +235,10 @@ class Stripe extends PaymentProcessor {
 
     return stripe.refunds.create(refundOptions);
   }
+
+  async retrieveIntent(id) {
+    return await stripe.paymentIntents.retrieve(id);
+  }
 }
 
 export default new Stripe();

server/src/jobs/emails.mjs

@@ -26,10 +26,6 @@ const CONTENT_TYPE_EMAIL_TEMPLATE_MAP = {
 const OPT_IN_STATUS_SYNCED = 'OPT_IN_STATUS_SYNCED';
 
 class EmailsJob extends CommonJob {
-  constructor() {
-    super();
-  }
-
   async allowToSendBalanceChangedEmail(notification) {
     const { id, userId, createdAt, data } = notification;
 

server/src/jobs/payments.mjs

@@ -0,0 +1,75 @@
+import CommonJob from './job.mjs';
+
+import Stripe from '../external/payment-processor/stripe.mjs';
+
+import logger from '../logger.mjs';
+
+import { Order, Payment, OrderItem, OrderItemStatus } from '../models';
+
+// https://stripe.com/docs/payments/intents#intent-statuses
+const STRIPE_INTENT_SUCCESS = 'succeeded';
+
+class PaymentsJob extends CommonJob {
+  async execute() {
+    const orders = await Order.findAll({
+      where: {
+        status: Order.STATUS.PAYMENT_PENDING,
+      },
+      include: [OrderItem, Payment],
+    });
+
+    const t = await Order.sequelize.transaction();
+
+    try {
+      for (const order of orders) {
+        const payments = await order.getPayments({
+          where: { processor: Payment.PROCESSOR.STRIPE },
+        });
+        const paymentStatuses = [];
+        for (const payment of payments) {
+          const orderItemStatus = await OrderItemStatus.findOne({
+            where: {
+              paymentId: payment.id,
+            },
+            transaction: t,
+          });
+
+          const intentId = payment.externalId;
+          const intent = await Stripe.retrieveIntent(intentId);
+          paymentStatuses.push(intent.status);
+          if (intent.status === STRIPE_INTENT_SUCCESS) {
+            await payment.update(
+              { status: Payment.STATUS.COMPLETED },
+              { transaction: t },
+            );
+            await orderItemStatus.update(
+              { paymentStatus: Payment.STATUS.COMPLETED },
+              { transaction: t },
+            );
+          } else {
+            await payment.update({ status: Payment.STATUS.FAILED }, { transaction: t });
+            await orderItemStatus.update(
+              { paymentStatus: Payment.STATUS.FAILED },
+              { transaction: t },
+            );
+          }
+        }
+
+        const allSucceeded = paymentStatuses.some(
+          status => status === STRIPE_INTENT_SUCCESS,
+        );
+        if (allSucceeded) {
+          await order.update({ status: Order.STATUS.SUCCESS }, { transaction: t });
+        } else {
+          await order.update({ status: Order.STATUS.FAILED }, { transaction: t });
+        }
+      }
+      await t.commit();
+    } catch (error) {
+      logger.error(`Update transaction failed error: ${error.message}`);
+      await t.rollback();
+    }
+  }
+}
+
+new PaymentsJob().execute();

server/src/jobs/tx-check.mjs

@@ -17,10 +17,6 @@ import logger from '../logger.mjs';
 const MAX_CHECK_TIMES = 10;
 
 class TxCheckJob extends CommonJob {
-  constructor() {
-    super();
-  }
-
   async execute() {
     await fioApi.getRawAbi();
 

server/src/jobs/wallet-data.mjs

@@ -44,10 +44,6 @@ const returnDayRange = timePeriod => {
 };
 
 class WalletDataJob extends CommonJob {
-  constructor() {
-    super();
-  }
-
   logFioError(e, wallet, action = '-') {
     if (e && e.errorCode !== 404) {
       if (wallet && wallet.id)

server/src/jobs/wrap-status.mjs

@@ -34,10 +34,6 @@ const WRAPPED_TOKEN_ABI = JSON.parse(
 const UNWRAP_RETRIES_LIMIT = 3;
 
 class WrapStatusJob extends CommonJob {
-  constructor() {
-    super();
-  }
-
   handleErrorMessage(message) {
     // eslint-disable-next-line no-console
     console.log(message);

server/src/migrations/20230124150753-create-fio-api-urls-table.js

@@ -14,6 +14,7 @@ module.exports = {
       },
       createdAt: { type: DT.DATE },
       updatedAt: { type: DT.DATE },
+      deletedAt: { type: DT.DATE },
     });
 
     return QI.sequelize.query(

server/src/scheduler.mjs

@@ -47,6 +47,14 @@ const availableJobsParams = {
     closeWorkerAfterMs:
       parseInt(process.env.WRAP_STATUS_JOB_CLOSE_TIMEOUT) || 60 * 60 * 1000, // 60 min
   },
+  payments: {
+    path: path.join(JOBS_PATH, 'payments.mjs'),
+    name: 'payments',
+    interval: process.env.PAYMENTS_JOB_INTERVAL || 30 * 1000, // 30 sec
+    timeout: 0,
+    closeWorkerAfterMs:
+      parseInt(process.env.PAYMENTS_JOB_CLOSE_TIMEOUT) || 60 * 60 * 1000, // 60 min
+  },
 };
 
 const jobsToLaunch = process.env.JOB_LIST;