Add coinrank v2 endpoint

Author: paullinator

src/coinrankEngine.ts

@@ -17,15 +17,19 @@ const NUM_PAGES = 8
 
 const { defaultFiatCode } = config
 
-export const coinrankEngine = async (): Promise<void> => {
+export const coinrankEngine = async (
+  runOnce: boolean = false
+): Promise<void> => {
   while (true) {
     try {
       const { coinrankOffsetSeconds, coinrankIntervalSeconds } = config
-      const delay = getDelay({
-        now: new Date(),
-        intervalSeconds: coinrankIntervalSeconds,
-        offsetSeconds: coinrankOffsetSeconds
-      })
+      const delay = runOnce
+        ? 0
+        : getDelay({
+            now: new Date(),
+            intervalSeconds: coinrankIntervalSeconds,
+            offsetSeconds: coinrankOffsetSeconds
+          })
 
       logger(`**** COINRANK ENGINE SNOOZING ${delay / 1000}s`)
       await snooze(delay)
@@ -76,5 +80,6 @@ export const coinrankEngine = async (): Promise<void> => {
       })
       logger(message)
     }
+    if (runOnce) break
   }
 }

src/exchangeRateRouter.ts

@@ -351,7 +351,7 @@ const sendExchangeRates: express.RequestHandler = (req, res, next): void => {
   res.json({ data: exReq.requestedRatesResult.data })
 }
 
-const getRedisMarkets = async (
+export const getRedisMarkets = async (
   fiatCode: string
 ): Promise<CoinrankRedis | undefined> => {
   const { ratesServerAddress } = config

src/v3/index.ts

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

src/v3/legacyRouter.ts

@@ -1,7 +1,8 @@
 import type { HttpResponse } from 'serverlet'
 import type { ExpressRequest } from 'serverlet/express'
 
-import { asExchangeRatesReq } from '../exchangeRateRouter'
+import { asExchangeRatesReq, getRedisMarkets } from '../exchangeRateRouter'
+import { asCoinrankReq, type CoinrankReq } from '../types'
 import { ratesV3, v2CurrencyCodeMapSyncDoc } from './router'
 import { asGetRatesParams } from './types'
 import { convertV2, convertV3ToV2 } from './v2converter'
@@ -70,3 +71,73 @@ export const rateV2 = async (
     }
   }
 }
+
+export const sendCoinranksV2 = 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: CoinrankReq
+  try {
+    query = asCoinrankReq(request.req.query)
+  } catch (e) {
+    return {
+      status: 400,
+      headers: { 'content-type': 'application/json' },
+      body: JSON.stringify({ error: `Invalid request query ${String(e)}` })
+    }
+  }
+  const { fiatCode, start, length } = query
+
+  try {
+    if (start < 1 || start > 2000) {
+      return {
+        status: 400,
+        headers: { 'content-type': 'application/json' },
+        body: JSON.stringify({
+          error: `Invalid start param: ${start}. Must be between 1-2000`
+        })
+      }
+    }
+    if (length < 1 || length > 100) {
+      return {
+        status: 400,
+        headers: { 'content-type': 'application/json' },
+        body: JSON.stringify({
+          error: `Invalid length param: ${length}. Must be between 1-100`
+        })
+      }
+    }
+    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 data = markets.slice(start - 1, start + length)
+
+    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

@@ -1,6 +1,7 @@
 import { asArray, asMaybe, asNumber, asObject, asString } from 'cleaners'
 import { asCouchDoc, syncedDocument } from 'edge-server-tools'
 
+import { coinrankEngine } from '../../../coinrankEngine'
 import { config } from '../../../config'
 import { dateOnly, snooze } from '../../../utils/utils'
 import { TOKEN_TYPES_KEY } from '../../constants'
@@ -355,6 +356,12 @@ export const coingecko: RateProvider = {
     {
       frequency: 'day',
       engine: tokenMapping
+    },
+    {
+      frequency: 120,
+      engine: async () => {
+        await coinrankEngine(true)
+      }
     }
   ]
 }