import { HermesClient } from "@pythnetwork/hermes-client";
import {
  ChainPriceListener,
  IPricePusher,
  PriceInfo,
  PriceItem,
} from "../interface";
import { addLeading0x, DurationInSeconds } from "../utils";
import { Logger } from "pino";
import { Provider, Contract, hexlify, arrayify, Wallet, BN } from "fuels";
import {
  PYTH_CONTRACT_ABI,
  FUEL_ETH_ASSET_ID,
} from "@pythnetwork/pyth-fuel-js";

// Convert TAI64 timestamp to Unix timestamp
function tai64ToUnix(tai64: BN): number {
  // TAI64 is 2^62 seconds ahead of Unix epoch (1970-01-01)
  // Additional 10-second offset accounts for TAI being ahead of UTC at Unix epoch
  const result = BigInt(tai64.toString()) - BigInt(2n ** 62n) - 10n;
  return Number(result);
}

export class FuelPriceListener extends ChainPriceListener {
  private contract: Contract;

  constructor(
    private provider: Provider,
    private pythContractId: string,
    priceItems: PriceItem[],
    private logger: Logger,
    config: {
      pollingFrequency: DurationInSeconds;
    }
  ) {
    super(config.pollingFrequency, priceItems);
    this.contract = new Contract(
      this.pythContractId,
      PYTH_CONTRACT_ABI,
      this.provider
    );
  }

  async getOnChainPriceInfo(priceId: string): Promise<PriceInfo | undefined> {
    try {
      const formattedPriceId = addLeading0x(priceId);
      const priceInfo = await this.contract.functions
        .price_unsafe(formattedPriceId)
        .get();

      console.log({
        conf: priceInfo.value.confidence.toString(),
        price: priceInfo.value.price.toString(),
        publishTime: tai64ToUnix(priceInfo.value.publish_time),
      });

      this.logger.debug(
        `Polled a Fuel on chain price for feed ${this.priceIdToAlias.get(
          priceId
        )} (${priceId}).`
      );

      return {
        conf: priceInfo.value.confidence.toString(),
        price: priceInfo.value.price.toString(),
        publishTime: tai64ToUnix(priceInfo.value.publish_time),
      };
    } catch (err) {
      this.logger.error({ err, priceId }, `Polling on-chain price failed.`);
      return undefined;
    }
  }
}

export class FuelPricePusher implements IPricePusher {
  private contract: Contract;

  constructor(
    private wallet: Wallet,
    private pythContractId: string,
    private hermesClient: HermesClient,
    private logger: Logger
  ) {
    this.contract = new Contract(
      this.pythContractId,
      PYTH_CONTRACT_ABI,
      this.wallet as Provider
    );
  }

  async updatePriceFeed(
    priceIds: string[],
    // eslint-disable-next-line @typescript-eslint/no-unused-vars
    pubTimesToPush: number[]
  ): Promise<void> {
    if (priceIds.length === 0) {
      return;
    }

    let priceFeedUpdateData: string[];
    try {
      const response = await this.hermesClient.getLatestPriceUpdates(priceIds, {
        encoding: "base64",
      });
      priceFeedUpdateData = response.binary.data;
    } catch (err: any) {
      this.logger.error(err, "getPriceFeedsUpdateData failed");
      return;
    }

    const updateData = priceFeedUpdateData.map((data) => arrayify(data));

    try {
      const updateFee = await this.contract.functions
        .update_fee(updateData)
        .get();

      const result = await this.contract.functions
        .update_price_feeds(updateData)
        .callParams({
          forward: [updateFee.value, hexlify(FUEL_ETH_ASSET_ID)],
        })
        .call();

      this.logger.info(
        { transactionId: result.transactionId },
        "updatePriceFeed successful"
      );
    } catch (err: any) {
      this.logger.error(err, "updatePriceFeed failed");
    }
  }
}