import crypto from 'node:crypto'
import { OrderStatus } from '@baguspay/db/types'
import { BadRequestException, GatewayTimeoutException, Injectable } from '@nestjs/common'
import { ConfigService } from '@nestjs/config'
import axios, { type AxiosInstance } from 'axios'
import type {
  DigiflazzApiTopupResponse,
  DigiflazzBayarTagihanData,
  DigiflazzBayarTagihanResponse,
  DigiflazzCekTagihanData,
  DigiflazzCekTagihanResponse,
  DigiflazzPostpaidCallbackData,
  DigiflazzPrepaidCallbackData,
  DigiflazzTopupData,
  DigiflazzTopupResponse,
} from './digiflazz.type'

@Injectable()
export class DigiflazzService {
  private apikey: string
  private username: string
  private callbackSecret: string
  private testing: boolean = false
  private apiClient: AxiosInstance

  constructor(private readonly configService: ConfigService) {
    this.apikey = this.configService.get<string>('DIGIFLAZZ_API_KEY')
    this.username = this.configService.get<string>('DIGIFLAZZ_USERNAME')
    this.callbackSecret = this.configService.get<string>('DIGIFLAZZ_CALLBACK_SECRET')

    const environment = this.configService.get<string>('NODE_ENV')
    this.testing = environment === 'development' || environment === 'test'

    this.apiClient = axios.create({
      baseURL: 'https://api.digiflazz.com/v1',
    })
  }

  async topup(data: DigiflazzTopupData): Promise<DigiflazzTopupResponse> {
    try {
      const sign = this.generateSignature(data.order_id)

      const response = await this.apiClient.post<DigiflazzApiTopupResponse>('/transaction', {
        username: this.username,
        buyer_sku_code: data.provider_code,
        customer_no: data.customer_input,
        ref_id: data.order_id,
        max_price: data.max_price,
        testing: this.testing,
        cb_url: data.callback_url,
        allow_dot: data.allow_dot,
        sign: sign,
      })

      switch (response.data.data.rc) {
        case '00':
          return {
            provider_code: data.provider_code,
            customer_input: data.customer_input,
            order_id: data.order_id,
            max_price: data.max_price,
            callback_url: data.callback_url,
            allow_dot: data.allow_dot,
            status: OrderStatus.COMPLETED,
            buyer_last_saldo: response.data.data.buyer_last_saldo,
            provider_price: response.data.data.price,
            wa: response.data.data.wa,
            tele: response.data.data.tele,
            sn: response.data.data.sn || null,
            raw: response.data,
          }
        case '01':
          throw new GatewayTimeoutException(`DF: ${response.data.data.message}`)
        case '02':
          return {
            provider_code: data.provider_code,
            customer_input: data.customer_input,
            order_id: data.order_id,
            max_price: data.max_price,
            callback_url: data.callback_url,
            allow_dot: data.allow_dot,
            status: OrderStatus.FAILED,
            buyer_last_saldo: response.data.data.buyer_last_saldo,
            provider_price: response.data.data.price,
            wa: response.data.data.wa,
            tele: response.data.data.tele,
            sn: response.data.data.sn || null,
            raw: response.data,
          }
        case '03':
          return {
            provider_code: data.provider_code,
            customer_input: data.customer_input,
            order_id: data.order_id,
            max_price: data.max_price,
            callback_url: data.callback_url,
            allow_dot: data.allow_dot,
            status: OrderStatus.PENDING,
            buyer_last_saldo: response.data.data.buyer_last_saldo,
            provider_price: response.data.data.price,
            wa: response.data.data.wa,
            tele: response.data.data.tele,
            sn: response.data.data.sn || null,
            raw: response.data,
          }
        case '99':
          return {
            provider_code: data.provider_code,
            customer_input: data.customer_input,
            order_id: data.order_id,
            max_price: data.max_price,
            callback_url: data.callback_url,
            allow_dot: data.allow_dot,
            status: OrderStatus.PENDING,
            buyer_last_saldo: response.data.data.buyer_last_saldo,
            provider_price: response.data.data.price,
            wa: response.data.data.wa,
            tele: response.data.data.tele,
            sn: response.data.data.sn || null,
            raw: response.data,
          }
        default:
          return {
            provider_code: data.provider_code,
            customer_input: data.customer_input,
            order_id: data.order_id,
            max_price: data.max_price,
            callback_url: data.callback_url,
            allow_dot: data.allow_dot,
            status: OrderStatus.FAILED,
            buyer_last_saldo: response.data.data.buyer_last_saldo,
            provider_price: response.data.data.price,
            wa: response.data.data.wa,
            tele: response.data.data.tele,
            sn: response.data.data.sn || null,
            raw: response.data,
          }
      }
    } catch (error) {
      if (axios.isAxiosError(error)) {
        throw new BadRequestException(`DF: ${error.response?.data.message}`)
      }

      throw new BadRequestException(`DF: ${error.message}`)
    }
  }

