diff --git a/src/modules/scraper/adapter/messaging/BlocksEventsConsumer.ts b/src/modules/scraper/adapter/messaging/BlocksEventsConsumer.ts index 1d726df2..08fc0fb4 100644 --- a/src/modules/scraper/adapter/messaging/BlocksEventsConsumer.ts +++ b/src/modules/scraper/adapter/messaging/BlocksEventsConsumer.ts @@ -19,9 +19,6 @@ import { import { Deposit } from "../../../deposit/model/deposit.entity"; import { ScraperQueuesService } from "../../service/ScraperQueuesService"; import { - RequestedSpeedUpDepositEv, - FilledRelayEv, - FundsDepositedEv, FundsDepositedEvent2, FundsDepositedEvent2_5, FilledRelayEvent2, @@ -45,10 +42,6 @@ export class BlocksEventsConsumer { constructor( private providers: EthProvidersService, @InjectRepository(Deposit) private depositRepository: Repository, - @InjectRepository(FundsDepositedEv) private fundsDepositedEvRepository: Repository, - @InjectRepository(FilledRelayEv) private filledRelayEvRepository: Repository, - @InjectRepository(RequestedSpeedUpDepositEv) - private requestedSpeedUpDepositEvRepository: Repository, private scraperQueuesService: ScraperQueuesService, private appConfig: AppConfig, ) {} @@ -229,11 +222,6 @@ export class BlocksEventsConsumer { // await this.insertRawFillEvents(chainId, events); for (const event of events) { - const { address } = event; - const { acrossVersion } = this.appConfig.values.web3.spokePoolContracts[chainId].filter( - (contract) => contract.address === address, - )[0]; - if (event.args.appliedRelayerFeePct) { const typedEvent = event as FilledRelayEvent2; const message: FillEventsQueueMessage = { diff --git a/src/modules/scraper/adapter/messaging/FillEventsV3Consumer.ts b/src/modules/scraper/adapter/messaging/FillEventsV3Consumer.ts index 42ff17a9..8af24edb 100644 --- a/src/modules/scraper/adapter/messaging/FillEventsV3Consumer.ts +++ b/src/modules/scraper/adapter/messaging/FillEventsV3Consumer.ts @@ -1,15 +1,9 @@ import { OnQueueFailed, Process, Processor } from "@nestjs/bull"; import { Logger } from "@nestjs/common"; import { Job } from "bull"; -import { - DepositFilledDateQueueMessage, - FeeBreakdownQueueMessage, - FillEventsQueueMessage2, - FillEventsV3QueueMessage, - ScraperQueue, -} from "."; +import { DepositFilledDateQueueMessage, FeeBreakdownQueueMessage, FillEventsV3QueueMessage, ScraperQueue } from "."; import { InjectRepository } from "@nestjs/typeorm"; -import { Deposit, DepositFillTx2, DepositFillTxV3 } from "../../../deposit/model/deposit.entity"; +import { Deposit, DepositFillTxV3 } from "../../../deposit/model/deposit.entity"; import { Repository } from "typeorm"; import { BigNumber } from "bignumber.js"; import { ScraperQueuesService } from "../../service/ScraperQueuesService"; diff --git a/src/modules/scraper/adapter/messaging/SpeedUpEventsConsumer.ts b/src/modules/scraper/adapter/messaging/SpeedUpEventsConsumer.ts index a73b23e2..0b9058dd 100644 --- a/src/modules/scraper/adapter/messaging/SpeedUpEventsConsumer.ts +++ b/src/modules/scraper/adapter/messaging/SpeedUpEventsConsumer.ts @@ -1,7 +1,7 @@ import { OnQueueFailed, Process, Processor } from "@nestjs/bull"; import { Logger } from "@nestjs/common"; import { Job } from "bull"; -import { DepositFilledDateQueueMessage, ScraperQueue, SpeedUpEventsQueueMessage } from "."; +import { ScraperQueue, SpeedUpEventsQueueMessage } from "."; import { InjectRepository } from "@nestjs/typeorm"; import { Deposit, RequestedSpeedUpDepositTx } from "../../../deposit/model/deposit.entity"; import { Repository } from "typeorm"; diff --git a/src/modules/scraper/adapter/messaging/SpeedUpEventsV3Consumer.ts b/src/modules/scraper/adapter/messaging/SpeedUpEventsV3Consumer.ts index d436dd97..4d269edb 100644 --- a/src/modules/scraper/adapter/messaging/SpeedUpEventsV3Consumer.ts +++ b/src/modules/scraper/adapter/messaging/SpeedUpEventsV3Consumer.ts @@ -1,7 +1,7 @@ import { OnQueueFailed, Process, Processor } from "@nestjs/bull"; import { Logger } from "@nestjs/common"; import { Job } from "bull"; -import { DepositFilledDateQueueMessage, SpeedUpEventsV3QueueMessage, ScraperQueue } from "."; +import { SpeedUpEventsV3QueueMessage, ScraperQueue } from "."; import { InjectRepository } from "@nestjs/typeorm"; import { Deposit, RequestedSpeedUpDepositTxV3 } from "../../../deposit/model/deposit.entity"; import { Repository } from "typeorm";