Add v2/coinrankAsset support

Author: paullinator

src/v3/index.ts

@@ -4,7 +4,12 @@ import { pickMethod, pickPath } from 'serverlet'
 import { makeExpressRoute } from 'serverlet/express'
 
 import { config } from '../config'
-import { ratesV2, rateV2, sendCoinranksV2 } from './legacyRouter'
+import {
+  ratesV2,
+  rateV2,
+  sendCoinrankAssetV2,
+  sendCoinranksV2
+} from './legacyRouter'
 import { heartbeatV3, ratesV3 } from './router'
 
 async function main(): Promise<void> {
@@ -17,6 +22,7 @@ function server(): void {
     '/v2/exchangeRate': pickMethod({ GET: rateV2 }),
     '/v2/exchangeRates': pickMethod({ POST: ratesV2 }),
     '/v2/coinrank': pickMethod({ GET: sendCoinranksV2 }),
+    '/v2/coinrankAsset/([^/]+)': pickMethod({ GET: sendCoinrankAssetV2 }),
     '/v3/rates': pickMethod({ POST: ratesV3 })
   })
 

src/v3/legacyRouter.ts

@@ -2,7 +2,12 @@ import type { HttpResponse } from 'serverlet'
 import type { ExpressRequest } from 'serverlet/express'
 
 import { asExchangeRatesReq, getRedisMarkets } from '../exchangeRateRouter'
-import { asCoinrankReq, type CoinrankReq } from '../types'
+import {
+  asCoinrankAssetReq,
+  asCoinrankReq,
+  type CoinrankAssetReq,
+  type CoinrankReq
+} from '../types'
 import { ratesV3, v2CurrencyCodeMapSyncDoc } from './router'
 import { asGetRatesParams } from './types'
 import { convertV2, convertV3ToV2 } from './v2converter'
@@ -141,3 +146,71 @@ export const sendCoinranksV2 = async (
     }
   }
 }
+
+export const sendCoinrankAssetV2 = async (
+  request: ExpressRequest
+): Promise<HttpResponse> => {
+  if (request.req.query == null) {
+    return {
+      status: 400,
+      headers: { 'content-type': 'application/json' },
+      body: JSON.stringify({ error: 'Invalid request query' })
+    }
+  }
+
+  let query: CoinrankAssetReq
+  try {
+    query = asCoinrankAssetReq(request.req.query)
+  } catch (e) {
+    return {
+      status: 400,
+      headers: { 'content-type': 'application/json' },
+      body: JSON.stringify({ error: `Invalid request query ${String(e)}` })
+    }
+  }
+  const { fiatCode } = query
+  const pathParts = request.path.split('/')
+  const assetId = pathParts[pathParts.length - 1]
+  if (assetId == null) {
+    return {
+      status: 400,
+      headers: { 'content-type': 'application/json' },
+      body: JSON.stringify({ error: 'Invalid request path' })
+    }
+  }
+  try {
+    const redisResult = await getRedisMarkets(fiatCode)
+
+    if (redisResult == null) {
+      return {
+        status: 400,
+        headers: { 'content-type': 'application/json' },
+        body: JSON.stringify({
+          error: `Unable to get results for fiatCode ${fiatCode}`
+        })
+      }
+    }
+
+    const { markets } = redisResult
+    const market = markets.find(m => m.assetId === assetId)
+    if (market == null) {
+      return {
+        status: 404,
+        headers: { 'content-type': 'application/json' },
+        body: JSON.stringify({ error: `assetId ${assetId} not found` })
+      }
+    }
+
+    return {
+      status: 200,
+      headers: { 'content-type': 'application/json' },
+      body: JSON.stringify({ data: market })
+    }
+  } catch (e: unknown) {
+    return {
+      status: 500,
+      headers: { 'content-type': 'application/json' },
+      body: JSON.stringify({ error: `Internal server error ${String(e)}` })
+    }
+  }
+}