  async cekTagihan(data: DigiflazzCekTagihanData): Promise<DigiflazzCekTagihanResponse> {
    try {
      const sign = this.generateSignature(data.inquiry_id)

      const response = await this.apiClient.post('/transaction', {
        commands: 'inq-pasca',
        username: this.username,
        buyer_sku_code: data.provider_code,
        customer_no: data.customer_input,
        ref_id: data.inquiry_id,
        sign: sign,
      })

      switch (response.data.data.rc) {
        case '00':
          return {
            provider_code: data.provider_code,
            customer_input: data.customer_input,
            status: OrderStatus.COMPLETED,
            buyer_last_saldo: response.data.data.buyer_last_saldo,
            admin: response.data.data.admin,
            customer_name: response.data.data.customer_name,
            message: response.data.data.message,
            periode: response.data.data.periode,
            price: response.data.data.price,
            selling_price: response.data.data.selling_price,
            inquiry_id: response.data.data.inquiry_id,
            desc: response.data.data.desc,
          }
        case '01':
          throw new GatewayTimeoutException(`DF: ${response.data?.data?.message}`)
        case '02':
          return {
            provider_code: data.provider_code,
            customer_input: data.customer_input,
            status: OrderStatus.FAILED,
            buyer_last_saldo: response.data.data.buyer_last_saldo,
            admin: response.data.data.admin,
            customer_name: response.data.data.customer_name,
            message: response.data.data.message,
            periode: response.data.data.periode,
            price: response.data.data.price,
            selling_price: response.data.data.selling_price,
            inquiry_id: response.data.data.inquiry_id,
            desc: response.data.data.desc,
          }
        case ['03', '99']:
          return {
            provider_code: data.provider_code,
            customer_input: data.customer_input,
            status: OrderStatus.PENDING,
            buyer_last_saldo: response.data.data.buyer_last_saldo,
            admin: response.data.data.admin,
            customer_name: response.data.data.customer_name,
            message: response.data.data.message,
            periode: response.data.data.periode,
            price: response.data.data.price,
            selling_price: response.data.data.selling_price,
            inquiry_id: response.data.data.inquiry_id,
            desc: response.data.data.desc,
          }
        default:
          return {
            provider_code: data.provider_code,
            customer_input: data.customer_input,
            status: OrderStatus.FAILED,
            buyer_last_saldo: response.data.data.buyer_last_saldo,
            admin: response.data.data.admin,
            customer_name: response.data.data.customer_name,
            message: response.data.data.message,
            periode: response.data.data.periode,
            price: response.data.data.price,
            selling_price: response.data.data.selling_price,
            inquiry_id: response.data.data.inquiry_id,
            desc: response.data.data.desc,
          }
      }
    } catch (error) {
      if (axios.isAxiosError(error)) {
        // console.log('Digiflazz Cek Tagihan Error Response:', error.response?.data)
        throw new BadRequestException(
          `DF: ${error.response?.data?.message || error.response?.data?.data?.message}`,
        )
      }

      throw new BadRequestException(`DF: ${error.message}`)
    }
  }

