fix subgraph calls

centrifuge · Dec 18, 2023 · 4eb4f45 · 4eb4f45
1 parent 76b1b9e
commit 4eb4f45
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 30 deletions.
diff --git a/functions/src/getPoolsData.ts b/functions/src/getPoolsData.ts
@@ -8,7 +8,7 @@ function getPoolsQuery({ skip, first }: { skip: number; first: number }) {
       pools(first: ${first}, skip: ${skip}) {
         reserve,
         assetValue,
-        totalRepaysAggregatedAmount,
+        totalBorrowsAggregatedAmount,
         totalDebt
       }
     }`
@@ -37,7 +37,7 @@ function getTotalValueLocked(pools) {
 function getTotalAssetsFinanced(pools) {
   return pools
     .reduce((sum, pool) => {
-      return sum.add(new BN(pool.totalRepaysAggregatedAmount)).add(new BN(pool.totalDebt))
+      return sum.add(new BN(pool.totalBorrowsAggregatedAmount))
     }, new BN(0))
     .div(new BN(10).pow(new BN(24)))
     .toString()
@@ -76,6 +76,6 @@ export default async function getPoolsData(req: Request, res: Response) {
       })
     )
   } catch (error) {
-    return res.status(422).send(JSON.stringify(error))
+    return res.status(500).send(error)
   }
 }
diff --git a/functions/src/getTotalAssetsTokenized.ts b/functions/src/getTotalAssetsTokenized.ts
@@ -3,41 +3,30 @@ import { chunkedFetch } from './subgraphUtils'
 
 export default async function getTotalAssetsTokenized(req: Request, res: Response) {
   try {
-    const poolIds = await chunkedFetch({
-      getQuery: getPoolsQuery,
-      getProperty: (obj) => obj?.pools,
+    const request = await chunkedFetch({
+      getQuery: getLoansQuery,
+      getProperty: (obj) => {
+        const loans = obj.pools.reduce((acc, pool) => {
+          acc.push(pool.loans)
+          return acc
+        }, [])
+        return loans
+      },
     })
 
-    const requests = poolIds.map(({ id }) =>
-      chunkedFetch({
-        id,
-        getQuery: getLoansQuery,
-        getProperty: (obj) => obj?.pool?.loans,
-      })
-    )
-
-    let totalAssetsTokenized = await Promise.all(requests).then((results) => results.flat().length)
+    let totalAssetsTokenized = request.flat().length
 
     return res.status(200).send(JSON.stringify({ totalAssetsTokenized }))
   } catch (error) {
     return res.status(422).send(JSON.stringify(error))
   }
 }
 
-function getPoolsQuery({ skip, first }: { skip: number; first: number }) {
-  return `
-    query {
-      pools(first: ${first}, skip: ${skip}) {
-        id
-      }
-    }`
-}
-
-function getLoansQuery({ skip, first, id }: { skip: number; first: number; id: string }) {
+function getLoansQuery({ skip, first }: { skip: number; first: number; id: string }) {
   return `
     query {
-      pool(id: "${id}") {
-        loans(where: {borrowsAggregatedAmount_gt: "0"}, first: ${first}, skip: ${skip}) {
+      pools {
+        loans(first: ${first}, skip: ${skip}) {
           id
         }
       }

diff --git a/functions/src/subgraphUtils.ts b/functions/src/subgraphUtils.ts
@@ -13,7 +13,7 @@ async function fetchSubgraphData(query) {
     throw new Error(`Failed to retrieve pool data for TVL: ${response.statusText}`)
   }
 
-  const { data } = await response.clone().json()
+  const { data } = await response.json()
   return data
 }
 
@@ -22,7 +22,7 @@ export async function chunkedFetch({
   day,
   getQuery,
   getProperty,
-  chunkSize = 100,
+  chunkSize = 1000,
 }: {
   id?: string
   day?: number
@@ -46,7 +46,6 @@ export async function chunkedFetch({
       const response = await fetchSubgraphData(query)
 
       const property = getProperty(response)
-
       if (property && property.length) {
         data.push(...property)
       }