diff --git a/packages/indexer-common/src/allocations/query-fees.ts b/packages/indexer-common/src/allocations/query-fees.ts index 732662a30..0e74f0238 100644 --- 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 { - this.stop = true - } - private startReceiptCollecting() { this.receiptsToCollect = new DHeap(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 index 9920d40a8..9c9245db9 100644 --- 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({}) }