import axios from 'axios' import { Button } from 'components/Button' import { dispatchQuery } from 'components/collections/queries/query' import { ContractPageHeader } from 'components/ContractPageHeader' import { AddressInput } from 'components/forms/FormInput' import { useInputState } from 'components/forms/FormInput.hooks' import Lister from 'components/Lister' import { useContracts } from 'contexts/contracts' import type { NextPage } from 'next' import { useRouter } from 'next/router' import { NextSeo } from 'next-seo' import { useEffect, useMemo, useState } from 'react' import { toast } from 'react-hot-toast' import { useQuery } from 'react-query' import { withMetadata } from 'utils/layout' import { links } from 'utils/links' const CollectionQueriesPage: NextPage = () => { const { baseMinter: baseMinterContract, vendingMinter: vendingMinterContract, sg721: sg721Contract } = useContracts() const type = 'config' const sg721ContractAddress = `sg721ContractState.value` const [doneList, setDoneList] = useState([]) const [processList, setProcessList] = useState([]) const [errorList, setErrorList] = useState([]) const [numTokens, setNumTokens] = useState(0) const [pers, setPers] = useState(0) const minterContractState = useInputState({ id: 'minter-contract-address', name: 'minter-contract-address', title: 'Minter Address', subtitle: 'Address of the Minter contract', }) const minterContractAddress = minterContractState.value const vendingMinterMessages = useMemo( () => vendingMinterContract?.use(minterContractAddress), [vendingMinterContract, minterContractAddress], ) const baseMinterMessages = useMemo( () => baseMinterContract?.use(minterContractAddress), [baseMinterContract, minterContractAddress], ) const sg721Messages = useMemo(() => sg721Contract?.use(sg721ContractAddress), [sg721Contract, sg721ContractAddress]) const router = useRouter() useEffect(() => { if (minterContractState.value.length > 0) { void router.replace({ query: { minterContractAddress } }) } }, [minterContractState.value]) useEffect(() => { const initial = new URL(document.URL).searchParams.get('minterContractAddress') if (initial && initial.length > 0) minterContractState.onChange(initial) console.log(minterContractState, minterContractAddress) }, []) const { data: response } = useQuery( [sg721Messages, baseMinterMessages, vendingMinterMessages, type] as const, async ({ queryKey }) => { const [_sg721Messages, _baseMinterMessages_, _vendingMinterMessages, _type] = queryKey // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment const result = await dispatchQuery({ vendingMinterMessages: _vendingMinterMessages, baseMinterMessages: _baseMinterMessages_, sg721Messages: _sg721Messages, type: _type, }) return result }, { placeholderData: null, onError: (error: any) => { toast.error(error.message, { style: { maxWidth: 'none' } }) }, enabled: Boolean(sg721ContractAddress && minterContractAddress && type), retry: false, }, ) useEffect(() => { if (response) { setNumTokens(response['num_tokens']) setPers(0) setDoneList([]) setProcessList([]) setErrorList([]) } else setNumTokens(0) }, [response]) useEffect(() => { if (numTokens !== 0) setPers((100 * doneList.length) / numTokens) else setPers(0) }, [doneList.length, numTokens]) function chooseAlternate(url: string, attempt: number) { let alternate switch (attempt) { case 1: { alternate = url.replace('ipfs://', 'https://cf-ipfs.com/ipfs/') break } case 2: { alternate = url.replace('ipfs://', 'https://ipfs.io/ipfs/') break } case 3: { alternate = url.replace('ipfs://', 'https://ipfs-gw.stargaze-apis.com/ipfs/') break } default: { alternate = url.replace('ipfs://', 'https://ipfs.stargaze.zone/ipfs/') break } } return alternate } async function warmOne(i: number, image: string, attempt: number, totalAttempt: number) { setProcessList((existingItems) => { return [i, ...existingItems] }) const link = image.replace('1', i.toString()) try { const result = await axios.get(chooseAlternate(link, attempt)) if (result.status === 200) { setDoneList((existingItems) => { return [i, ...existingItems] }) setProcessList((existingItems) => { const index = existingItems.indexOf(i, 0) if (index > -1) { existingItems.splice(index, 1) } return existingItems }) return } } catch (e) { console.log('hata: ', i, e) } if (totalAttempt !== 4) { void warmOne(i, image, attempt === 3 ? 0 : attempt + 1, attempt === 3 ? totalAttempt + 1 : totalAttempt) } else { setErrorList((existingItems) => { return [i, ...existingItems] }) setProcessList((existingItems) => { const index = existingItems.indexOf(i, 0) if (index > -1) { existingItems.splice(index, 1) } return existingItems }) } } async function warmingProcess(url: string, attempt: number) { const link = `${chooseAlternate(url, attempt)}/1` try { // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment const { data, status } = await axios.get(link) if (status === 200) { // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access for (let i = 1; i <= response['num_tokens']; i++) { // eslint-disable-next-line @typescript-eslint/no-unsafe-argument, @typescript-eslint/no-unsafe-member-access void warmOne(i, data.image, 0, 0) } } else if (attempt < 3) { void warmingProcess(url, attempt + 1) } else toast.error('File can not be reachable at the moment! Please try again later...') } catch (e) { console.log(e) } } return (
Total
Warmed
Percentage
{numTokens}
{doneList.length}
{(Math.round(pers * 100) / 100).toFixed(2)}%
{errorList.map((value: number, index: number) => { return })}
) } export default withMetadata(CollectionQueriesPage, { center: false })