import { spreadIfDefined } from '@tonyshark/shared'
import axios, { AxiosError, AxiosInstance, isAxiosError } from 'axios'
import axiosRetry from 'axios-retry'
import { StatusCodes } from 'http-status-codes'

export class ApAxiosError extends Error {
    constructor(public error: AxiosError, message?: string) {
        super(message)
    }
}

export class ApAxiosClient {

    private _axios: AxiosInstance
    constructor(baseUrl: string, apiToken: string) {
        this._axios = axios.create({
            baseURL: baseUrl,
            headers: {
                'Content-Type': 'application/json',
                Authorization: `Bearer ${apiToken}`,
            },
        })
        axiosRetry(this._axios, {
            retries: 3, 
            retryDelay: (retryCount: number) => {
                return retryCount * 10000 
            },
            // eslint-disable-next-line @typescript-eslint/no-explicit-any
            retryCondition: (error: any) => {
                return error?.response?.status && error?.response?.status === StatusCodes.GATEWAY_TIMEOUT
            },
        })
    }

    static isApAxiosError(error: unknown): error is ApAxiosError {
        return error instanceof ApAxiosError
    }

    async post<T>(url: string, data: unknown): Promise<T> {
        try {
            const response = await this._axios.post<T>(url, data)
            return response.data
        }
        catch (error) {
            if (isAxiosError(error)) {
                throw this.formatAxiosError(error)
            }
            else {
                throw error
            }
        }
    }

    async get<T>(url: string, opts: {
        params?: Record<string, string>
        responseType?: 'arraybuffer' | undefined
    }): Promise<T> {
        try {
            const response = await this._axios.get<T>(url, {
                ...spreadIfDefined('params', opts.params),
                ...spreadIfDefined('responseType', opts.responseType),
            })
            return response.data
        }
        catch (error) {
            if (isAxiosError(error)) {
                throw this.formatAxiosError(error)
            }
            else {
                throw error
            }
        }
    }

    private formatAxiosError(error: AxiosError): Error {
        const { request, response, message } = error
        const newError = new ApAxiosError(error, JSON.stringify({
            message,
            request: request && {
                method: request.method,
                url: request.path,
                headers: request._header,
            },
            response: response && {
                status: response.status,
                headers: response.headers,
                data: response.data,
            },
        }))
        return newError
    }
}