Merge branch 'fix/payments-logs' into stage

Author: TatianaFomina

src/billing/cloudpayments.ts

@@ -25,7 +25,6 @@ import {
   PlanDBScheme,
   PlanProlongationPayload
 } from '@hawk.so/types';
-import { PENNY_MULTIPLIER } from 'codex-accounting-sdk';
 import WorkspaceModel from '../models/workspace';
 import HawkCatcher from '@hawk.so/nodejs';
 import { publish } from '../rabbitmq';
@@ -45,6 +44,8 @@ import PlanModel from '../models/plan';
 import { ClientApi, ClientService, CustomerReceiptItem, ReceiptApi, ReceiptTypes, TaxationSystem } from 'cloudpayments';
 import { ComposePaymentPayload } from './types/composePaymentPayload';
 
+const PENNY_MULTIPLIER = 100;
+
 interface ComposePaymentRequest extends express.Request {
   query: ComposePaymentPayload & { [key: string]: any };
   context: import('../types/graphql').ResolverContextBase;
@@ -105,7 +106,12 @@ export default class CloudPaymentsWebhooks {
     const userId = req.context.user.id;
 
     if (!workspaceId || !tariffPlanId || !userId) {
-      this.sendError(res, 1, `[Billing / Compose payment] No workspace, tariff plan or user id in request body`, req.query);
+      this.sendError(res, 1, `[Billing / Compose payment] No workspace, tariff plan or user id in request body
+Details:
+workspaceId: ${workspaceId}
+tariffPlanId: ${tariffPlanId}
+userId: ${userId}`
+      , req.query);
 
       return;
     }
@@ -137,18 +143,33 @@ export default class CloudPaymentsWebhooks {
 
     const isCardLinkOperation = workspace.tariffPlanId.toString() === tariffPlanId && !workspace.isTariffPlanExpired();
 
+    // Calculate next payment date
+    const lastChargeDate = new Date(workspace.lastChargeDate);
+    const now = new Date();
+    let nextPaymentDate: Date;
+
+    if (isCardLinkOperation) {
+      nextPaymentDate = new Date(lastChargeDate);
+      nextPaymentDate.setMonth(lastChargeDate.getMonth() + 1);
+    } else {
+      nextPaymentDate = new Date(now);
+      nextPaymentDate.setMonth(nextPaymentDate.getMonth() + 1);
+    }
+
     let checksum;
 
     try {
       const checksumData = isCardLinkOperation ? {
         isCardLinkOperation: true,
         workspaceId: workspace._id.toString(),
         userId: userId,
+        nextPaymentDate: nextPaymentDate.toISOString(),
       } : {
         workspaceId: workspace._id.toString(),
         userId: userId,
         tariffPlanId: tariffPlan._id.toString(),
         shouldSaveCard: shouldSaveCard === 'true',
+        nextPaymentDate: nextPaymentDate.toISOString(),
       };
 
       checksum = await checksumService.generateChecksum(checksumData);
@@ -170,6 +191,7 @@ export default class CloudPaymentsWebhooks {
       isCardLinkOperation,
       currency: 'RUB',
       checksum,
+      nextPaymentDate: nextPaymentDate.toISOString(),
     });
   }
 
@@ -478,8 +500,6 @@ export default class CloudPaymentsWebhooks {
        * Refund the money that were charged to link a card
        */
       if (data.isCardLinkOperation) {
-        this.handleSendingToTelegramError(telegram.sendMessage(`✅ [Billing / Pay] Recurrent payments activated for «${workspace.name}». 1 RUB charged`, TelegramBotURLs.Money));
-
         await cloudPaymentsApi.cancelPayment(body.TransactionId);
 
         const member = await this.getMember(data.userId, workspace);
@@ -502,7 +522,13 @@ export default class CloudPaymentsWebhooks {
           dtCreated: new Date(),
         });
 
-        this.handleSendingToTelegramError(telegram.sendMessage(`✅ [Billing / Pay] Recurrent payments activated for «${workspace.name}». 1 RUB returned`, TelegramBotURLs.Money));
+        this.handleSendingToTelegramError(telegram.sendMessage(`✅ [Billing / Pay] Card linked
+Transaction details:
+workspace id: ${workspace._id}
+date of operation: ${body.DateTime}
+first payment date: ${data.cloudPayments?.recurrent.startDate}
+sum: ${data.cloudPayments?.recurrent.amount}${body.Currency}`
+        , TelegramBotURLs.Money));
       } else {
         /**
          * Russia code from ISO 3166-1
@@ -516,7 +542,15 @@ export default class CloudPaymentsWebhooks {
 
         await this.sendReceipt(workspace, tariffPlan, userEmail);
 
-        this.handleSendingToTelegramError(telegram.sendMessage(`✅ [Billing / Pay] Payment passed successfully for «${workspace.name}»`, TelegramBotURLs.Money));
+        this.handleSendingToTelegramError(telegram.sendMessage(`✅ [Billing / Pay] New payment
+Transaction details:
+amount: ${+body.Amount * PENNY_MULTIPLIER}
+currency: ${body.Currency}
+next payment date: ${data.cloudPayments?.recurrent.startDate}
+workspace id: ${workspace._id}
+date of operation: ${body.DateTime}
+subscription id: ${body.SubscriptionId}`
+        , TelegramBotURLs.Money));
       }
     } catch (e) {
       const error = e as Error;
@@ -606,7 +640,7 @@ export default class CloudPaymentsWebhooks {
       return;
     }
 
-    this.handleSendingToTelegramError(telegram.sendMessage(`✅ [Billing / Fail] Transaction failed for «${workspace.name}»`, TelegramBotURLs.Money));
+    this.handleSendingToTelegramError(telegram.sendMessage(`❌ [Billing / Fail] Transaction failed for «${workspace.name}»`, TelegramBotURLs.Money));
 
     HawkCatcher.send(new Error('[Billing / Fail] Transaction failed'), body as any);
 
@@ -628,7 +662,14 @@ export default class CloudPaymentsWebhooks {
 
     console.log('💎 CloudPayments /recurrent request', body);
 
-    this.handleSendingToTelegramError(telegram.sendMessage(`[Billing / Recurrent] New recurrent event with ${body.Status} status`, TelegramBotURLs.Money));
+    this.handleSendingToTelegramError(telegram.sendMessage(`✅ [Billing / Recurrent] New recurrent transaction
+      Transaction details:
+      amount: ${+body.Amount * PENNY_MULTIPLIER}
+      currency: ${body.Currency}
+      next payment date: ${body.NextTransactionDate}
+      workspace id: ${body.AccountId}
+      subscription id: ${body.Id}`
+    , TelegramBotURLs.Money));
     HawkCatcher.send(new Error(`[Billing / Recurrent] New recurrent event with ${body.Status} status`), req.body);
 
     switch (body.Status) {

src/utils/checksumService.ts

@@ -20,6 +20,10 @@ interface PlanPurchaseChecksumData {
    * If true, we will save user card
    */
   shouldSaveCard: boolean;
+  /**
+   * Next payment date
+   */
+  nextPaymentDate: string;
 }
 
 interface CardLinkChecksumData {
@@ -35,6 +39,10 @@ interface CardLinkChecksumData {
    * True if this is card linking operation – charging minimal amount of money to validate card info
    */
   isCardLinkOperation: boolean;
+  /**
+   * Next payment date
+   */
+  nextPaymentDate: string;
 }
 
 /**
@@ -67,13 +75,15 @@ class ChecksumService {
         workspaceId: payload.workspaceId,
         userId: payload.userId,
         isCardLinkOperation: payload.isCardLinkOperation,
+        nextPaymentDate: payload.nextPaymentDate,
       };
     } else {
       return {
         workspaceId: payload.workspaceId,
         userId: payload.userId,
         tariffPlanId: payload.tariffPlanId,
         shouldSaveCard: payload.shouldSaveCard,
+        nextPaymentDate: payload.nextPaymentDate,
       };
     }
   }