certusone
/
wormhole-explorer
mirror of https://github.com/certusone/wormhole-explorer.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Improve code

This commit is contained in:
julian merlo 2024-03-25 12:02:51 -03:00
parent fcc6f0338c
commit a7ba1e5269
3 changed files with 10 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
blockchain-watcher/src/infrastructure/mappers/wormchain/wormchainLogMessagePublishedMapper.ts
View File

@ -14,7 +14,7 @@ export const wormchainLogMessagePublishedMapper = (
if (coreContract && sequence && payload && emitter && payload && nonce && hash) {
logger.info(
`[wormchain] Source event info: [tx: ${hash}][emitterChain: ${CHAIN_ID_WORMCHAIN}][sender: ${emitter}][sequence: ${sequence} ]`
`[wormchain] Source event info: [tx: ${hash}][emitterChain: ${CHAIN_ID_WORMCHAIN}][sender: ${emitter}][sequence: ${sequence}]`
);
return {

2
blockchain-watcher/src/infrastructure/repositories/RepositoriesBuilder.ts
View File

@ -1,3 +1,4 @@
import { RateLimitedWormchainJsonRPCBlockRepository } from "./wormchain/RateLimitedWormchainJsonRPCBlockRepository";
import { RateLimitedAptosJsonRPCBlockRepository } from "./aptos/RateLimitedAptosJsonRPCBlockRepository";
import { RateLimitedEvmJsonRPCBlockRepository } from "./evm/RateLimitedEvmJsonRPCBlockRepository";
import { RateLimitedSuiJsonRPCBlockRepository } from "./sui/RateLimitedSuiJsonRPCBlockRepository";
@ -34,7 +35,6 @@ import {
SnsEventRepository,
ProviderPoolMap,
} from ".";
import { RateLimitedWormchainJsonRPCBlockRepository } from "./wormchain/RateLimitedWormchainJsonRPCBlockRepository";
const WORMCHAIN_CHAIN = "wormchain";
const SOLANA_CHAIN = "solana";

17
blockchain-watcher/test/domain/actions/wormchain/PollWormchain.test.ts
View File

@ -1,23 +1,22 @@
import { afterEach, describe, it, expect, jest } from "@jest/globals";
import { thenWaitForAssertion } from "../../../wait-assertion";
import { WormchainLog } from "../../../../src/domain/entities/wormchain";
import {
PollEvmLogsConfig,
PollWormchain,
PollWormchainLogsConfig,
PollWormchainLogsMetadata,
PollWormchainLogsConfig,
PollWormchain,
} from "../../../../src/domain/actions";
import {
WormchainRepository,
MetadataRepository,
StatRepository,
WormchainRepository,
} from "../../../../src/domain/repositories";
import { EvmBlock, EvmLog, ReceiptTransaction } from "../../../../src/domain/entities";
import { thenWaitForAssertion } from "../../../wait-assertion";
let cfg = PollWormchainLogsConfig.fromBlock(7626734n);
let getBlockHeightSpy: jest.SpiedFunction<WormchainRepository["getBlockHeight"]>;
let getBlockLogsSpy: jest.SpiedFunction<WormchainRepository["getBlockLogs"]>;
let handlerSpy: jest.SpiedFunction<(logs: EvmLog[]) => Promise<void>>;
let handlerSpy: jest.SpiedFunction<(logs: WormchainLog[]) => Promise<void>>;
let metadataSaveSpy: jest.SpiedFunction<MetadataRepository<PollWormchainLogsMetadata>["save"]>;
let metadataRepo: MetadataRepository<PollWormchainLogsMetadata>;
@ -25,8 +24,8 @@ let wormchainBlockRepo: WormchainRepository;
let statsRepo: StatRepository;
let handlers = {
working: (logs: EvmLog[]) => Promise.resolve(),
failing: (logs: EvmLog[]) => Promise.reject(),
working: (logs: WormchainLog[]) => Promise.resolve(),
failing: (logs: WormchainLog[]) => Promise.reject(),
};
let pollWormchain: PollWormchain;