import { BNestBaseModuleService } from "@bish-nest/core/data/module-service/base-module.service";
import { BNestPrismaService } from "@bish-nest/core/services";
import { SystemLogService } from "@api/shared/services";
import { Injectable, NotFoundException } from "@nestjs/common";
import { SystemLogEntityType } from "@prisma/client";

@Injectable()
export class PackageService extends BNestBaseModuleService {
  constructor(
    protected prisma: BNestPrismaService,
    private readonly systemLogService: SystemLogService,
  ) {
    super();
  }

  /**
   * Override add method to log creation
   */
  async add(data: any): Promise<any> {
    const addResponse = await super.add(data);
    const package_ = addResponse.data;

    // Log the creation
    await this.systemLogService.logInsert(
      SystemLogEntityType.PACKAGE,
      package_.id,
      package_ as Record<string, unknown>,
    );

    return addResponse;
  }

  /**
   * Override save method to log update
   */
  async save(id: number, data: any): Promise<any> {
    // Get old data before update
    const oldPackage = await this.prisma.client.package.findUnique({
      where: { id },
    });

    if (!oldPackage) {
      throw new NotFoundException(`Package with ID ${id} not found`);
    }

    const saveResponse = await super.save(id, data);
    const updatedPackage = saveResponse.data;

    // Calculate changed fields and log the update
    const changedFields = SystemLogService.calculateChangedFields(
      oldPackage as Record<string, unknown>,
      updatedPackage as Record<string, unknown>,
    );

    await this.systemLogService.logUpdate(
      SystemLogEntityType.PACKAGE,
      id,
      oldPackage as Record<string, unknown>,
      updatedPackage as Record<string, unknown>,
      changedFields,
    );

    return saveResponse;
  }

  /**
   * Override delete method to log deletion
   */
  async delete(id: number): Promise<void> {
    // Get package data before deletion
    const package_ = await this.prisma.client.package.findUnique({
      where: { id },
    });

    if (!package_) {
      throw new NotFoundException(`Package with ID ${id} not found`);
    }

    // Call parent delete method
    await super.delete(id);

    // Log the deletion
    await this.systemLogService.logDelete(
      SystemLogEntityType.PACKAGE,
      id,
      package_ as Record<string, unknown>,
    );
  }
}