diff --git a/src/modules/scraper/adapter/messaging/SpeedUpEventsV3Consumer.ts b/src/modules/scraper/adapter/messaging/SpeedUpEventsV3Consumer.ts index 4d269edb..a4e14b14 100644 --- a/src/modules/scraper/adapter/messaging/SpeedUpEventsV3Consumer.ts +++ b/src/modules/scraper/adapter/messaging/SpeedUpEventsV3Consumer.ts @@ -23,6 +23,7 @@ export class SpeedUpEventsV3Consumer { const deposit = await this.depositRepository.findOne({ where: { sourceChainId: depositSourceChainId, depositId } }); if (!deposit) throw new Error("Deposit not found"); + if (this.isSpeedUpAlreadyProcessed(deposit, job.data)) return; await this.processSpeedUpEventQueueMessage(deposit, job.data);