[limit] add limit to vault & user stats

codegen.ts

@@ -3,8 +3,8 @@ import type { CodegenConfig } from '@graphql-codegen/cli'
 import { Network } from './src/utils/enums'
 import configs from './src/utils/configs'
 
-// TODO change
-let network: Network = Network.Mainnet
+
+let network: Network = Network.Holesky
 
 if (process.env.NETWORK === 'mainnet') {
   network = Network.Mainnet

src/graphql/subgraph/stats/fiatRatesQuery.graphql

@@ -1,5 +1,5 @@
 query FiatRates {
-  networks {
+  exchangeRates {
     assetsUsdRate
     usdToEurRate
     usdToGbpRate

src/graphql/subgraph/vault/userRewardsQuery.graphql

@@ -1,8 +1,10 @@
 query UserRewards(
   $where: AllocatorStats_filter
+  $limit: Int
 ) {
   allocator: allocatorStats_collection(
     interval: day
+    first: $limit
     where: $where
   ) {
     apy

src/graphql/subgraph/vault/vaultStatsQuery.graphql

@@ -1,6 +1,7 @@
-query VaultStats($vaultAddress: String!  $timestamp: Timestamp!) {
+query VaultStats($vaultAddress: String!  $timestamp: Timestamp!, $limit: Int) {
   vaultStats: vaultStats_collection(
     interval: day
+    first: $limit
     where: {
       vault: $vaultAddress
       timestamp_gte: $timestamp,

src/methods/utils/getFiatRates/index.ts

@@ -8,7 +8,7 @@ type GetFiatRatesInput = {
 
 const getGnoRate = () => graphql.subgraph.stats.fetchFiatRatesQuery({
   url: configs[Network.Gnosis].api.subgraph,
-  modifyResult: (data) => Number(data.networks[0].assetsUsdRate),
+  modifyResult: (data) => Number(data.exchangeRates[0].assetsUsdRate),
 })
 
 const getFiatRates = (values: GetFiatRatesInput) => {
@@ -26,7 +26,7 @@ const getFiatRates = (values: GetFiatRatesInput) => {
         usdToKrwRate,
         usdToAudRate,
         swiseUsdRate,
-      } = data.networks[0]
+      } = data.exchangeRates[0]
 
       let assetUsd = Number(assetsUsdRate)
 

src/methods/vault/requests/getUserRewards/index.ts

@@ -11,6 +11,12 @@ type GetUserRewardsInput = {
   vaultAddress: string
 }
 
+const calculateLimit = (dateTo: number, dateFrom: number): number => {
+  const millisecondsInDay = 1000 * 60 * 60 * 24
+
+  return Math.floor((dateTo - dateFrom) / millisecondsInDay)
+}
+
 const getUserRewards = async (input: GetUserRewardsInput): Promise<MergedReward[]> => {
   const { options, vaultAddress, userAddress, dateFrom, dateTo } = input
 
@@ -29,13 +35,16 @@ const getUserRewards = async (input: GetUserRewardsInput): Promise<MergedReward[
     ? configs[Network.Mainnet].api.subgraph
     : subgraphUrl
 
+  const limit = calculateLimit(dateTo, dateFrom)
+
   const timestampTo = String(dateTo * 1_000)
   const timestampFrom = String(dateFrom * 1_000)
 
   const [ rewards, networkFiatRates, gnosisFiatRates ] = await Promise.all([
     graphql.subgraph.vault.fetchUserRewardsQuery({
       url: subgraphUrl,
       variables: {
+        limit,
         where: {
           timestamp_lte: timestampTo,
           timestamp_gte: timestampFrom,

src/methods/vault/requests/getUserStats/index.ts

@@ -1,6 +1,5 @@
 import { apiUrls, validateArgs, calculateUserStats, getTimestamp } from '../../../../utils'
 import graphql from '../../../../graphql'
-import { StakeWiseSubgraphGraph } from '../../../../types/graphql/subgraph'
 
 
 type GetUserStatsInput = {
@@ -19,6 +18,7 @@ const getUserStats = (input: GetUserStatsInput) => {
   return graphql.subgraph.vault.fetchUserRewardsQuery({
     url: apiUrls.getSubgraphqlUrl(options),
     variables: {
+      limit: daysCount,
       where: {
         timestamp_gte: String(getTimestamp(daysCount)),
         allocator_: {

src/methods/vault/requests/getVaultStats/index.ts

@@ -21,6 +21,7 @@ const getVaultStats = (input: GetVaultStatsInput) => {
     url: apiUrls.getSubgraphqlUrl(options),
     variables: {
       timestamp,
+      limit: daysCount,
       vaultAddress: vaultAddress.toLowerCase(),
     },
     modifyResult: modifyVaultStats,