diff --git a/relayer_engine/src/plugin/src/plugin.ts b/relayer_engine/src/plugin/src/plugin.ts index f501633..c0c7760 100644 --- a/relayer_engine/src/plugin/src/plugin.ts +++ b/relayer_engine/src/plugin/src/plugin.ts @@ -13,7 +13,7 @@ import { Workflow, } from "@wormhole-foundation/relayer-engine" import * as wh from "@certusone/wormhole-sdk" -import {SignedVaa} from "@certusone/wormhole-sdk" +import { SignedVaa } from "@certusone/wormhole-sdk" import { Logger } from "winston" import { PluginError } from "./utils" import { @@ -167,7 +167,8 @@ export class GenericRelayerPlugin implements Plugin { coreRelayerVaa.sequence, chainId, providers.evm[chainId], - this.pluginConfig.supportedChains.get(chainId)! + this.pluginConfig.supportedChains.get(chainId)!, + this.logger ) const chainConfig = this.pluginConfig.supportedChains.get(chainId)! @@ -407,4 +408,3 @@ export class GenericRelayerPlugin implements Plugin { } } } - diff --git a/relayer_engine/src/plugin/src/syntheticBatch.ts b/relayer_engine/src/plugin/src/syntheticBatch.ts index 76e5315..6eb8175 100644 --- a/relayer_engine/src/plugin/src/syntheticBatch.ts +++ b/relayer_engine/src/plugin/src/syntheticBatch.ts @@ -5,8 +5,8 @@ import * as ethers from "ethers" import { Implementation__factory } from "@certusone/wormhole-sdk/lib/cjs/ethers-contracts" import { retryAsyncUntilDefined } from "ts-retry/lib/cjs/retry" import { ChainInfo } from "./plugin" -import { ScopedLogger } from "@wormhole-foundation/relayer-engine/relayer-engine/lib/helpers/logHelper" import { tryNativeToHexString } from "@certusone/wormhole-sdk" +import { Logger } from "winston" // fetch the contract transaction receipt for the given sequence number emitted by the core relayer contract export async function fetchReceipt( @@ -14,7 +14,7 @@ export async function fetchReceipt( chainId: wh.EVMChainId, provider: ethers.providers.Provider, chainConfig: ChainInfo, - logger: ScopedLogger + logger: Logger ): Promise { const coreWHContract = IWormhole__factory.connect(chainConfig.coreContract!, provider) const filter = coreWHContract.filters.LogMessagePublished(chainConfig.relayerAddress) @@ -70,7 +70,7 @@ export function filterLogs( rx: ethers.ContractReceipt, nonce: number, chainConfig: ChainInfo, - logger: ScopedLogger + logger: Logger ): { vaas: { sequence: string