feat: autodown grade with email template

Author: aakashreddy-p

package.json

@@ -82,6 +82,7 @@
     "crypto-js": "^4.2.0",
     "curlconverter": "^4.9.0",
     "dotenv": "16.0.1",
+    "exceljs": "^4.4.0",
     "fastify": "4.28.1",
     "form-data": "^4.0.1",
     "gravatar": "1.8.2",

pnpm-lock.yaml

@@ -26,6 +26,7 @@ import { DownGradeTeamRepository } from "./repositories/downgradeTeam.repository
 import { DownGradeUserRepository } from "./repositories/downgradeUser.repository";
 import { DownGradeWorkspaceRepository } from "./repositories/downgradeWorkspace.repository";
 import { DownGradeService } from "./services/downgrade.service";
+import { ExcelEmailService } from "./services/excel-email.service";
 
 // Try to import the Stripe module, but don't crash if it's not available
 let StripeModule: any;
@@ -56,6 +57,7 @@ export class BillingModule {
       DownGradeUserRepository,
       DownGradeWorkspaceRepository,
       DownGradeService,
+      ExcelEmailService,
       BillingAuditService,
       PromoCodeService,
       PricingService,
@@ -85,6 +87,7 @@ export class BillingModule {
       DownGradeUserRepository,
       DownGradeWorkspaceRepository,
       DownGradeService,
+      ExcelEmailService,
       PricingService,
       PaymentEmailService,
       PaymentEmailHelper,

src/modules/billing/billing.module.ts

@@ -6,6 +6,10 @@ import {
 } from "../services/payment-email.service";
 import { StripeCustomerService } from "../services/stripe-customer.service";
 import { PlanName } from "@src/modules/common/enum/plan.enum";
+import {
+  UserExcelDto,
+  WorkspaceExcelDto,
+} from "../payloads/downgrade-user.payload";
 
 // Dynamically import payment methods service
 let PaymentMethodsService: any;
@@ -187,6 +191,64 @@ export class PaymentEmailHelper {
     }
   }
 
+  /**
+   * Send plan downgraded emails to existing users in Hub.
+   */
+  async sendHubDowngradedEmail(
+    team: any,
+    startDate: Date,
+    previousPlan: string,
+    newPlan: string,
+    sendEmails: string[],
+    workspaces: WorkspaceExcelDto[],
+    users: UserExcelDto[],
+  ): Promise<void> {
+    try {
+      const emailData = await this.buildPlanDowngradeEmailData(
+        team,
+        startDate,
+        previousPlan,
+        newPlan,
+      );
+      if (!emailData) return;
+      const updateEmailData = { ...emailData, sendEmails, workspaces, users };
+      await this.paymentEmailService.sendPaymentEmail(
+        PaymentEmailType.HUB_DOWNGRADED,
+        updateEmailData,
+      );
+    } catch (error) {
+      console.error("Error sending plan downgraded email:", error);
+    }
+  }
+
+  /**
+   * Send plan downgraded emails to Removed users in Hub.
+   */
+  async sendHubDowngradeRemoveUserEmail(
+    team: any,
+    startDate: Date,
+    previousPlan: string,
+    newPlan: string,
+    sendEmails: string[],
+  ): Promise<void> {
+    try {
+      const emailData = await this.buildPlanDowngradeEmailData(
+        team,
+        startDate,
+        previousPlan,
+        newPlan,
+      );
+      if (!emailData) return;
+      const updateEmailData = { ...emailData, sendEmails };
+      await this.paymentEmailService.sendPaymentEmail(
+        PaymentEmailType.HUB_DOWNGRADED_REMOVE_USER,
+        updateEmailData,
+      );
+    } catch (error) {
+      console.error("Error sending plan downgraded email:", error);
+    }
+  }
+
   /**
    * Send upcoming payment email using customer's default payment method email
    */

src/modules/billing/helpers/payment-email.helper.ts

@@ -112,3 +112,16 @@ export class DownGradeUserTourGuideDto extends DownGradeUserGenerateVariableDto
   @Type(() => TourGuideDto)
   tourGuide?: TourGuideDto;
 }
+
+export interface WorkspaceExcelDto {
+  name: string;
+  created_at: string;
+  collections: number;
+  testflow: number;
+}
+
+export interface UserExcelDto {
+  name: string;
+  email: string;
+}
+

src/modules/billing/payloads/downgrade-user.payload.ts

@@ -1,4 +1,4 @@
-import { Injectable, Inject } from "@nestjs/common";
+import { Injectable, Inject, BadRequestException } from "@nestjs/common";
 import { Db } from "mongodb";
 import { ObjectId, WithId } from "mongodb";
 import { User } from "@src/modules/common/models/user.model";
