import { ITransferObject } from "../constants/type"
import { EstimateAmtRequest } from "../ts-proto/gateway/gateway_pb"
import { WebClient } from "../ts-proto/gateway/GatewayServiceClientPb"

import { transactor } from "../helper"
import { BigNumber, Contract, ContractTransaction } from "ethers"

export const poolBasedTransfer = async (
    bridge: Contract,
    rpc: string,
    addr: string,
    estimateRequest: EstimateAmtRequest,
    transferObject: ITransferObject,
    srcChainRPC: string,
    privateKey: string,
    isNative?: boolean
): Promise<ContractTransaction | undefined> => {
    const client = new WebClient(rpc, null, null)
    const estimateAmount = await client.estimateAmt(estimateRequest, null)

    const { transferToken, toChain, value, nonce } = transferObject

    try {
        const result = await transactor(
            isNative
                ? bridge.sendNative(
                      addr,
                      value,
                      BigNumber.from(toChain?.id),
                      BigNumber.from(nonce),
                      BigNumber.from( estimateRequest.getSlippageTolerance() || estimateAmount.getMaxSlippage() || 0),
                      { value: value, gasLimit: 200000 }
                  )
                : bridge.send(
                      addr,
                      transferToken?.token?.address,
                      value,
                      BigNumber.from(toChain?.id),
                      BigNumber.from(nonce),
                      BigNumber.from(estimateRequest.getSlippageTolerance() || estimateAmount.getMaxSlippage() || 0),
                      {gasLimit: 200000 }
                  ),
                  srcChainRPC,
                  privateKey
        )
        return result;
    } catch (err: any) {
        console.log(err)
        console.log("PoolBasedTransfer.ts - error:", err.reason)
    }
}