chore(mx): mx changes

src/handler/index.ts

@@ -2,6 +2,7 @@ import { setTimeout } from "node:timers/promises";
 import type { EntityManager } from "@mikro-orm/sqlite";
 import type { MutexInterface } from "async-mutex";
 import type { AxiosInstance } from "axios";
+import axios from "axios";
 import type { TSupportedChainTypes, TSupportedChains } from "../config";
 import type { BridgeStorage } from "../contractsTypes/evm";
 import { LockedEvent } from "../persistence/entities/locked";
@@ -13,7 +14,7 @@ import type {
   TNftTransferDetailsObject,
   TStakingHandler,
 } from "./types";
-import { retry } from "./utils";
+import { fetchHttpOrIpfs, retry } from "./utils";
 
 export async function listenEvents(
   chains: Array<THandler>,
@@ -73,6 +74,9 @@ export async function listenEvents(
       ev.destinationChain,
     );
 
+    const imgUri = (await fetchHttpOrIpfs(nftDetails.metadata, axios.create()))
+      .image;
+
     const inft: TNftTransferDetailsObject = {
       destinationChain: ev.destinationChain,
       destinationUserAddress: ev.destinationUserAddress,
@@ -89,6 +93,7 @@ export async function listenEvents(
       tokenId: ev.tokenId,
       transactionHash: ev.transactionHash,
       lockTxChain: chain.chainIdent,
+      imgUri: imgUri,
     };
     log.trace(inft);
 

src/handler/multiversx/utils/signClaimData.ts

@@ -57,6 +57,7 @@ export default async function signClaimData(
     new Field(new BytesValue(Buffer.from(buf.nftType)), "nft_type"),
     new Field(new BigUIntValue(buf.fee), "fee"),
     new Field(new BytesValue(Buffer.from(buf.lockTxChain)), "lock_tx_chain"),
+    new Field(new BytesValue(Buffer.from(buf.imgUri || "")), "img_uri"),
   ]);
 
   const data = new BinaryCodec().encodeNested(claimDataArgs);

src/handler/ton/utils/nftData.ts

@@ -1,8 +1,9 @@
 import { Address, type TonClient } from "@ton/ton";
-import axios, { type AxiosInstance } from "axios";
+import axios from "axios";
 import { raise } from "..";
 import { NftCollection } from "../../../contractsTypes/ton/tonNftCollection";
 import { NftItem } from "../../../contractsTypes/ton/tonNftContract";
+import { fetchHttpOrIpfs } from "../../utils";
 
 export default async function nftData(
   tokenId: string,
@@ -70,18 +71,3 @@ export default async function nftData(
     royalty: BigInt(royalty),
   };
 }
-
-async function fetchHttpOrIpfs(uri: string, http: AxiosInstance) {
-  const url = new URL(uri);
-  if (url.protocol === "http:" || url.protocol === "https:") {
-    const response = await http.get(uri);
-    return response.data;
-  }
-  if (url.protocol === "ipfs:") {
-    const response = await http.get(
-      `https://ipfs.io/ipfs/${uri.replace("ipfs://", "")}`,
-    );
-    return response.data;
-  }
-  throw new Error("Unsupported protocol");
-}

src/handler/types.ts

@@ -25,6 +25,7 @@ export type TNftTransferDetailsObject = {
   nftType: string;
   fee: string;
   lockTxChain: string;
+  imgUri?: string;
 };
 
 export type LockEventIter = (event: LockEvent) => Promise<void>;

src/handler/utils.ts

@@ -1,4 +1,5 @@
 import { setTimeout } from "node:timers/promises";
+import type { AxiosInstance } from "axios";
 import { JsonRpcProvider, Wallet } from "ethers";
 import { ERC20Staking__factory, ERC20__factory } from "../contractsTypes/evm";
 import type { IGeneratedWallets, IStakingConfig } from "../types";
@@ -109,3 +110,18 @@ export async function stakeTokens(
     throw new Error("Failed to stake");
   }
 }
+
+export async function fetchHttpOrIpfs(uri: string, http: AxiosInstance) {
+  const url = new URL(uri);
+  if (url.protocol === "http:" || url.protocol === "https:") {
+    const response = await http.get(uri);
+    return response.data;
+  }
+  if (url.protocol === "ipfs:") {
+    const response = await http.get(
+      `https://ipfs.io/ipfs/${uri.replace("ipfs://", "")}`,
+    );
+    return response.data;
+  }
+  throw new Error("Unsupported protocol");
+}