@@ -38,4 +38,20 @@ export class DownGradeUserRepository {
       .toArray();
     return response;
   }
+
+  async findUsersByStringIds(ids: string[]): Promise<WithId<User>[]> {
+    try {
+      const objectIds = ids.map((id) => new ObjectId(id));
+      const users = await this.db
+        .collection<User>(Collections.USER)
+        .find({ _id: { $in: objectIds } })
+        .toArray();
+      if (!users || users.length === 0) {
+        return;
+      }
+      return users;
+    } catch (error) {
+      console.error("Error fetching users by string IDs:", error);
+    }
+  }
 }

src/modules/billing/repositories/downgradeUser.repository.ts

@@ -1,6 +1,6 @@
 import { Injectable, Inject, BadRequestException } from "@nestjs/common";
 import { Collections } from "@src/modules/common/enum/database.collection.enum";
-import { Workspace } from "@src/modules/common/models/workspace.model";
+import { UserDto, Workspace } from "@src/modules/common/models/workspace.model";
 import { Db, DeleteResult } from "mongodb";
 import { ObjectId, WithId } from "mongodb";
 
@@ -22,6 +22,26 @@ export class DownGradeWorkspaceRepository {
     return data;
   }
 
+  async getWorkspacesByIds(ids: string[]): Promise<WithId<Workspace>[]> {
+    if (!ids || ids.length === 0) {
+      throw new BadRequestException("workspaceIds are required.");
+    }
+    const objectIds = ids.map((id) => new ObjectId(id));
+    try {
+      const data = await this.db
+        .collection<Workspace>(Collections.WORKSPACE)
+        .find({ _id: { $in: objectIds } })
+        .toArray();
+      if (!data || data.length === 0) {
+        throw new BadRequestException("No workspaces found.");
+      }
+      return data;
+    } catch (error) {
+      console.error("Error fetching workspaces:", error);
+      throw new BadRequestException("Failed to fetch workspaces.");
+    }
+  }
+
   delete(id: string): Promise<DeleteResult> {
     const _id = new ObjectId(id);
     return this.db
@@ -46,4 +66,33 @@ export class DownGradeWorkspaceRepository {
     }
     return result.value;
   }
+
+  async updateWorkspaceUsers(
+    workspaceId: string,
+    updatedUsers: UserDto[],
+  ): Promise<any> {
+    if (!workspaceId) {
+      throw new BadRequestException("workspaceId is required.");
+    }
+    if (!Array.isArray(updatedUsers)) {
+      throw new BadRequestException("updatedUsers must be an array.");
+    }
+    const _id = new ObjectId(workspaceId);
+    const updatePayload: Partial<Workspace> = {
+      users: updatedUsers,
+      updatedAt: new Date(),
+    };
+    try {
+      const result = await this.db
+        .collection<Workspace>(Collections.WORKSPACE)
+        .updateOne({ _id }, { $set: updatePayload });
+      if (result.matchedCount === 0) {
+        throw new BadRequestException("Workspace not found.");
+      }
+      return result;
+    } catch (error) {
+      console.error("Error updating workspace users:", error);
+      throw new BadRequestException("Failed to update workspace users.");
+    }
+  }
 }

src/modules/billing/repositories/downgradeWorkspace.repository.ts

