Merge pull request #34 from DimensionDev/ci/3

Author: guanbinrui

package.json

@@ -1,6 +1,6 @@
 {
   "name": "mask-dsearch",
-  "version": "0.0.2",
+  "version": "0.0.3",
   "repository": "https://github.com/DimensionDev/Mask-DSearch.git",
   "license": "MIT",
   "author": "guanbinrui <[email protected]>",

src/providers/NFTScan.ts

@@ -1,5 +1,4 @@
 import axios from 'axios'
-import { orderBy } from 'lodash'
 import urlcat from 'urlcat'
 import {
   EVMChainId,
@@ -12,17 +11,85 @@ import {
   SolanaChainId,
   SourceType,
 } from '../type'
+import { orderBy } from 'lodash'
 import { delay } from '../utils'
 
 const baseURL = 'https://nftscan-proxy.r2d2.to'
 
-const config = {
-  chain: 'eth',
+const evmConfigs = [
+  {
+    chain: 'eth',
+    chainId: EVMChainId.Mainnet,
+    pluginID: NetworkPluginID.PLUGIN_EVM,
+    url: 'https://restapi.nftscan.com',
+    coin: 'ETH',
+    limit: 500,
+  },
+  {
+    chain: 'bnb',
+    chainId: EVMChainId.BNB,
+    pluginID: NetworkPluginID.PLUGIN_EVM,
+    url: 'https://bnbapi.nftscan.com',
+    coin: 'BNB',
+    limit: 500,
+  },
+  {
+    chain: 'polygon',
+    chainId: EVMChainId.Polygon,
+    pluginID: NetworkPluginID.PLUGIN_EVM,
+    url: 'https://polygonapi.nftscan.com',
+    coin: 'MATIC',
+    limit: 500,
+  },
+  {
+    chain: 'moonbeam',
+    chainId: EVMChainId.Moonbeam,
+    pluginID: NetworkPluginID.PLUGIN_EVM,
+    url: 'https://restapi.nftscan.com',
+    coin: 'GLMR',
+    limit: 200,
+  },
+  {
+    chain: 'arbitrum',
+    chainId: EVMChainId.Arbitrum,
+    pluginID: NetworkPluginID.PLUGIN_EVM,
+    url: 'https://arbitrumapi.nftscan.com',
+    coin: 'ETH',
+    limit: 200,
+  },
+  {
+    chain: 'optimism',
+    chainId: EVMChainId.Optimistic,
+    pluginID: NetworkPluginID.PLUGIN_EVM,
+    url: 'https://optimismapi.nftscan.com',
+    coin: 'ETH',
+    limit: 200,
+  },
+  // {
+  //   chain: 'cronos',
+  //   chainId: ChainId.xDai,
+  //   pluginID: NetworkPluginID.PLUGIN_EVM,
+  //   url: 'https://cronosapi.nftscan.com',
+  //   coin: 'CRO',
+  //   limit: 200
+  // },
+  {
+    chain: 'avalanche',
+    chainId: EVMChainId.Avalanche,
+    pluginID: NetworkPluginID.PLUGIN_EVM,
+    url: 'https://avaxapi.nftscan.com',
+    coin: 'AVAX',
+    limit: 200,
+  },
+]
+
+const solanaConfigs = {
+  chain: 'solana',
   chainId: EVMChainId.Mainnet,
-  pluginID: NetworkPluginID.PLUGIN_EVM,
-  url: 'https://restapi.nftscan.com',
-  coin: 'ETH',
-  limit: 500,
+  pluginID: NetworkPluginID.PLUGIN_SOLANA,
+  url: 'https://solana.nftscan.com',
+  coin: 'SOL',
+  limit: 200,
 }
 
 export type Response = {
@@ -99,17 +166,18 @@ export class NFTScanToken implements NonFungibleTokenProvider {
   async getTopTokens() {
     let result: NonFungibleToken[] = []
 
-    const url = urlcat(baseURL, '/api/v2/statistics/ranking/marketcap')
-    const list = await axios.get<Response>(url, {
-      headers: {
-        'content-type': 'application/json',
-        'x-app-chainid': config.chainId.toString(),
-      },
-    })
+    for (let config of evmConfigs) {
+      const url = urlcat(baseURL, '/api/v2/statistics/ranking/marketcap')
+      const list = await axios.get<Response>(url, {
+        headers: {
+          'content-type': 'application/json',
+          'x-app-chainid': config.pluginID === NetworkPluginID.PLUGIN_SOLANA ? 'solana' : config.chainId.toString(),
+        },
+      })
 
-    const data = list.data.data
-      .map(
-        (x, index) =>
+      const data = list.data.data
+        .map(
+          (x, index) =>
           ({
             pluginID: config.pluginID,
             address: x.contract_address,
@@ -120,10 +188,11 @@ export class NFTScanToken implements NonFungibleTokenProvider {
             logoURL: x.logo_url,
             rank: index + 1,
           } as NonFungibleToken),
-      )
-      .slice(0, config.limit)
+        )
+        .slice(0, config.limit)
 
-    result = [...result, ...data]
+      result = [...result, ...data]
+    }
 
     return result
   }
@@ -133,8 +202,6 @@ export class NFTScanToken implements NonFungibleTokenProvider {
   }
 }
 
-let cache: NonFungibleCollection[] | undefined = undefined
-
 export class NFTScanCollection implements NonFungibleCollectionProvider {
   async getSolanaCollection(name: string, rank: number) {
     const collectionURL = urlcat(baseURL, '/api/sol/collections/:collection_name', { collection_name: name })
@@ -229,27 +296,52 @@ export class NFTScanCollection implements NonFungibleCollectionProvider {
   async getCollections(): Promise<NonFungibleCollection[]> {
     let result: NonFungibleCollection[] = []
 
-    const chainId = config.chainId.toString()
-    const url = urlcat(baseURL, '/api/v2/statistics/ranking/marketcap')
+    for (let config of evmConfigs) {
+      const chainId = config.pluginID === NetworkPluginID.PLUGIN_SOLANA ? 'solana' : config.chainId.toString()
+      const url = urlcat(baseURL, '/api/v2/statistics/ranking/marketcap')
 
-    const list = await axios.get<CollectionsRankingResponse>(url, {
+      const list = await axios.get<CollectionsRankingResponse>(url, {
+        headers: {
+          'content-type': 'application/json',
+          'x-app-chainid': chainId,
+        },
+      })
+
+      const data = orderBy(list.data.data, ['market_cap'], ['desc']).slice(0, config.limit)
+
+      for (let i = 0; i < data.length; i++) {
+        const item = data[i]
+        try {
+          const collection = await this.getCollection(item.contract_address, chainId, i + 1, config)
+          if (collection) {
+            result = [...result, collection]
+          }
+        } catch (e) {
+          console.log(`Fetch error for ${config.chainId} ${item.contract_address} from nftscan`)
+        }
+      }
+    }
+
+    const solanaURL = urlcat(baseURL, '/api/sol/statistics/ranking/trade')
+
+    const list = await axios.get<SolanaCollectionsRankingResponse>(solanaURL, {
       headers: {
         'content-type': 'application/json',
-        'x-app-chainid': chainId,
+        'x-app-chainid': 'solana',
       },
     })
 
-    const data = orderBy(list.data.data, ['market_cap'], ['desc']).slice(0, config.limit)
+    const data = orderBy(list.data.data, ['market_cap'], ['desc']).slice(0, 200)
 
     for (let i = 0; i < data.length; i++) {
       const item = data[i]
       try {
-        const collection = await this.getCollection(item.contract_address, chainId, i + 1, config)
+        const collection = await this.getSolanaCollection(item.collection, i + 1)
         if (collection) {
           result = [...result, collection]
         }
       } catch (e) {
-        console.log(`Fetch error for ${config.chainId} ${item.contract_address} from nftscan`)
+        console.log(`Fetch error for solana ${item.collection} from nftscan`)
       }
     }
 
@@ -259,4 +351,4 @@ export class NFTScanCollection implements NonFungibleCollectionProvider {
   getProviderName(): SourceType {
     return SourceType.NFTScan
   }
-}
+}