liq

.ts

import { ethers } from "ethers";
import { createWeb3 } from "../lib/web3";
import { delay } from "../helpers/delay";
import { VaultPermitParams, brandService, relay, signConsent } from "@developeruche/protocol-core";
import { AddLiquidityForOpenRewardsWithTreasuryAndMeDispenserAndStartPoolProps } from "../lib/types";
import axios from "axios";
export async function addLiquidityForOpenRewardsWithTreasuryAndMeDispenserAndStartPoolFN({
  email,
  magic,
  rewardAmount,
  meAmount,
  rewardAddress,
  setLoading,
  setError,
  meApiKey,
  reqURL,
  costPayerId,
  currentBrandId,
  persist,
  GELATO_API_KEY,
  debug,
  OPEN_REWARD_DIAMOND,
  JSON_RPC_URL,
  CHAIN_ID,
  ME_TOKEN,
}: AddLiquidityForOpenRewardsWithTreasuryAndMeDispenserAndStartPoolProps) {
  setLoading(true);

  try {
    const magicWeb3 = await createWeb3(magic);

    if (!(await magic.user.isLoggedIn())) {
      await magic.auth.loginWithEmailOTP({ email });
      let isConnected = magicWeb3;
      while (!isConnected) {
        await delay(1000); // Wait for 1 second
        isConnected = magicWeb3;
      }
      const accounts = await magicWeb3.eth.getAccounts();
      //if the user accounts is not found - update it on the console
      if (accounts.length === 0) {
        return { taskId: "no accounts found" };
      }
      const userAccount = accounts[0];
      // console.log(userAccount, "user account is this");
      const provider = await magic.wallet.getProvider();
      const web3Provider = new ethers.providers.Web3Provider(provider);
      const signer = web3Provider.getSigner(userAccount);
      const loggedInUserInfo = await magic.user.getInfo().then((info: any) => info);

      // ============================================FROM HERE=====================================================================

      // console.log(OPEN_REWARD_DIAMOND, "REWARD DIAMOND DEV");
      let sign = await signConsent(signer, ME_TOKEN, ethers.utils.parseEther(meAmount).toString());

      const { data: GTP }: { data: { data: VaultPermitParams } } = await axios.post(
        `${reqURL}/reward/get-vault-permit`,
        // `${reqURL}/reward/get-treasury-permit`,
        {
          // token: TREASURY,

          value: ethers.utils.parseEther(meAmount).toString(),
          brandId: currentBrandId,
          rewardAddress,
          sign,
        },
        {
          headers: {
            Authorization: `Bearer ${meApiKey}`,
          },
        }
      );
      // console.log(GTP, "FROM TREASUREY PERMIT REQ");

      const data = await brandService.addLiquidityForOpenRewardsWithTreasuryAndMeDispenserAndStartPool(
        rewardAddress,
        ethers.utils.parseEther(rewardAmount),
        ethers.utils.parseEther(meAmount),
        GTP?.data,
        JSON_RPC_URL,
        OPEN_REWARD_DIAMOND
      );

      const relayInput = {
        from: loggedInUserInfo.publicAddress,
        data: data.data,
        to: OPEN_REWARD_DIAMOND,
      };
      // const wallet = new ethers.Wallet(
      //   "5393eb89457505dc0cea935ef8f3e09b03ecc283234fff38fdf6c8a8d0ccf35a",
      //   defaultProvider
      // );
      // const hash = await wallet.sendTransaction({
      //   to: OPEN_REWARD_DIAMOND,
      //   data: relayInput.data + "b6933fa10F5179FA2de6C8B1D0C5B0A9A5B87327",
      // });

      // 0xb6933fa10F5179FA2de6C8B1D0C5B0A9A5B87327;

      const { taskId }: { taskId: string } = await relay(
        relayInput,
        signer,
        meApiKey,
        reqURL,
        GELATO_API_KEY,
        JSON_RPC_URL,
        CHAIN_ID,
        OPEN_REWARD_DIAMOND,
        costPayerId,
        debug
      );
      return { taskId };
    } else {
      let isConnected = magicWeb3;
      while (!isConnected) {
        await delay(1000); // Wait for 1 second
        isConnected = magicWeb3;
      }

      const { email: connectedEmail } = await magic.user.getInfo();
      //IF THE PERSISTED USER INFO IS NOT THE INFO OF THE USER TRYING TO PERFORM THE FUNCTION logout and try to login again
      if (email !== connectedEmail) {
        await magic.user.logout();
        await magic.auth.loginWithEmailOTP({ email });
        let isConnected = magicWeb3;
        while (!isConnected) {
          await delay(1000); // Wait for 1 second
          isConnected = magicWeb3;
        }
        const accounts = await magicWeb3.eth.getAccounts();
        //if the user accounts is not found - update it on the console
        if (accounts.length === 0) {
          return { taskId: "no accounts found" };
        }
        const userAccount = accounts[0];
        // console.log(userAccount, "user account is this");
        const provider = await magic.wallet.getProvider();
        const web3Provider = new ethers.providers.Web3Provider(provider);
        const signer = web3Provider.getSigner(userAccount);
        const loggedInUserInfo = await magic.user.getInfo().then((info: any) => info);

        // ============================================FROM HERE=====================================================================

        // console.log(OPEN_REWARD_DIAMOND, "REWARD DIAMOND DEV");
        let sign = await signConsent(signer, ME_TOKEN, ethers.utils.parseEther(meAmount).toString());

        const { data: GTP }: { data: { data: VaultPermitParams } } = await axios.post(
          `${reqURL}/reward/get-vault-permit`,
          {
            // token: TREASURY,

            value: ethers.utils.parseEther(meAmount).toString(),
            brandId: currentBrandId,
            rewardAddress,
            sign,
          },
          {
            headers: {
              Authorization: `Bearer ${meApiKey}`,
            },
          }
        );
        // console.log(GTP, "FROM TREASUREY PERMIT REQ");

        const data = await brandService.addLiquidityForOpenRewardsWithTreasuryAndMeDispenserAndStartPool(
          rewardAddress,
          ethers.utils.parseEther(rewardAmount),
          ethers.utils.parseEther(meAmount),
          GTP?.data,
          JSON_RPC_URL,
          OPEN_REWARD_DIAMOND
        );

        const relayInput = {
          from: loggedInUserInfo.publicAddress,
          data: data.data,
          to: OPEN_REWARD_DIAMOND,
        };
        // const wallet = new ethers.Wallet(
        //   "5393eb89457505dc0cea935ef8f3e09b03ecc283234fff38fdf6c8a8d0ccf35a",
        //   defaultProvider
        // );
        // const hash = await wallet.sendTransaction({
        //   to: OPEN_REWARD_DIAMOND,
        //   data: relayInput.data + "b6933fa10F5179FA2de6C8B1D0C5B0A9A5B87327",
        // });

        // 0xb6933fa10F5179FA2de6C8B1D0C5B0A9A5B87327;

        const { taskId }: { taskId: string } = await relay(
          relayInput,
          signer,
          meApiKey,
          reqURL,
          GELATO_API_KEY,
          JSON_RPC_URL,
          CHAIN_ID,
          OPEN_REWARD_DIAMOND,
          costPayerId,
          debug
        );
        return { taskId };
      }
      const accounts = await magicWeb3.eth.getAccounts();
      //if the user accounts is not found - update it on the console
      if (accounts.length === 0) {
        return { taskId: "no accounts found" };
      }
      const userAccount = accounts[0];
      // console.log(userAccount, "user account is this");
      const provider = await magic.wallet.getProvider();
      const web3Provider = new ethers.providers.Web3Provider(provider);
      const signer = web3Provider.getSigner(userAccount);
      const loggedInUserInfo = await magic.user.getInfo().then((info: any) => info);

      // ============================================FROM HERE=====================================================================

      // console.log(OPEN_REWARD_DIAMOND, "REWARD DIAMOND DEV");
      let sign = await signConsent(signer, ME_TOKEN, ethers.utils.parseEther(meAmount).toString());

      const { data: GTP }: { data: { data: VaultPermitParams } } = await axios.post(
        `${reqURL}/reward/get-vault-permit`,
        {
          // token: TREASURY,

          value: ethers.utils.parseEther(meAmount).toString(),
          brandId: currentBrandId,
          rewardAddress,
          sign,
        },
        {
          headers: {
            Authorization: `Bearer ${meApiKey}`,
          },
        }
      );
      // console.log(GTP, "FROM TREASUREY PERMIT REQ");

      const data = await brandService.addLiquidityForOpenRewardsWithTreasuryAndMeDispenserAndStartPool(
        rewardAddress,
        ethers.utils.parseEther(rewardAmount),
        ethers.utils.parseEther(meAmount),
        GTP?.data,
        JSON_RPC_URL,
        OPEN_REWARD_DIAMOND
      );

      const relayInput = {
        from: loggedInUserInfo.publicAddress,
        data: data.data,
        to: OPEN_REWARD_DIAMOND,
      };
      // const wallet = new ethers.Wallet(
      //   "5393eb89457505dc0cea935ef8f3e09b03ecc283234fff38fdf6c8a8d0ccf35a",
      //   defaultProvider
      // );
      // const hash = await wallet.sendTransaction({
      //   to: OPEN_REWARD_DIAMOND,
      //   data: relayInput.data + "b6933fa10F5179FA2de6C8B1D0C5B0A9A5B87327",
      // });

      // 0xb6933fa10F5179FA2de6C8B1D0C5B0A9A5B87327
      // 0xb6933fa10F5179FA2de6C8B1D0C5B0A9A5B87327;

      // 0xb6933fa10F5179FA2de6C8B1D0C5B0A9A5B87327;

      const { taskId }: { taskId: string } = await relay(
        relayInput,
        signer,
        meApiKey,
        reqURL,
        GELATO_API_KEY,
        JSON_RPC_URL,
        CHAIN_ID,
        OPEN_REWARD_DIAMOND,
        costPayerId,
        debug
      );
      return { taskId };
    }
  } catch (error) {
    console.log(error, "HAsg err");

    setError(error);
    throw error;
  } finally {
    setLoading(false);
    if (!persist) {
      magic.user.logout();
    }
  }
}