rename resolv

Author: slasher125

src/adaptors/meteora/index.js

@@ -0,0 +1,34 @@
+const standardPools = 'https://app.meteora.ag/amm/pools/v1?page=0&size=100';
+const clPools =
+  'https://app.meteora.ag/clmm-api/pair/all_by_groups?page=0&limit=100&unknown=true&sort_key=volume&order_by=desc';
+
+const apy = async () => {
+  const response = await fetch(standardPools);
+  const data = await response.json();
+  return data.data.map((pool) => {
+    return {
+      pool: pool.pool_address,
+      chain: 'Solana',
+      project: 'meteora',
+      symbol: pool.pool_name,
+      underlyingTokens: p.pool_token_mints,
+      tvlUsd: pool.pool_tvl,
+      apyBase: pool.day.feeApr,
+      apyReward,
+      rewardTokens:
+        apyReward > 0
+          ? pool?.rewardDefaultInfos?.map((r) => r.mint?.address)
+          : [],
+      apyBase7d: pool.week.feeApr,
+      volumeUsd1d: pool.day.volume,
+      volumeUsd7d: pool.week.volume,
+      poolMeta: `${pool.type} - ${pool.feeRate * 100}%`,
+      url:
+        pool.type.toLowerCase() === 'concentrated'
+          ? `https://raydium.io/clmm/create-position/?pool_id=${pool.id}`
+          : `https://raydium.io/liquidity/increase/?mode=add&pool_id=${pool.id}`,
+    };
+  });
+};
+
+module.exports = { apy };

src/adaptors/resolv-rlp/index.js

@@ -3,13 +3,21 @@ const axios = require('axios');
 const utils = require('../utils');
 const ethers = require('ethers');
 
+// RLP Constants
+const RLP = '0x4956b52aE2fF65D74CA2d61207523288e4528f96';
+const rlpPriceStorage = '0xaE2364579D6cB4Bbd6695846C1D595cA9AF3574d';
+const topic0priceSet =
+  '0x2f0fe01aa6daff1c7bb411a324bdebe55dc2cd1e0ff2fc504b7569346e7d7d5a';
+const priceSetInterface = new ethers.utils.Interface([
+  'event PriceSet(bytes32 indexed key, uint256 price, uint256 timestamp);',
+]);
+
+// stUSR Constants
 const stUSR = '0x6c8984bc7DBBeDAf4F6b2FD766f16eBB7d10AAb4';
 const USR = '0x66a1E37c9b0eAddca17d3662D6c05F4DECf3e110';
 const rewardDistributor = '0xbE23BB6D817C08E7EC4Cd0adB0E23156189c1bA9';
-
 const topic0rewardDistributed =
   '0x3863fc447b7dde3f3f5a5ca0b5b06a5fd3570963a1a29918f09036746293f658';
-
 const rewardDistributedInterface = new ethers.utils.Interface([
   'event RewardDistributed(bytes32 indexed idempotencyKey, uint256 totalShares, uint256 totalUSRBefore, uint256 totalUSRAfter, uint256 stakingReward, uint256 feeReward)',
 ]);
@@ -50,6 +58,62 @@ const calculateStUSRApy = (logDescription) => {
   return ((sharesRateAfter - sharesRateBefore) / sharesRateBefore) * 365;
 };
 
+const rlpPool = async () => {
+  try {
+    const totalSupply = await getTotalSupply(RLP);
+    const currentBlock = await sdk.api.util.getLatestBlock('ethereum');
+    const currentDate = new Date(currentBlock.timestamp * 1000);
+    const previousStartOfDay =
+      new Date(currentDate).setHours(0, 0, 0, 0) - 2 * DAY_IN_MS;
+
+    const [fromBlock] = await utils.getBlocksByTime(
+      [previousStartOfDay / 1000],
+      'ethereum'
+    );
+    const toBlock = currentBlock.block;
+
+    const logs = (
+      await sdk.api.util.getLogs({
+        target: rlpPriceStorage,
+        topic: '',
+        fromBlock,
+        toBlock,
+        keys: [],
+        chain: 'ethereum',
+        topics: [topic0priceSet],
+      })
+    ).output.sort((a, b) => a.blockNumber - b.blockNumber);
+
+    let aprBase = 0;
+    if (logs.length >= 2) {
+      const lastLpPrice = priceSetInterface.parseLog(logs[logs.length - 1]).args
+        .price;
+      const previousLpPrice = priceSetInterface.parseLog(logs[logs.length - 2])
+        .args.price;
+
+      aprBase = ((lastLpPrice - previousLpPrice) / previousLpPrice) * 365;
+    }
+
+    const price =
+      logs.length > 0
+        ? priceSetInterface.parseLog(logs[logs.length - 1]).args.price / 1e18
+        : await getTokenPrice(RLP);
+    const tvl = totalSupply * price;
+
+    return {
+      pool: RLP,
+      symbol: 'RLP',
+      chain: 'ethereum',
+      project: 'resolv',
+      tvlUsd: tvl,
+      apyBase: aprBase * 100,
+    };
+  } catch (error) {
+    console.error('Error fetching RLP pool data:', error);
+    throw error;
+  }
+};
+
 const stUsrPool = async () => {
   try {
     const totalSupply = await getTotalSupply(stUSR);
@@ -91,7 +155,7 @@ const stUsrPool = async () => {
       pool: stUSR,
       symbol: 'stUSR',
       chain: 'ethereum',
-      project: 'resolv-usr',
+      project: 'resolv',
       tvlUsd: tvl,
       apyBase: aprBase * 100,
     };
@@ -103,7 +167,7 @@ const stUsrPool = async () => {
 
 const apy = async () => {
   try {
-    return [await stUsrPool()];
+    return [await rlpPool(), await stUsrPool()];
   } catch (error) {
     console.error('Error fetching APYs:', error);
     throw error;