wormhole-explorer/blockchain-watcher/test/infrastructure/repositories/RepositoriesBuilder.test.ts

48 lines
1.7 KiB
TypeScript
Raw Normal View History

[Blockchain Watcher] Feature 798/enable evm karura chain (#831) * adding gen-relayer watcher code to branch * folder rename * adding some new abstract types for processor redesign * added first cut of new process manager logic * large refactoring to environment configuration * Add basic default config * prettier run * modifying event handler interface * abstract handler typing changes * Blockchain watcher: adding domain and infra layers (#786) * reorg domain-infra * watch evm blocks action * adding evm log parser * wider prettier * renaming watch action * adding doc * persist latest metadata * gh action for blockchain-watcher * adding log-message-published mapper * deps: remove peers and nodemon * adding handler for LogMessagePublished * added parser for log message published --------- Co-authored-by: chase-45 <chasemoran45@gmail.com> * Blockchain Watcher: ethereum -> sns implementation (#790) * evm block repo implementation * adding sns publisher * adding external config and initial runner * fix: start from latest if no fromBlock configured * feat: add dryRun option * fix: handler filtering and eth_getLogs filter payload * local e2e * actual sns arns for testnet * smaller docker image * deployment changes * [Blockchain Watcher] Apply missing formatting for log message published (#791) * Apply missing formatting for log message published * keep extracting * emitterAddress -> emitter * using configured default winston logger * wait for new block * adding basic metrics * staging mainnet config * send hexa block number * simpler log format * group entities in different files * [Blockchain watcher] Adding light observability (#793) * using configured default winston logger * wait for new block * adding basic metrics * staging mainnet config * send hexa block number * simpler log format * better error logs * wait when no block available * grouping watchers * adding 429 handling http client * abstracting polling iteration * Load jobs dinamically * changing deployment strategy to jobs per pod * group actions per platform * [Blockchain Watcher] Add StartJob action + rate limit handling (#799) * using configured default winston logger * wait for new block * adding basic metrics * staging mainnet config * send hexa block number * simpler log format * group entities in different files * grouping watchers * adding 429 handling http client * abstracting polling iteration * Load jobs dinamically * changing deployment strategy to jobs per pod * adding poll solana txs action * adding solana repo implementation * solana: mapping to logmsgpublished * fixing solana mapper test * updating readme * adding some metrics * adding solana worker * adding finality param to get solana block * minor changes - using confirmed for solana log extraction * updating version * add solana env var * [Blockchain Watcher] Feature-813/fix-coverage-report (#815) * Fix coverage report * Run prettier * Rollback global coverage value * Set global coverage value to 55 * Add github PR template * Run prettier * Rename github template file --------- Co-authored-by: Julian Merlo <julianmerlo@MacBook-Pro-de-Julian.local> * private solana urls as secret * adding prod cfg files * Change repository name and cretae error foulder (#819) * Change repository name and cretae error foulder * Rename SolanaFailure file * Rename SolanaFailure file --------- Co-authored-by: Julian Merlo <julianmerlo@MacBook-Pro-de-Julian.local> * passing node_options for solana * adding missing envs templates * cru * ratelimited solana client + increase coverage * [Blockchain Watcher] Feature 817/add hexagonal prefix (#824) * Put hexadecimal prefix * Create id variable * Add error log * Add error log * Remove bigint in getBlock params --------- Co-authored-by: Julian Merlo <julianmerlo@MacBook-Pro-de-Julian.local> * fix never ending solana jobs * adding job counter metric * solana: add retry handling for 429s * cleanup * remove duplicated tests * [Blockchain watcher] feature-798/enable-evm-karura-chain * [Blockchain watcher] feature-798/enable-evm-karura-chain * Add karura job in mainnet * Mapped karura addresses * Improve address tesnet * Delete from block * Resolve comment in PR, mapped chainId into EvmLog entity * Revert address change * Mapped mainet address * Create chains constants * Imporve config mock * Resolve comment * Mapped chainId into repository * Run prettier * Change commitment status for karura * Run prettier --------- Co-authored-by: chase-45 <chasemoran45@gmail.com> Co-authored-by: matias martinez <matias@xlabs.xyz> Co-authored-by: Matías Martínez <131624652+mat1asm@users.noreply.github.com> Co-authored-by: Julian Merlo <julianmerlo@MacBook-Pro-de-Julian.local>
2023-11-30 07:43:37 -08:00
import { describe, expect, it } from "@jest/globals";
import { RepositoriesBuilder } from "../../../src/infrastructure/RepositoriesBuilder";
import { configMock } from "../../mocks/configMock";
import {
EvmJsonRPCBlockRepository,
FileMetadataRepository,
PromStatRepository,
RateLimitedSolanaSlotRepository,
SnsEventRepository,
} from "../../../src/infrastructure/repositories";
describe("RepositoriesBuilder", () => {
it("should be throw error because dose not have any chain", async () => {
try {
// When
new RepositoriesBuilder(configMock([]));
} catch (e: Error | any) {
// Then
expect(e).toBeInstanceOf(Error);
}
});
it("should be throw error because dose not support test chain", async () => {
try {
// When
new RepositoriesBuilder(configMock(["test"]));
} catch (e) {
// Then
expect(e).toBeInstanceOf(Error);
}
});
it("should be return all repositories instances", async () => {
// When
const repos = new RepositoriesBuilder(configMock(["ethereum", "solana", "karura"]));
// Then
const job = repos.getJobsRepository();
expect(job).toBeTruthy();
expect(repos.getEvmBlockRepository("ethereum")).toBeInstanceOf(EvmJsonRPCBlockRepository);
expect(repos.getEvmBlockRepository("karura")).toBeInstanceOf(EvmJsonRPCBlockRepository);
expect(repos.getMetadataRepository()).toBeInstanceOf(FileMetadataRepository);
expect(repos.getSnsEventRepository()).toBeInstanceOf(SnsEventRepository);
expect(repos.getStatsRepository()).toBeInstanceOf(PromStatRepository);
expect(repos.getSolanaSlotRepository()).toBeInstanceOf(RateLimitedSolanaSlotRepository);
});
});