  async bayarTagihan(data: DigiflazzBayarTagihanData): Promise<DigiflazzBayarTagihanResponse> {
    try {
      const sign = this.generateSignature(data.inquiry_id)

      const response = await this.apiClient.post('/transaction', {
        commands: 'pay-pasca',
        username: this.username,
        buyer_sku_code: data.provider_code,
        customer_no: data.customer_input,
        ref_id: data.inquiry_id,
        sign: sign,
        testing: this.testing,
      })

      switch (response.data.data.rc) {
        case '00':
          return {
            provider_code: data.provider_code,
            customer_input: data.customer_input,
            order_id: data.order_id,
            max_price: 0,
            callback_url: null,
            allow_dot: false,
            status: OrderStatus.COMPLETED,
            buyer_last_saldo: response.data.data.buyer_last_saldo,
            provider_price: response.data.data.price,
            wa: response.data.data.wa,
            tele: response.data.data.tele,
            sn: response.data.data.sn || null,

            admin: response.data.data.admin,
            customer_name: response.data.data.customer_name,
            message: response.data.data.message,
            inquiry_id: data.inquiry_id,
            periode: response.data.data.periode,
            price: response.data.data.price,
            selling_price: response.data.data.selling_price,
            desc: response.data.data.desc,
            raw: response.data,
          }
        case '01':
          throw new GatewayTimeoutException(`DF: ${response.data.data.message}`)
        case '02':
          return {
            provider_code: data.provider_code,
            customer_input: data.customer_input,
            order_id: data.order_id,
            max_price: 0,
            callback_url: null,
            allow_dot: false,
            status: OrderStatus.FAILED,
            buyer_last_saldo: response.data.data.buyer_last_saldo,
            provider_price: response.data.data.price,
            wa: response.data.data.wa,
            tele: response.data.data.tele,
            sn: response.data.data.sn || null,
            admin: response.data.data.admin,
            customer_name: response.data.data.customer_name,
            message: response.data.data.message,
            inquiry_id: data.inquiry_id,
            periode: response.data.data.periode,
            price: response.data.data.price,
            selling_price: response.data.data.selling_price,
            desc: response.data.data.desc,
            raw: response.data,
          }
        case '03':
          return {
            provider_code: data.provider_code,
            customer_input: data.customer_input,
            order_id: data.order_id,
            max_price: 0,
            callback_url: null,
            allow_dot: false,
            status: OrderStatus.PENDING,
            buyer_last_saldo: response.data.data.buyer_last_saldo,
            provider_price: response.data.data.price,
            wa: response.data.data.wa,
            tele: response.data.data.tele,
            sn: response.data.data.sn || null,
            admin: response.data.data.admin,
            customer_name: response.data.data.customer_name,
            message: response.data.data.message,
            inquiry_id: data.inquiry_id,
            periode: response.data.data.periode,
            price: response.data.data.price,
            selling_price: response.data.data.selling_price,
            desc: response.data.data.desc,
            raw: response.data,
          }
        case '99':
          return {
            provider_code: data.provider_code,
            customer_input: data.customer_input,
            order_id: data.order_id,
            max_price: 0,
            callback_url: null,
            allow_dot: false,
            status: OrderStatus.PENDING,
            buyer_last_saldo: response.data.data.buyer_last_saldo,
            provider_price: response.data.data.price,
            wa: response.data.data.wa,
            tele: response.data.data.tele,
            sn: response.data.data.sn || null,
            admin: response.data.data.admin,
            customer_name: response.data.data.customer_name,
            message: response.data.data.message,
            inquiry_id: data.inquiry_id,
            periode: response.data.data.periode,
            price: response.data.data.price,
            selling_price: response.data.data.selling_price,
            desc: response.data.data.desc,
            raw: response.data,
          }
        default:
          return {
            provider_code: data.provider_code,
            customer_input: data.customer_input,
            order_id: data.order_id,
            max_price: 0,
            callback_url: null,
            allow_dot: false,
            status: OrderStatus.FAILED,
            buyer_last_saldo: response.data.data.buyer_last_saldo,
            provider_price: response.data.data.price,
            wa: response.data.data.wa,
            tele: response.data.data.tele,
            sn: response.data.data.sn || null,
            admin: response.data.data.admin,
            customer_name: response.data.data.customer_name,
            message: response.data.data.message,
            inquiry_id: data.inquiry_id,
            periode: response.data.data.periode,
            price: response.data.data.price,
            selling_price: response.data.data.selling_price,
            desc: response.data.data.desc,
            raw: response.data,
          }
      }
    } catch (error) {
      if (axios.isAxiosError(error)) {
        throw new BadRequestException(`DF: ${error.response?.data.message}`)
      }

      throw new BadRequestException(`DF: ${error.message}`)
    }
  }

  private generateSignature(value: string) {
    return crypto
      .createHash('md5')
      .update(this.username + this.apikey + value)
      .digest('hex')
  }

  public verifyCallbackSignature(
    payload: DigiflazzPrepaidCallbackData | DigiflazzPostpaidCallbackData,
    signFromPost: string,
  ) {
    const sign = crypto
      .createHmac('sha1', this.callbackSecret)
      .update(JSON.stringify(payload))
      .digest('hex')

    // console.log('Generated Sign:', sign, signFromPost)

    return {
      isValid: `sha1=${sign}` === signFromPost,
      sign: sign,
    }
  }
}