searching/searching-front/services/domain-watcher.ts

import tonweb from "tonweb"
import {
  JettonApi,
  DNSApi,
  NFTApi,
  RawBlockchainApi,
  SubscriptionApi,
  TraceApi,
  WalletApi,
  Configuration,
} from "tonapi-sdk-js"
import db from "../db/index"
import axios from "axios"
import { getTonProxy } from "./helpers"

interface SearchNFTItemsParams {
  limit: number
  offset: number
}

const getFullUrl = (dmn: string) => `http://${dmn}`
const upsertDmn = async (dmn: string, available: boolean) => {
  const domainFromDB = await db.nftDomain.findFirst({where:{address: getFullUrl(dmn)}})
  const shouldUpdateFirstAvailableDate = !domainFromDB?.firstAvailableDate && available;

  const upsertObj = { available, address: getFullUrl(dmn) };
  if(shouldUpdateFirstAvailableDate){
    upsertObj.firstAvailableDate = new Date();
  }
  return await db.nftDomain.upsert({
    where: {
      address: getFullUrl(dmn),
    },
    update: upsertObj,
    create: upsertObj,
  })
}


const wait = (time: number) => new Promise((resolve) => setTimeout(() => resolve(true), time))

const searchNFTItems = async ({ limit, offset }: SearchNFTItemsParams) => {
  try {
    console.log(`Start search limit:${limit}, offset:${offset}`)
    await wait(1000)
    const { data } = await axios.get(
      `https://tonapi.io/v1/nft/searchItems?collection=EQC3dNlesgVD8YbAazcauIrXBPfiVhMMr5YYk2in0Mtsz0Bz&include_on_sale=false&limit=${limit}&offset=${offset}`,
      {
        headers: {
          // 'Authorization': 'Bearer '+ '6c456b1e31217a79e121dcb9b506c280358d58bc86659bdbac1d737bfc3691fb',
        },
      }
    )
    return data.nft_items
  } catch (e) {
    return searchNFTItems({ limit, offset })
  }
}

const portion = 1000

const fetchTonSite = async (url: string) => {
  try {
    const urlToFetch = `http://${url}/`
    const response = await axios.get(urlToFetch, {
      proxy: getTonProxy(),
    })
    if (!response.data) {
      console.log("Error fetch")
      throw "err"
    }
    return url
  } catch (e) {
    throw url
  }
}

const main = async () =>
  new Promise(async (resolve) => {
    // Receive typed array of owner nfts
    let count = 0
    while (true) {
      // в nftItems 1000 сайтов
      const nftItems = await searchNFTItems({
        limit: portion,
        offset: count * portion,
      })
      if (nftItems.length) {
        console.time('fetchDomain')
        const promises1: Promise<unknown>[] = []
        for (let i = 0; i < nftItems.length; i++) {
          const nftDomainItem = nftItems[i]
          if (nftDomainItem.dns) {
            
            promises1.push(fetchTonSite(nftDomainItem.dns)
              .then(async (dmn) => {
                console.log("success dmn", dmn)
                upsertDmn(dmn, true)
              })
              .catch((dmn) => {
                upsertDmn(dmn,false)
              }))
              
          }
        }
        count++
        await Promise.all(promises1)
        console.timeEnd('fetchDomain')
        continue
      }
      break
    }

    console.log("Finish fetch nft")
    setTimeout(() => {
      resolve(true)
    }, 3000)
  })

export default main