import { SolanaParser } from "@debridge-finance/solana-transaction-parser";
const CCTP_PROGRAM_ID = "CCTPiPYPc6AsJuwueEnWgSgucamXDZwBd53dQ11YiKX3";
const rpcConnection = new Connection(process.env.SOLANA_RPC_URL || "");
const txParser = new SolanaParser([{ idl: CCTPIdl as unknown as Idl, programId: new PublicKey(CCTP_PROGRAM_ID) }]);
  const parsed = await txParser.parseTransaction(
    rpcConnection,
    txSignature
  );
    if (parsed && parsed.length > 0) {
        if (parsed[0].name == 'depositForBurn' && parsed[0].args ) {
            let args = parsed[0].args as DepositForBurnArgs;
            // do something
        }
    }

async function getAllTransactions() {
    const txs = await rpcConnection.getSignaturesForAddress(new PublicKey(CCTP_PROGRAM_ID), {limit: 1000});
    //console.log("Length: ", txs.length);
    for (const tx of txs) {
  
        parseTx(tx.signature).catch((error) => {
            console.error(`Error parsing transaction ${tx.signature}:`, error);
        });
        
        // wait 1 second
        await new Promise(resolve => setTimeout(resolve, 1000));
    }
}

function publicKeyToEthereumAddress(publicKey: PublicKey) {
    let hash = (publicKey as any)._bn as BN;
    return "0x"+hash.toString(16);
}

let transferFilterTopic = "0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef";
let ethereumStandardAddress =  web3.utils.toChecksumAddress(web3.utils.padLeft(targetAddress, 40, '0').toLowerCase());
let padding = web3.utils.padLeft(ethereumStandardAddress, 64, '0').toLowerCase();
const filter = {
            fromBlock: fromBlock,
            toBlock: toBlock,
            topics: [transferFilterTopic, "0x0000000000000000000000000000000000000000000000000000000000000000",padding],
        };

async function getL2Fee(chainId: number,txId: string) {
    let method = "eth_getTransactionReceipt";
    let params = [txId];
    let rpcInstanceCfg = getConfig(chainId);
    if (!rpcInstanceCfg) {
        console.error("Invalid chain ID");
        return;
    }
    let url = rpcInstanceCfg.rpcAddress;
    let axiosInstance = axios.create({
        baseURL: url,
        timeout: 10000,
        headers: {
            'Content-Type': 'application/json'
        }
    });
    let data = {
        jsonrpc: "2.0",
        method: method,
        params: params,
        id: 1
    }
    let response = await axiosInstance.post(url, data);
    let l1Fee = response.data.result.l1Fee;
    let l2GasUsed = response.data.result.gasUsed;
    let l2GasPrice = response.data.result.effectiveGasPrice;
    let l2Fee = l2GasUsed * l2GasPrice;
    l1Fee = parseInt(l1Fee);
    if (isNaN(l1Fee)) {
        l1Fee = 0;
    }
    let totalFee = l1Fee + l2Fee;
    totalFee = totalFee / 1e18;
    //console.log(`L1 Fee: ${l1Fee}, L2 Fee: ${l2Fee}, Total Fee: ${totalFee}`);
    return totalFee;
}