TW-1416: BTC exchange rate

src/index.ts

@@ -30,14 +30,14 @@
 import { getAliceBobOrderInfo } from './utils/alice-bob/get-alice-bob-order-info';
 import { getAliceBobPairInfo } from './utils/alice-bob/get-alice-bob-pair-info';
 import { getAliceBobPairsInfo } from './utils/alice-bob/get-alice-bob-pairs-info';
+import { btcExchangeRateProvider, tezExchangeRateProvider } from './utils/coingecko';
 import { CodedError } from './utils/errors';
 import { coinGeckoTokens } from './utils/gecko-tokens';
 import { getExternalApiErrorPayload, isDefined, isNonEmptyString } from './utils/helpers';
 import logger from './utils/logger';
 import { getSignedMoonPayUrl } from './utils/moonpay/get-signed-moonpay-url';
 import { getSigningNonce } from './utils/signing-nonce';
 import SingleQueryDataProvider from './utils/SingleQueryDataProvider';
-import { tezExchangeRateProvider } from './utils/tezos';
 import { getExchangeRates } from './utils/tokens';
 
 const PINO_LOGGER = {
@@ -156,7 +156,7 @@
     await redisClient.lpush('notifications', JSON.stringify(newNotification));
 
     res.status(200).send({ message: 'Notification added successfully', notification: newNotification });
   } catch (error: any) {
     res.status(500).send({ error: error.message });
   }
 });
@@ -175,6 +175,7 @@
 });
 
 app.get('/api/exchange-rates/tez', makeProviderDataRequestHandler(tezExchangeRateProvider));
+app.get('/api/exchange-rates/btc', makeProviderDataRequestHandler(btcExchangeRateProvider));
 
 app.get('/api/exchange-rates', async (_req, res) => {
   const tokensExchangeRates = await getExchangeRates();
@@ -342,7 +343,7 @@
     await startMagicSquareQuest(req.body);
 
     res.status(200).send({ message: 'Quest successfully started' });
   } catch (error: any) {
     console.error(error);
 
     if (error instanceof CodedError) {
@@ -356,7 +357,7 @@
 app.get('/api/magic-square-quest/participants', basicAuth, async (req, res) => {
   try {
     res.status(200).send(await getMagicSquareQuestParticipants());
   } catch (error: any) {
     console.error(error);
 
     if (error instanceof CodedError) {
@@ -370,10 +371,10 @@
 app.get('/api/signing-nonce', (req, res) => {
   try {
     const pkh = req.query.pkh;
     if (!pkh || typeof pkh !== 'string') throw new Error('PKH is not a string');
 
     res.status(200).send(getSigningNonce(pkh));
   } catch (error: any) {
     console.error(error);
 
     if (error instanceof CodedError) {

src/utils/coingecko.ts

@@ -1,4 +1,7 @@
-import { range } from './helpers';
+import { AxiosError } from 'axios';
+
+import { isDefined, range } from './helpers';
+import logger from './logger';
 import { makeBuildQueryFn } from './makeBuildQueryFn';
 import SingleQueryDataProvider from './SingleQueryDataProvider';
 
@@ -89,3 +92,29 @@ export const getMarketsBySymbols = async (symbols: string[]) => {
 
   return chunks.flat();
 };
+
+const createCoingeckoExchangeRateProvider = (tokenSymbol: string) =>
+  new SingleQueryDataProvider(60000, async () => {
+    try {
+      const [market] = await getMarketsBySymbols([tokenSymbol]);
+
+      return market.current_price;
+    } catch (e) {
+      if (!(e instanceof AxiosError)) {
+        logger.error(`Request for ${tokenSymbol} exchange rate failed with unknown error`);
+      } else if (isDefined(e.response) && isDefined(e.response.data)) {
+        logger.error(
+          `Request for ${tokenSymbol} exchange rate failed with status ${e.response.status} and message ${e.response.data}`
+        );
+      } else if (isDefined(e.response) && isDefined(e.response.status)) {
+        logger.error(`Request for ${tokenSymbol} exchange rate failed with status ${e.response.status}`);
+      } else {
+        logger.error(`Request for ${tokenSymbol} exchange rate failed without response`);
+      }
+
+      throw e;
+    }
+  });
+
+export const tezExchangeRateProvider = createCoingeckoExchangeRateProvider('xtz');
+export const btcExchangeRateProvider = createCoingeckoExchangeRateProvider('btc');

src/utils/tezos.ts

@@ -1,13 +1,8 @@
 import { compose, MichelCodecPacker, Signer, TezosToolkit } from '@taquito/taquito';
 import { tzip12 } from '@taquito/tzip12';
 import { tzip16 } from '@taquito/tzip16';
-import { AxiosError } from 'axios';
 import memoizee from 'memoizee';
 
-import { getMarketsBySymbols } from './coingecko';
-import { isDefined } from './helpers';
-import logger from './logger';
-import SingleQueryDataProvider from './SingleQueryDataProvider';
 import { BcdTokenData } from './tzkt';
 
 const RPC_URL = process.env.RPC_URL ?? 'https://mainnet-node.madfish.solutions';
@@ -54,30 +49,6 @@ export const getStorage = memoizee(
   { promise: true, maxAge: 30000 }
 );
 
-const getTezExchangeRate = async () => {
-  try {
-    const [xtzMarket] = await getMarketsBySymbols(['xtz']);
-
-    return xtzMarket.current_price;
-  } catch (e) {
-    if (!(e instanceof AxiosError)) {
-      logger.error('Request for TEZ exchange rate failed with unknown error');
-    } else if (isDefined(e.response) && isDefined(e.response.data)) {
-      logger.error(
-        `Request for TEZ exchange rate failed with status ${e.response.status} and message ${e.response.data}`
-      );
-    } else if (isDefined(e.response) && isDefined(e.response.status)) {
-      logger.error(`Request for TEZ exchange rate failed with status ${e.response.status}`);
-    } else {
-      logger.error('Request for TEZ exchange rate failed without response');
-    }
-
-    throw e;
-  }
-};
-
-export const tezExchangeRateProvider = new SingleQueryDataProvider(60000, getTezExchangeRate);
-
 export class MetadataParseError extends Error {}
 
 export const getTokenMetadata = memoizee(

src/utils/tokens.ts

@@ -1,10 +1,10 @@
 import { BigNumber } from 'bignumber.js';
 
 import { redisClient } from '../redis';
+import { tezExchangeRateProvider } from './coingecko';
 import { isDefined } from './helpers';
 import logger from './logger';
 import SingleQueryDataProvider, { SingleQueryDataProviderState } from './SingleQueryDataProvider';
-import { tezExchangeRateProvider } from './tezos';
 import {
   getThreeRouteExchangeRates,
   getThreeRouteTokens,
@@ -40,14 +40,14 @@
   }
 
   const exchangeRatesWithHoles = await Promise.all(
     tokens!
       .filter(
         (token): token is ThreeRouteFa12Token | ThreeRouteFa2Token => token.standard !== ThreeRouteStandardEnum.xtz
       )
       .map(async (token): Promise<TokenExchangeRateEntry | undefined> => {
         const { contract, tokenId: rawTokenId, symbol } = token;
         const tokenId = isDefined(rawTokenId) ? Number(rawTokenId) : undefined;
         const { ask, bid } = exchangeRatesInputs![symbol] ?? { ask: 0, bid: 0 };
 
         if (ask === 0 && bid === 0) {
           logger.error(`Failed to get exchange rate for token ${token.symbol}`);