chore: complete ticket service but not tested

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

@@ -6,14 +6,23 @@ import { CommonMessage, TicketMessageEnum } from "../../../common/enums/message.
 import { UsersService } from "../../users/providers/users.service";
 import { PaginationUtils } from "../../utils/providers/pagination.utils";
 import { CreateTicketCategoryDto } from "../DTO/create-ticket-category.dto";
+import { CreateTicketMessageDto } from "../DTO/create-ticket-message.dto";
+import { CreateTicketDto } from "../DTO/create-ticket.dto";
 import { SearchTicketCategoryDto } from "../DTO/search-ticket-category.dto";
+import { SearchTicketQueryDto } from "../DTO/search-ticket-query.dto";
 import { UpdateTicketCategoryDto } from "../DTO/update-ticket-category.dto";
+import { TicketMessage } from "../entities/ticket-message.entity";
+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 {
   constructor(
     private readonly ticketsCategoryRepository: TicketCategoryRepository,
+    private readonly ticketsRepository: TicketsRepository,
+    private readonly ticketMessagesRepository: TicketMessagesRepository,
     private readonly usersService: UsersService,
   ) {}
   //******************************** */
@@ -93,5 +102,117 @@ export class TicketsService {
 
   //******************************** */
 
-  async createTicket() {}
+  async createTicket(createDto: CreateTicketDto, userId: string) {
+    const { user } = await this.usersService.findOneById(userId);
+    const ticketCategory = await this.ticketsCategoryRepository.findCategoryById(createDto.categoryId);
+    if (!ticketCategory) throw new BadRequestException(TicketMessageEnum.CATEGORY_NOT_FOUND);
+
+    //
+    const ticketMessage: Partial<TicketMessage> = { content: createDto.message, author: user };
+    const ticket = this.ticketsRepository.create({ ...createDto, user, category: ticketCategory, messages: [ticketMessage] });
+
+    await this.ticketsRepository.save(ticket);
+
+    return {
+      message: TicketMessageEnum.CREATED,
+      ticket,
+    };
+  }
+
+  //******************************** */
+
+  async getTickets(queryDto: SearchTicketQueryDto, userId: string) {
+    const { limit, skip } = PaginationUtils(queryDto);
+
+    const findOptions = {
+      where: {
+        user: { id: userId },
+        ...(queryDto.status && { status: queryDto.status }),
+      },
+      relations: {
+        category: true,
+        user: true,
+      },
+      order: {
+        createdAt: "DESC" as const,
+      },
+      skip,
+      take: limit,
+    };
+
+    const [tickets, count] = await this.ticketsRepository.findAndCount(findOptions);
+
+    return {
+      tickets,
+      count,
+    };
+  }
+
+  //******************************** */
+
+  async createTicketMessage(ticketId: string, createDto: CreateTicketMessageDto, userId: string) {
+    const ticket = await this.ticketsRepository.findTicketById(ticketId, userId);
+    if (!ticket) throw new BadRequestException(TicketMessageEnum.TICKET_NOT_FOUND);
+    //
+    const { user } = await this.usersService.findOneById(userId);
+
+    const ticketMessage = this.ticketMessagesRepository.create({ ...createDto, author: user, ticket });
+
+    await this.ticketMessagesRepository.save(ticketMessage);
+
+    return {
+      message: TicketMessageEnum.MESSAGE_CREATED,
+      ticketMessage,
+    };
+  }
+
+  //******************************** */
+
+  async getTicketMessages(ticketId: string, userId: string) {
+    const ticket = await this.ticketsRepository.findTicketById(ticketId, userId);
+    if (!ticket) throw new BadRequestException(TicketMessageEnum.TICKET_NOT_FOUND);
+
+    const messages = await this.ticketMessagesRepository.findMessagesByTicketId(ticketId);
+    return {
+      messages,
+    };
+  }
+
+  //******************************** */
+
+  async closeTicketByUser(ticketId: string, userId: string) {
+    const ticket = await this.ticketsRepository.findTicketById(ticketId, userId);
+    if (!ticket) throw new BadRequestException(TicketMessageEnum.TICKET_NOT_FOUND);
+
+    ticket.status = TicketStatus.CLOSED;
+    await this.ticketsRepository.save(ticket);
+
+    return {
+      message: TicketMessageEnum.CLOSED,
+    };
+  }
+
+  //******************************** */
 }
+
+// async getTickets(queryDto: SearchTicketQueryDto, userId: string) {
+//   const { limit, skip } = PaginationUtils(queryDto);
+//   //TODO:add danak-service to query
+//   const queryBuilder = this.ticketsRepository
+//     .createQueryBuilder("ticket")
+//     .leftJoinAndSelect("ticket.category", "category")
+//     .leftJoinAndSelect("ticket.user", "user")
+//     .where("user.id = :userId", { userId })
+//     .orderBy("ticket.createdAt", "DESC");
+
+//   if (queryDto.status) {
+//     queryBuilder.andWhere("ticket.status = :status", { status: queryDto.status });
+//   }
+
+//   const [tickets, count] = await queryBuilder.skip(skip).take(limit).getManyAndCount();
+
+//   return {
+//     tickets,
+//     count,
+//   };
+// }