TW-2021 Add an endpoint for Youves stats

package.json

@@ -11,12 +11,12 @@
     "@ethersproject/strings": "^5.7.0",
     "@ethersproject/transactions": "^5.7.0",
     "@stablelib/random": "^1.0.2",
-    "@taquito/rpc": "14.0.0",
-    "@taquito/taquito": "14.0.0",
-    "@taquito/tzip12": "14.0.0",
-    "@taquito/tzip16": "14.0.0",
-    "@taquito/utils": "14.0.0",
-    "axios": "^0.27.2",
+    "@taquito/rpc": "^23.0.0",
+    "@taquito/taquito": "^23.0.0",
+    "@taquito/tzip12": "^23.0.0",
+    "@taquito/tzip16": "^23.0.0",
+    "@taquito/utils": "^23.0.0",
+    "@temple-wallet/youves-sdk": "1.0.0-beta.3",
     "bignumber.js": "^9.1.0",
     "body-parser": "^1.20.2",
     "cors": "^2.8.5",
@@ -70,5 +70,9 @@
     "ts-prune": "^0.10.3",
     "typescript": "^5",
     "typescript-eslint": "^7"
+  },
+  "resolutions": {
+    "axios": "0.27.2",
+    "bignumber.js": "9.1.0"
   }
 }

src/index.ts

@@ -42,6 +42,7 @@ import { getSignedMoonPayUrl } from './utils/moonpay/get-signed-moonpay-url';
 import SingleQueryDataProvider from './utils/SingleQueryDataProvider';
 import { getExchangeRates } from './utils/tokens';
 import { getWertSessionId } from './utils/wert';
+import { youvesStatsProvider } from './utils/youves';
 
 const PINO_LOGGER = {
   logger: logger.child({ name: 'web' }),
@@ -411,6 +412,8 @@ app.post('/api/temple-tap/check-airdrop-confirmation', tezosSigAuthMiddleware, (
   handleTempleTapApiProxyRequest(req, res, 'v1/check-airdrop-address-confirmation')
 );
 
+app.get('/api/youves/stats', makeProviderDataRequestHandler(youvesStatsProvider));
+
 // start the server listening for requests
 const port = Boolean(process.env.PORT) ? process.env.PORT : 3000;
 app.listen(port, () => console.info(`Server is running on port ${port}...`));

src/utils/tezos.ts

@@ -28,6 +28,7 @@ class LambdaViewSigner implements Signer {
 
 const lambdaSigner = new LambdaViewSigner();
 const michelEncoder = new MichelCodecPacker();
-const tezosToolkit = new TezosToolkit(RPC_URL);
+
+export const tezosToolkit = new TezosToolkit(RPC_URL);
 tezosToolkit.setSignerProvider(lambdaSigner);
 tezosToolkit.setPackerProvider(michelEncoder);

src/utils/youves.ts

@@ -0,0 +1,110 @@
+import {
+  BailoutPool,
+  contracts,
+  AssetDefinition,
+  createEngine,
+  Storage,
+  StorageKey,
+  StorageKeyReturnType,
+  UnifiedStaking,
+  mainnetTokens,
+  mainnetNetworkConstants
+} from '@temple-wallet/youves-sdk';
+import BigNumber from 'bignumber.js';
+import memoizee from 'memoizee';
+
+import SingleQueryDataProvider from './SingleQueryDataProvider';
+import { tezosToolkit as tezos } from './tezos';
+import { getExchangeRates } from './tokens';
+
+const YOUVES_INDEXER_URL = 'https://indexer.youves.com/v1/graphql';
+const INDEXER_CONFIG = { url: YOUVES_INDEXER_URL, headCheckUrl: '' };
+const MULTIPLIER = 100;
+const ubtcToken = contracts.mainnet.find(token => token.id === 'uBTC')!;
+const uusdToken = contracts.mainnet.find(token => token.id === 'uUSD')!;
+const youToken = mainnetTokens.youToken;
+
+class MemoryStorage implements Storage {
+  public storage: Map<string, any>;
+
+  constructor() {
+    this.storage = new Map();
+  }
+  public async set<K extends StorageKey>(key: K, value: StorageKeyReturnType[K]): Promise<void> {
+    this.storage.set(key, value);
+  }
+  public async get<K extends StorageKey>(key: K): Promise<StorageKeyReturnType[K]> {
+    return this.storage.get(key);
+  }
+  public async delete<K extends StorageKey>(key: K): Promise<void> {
+    this.storage.delete(key);
+  }
+  public async clear() {
+    this.storage.clear();
+  }
+}
+
+const unifiedStaking = new UnifiedStaking(tezos, INDEXER_CONFIG, mainnetNetworkConstants);
+const bailoutPool = new BailoutPool(tezos, INDEXER_CONFIG, mainnetNetworkConstants);
+
+const createEngineMemoized = memoizee(
+  (token: AssetDefinition) =>
+    createEngine({
+      tezos,
+      contracts: token,
+      storage: new MemoryStorage(),
+      indexerConfig: INDEXER_CONFIG,
+      tokens: mainnetTokens,
+      activeCollateral: token.collateralOptions[0],
+      networkConstants: mainnetNetworkConstants
+    }),
+  { normalizer: ([token]) => token.id }
+);
+
+const withToPercentage =
+  <A extends unknown[]>(fn: (...args: A) => Promise<BigNumber>) =>
+  async (...args: A) => {
+    const rawApr = await fn(...args);
+
+    return Number(rawApr.multipliedBy(MULTIPLIER));
+  };
+
+const getV2YOUTokenApr = withToPercentage((assetToUsdExchangeRate: BigNumber, governanceToUsdExchangeRate: BigNumber) =>
+  unifiedStaking.getAPR(assetToUsdExchangeRate, governanceToUsdExchangeRate)
+);
+
+const getV3YOUTokenApr = withToPercentage(() => bailoutPool.getAPR());
+
+const getYouvesTokenApr = withToPercentage((token: AssetDefinition) =>
+  createEngineMemoized(token).getSavingsPoolV3YearlyInterestRate()
+);
+
+export const youvesStatsProvider = new SingleQueryDataProvider(60000, async () => {
+  const exchangeRates = await getExchangeRates();
+  const youToUsdExchangeRate = exchangeRates.find(
+    rate => rate.tokenAddress === youToken.contractAddress && rate.tokenId === youToken.tokenId
+  )!.exchangeRate;
+
+  const aprResults = await Promise.all([
+    Promise.all([
+      getV2YOUTokenApr(youToUsdExchangeRate, youToUsdExchangeRate).then(value => ({ v2: value })),
+      getV3YOUTokenApr().then(value => ({ v3: value }))
+    ]),
+    getYouvesTokenApr(ubtcToken),
+    getYouvesTokenApr(uusdToken)
+  ]);
+
+  return {
+    apr: Object.fromEntries(
+      [youToken, ubtcToken, uusdToken].map((asset, index) => {
+        const rawResult = aprResults[index];
+        const { contractAddress, tokenId } = 'token' in asset ? asset.token : asset;
+
+        return [
+          `${contractAddress}_${tokenId}`,
+          typeof rawResult === 'number' ? rawResult : Object.assign(...rawResult)
+        ];
+      })
+    )
+  };
+});