feat: add support plan features and user support plan functionality

src/modules/tickets/providers/tickets.service.ts

@@ -1,11 +1,14 @@
 import { BadRequestException, HttpException, Injectable, InternalServerErrorException, Logger } from "@nestjs/common";
-import { DataSource, Not, QueryRunner } from "typeorm";
+import dayjs from "dayjs";
+import { DataSource, MoreThanOrEqual, Not, QueryRunner } from "typeorm";
 
 import { ReferralService } from "./referral.service";
 import { ParamDto } from "../../../common/DTO/param.dto";
 import { CommonMessage, TicketMessageEnum, UserMessage } from "../../../common/enums/message.enum";
 import { DanakService } from "../../danak-services/entities/danak-service.entity";
 import { NotificationQueue } from "../../notifications/queue/notification.queue";
+import { SupportPlanFeatureKey } from "../../support-plans/enums/support-plan-feature-key.enum";
+import { SupportPlansService } from "../../support-plans/providers/support-plans.service";
 import { User } from "../../users/entities/user.entity";
 import { AdminsService } from "../../users/providers/admins.service";
 import { UsersService } from "../../users/providers/users.service";
@@ -24,19 +27,23 @@ import { TicketStatus } from "../enums/ticket-status.enum";
 import { TicketCategoryRepository } from "../repositories/tickets-category.repository";
 import { TicketMessagesRepository } from "../repositories/tickets-message.repository";
 import { TicketsRepository } from "../repositories/tickets.repository";
+
 @Injectable()
 export class TicketsService {
   private readonly logger = new Logger(TicketsService.name);
+
   constructor(
-    private readonly notificationQueue: NotificationQueue,
-    private readonly ticketsCategoryRepository: TicketCategoryRepository,
     private readonly ticketsRepository: TicketsRepository,
+    private readonly ticketsCategoryRepository: TicketCategoryRepository,
     private readonly ticketMessagesRepository: TicketMessagesRepository,
     private readonly usersService: UsersService,
     private readonly adminsService: AdminsService,
+    private readonly notificationQueue: NotificationQueue,
     private readonly referralService: ReferralService,
-    private dataSource: DataSource,
+    private readonly dataSource: DataSource,
+    private readonly supportPlansService: SupportPlansService,
   ) {}
+
   //******************************** */
   async getTicketCategories() {
     const ticketCategories = await this.ticketsCategoryRepository.find({});
@@ -106,6 +113,36 @@ export class TicketsService {
 
   //******************************** */
 
+  private async checkTicketLimit(userId: string, queryRunner: QueryRunner): Promise<void> {
+    const { userSupportPlan } = await this.supportPlansService.getUserSupportPlanOfUser(userId);
+
+    if (!userSupportPlan) throw new BadRequestException(TicketMessageEnum.NO_ACTIVE_SUPPORT_PLAN);
+
+    const ticketLimitFeature = userSupportPlan.supportPlan.features.find(
+      (feature) => feature.featureKey === SupportPlanFeatureKey.TICKET_LIMIT,
+    );
+
+    if (!ticketLimitFeature) throw new BadRequestException(TicketMessageEnum.TICKET_LIMIT_NOT_FOUND);
+
+    const ticketLimit = parseInt(ticketLimitFeature.featureValue);
+    if (isNaN(ticketLimit)) return;
+
+    if (isNaN(ticketLimit)) throw new BadRequestException(TicketMessageEnum.INVALID_TICKET_LIMIT);
+
+    const today = dayjs().startOf("day").toDate();
+
+    const ticketCount = await queryRunner.manager.count(this.ticketsRepository.target, {
+      where: {
+        user: { id: userId },
+        createdAt: MoreThanOrEqual(today),
+      },
+    });
+
+    if (ticketCount >= ticketLimit) throw new BadRequestException(TicketMessageEnum.TICKET_LIMIT_EXCEEDED);
+  }
+
+  //******************************** */
+
   async createTicket(createDto: CreateTicketDto, userId: string) {
     const queryRunner = this.dataSource.createQueryRunner();
     await queryRunner.connect();
@@ -122,6 +159,8 @@ export class TicketsService {
 
       if (!ticketCategory) throw new BadRequestException(TicketMessageEnum.CATEGORY_NOT_FOUND);
 
+      await this.checkTicketLimit(userId, queryRunner);
+
       let service = null;
       if (createDto.danakServiceId) {
         service = await queryRunner.manager.findOneBy(DanakService, {