-
Notifications
You must be signed in to change notification settings - Fork 7
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
66 changed files
with
2,434 additions
and
1,431 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,141 +1,154 @@ | ||
| import dotenv from 'dotenv' | ||
| if(process.env.NODE_ENV !== 'production'){ | ||
| dotenv.config() | ||
| import dotenv from "dotenv"; | ||
| if (process.env.NODE_ENV !== "production") { | ||
| dotenv.config(); | ||
| } | ||
|
|
||
| import { chains } from '../types/chains.js'; | ||
| import { chains } from "../types/chains.js"; | ||
|
|
||
| import { ethers } from 'ethers' | ||
| import { ethers } from "ethers"; | ||
|
|
||
| import Moralis from 'moralis'; | ||
| import Moralis from "moralis"; | ||
|
|
||
| const ethProvider = new ethers.providers.InfuraProvider("mainnet", { | ||
| projectId: `75984fd56f8c4508a6f8e0cdb21c3edb`, | ||
| projectSecret: `uQJdKF6wMPvmF+213HwEHS9mU7ODPD5zm1yB/r/YkJK9JQNwSWZAGg`, | ||
| }); | ||
|
|
||
| const ethProvider = new ethers.providers.InfuraProvider("mainnet") | ||
| import RedisClient from "../clients/redis.js"; | ||
| const redis = RedisClient.getInstance(); | ||
|
|
||
| export const getAvatar = async (ensName) => { | ||
| try { | ||
| const resolver = await ethProvider.getResolver(ensName); | ||
| const avatar = await resolver?.getText("avatar"); | ||
| if (!avatar || avatar.length === 0) return null; | ||
| return avatar; | ||
| } catch (error) { | ||
| console.log(`get Avatar error`, error); | ||
| return null; | ||
| } | ||
| } | ||
| try { | ||
| const resolver = await ethProvider.getResolver(ensName); | ||
| const avatar = await resolver?.getText("avatar"); | ||
| if (!avatar || avatar.length === 0) return null; | ||
| return avatar; | ||
| } catch (error) { | ||
| console.log(`get Avatar error`, error); | ||
| return null; | ||
| } | ||
| }; | ||
|
|
||
| export const getENSProfileByWallet = async (wallet) => { | ||
| const walletData = await ethProvider.lookupAddress(wallet); | ||
| if(walletData){ | ||
| let profile = { | ||
| ensName: walletData, | ||
| }; | ||
| const avatar = await getAvatar(walletData) | ||
| if(avatar){ | ||
| profile.image = avatar; | ||
| } | ||
| return profile; | ||
| const cache = await redis.hGet(`ens`, wallet); | ||
| if (cache) { | ||
| return JSON.parse(cache); | ||
| } | ||
| const walletData = await ethProvider.lookupAddress(wallet); | ||
| if (walletData) { | ||
| let profile = { | ||
| ensName: walletData, | ||
| }; | ||
| const avatar = await getAvatar(walletData); | ||
| if (avatar) { | ||
| profile.image = avatar; | ||
| } | ||
| await redis.hSet(`ens`, wallet, JSON.stringify(profile)); | ||
| return profile; | ||
| } | ||
| }; | ||
| export const getWalletByENS = async (ens) => { | ||
| const walletData = await ethProvider.resolveName(ens); | ||
| return walletData; | ||
| const walletData = await ethProvider.resolveName(ens); | ||
| return walletData; | ||
| }; | ||
| export const getCollectionMetadataApi = async (chainName, tokenAddress) => { | ||
| const chain = chains[chainName]; | ||
|
|
||
|
|
||
| try { | ||
| const hexChain = '0x' + chain.chainId.toString(16);; | ||
| const response = await Moralis.EvmApi.nft.getNFTContractMetadata({ | ||
| "chain": hexChain, | ||
| "address": tokenAddress | ||
| }); | ||
|
|
||
| if(response && response.raw && response.raw.token_address) { | ||
| return { | ||
| symbol: response.raw.symbol, | ||
| name: response.raw.name, | ||
| token: response.raw.token_address, | ||
| tokenType: response.raw.contract_type | ||
| } | ||
| } | ||
| } catch (e) { | ||
| console.error(e); | ||
| const chain = chains[chainName]; | ||
|
|
||
| try { | ||
| const hexChain = "0x" + chain.chainId.toString(16); | ||
| const response = await Moralis.EvmApi.nft.getNFTContractMetadata({ | ||
| chain: hexChain, | ||
| address: tokenAddress, | ||
| }); | ||
|
|
||
| if (response && response.raw && response.raw.token_address) { | ||
| return { | ||
| symbol: response.raw.symbol, | ||
| name: response.raw.name, | ||
| token: response.raw.token_address, | ||
| tokenType: response.raw.contract_type, | ||
| }; | ||
| } | ||
|
|
||
|
|
||
|
|
||
| } catch (e) { | ||
| console.error(e); | ||
| } | ||
| }; | ||
|
|
||
| export const getNftMetadataApi = async (chainName, tokenAddress, tokenId, resyncMetadata = false) => { | ||
| try { | ||
| const chain = chains[chainName]; | ||
| const hexChain = '0x' + chain.chainId.toString(16); | ||
|
|
||
| const response = await Moralis.EvmApi.nft.getNFTMetadata({ | ||
| "chain": hexChain, | ||
| "address": tokenAddress, | ||
| "normalizeMetadata": true, | ||
| "tokenId": tokenId | ||
| }); | ||
|
|
||
| return { | ||
| metadata: { | ||
| name: response.raw.name, | ||
| image: response.raw.normalized_metadata.image | ||
| } | ||
| }; | ||
|
|
||
| } catch (error) { | ||
| console.log(error) | ||
| //throw new Error('Failed to fetch NFT metadata'); | ||
| } | ||
| export const getNftMetadataApi = async ( | ||
| chainName, | ||
| tokenAddress, | ||
| tokenId, | ||
| resyncMetadata = false, | ||
| ) => { | ||
| try { | ||
| const chain = chains[chainName]; | ||
| const hexChain = "0x" + chain.chainId.toString(16); | ||
|
|
||
| const response = await Moralis.EvmApi.nft.getNFTMetadata({ | ||
| chain: hexChain, | ||
| address: tokenAddress, | ||
| normalizeMetadata: true, | ||
| tokenId: tokenId, | ||
| }); | ||
|
|
||
| return { | ||
| metadata: { | ||
| name: response.raw.name, | ||
| image: response.raw.normalized_metadata.image, | ||
| }, | ||
| }; | ||
| } catch (error) { | ||
| console.log(error); | ||
| //throw new Error('Failed to fetch NFT metadata'); | ||
| } | ||
| }; | ||
|
|
||
|
|
||
| export const getCollectionMetadataHandler = async (req, res) => { | ||
| const { chainName, tokenAddress } = req.params; | ||
| try { | ||
| const metadata = await getCollectionMetadataApi(chainName, tokenAddress); | ||
| if(metadata){ | ||
| res.json(metadata); | ||
| }else{ | ||
| res.status(404).json({ error: 'Contract not found' }); | ||
| } | ||
|
|
||
| } catch (error) { | ||
| res.status(500).json({ error: error.message }); | ||
| const { chainName, tokenAddress } = req.params; | ||
| try { | ||
| const metadata = await getCollectionMetadataApi(chainName, tokenAddress); | ||
| if (metadata) { | ||
| res.json(metadata); | ||
| } else { | ||
| res.status(404).json({ error: "Contract not found" }); | ||
| } | ||
| } catch (error) { | ||
| res.status(500).json({ error: error.message }); | ||
| } | ||
| }; | ||
|
|
||
| export const getNftMetadataHandler = async (req, res) => { | ||
| const { chainName, tokenAddress, tokenId } = req.params; | ||
| const resyncMetadata = req.query.resyncMetadata || false; | ||
| try { | ||
| const contract = await getCollectionMetadataApi(chainName, tokenAddress); | ||
| if(!contract){ | ||
| return res.status(404).json({ error: 'Contract not found' }); | ||
| } | ||
| const tokenData = await getNftMetadataApi(chainName, tokenAddress, tokenId, resyncMetadata); | ||
|
|
||
| if(tokenData){ | ||
| contract.token = tokenData.token_id; | ||
| } | ||
| res.json(contract); | ||
| } catch (error) { | ||
| res.status(500).json({ error: error.message }); | ||
| const { chainName, tokenAddress, tokenId } = req.params; | ||
| const resyncMetadata = req.query.resyncMetadata || false; | ||
| try { | ||
| const contract = await getCollectionMetadataApi(chainName, tokenAddress); | ||
| if (!contract) { | ||
| return res.status(404).json({ error: "Contract not found" }); | ||
| } | ||
| const tokenData = await getNftMetadataApi( | ||
| chainName, | ||
| tokenAddress, | ||
| tokenId, | ||
| resyncMetadata, | ||
| ); | ||
|
|
||
| if (tokenData) { | ||
| contract.token = tokenData.token_id; | ||
| } | ||
| res.json(contract); | ||
| } catch (error) { | ||
| res.status(500).json({ error: error.message }); | ||
| } | ||
| }; | ||
|
|
||
| export const getWalletByENSHandler = async (req, res) => { | ||
| const { ensName } = req.params; | ||
| try { | ||
| const metadata = await getWalletByENS(ensName); | ||
| res.json({ | ||
| walletAddress: metadata | ||
| }); | ||
| } catch (error) { | ||
| res.status(500).json({ error: error.message }); | ||
| } | ||
| const { ensName } = req.params; | ||
| try { | ||
| const metadata = await getWalletByENS(ensName); | ||
| res.json({ | ||
| walletAddress: metadata, | ||
| }); | ||
| } catch (error) { | ||
| res.status(500).json({ error: error.message }); | ||
| } | ||
| }; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.