[fix-export-rewards] fixed

stakewise · Feb 3, 2025 · a3e04ed · a3e04ed
1 parent 5bf8ab9
commit a3e04ed
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 4 deletions.
diff --git a/src/graphql/subgraph/stats/fiatByDayQuery.graphql b/src/graphql/subgraph/stats/fiatByDayQuery.graphql
@@ -1,9 +1,11 @@
 query FiatByDay(
+  $limit: Int!
   $dateTo: Timestamp!
   $dateFrom: Timestamp!
 ) {
   exchangeRate: exchangeRateStats_collection(
     interval: day
+    first: $limit
     where: {
       timestamp_gte: $dateFrom,
       timestamp_lte: $dateTo

diff --git a/src/methods/vault/requests/getUserRewards/index.ts b/src/methods/vault/requests/getUserRewards/index.ts
@@ -59,6 +59,7 @@ const getUserRewards = async (input: GetUserRewardsInput): Promise<MergedReward[
     graphql.subgraph.stats.fetchFiatByDayQuery({
       url: ratesUrl,
       variables: {
+        limit,
         dateTo: timestampTo,
         dateFrom: timestampFrom,
       },
@@ -68,13 +69,15 @@ const getUserRewards = async (input: GetUserRewardsInput): Promise<MergedReward[
       ? graphql.subgraph.stats.fetchFiatByDayQuery({
         url: subgraphUrl,
         variables: {
+          limit,
           dateTo: timestampTo,
           dateFrom: timestampFrom,
         },
-        modifyResult: (data) => (data.exchangeRate || []).reduce((acc, { timestamp, assetsUsdRate }) => ({
-          ...acc,
-          [timestamp]: assetsUsdRate,
-        }), {}),
+        modifyResult: (data) => (data.exchangeRate || [])
+          .reduce((acc, { timestamp, assetsUsdRate }) => ({
+            ...acc,
+            [timestamp]: assetsUsdRate,
+          }), {}),
       })
       : Promise.resolve({}),
   ])