Add legacy v2/coinrankList endpoint

Author: paullinator

src/v3/index.ts

@@ -8,6 +8,7 @@ import {
   ratesV2,
   rateV2,
   sendCoinrankAssetV2,
+  sendCoinrankListV2,
   sendCoinranksV2
 } from './legacyRouter'
 import { heartbeatV3, ratesV3 } from './router'
@@ -23,6 +24,7 @@ function server(): void {
     '/v2/exchangeRates': pickMethod({ POST: ratesV2 }),
     '/v2/coinrank': pickMethod({ GET: sendCoinranksV2 }),
     '/v2/coinrankAsset/([^/]+)': pickMethod({ GET: sendCoinrankAssetV2 }),
+    '/v2/coinrankList': pickMethod({ GET: sendCoinrankListV2 }),
     '/v3/rates': pickMethod({ POST: ratesV3 })
   })
 

src/v3/legacyRouter.ts

@@ -8,6 +8,7 @@ import {
   type CoinrankAssetReq,
   type CoinrankReq
 } from '../types'
+import { hgetallAsync } from '../utils/dbUtils'
 import { ratesV3, v2CurrencyCodeMapSyncDoc } from './router'
 import { asGetRatesParams } from './types'
 import { convertV2, convertV3ToV2 } from './v2converter'
@@ -214,3 +215,22 @@ export const sendCoinrankAssetV2 = async (
     }
   }
 }
+
+export const sendCoinrankListV2 = async (
+  request: ExpressRequest
+): Promise<HttpResponse> => {
+  try {
+    const data = await hgetallAsync('coingeckoassets')
+    return {
+      status: 200,
+      headers: { 'content-type': 'application/json' },
+      body: JSON.stringify({ data })
+    }
+  } catch (e: unknown) {
+    return {
+      status: 500,
+      headers: { 'content-type': 'application/json' },
+      body: JSON.stringify({ error: `Internal server error ${String(e)}` })
+    }
+  }
+}

src/v3/providers/coingecko/coingecko.ts

@@ -3,6 +3,9 @@ import { asCouchDoc, syncedDocument } from 'edge-server-tools'
 
 import { coinrankEngine } from '../../../coinrankEngine'
 import { config } from '../../../config'
+import { coingeckoAssetsInternal } from '../../../providers/coingecko'
+import type { AssetMap } from '../../../rates'
+import { hsetAsync } from '../../../utils/dbUtils'
 import { dateOnly, snooze } from '../../../utils/utils'
 import { TOKEN_TYPES_KEY } from '../../constants'
 import {
@@ -289,6 +292,17 @@ const getHistoricalRates = async (
   return out
 }
 
+const coingeckoAssetsEngine: RateEngine = async () => {
+  const assets = await coingeckoAssetsInternal(3000)
+  const assetMap: AssetMap = {}
+  for (const asset of assets) {
+    const currencyCode = asset.symbol.toUpperCase()
+    const { id } = asset
+    assetMap[currencyCode] ??= id
+  }
+  await hsetAsync('coingeckoassets', assetMap)
+}
+
 export const coingecko: RateProvider = {
   providerId: 'coingecko',
   type: 'api',
@@ -362,6 +376,10 @@ export const coingecko: RateProvider = {
       engine: async () => {
         await coinrankEngine(true)
       }
+    },
+    {
+      frequency: 'day',
+      engine: coingeckoAssetsEngine
     }
   ]
 }