fix: remove unused stop

graphprotocol · Jul 28, 2023 · 70e0057 · 70e0057
1 parent c0d5892
commit 70e0057
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 10 deletions.
diff --git a/packages/indexer-common/src/allocations/query-fees.ts b/packages/indexer-common/src/allocations/query-fees.ts
@@ -89,7 +89,6 @@ export class AllocationReceiptCollector implements ReceiptCollector {
   private voucherRedemptionBatchThreshold: BigNumber
   private voucherRedemptionMaxBatchSize: number
   private protocolNetwork: string
-  private stop: boolean
 
   constructor({
     logger,
@@ -99,7 +98,6 @@ export class AllocationReceiptCollector implements ReceiptCollector {
     allocationExchange,
     networkSpecification,
   }: AllocationReceiptCollectorOptions) {
-    this.stop = false
     this.logger = logger.child({ component: 'AllocationReceiptCollector' })
     this.metrics = registerReceiptMetrics(metrics, networkSpecification.networkIdentifier)
     this.transactionManager = transactionManager
@@ -233,10 +231,6 @@ export class AllocationReceiptCollector implements ReceiptCollector {
     }
   }
 
-  async stopCollectingReceipts(): Promise<void> {
-    this.stop = true
-  }
-
   private startReceiptCollecting() {
     this.receiptsToCollect = new DHeap<AllocationReceiptsBatch>(null, {
       compare: (t1, t2) => t1.timeout - t2.timeout,
@@ -268,9 +262,6 @@ export class AllocationReceiptCollector implements ReceiptCollector {
 
   private startVoucherProcessing() {
     timer(30_000).pipe(async () => {
-      if (this.stop) {
-        return
-      }
       const pendingVouchers = await this.pendingVouchers() // Ordered by value
 
       const logger = this.logger.child({})

diff --git a/packages/indexer-common/src/indexer-management/__tests__/allocations.test.ts b/packages/indexer-common/src/indexer-management/__tests__/allocations.test.ts
@@ -96,7 +96,6 @@ const teardownEach = async () => {
 }
 
 const teardownAll = async () => {
-  //await network.receiptCollector.stopCollectingReceipts()
   //await sequelize.drop({})
 }