fix: cfg pending amounts (#270)

centrifuge · Nov 19, 2024 · d1ca2a2 · d1ca2a2
1 parent 2de44dc
commit d1ca2a2
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 4 deletions.
diff --git a/.github/workflows/subql_multi_deploy_workflow.yaml b/.github/workflows/subql_multi_deploy_workflow.yaml
@@ -121,7 +121,6 @@ jobs:
           --dict="$SUBQL_DICTIONARIES" \
           --type=$SUBQL_DEPLOYMENT_TYPE \
           --disableHistorical \
-          --disableIndexerStoreCacheAsync \
           --queryLimit=1000 \
           --indexerWorkers=0 \
           --indexerUnsafe \

diff --git a/src/mappings/services/poolFeeService.ts b/src/mappings/services/poolFeeService.ts
@@ -54,7 +54,13 @@ export class PoolFeeService extends PoolFee {
   }
 
   static async getActives(poolId: string) {
-    const poolFees = await this.getByFields([['poolId', '=', poolId],['isActive', '=', true]], { limit: 100 })
+    const poolFees = await this.getByFields(
+      [
+        ['poolId', '=', poolId],
+        ['isActive', '=', true],
+      ],
+      { limit: 100 }
+    )
     return poolFees as PoolFeeService[]
   }
 
@@ -147,11 +153,12 @@ export class PoolFeeService extends PoolFee {
   }
 
   static computeSumPendingFees(poolFees: PoolFeeService[]): bigint {
-    if(poolFees.length === 0) return BigInt(0)
+    if (poolFees.length === 0) return BigInt(0)
     const poolId = poolFees[0].poolId
     logger.info(`Computing pendingFees for pool: ${poolId} `)
     return poolFees.reduce((sumPendingAmount, poolFee) => {
-      if (!poolFee.pendingAmount) throw new Error(`pendingAmount not available in poolFee ${poolFee.id}`)
+      if (typeof poolFee.pendingAmount !== 'bigint')
+        throw new Error(`pendingAmount not available in poolFee ${poolFee.id}`)
       return sumPendingAmount + poolFee.pendingAmount
     }, BigInt(0))
   }