fix: migrate cctx tracking to using isomorphic fetch (#77)

helpers/index.ts

@@ -1,4 +1,6 @@
 export * from "./balances";
 export * from "./fees";
 export * from "./pools";
+export * from "./prepare";
+export * from "./sendZETA";
 export * from "./tx";

helpers/prepare.ts

@@ -0,0 +1,16 @@
+import { ethers } from "ethers";
+
+export const prepareData = (contract: string, types: string[], args: any[]) => {
+  const params = prepareParams(types, args);
+  return `${contract}${params.slice(2)}`;
+};
+
+export const prepareParams = (types: string[], args: any[]) => {
+  const abiCoder = ethers.utils.defaultAbiCoder;
+  for (let i = 0; i < args.length; i++) {
+    if (types[i] === "bytes32") {
+      args[i] = ethers.utils.hexlify(ethers.utils.zeroPad(args[i], 32));
+    }
+  }
+  return abiCoder.encode(types, args);
+};

helpers/tx.ts

@@ -1,9 +1,16 @@
 import { getEndpoints } from "@zetachain/networks/dist/src/getEndpoints";
 import networks from "@zetachain/networks/dist/src/networks";
-import axios from "axios";
 import { ethers } from "ethers";
 import fetch from "isomorphic-fetch";
 
+const apiFetch = async (url: string) => {
+  const response = await fetch(url);
+  if (!response.ok) {
+    throw new Error(`Fetch failed with status: ${response.status}`);
+  }
+  return await response.json();
+};
+
 const getEndpoint = (key: any): string => {
   const endpoint = getEndpoints(key, "zeta_testnet")[0]?.url;
   if (!endpoint) {
@@ -33,8 +40,8 @@ const fetchCCTXByInbound = async (
 ) => {
   try {
     const url = `${API}/zeta-chain/crosschain/inTxHashToCctx/${hash}`;
-    const apiResponse = await axios.get(url);
-    const res = apiResponse?.data?.inTxHashToCctx?.cctx_index;
+    const apiResponseData = await apiFetch(url);
+    const res = apiResponseData?.inTxHashToCctx?.cctx_index;
     res.forEach((hash: any) => {
       if (hash && !cctxs[hash] && !spinners[hash]) {
         cctxs[hash] = [];
@@ -119,25 +126,25 @@ const fetchCCTXData = async (
 const getCCTX = async (hash: string, API: string) => {
   try {
     const url = `${API}/zeta-chain/crosschain/cctx/${hash}`;
-    const apiResponse = await axios.get(url);
-    return apiResponse?.data?.CrossChainTx;
+    const apiResponseData = await apiFetch(url);
+    return apiResponseData?.CrossChainTx;
   } catch (e) {}
 };
 
 const fetchNonces = async (API: string, TSS: string) => {
   try {
     const url = `${API}/zeta-chain/crosschain/pendingNonces`;
-    const apiResponse = await axios.get(url);
-    const nonces = apiResponse?.data?.pending_nonces;
+    const apiResponseData = await apiFetch(url);
+    const nonces = apiResponseData?.pending_nonces;
     return nonces.filter((n: any) => n.tss === TSS);
   } catch (e) {}
 };
 
 const fetchTSS = async (API: string) => {
   try {
     const url = `${API}/zeta-chain/crosschain/TSS`;
-    const apiResponse = await axios.get(url);
-    return apiResponse?.data?.TSS.tss_pubkey;
+    const apiResponseData = await apiFetch(url);
+    return apiResponseData?.TSS.tss_pubkey;
   } catch (e) {}
 };
 
@@ -155,7 +162,7 @@ export const trackCCTX = async (
     let cctxs: any = {};
     let pendingNonces: any = [];
 
-    setInterval(async () => {
+    const intervalID = setInterval(async () => {
       pendingNonces = await fetchNonces(API, TSS);
       if (Object.keys(cctxs).length === 0) {
         if (!json && emitter) {
@@ -219,6 +226,8 @@ export const trackCCTX = async (
           })
           .every((s) => s === "OutboundMined");
 
+        clearInterval(intervalID);
+
         if (!allOutboundMined) {
           reject("CCTX aborted or reverted");
         } else {