import {CtorCoinTypes} from "../abstract/IPriceProvider";
import {ExchangePriceProvider} from "./abstract/ExchangePriceProvider";
import {MultiChain} from "../../swapper/Swapper";
import {httpGet} from "../../http/HttpUtils";

export type OKXResponse = {
    code: string;
    msg: string;
    data: [
        {
            instId: string;
            idxPx: string;
            high24h: string;
            sodUtc0: string;
            open24h: string;
            low24h: string;
            sodUtc8: string;
            ts: string;
        }
    ]
};

/**
 * Price provider using OKX exchange API
 * @category Pricing
 */
export class OKXPriceProvider<T extends MultiChain> extends ExchangePriceProvider<T> {

    constructor(coinsMap: CtorCoinTypes<T>, url: string = "https://www.okx.com/api/v5", httpRequestTimeout?: number) {
        super(coinsMap, url, httpRequestTimeout);
    }

    /**
     * @inheritDoc
     */
    async fetchPair(pair: string, abortSignal?: AbortSignal) {
        const response = await httpGet<OKXResponse>(
            this.url+"/market/index-tickers?instId="+pair,
            this.httpRequestTimeout,
            abortSignal
        );

        return parseFloat(response.data[0].idxPx);
    }

    /**
     * @inheritDoc
     */
    protected async fetchUsdPrice(abortSignal?: AbortSignal): Promise<number> {
        const response = await httpGet<OKXResponse>(
            this.url+"/market/index-tickers?instId=BTC-USD",
            this.httpRequestTimeout,
            abortSignal
        );

        return parseFloat(response.data[0].idxPx)/100000000;
    }

}