@@ -56,6 +56,19 @@ export class DownGradeService {
     const userFilteredWorkspaces = userData.workspaces.filter(
       (workspace) => workspace.teamId !== payload.teamId,
     );
+    const workspaces = teamData.workspaces;
+    for (let workspace of workspaces) {
+      const workspaceData = await this.downgradeWorkspaceReposiory.get(
+        workspace.id.toString(),
+      );
+      const updatedUsers = workspaceData.users.filter(
+        (user) => user.id !== payload.userId,
+      );
+      await this.downgradeWorkspaceReposiory.updateWorkspaceUsers(
+        workspace.id.toString(),
+        updatedUsers,
+      );
+    }
     const userUpdatedParams = {
       teams: userFilteredTeams,
       workspaces: userFilteredWorkspaces,

src/modules/billing/services/downgrade.service.ts

@@ -0,0 +1,157 @@
+// src/excel/excel.service.ts
+import { Injectable } from "@nestjs/common";
+import * as ExcelJS from "exceljs";
+import {
+  UserExcelDto,
+  WorkspaceExcelDto,
+} from "../payloads/downgrade-user.payload";
+
+@Injectable()
+export class ExcelEmailService {
+  /**
+   * Generate downgrade summary Excel with deleted workspaces and members
+   */
+  async generateDowngradeSummaryExcel(
+    workspaces: WorkspaceExcelDto[],
+    users: UserExcelDto[],
+  ): Promise<Buffer> {
+    const workbook = new ExcelJS.Workbook();
+    // Set workbook properties
+    workbook.creator = "Sparrow";
+    workbook.created = new Date();
+    workbook.modified = new Date();
+    // ==================== Deleted Workspaces Sheet ====================
+    const workspacesSheet = workbook.addWorksheet("Deleted Workspaces", {
+      properties: { tabColor: { argb: "FF316CF6" } },
+    });
+    // Define columns for workspaces
+    workspacesSheet.columns = [
+      { header: "Workspace Name", key: "name", width: 35 },
+      { header: "Created At", key: "created_at", width: 20 },
+      { header: "Collections", key: "collections", width: 15 },
+      { header: "Test Flows", key: "testflow", width: 15 },
+    ];
+    // Style header row for workspaces
+    const workspaceHeaderRow = workspacesSheet.getRow(1);
+    workspaceHeaderRow.font = {
+      bold: true,
+      color: { argb: "FFFFFFFF" },
+      size: 12,
+    };
+    workspaceHeaderRow.fill = {
+      type: "pattern",
+      pattern: "solid",
+      fgColor: { argb: "FF316CF6" },
+    };
+    workspaceHeaderRow.alignment = {
+      vertical: "middle",
+      horizontal: "center",
+    };
+    workspaceHeaderRow.height = 25;
+    // Add border to header
+    workspaceHeaderRow.eachCell((cell) => {
+      cell.border = {
+        top: { style: "thin" },
+        left: { style: "thin" },
+        bottom: { style: "thin" },
+        right: { style: "thin" },
+      };
+    });
+    // Add workspace data
+    workspaces.forEach((workspace, index) => {
+      const row = workspacesSheet.addRow({
+        name: workspace.name,
+        created_at: workspace.created_at || "N/A",
+        collections: workspace.collections,
+        testflow: workspace.testflow,
+      });
+      // Alternate row colors for better readability
+      if (index % 2 === 0) {
+        row.fill = {
+          type: "pattern",
+          pattern: "solid",
+          fgColor: { argb: "FFF8F9FA" },
+        };
+      }
+      // Add borders to data cells
+      row.eachCell((cell) => {
+        cell.border = {
+          top: { style: "thin", color: { argb: "FFE0E0E0" } },
+          left: { style: "thin", color: { argb: "FFE0E0E0" } },
+          bottom: { style: "thin", color: { argb: "FFE0E0E0" } },
+          right: { style: "thin", color: { argb: "FFE0E0E0" } },
+        };
+        cell.alignment = { vertical: "middle" };
+      });
+    });
+    // ==================== Deleted Members Sheet ====================
+    const membersSheet = workbook.addWorksheet("Deleted Members", {
+      properties: { tabColor: { argb: "FF316CF6" } },
+    });
+    // Define columns for members
+    membersSheet.columns = [
+      { header: "Name", key: "name", width: 30 },
+      { header: "Email", key: "email", width: 40 },
+      { header: "Role", key: "role", width: 15 },
+    ];
+    // Style header row for members
+    const memberHeaderRow = membersSheet.getRow(1);
+    memberHeaderRow.font = {
+      bold: true,
+      color: { argb: "FFFFFFFF" },
+      size: 12,
+    };
+    memberHeaderRow.fill = {
+      type: "pattern",
+      pattern: "solid",
+      fgColor: { argb: "FF316CF6" },
+    };
+    memberHeaderRow.alignment = {
+      vertical: "middle",
+      horizontal: "center",
+    };
+    memberHeaderRow.height = 25;
+
+    // Add border to header
+    memberHeaderRow.eachCell((cell) => {
+      cell.border = {
+        top: { style: "thin" },
+        left: { style: "thin" },
+        bottom: { style: "thin" },
+        right: { style: "thin" },
+      };
+    });
+
+    // Add member data
+    users.forEach((user, index) => {
+      const row = membersSheet.addRow({
+        name: user.name,
+        email: user.email,
+      });
+
+      // Alternate row colors
+      if (index % 2 === 0) {
+        row.fill = {
+          type: "pattern",
+          pattern: "solid",
+          fgColor: { argb: "FFF8F9FA" },
+        };
+      }
+
+      // Add borders to data cells
+      row.eachCell((cell) => {
+        cell.border = {
+          top: { style: "thin", color: { argb: "FFE0E0E0" } },
+          left: { style: "thin", color: { argb: "FFE0E0E0" } },
+          bottom: { style: "thin", color: { argb: "FFE0E0E0" } },
+          right: { style: "thin", color: { argb: "FFE0E0E0" } },
+        };
+        cell.alignment = { vertical: "middle" };
+      });
+    });
+
+    // Generate and return buffer
+    const buffer = await workbook.xlsx.writeBuffer();
+    return Buffer.from(buffer);
+  }
+}