Merge branch 'master' into update-notification-rule-types

Author: e11sy

package.json

@@ -1,6 +1,6 @@
 {
   "name": "hawk.api",
-  "version": "1.1.7",
+  "version": "1.1.10",
   "main": "index.ts",
   "license": "UNLICENSED",
   "scripts": {

src/billing/cloudpayments.ts

@@ -43,11 +43,12 @@ import { PaymentData } from './types/paymentData';
 import cloudPaymentsApi from '../utils/cloudPaymentsApi';
 import PlanModel from '../models/plan';
 import { ClientApi, ClientService, CustomerReceiptItem, ReceiptApi, ReceiptTypes, TaxationSystem } from 'cloudpayments';
+import { ComposePaymentPayload } from './types/composePaymentPayload';
 
-/**
- * Custom data of the plan prolongation request
- */
-type PlanProlongationData = PlanProlongationPayload & PaymentData;
+interface ComposePaymentRequest extends express.Request {
+  query: ComposePaymentPayload & { [key: string]: any };
+  context: import('../types/graphql').ResolverContextBase;
+};
 
 /**
  * Class for describing the logic of payment routes
@@ -99,8 +100,8 @@ export default class CloudPaymentsWebhooks {
    * @param req — Express request object
    * @param res - Express response object
    */
-  private async composePayment(req: express.Request, res: express.Response): Promise<void> {
-    const { workspaceId, tariffPlanId, shouldSaveCard } = req.query as Record<string, string>;
+  private async composePayment(req: ComposePaymentRequest, res: express.Response): Promise<void> {
+    const { workspaceId, tariffPlanId, shouldSaveCard } = req.query;
     const userId = req.context.user.id;
 
     if (!workspaceId || !tariffPlanId || !userId) {
@@ -134,15 +135,23 @@ export default class CloudPaymentsWebhooks {
     }
     const invoiceId = this.generateInvoiceId(tariffPlan, workspace);
 
+    const isCardLinkOperation = workspace.tariffPlanId.toString() === tariffPlanId && !this.isPlanExpired(workspace);
+
     let checksum;
 
     try {
-      checksum = await checksumService.generateChecksum({
+      const checksumData = isCardLinkOperation ? {
+        isCardLinkOperation: true,
+        workspaceId: workspace._id.toString(),
+        userId: userId,
+      } : {
         workspaceId: workspace._id.toString(),
         userId: userId,
         tariffPlanId: tariffPlan._id.toString(),
         shouldSaveCard: shouldSaveCard === 'true',
-      });
+      };
+
+      checksum = await checksumService.generateChecksum(checksumData);
     } catch (e) {
       const error = e as Error;
 
@@ -158,11 +167,32 @@ export default class CloudPaymentsWebhooks {
         name: tariffPlan.name,
         monthlyCharge: tariffPlan.monthlyCharge,
       },
+      isCardLinkOperation,
       currency: 'RUB',
       checksum,
     });
   }
 
+  /**
+   * Returns true if workspace's plan is expired
+   * @param workspace - workspace to check
+   */
+  private isPlanExpired(workspace: WorkspaceModel): boolean {
+    const lastChargeDate = new Date(workspace.lastChargeDate);
+
+    let planExpiracyDate;
+
+    if (workspace.isDebug) {
+      planExpiracyDate = lastChargeDate.setDate(lastChargeDate.getDate() + 1);
+    } else {
+      planExpiracyDate = lastChargeDate.setMonth(lastChargeDate.getMonth() + 1);
+    }
+
+    const isPlanExpired = planExpiracyDate < Date.now();
+
+    return isPlanExpired;
+  }
+
   /**
    * Generates invoice id for payment
    *
@@ -175,6 +205,36 @@ export default class CloudPaymentsWebhooks {
     return `${workspace.name} ${now.getDate()}/${now.getMonth() + 1} ${tariffPlan.name}`;
   }
 
+  /**
+   * Confirms the correctness of a user's payment for card linking
+   * @param req - express request
+   * @param res - express response
+   * @param data - payment data receinved from checksum and request payload
+   */
+  private async checkCardLinkOperation(req: express.Request, res: express.Response, data: PaymentData): Promise<void> {
+    if (data.isCardLinkOperation && (!data.userId || !data.workspaceId)) {
+      this.sendError(res, CheckCodes.PAYMENT_COULD_NOT_BE_ACCEPTED, '[Billing / Check] Card linking – invalid data', req.body);
+
+      return;
+    }
+
+    try {
+      const workspace = await this.getWorkspace(req, data.workspaceId);
+
+      telegram
+        .sendMessage(`✅ [Billing / Check] Card linked for subscription workspace «${workspace.name}»`, TelegramBotURLs.Money)
+        .catch(e => console.error('Error while sending message to Telegram: ' + e));
+
+      res.json({
+        code: CheckCodes.SUCCESS,
+      } as CheckResponse);
+    } catch (e) {
+      const error = e as Error;
+
+      this.sendError(res, CheckCodes.PAYMENT_COULD_NOT_BE_ACCEPTED, `[Billing / Check] ${error.toString()}`, req.body);
+    }
+  }
+
   /**
    * Route to confirm the correctness of a user's payment
    * https://developers.cloudpayments.ru/#check
@@ -197,11 +257,17 @@ export default class CloudPaymentsWebhooks {
       return;
     }
 
+    if (data.isCardLinkOperation) {
+      this.checkCardLinkOperation(req, res, data);
+
+      return;
+    }
+
     let workspace: WorkspaceModel;
     let member: ConfirmedMemberDBScheme;
     let plan: PlanDBScheme;
 
-    if (!data.workspaceId || !data.tariffPlanId || !data.userId) {
+    if (!data.userId || !data.workspaceId || !data.tariffPlanId) {
       this.sendError(res, CheckCodes.PAYMENT_COULD_NOT_BE_ACCEPTED, '[Billing / Check] There is no necessary data in the request', body);
 
       return;
@@ -266,6 +332,7 @@ export default class CloudPaymentsWebhooks {
 
     telegram.sendMessage(`✅ [Billing / Check] All checks passed successfully «${workspace.name}»`, TelegramBotURLs.Money)
       .catch(e => console.error('Error while sending message to Telegram: ' + e));
+
     HawkCatcher.send(new Error('[Billing / Check] All checks passed successfully'), body as any);
 
     res.json({
@@ -294,7 +361,13 @@ export default class CloudPaymentsWebhooks {
       return;
     }
 
-    if (!data.workspaceId || !data.tariffPlanId || !data.userId) {
+    if (data.isCardLinkOperation && (!data.userId || !data.workspaceId)) {
+      this.sendError(res, PayCodes.SUCCESS, '[Billing / Pay] No workspace or user id in request body', req.body);
+
+      return;
+    }
+
+    if (!data.isCardLinkOperation && (!data.workspaceId || !data.tariffPlanId || !data.userId)) {
       this.sendError(res, PayCodes.SUCCESS, `[Billing / Pay] No workspace, tariff plan or user id in request body`, body);
 
       return;
@@ -304,12 +377,15 @@ export default class CloudPaymentsWebhooks {
     let workspace;
     let tariffPlan;
     let user;
+    let planId;
 
     try {
       businessOperation = await this.getBusinessOperation(req, body.TransactionId.toString());
       workspace = await this.getWorkspace(req, data.workspaceId);
-      tariffPlan = await this.getPlan(req, data.tariffPlanId);
       user = await this.getUser(req, data.userId);
+      planId = data.isCardLinkOperation ? workspace.tariffPlanId.toString() : data.tariffPlanId;
+
+      tariffPlan = await this.getPlan(req, planId);
     } catch (e) {
       const error = e as Error;
 
@@ -407,7 +483,7 @@ export default class CloudPaymentsWebhooks {
         type: SenderWorkerTaskType.PaymentSuccess,
         payload: {
           workspaceId: data.workspaceId,
-          tariffPlanId: data.tariffPlanId,
+          tariffPlanId: planId,
           userId: data.userId,
         },
       };
@@ -720,9 +796,9 @@ export default class CloudPaymentsWebhooks {
    *
    * @param req - request with necessary data
    */
-  private async getDataFromRequest(req: express.Request): Promise<PlanProlongationData> {
+  private async getDataFromRequest(req: express.Request): Promise<PaymentData> {
     const context = req.context;
-    const body: CheckRequest = req.body;
+    const body: CheckRequest | PayRequest | FailRequest = req.body;
 
     /**
      * If Data is not presented in body means there is a recurring payment
@@ -752,6 +828,7 @@ export default class CloudPaymentsWebhooks {
         tariffPlanId: workspace.tariffPlanId.toString(),
         userId,
         shouldSaveCard: false,
+        isCardLinkOperation: false,
       };
     }
 

src/billing/types/composePaymentPayload.ts

@@ -0,0 +1,18 @@
+export interface ComposePaymentPayload {
+  /**
+   * Workspace Identifier
+   */
+  workspaceId: string;
+  /**
+   * Id of the user making the payment
+   */
+  userId: string;
+  /**
+   * Workspace current plan id or plan id to change
+   */
+  tariffPlanId: string;
+  /**
+   * If true, we will save user card
+   */
+  shouldSaveCard: 'true' | 'false';
+}

src/billing/types/paymentData.ts

@@ -40,4 +40,24 @@ export interface PaymentData {
    * Data for Cloudpayments needs
    */
   cloudPayments?: CloudPaymentsSettings;
+  /**
+   * Workspace Identifier
+   */
+  workspaceId: string;
+  /**
+   * Id of the user making the payment
+   */
+  userId: string;
+  /**
+   * Workspace current plan id or plan id to change
+   */
+  tariffPlanId: string;
+  /**
+   * If true, we will save user card
+   */
+  shouldSaveCard: boolean;
+  /**
+   * True if this is card linking operation – charging minimal amount of money to validate card info
+   */
+  isCardLinkOperation: boolean;
 }

src/models/eventsFactory.js

@@ -159,7 +159,21 @@ class EventsFactory extends Factory {
     filters = {}
   ) {
     limit = this.validateLimit(limit);
-    sort = sort === 'BY_COUNT' ? 'count' : 'lastRepetitionTime';
+
+    switch (sort) {
+      case 'BY_COUNT':
+        sort = 'count';
+        break;
+      case 'BY_DATE':
+        sort = 'lastRepetitionTime';
+        break;
+      case 'BY_AFFECTED_USERS':
+        sort = 'affectedUsers';
+        break;
+      default:
+        sort = 'lastRepetitionTime';
+        break;
+    }
 
     const pipeline = [
       {

src/resolvers/billingNew.ts

@@ -138,6 +138,11 @@ export default {
      */
     async payWithCard(_obj: undefined, args: PayWithCardArgs, { factories, user }: ResolverContextWithUser): Promise<any> {
       const paymentData = checksumService.parseAndVerifyChecksum(args.input.checksum);
+
+      if (!('tariffPlanId' in paymentData)) {
+        throw new UserInputError('Invalid checksum');
+      }
+
       const fullUserInfo = await factories.usersFactory.findById(user.id);
 
       const workspace = await factories.workspacesFactory.findById(paymentData.workspaceId);

src/typeDefs/event.ts

@@ -392,6 +392,11 @@ type DailyEventInfo {
   Last event occurrence timestamp
   """
   lastRepetitionTime: Float!
+
+  """
+  How many users catch this error per day
+  """
+  affectedUsers: Int
 }
 
 type Subscription {

src/typeDefs/project.ts

@@ -8,6 +8,7 @@ Possible events order
 enum EventsSortOrder {
   BY_DATE
   BY_COUNT
+  BY_AFFECTED_USERS
 }
 
 """