common: drive getPendingRAVs from allocations eventual instead of re-…

…querying, disable jsonify of allocations

config/config.yaml

@@ -0,0 +1,14 @@
+networkIdentifier: "hardhat"
+indexerOptions:
+  geoCoordinates: [48.4682, -123.524]
+  defaultAllocationAmount: 10000
+  allocationManagementMode: "auto"
+  restakeRewards: true
+  poiDisputeMonitoring: false
+  voucherRedemptionThreshold: 0.00001
+  voucherRedemptionBatchThreshold: 10
+  rebateClaimThreshold: 0.00001
+  rebateClaimBatchThreshold: 10
+subgraphs:
+  maxBlockDistance: 5000
+  freshnessSleepMilliseconds: 1000

packages/indexer-common/src/allocations/tap-collector.ts

@@ -21,7 +21,6 @@ import {
   allocationSigner,
   tapAllocationIdProof,
   parseGraphQLAllocation,
-  sequentialTimerMap,
 } from '..'
 import { BigNumber } from 'ethers'
 import pReduce from 'p-reduce'
@@ -184,12 +183,8 @@ export class TapCollector {
   }
 
   private getPendingRAVs(): Eventual<RavWithAllocation[]> {
-    return sequentialTimerMap(
-      {
-        logger: this.logger,
-        milliseconds: RAV_CHECK_INTERVAL_MS,
-      },
-      async () => {
+    return this.allocations.throttle(RAV_CHECK_INTERVAL_MS).tryMap(
+      async (allocations) => {
         let ravs = await this.pendingRAVs()
         if (ravs.length === 0) {
           this.logger.info(`No pending RAVs to process`)
@@ -198,10 +193,6 @@ export class TapCollector {
         if (ravs.length > 0) {
           ravs = await this.filterAndUpdateRavs(ravs)
         }
-        const allocations: Allocation[] = await this.getAllocationsfromAllocationIds(ravs)
-        this.logger.info(
-          `Retrieved allocations for pending RAVs \n: ${JSON.stringify(allocations)}`,
-        )
         return ravs
           .map((rav) => {
             const signedRav = rav.getSignedRAV()

tap-contracts.json

@@ -0,0 +1,7 @@
+{
+  "1337": {
+    "TAPVerifier": "0x8198f5d8F8CfFE8f9C413d98a0A55aEB8ab9FbB7",
+    "AllocationIDTracker": "0x36b58F5C1969B7b6591D752ea6F5486D069010AB",
+    "Escrow": "0x0355B7B8cb128fA5692729Ab3AAa199C1753f726"
+  }
+}