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

Improve names

This commit is contained in:
julian merlo 2024-02-12 16:34:59 -03:00
parent 69a2067111
commit d12ef9b3a0
5 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
blockchain-watcher/src/infrastructure/repositories/common/rateLimitedOptions.ts Normal file
View File

@ -0,0 +1,4 @@
export type Options = {
period: number;
limit: number;
};

10
blockchain-watcher/src/infrastructure/repositories/evm/RateLimitedEvmJsonRPCBlockRepository.ts
View File

@ -1,3 +1,7 @@
import { Circuit, Ratelimit, Retry, RetryMode } from "mollitia";
import { EvmBlockRepository } from "../../../domain/repositories";
import { Options } from "../common/rateLimitedOptions";
import winston from "../../log";
import {
EvmBlock,
EvmLogFilter,
@ -5,10 +9,6 @@ import {
EvmTag,
ReceiptTransaction,
} from "../../../domain/entities";
import { EvmBlockRepository } from "../../../domain/repositories";
import winston from "../../log";
import { Circuit, Ratelimit, Retry, RetryMode } from "mollitia";
import { Options } from "../solana/RateLimitedSolanaSlotRepository";
export class RateLimitedEvmJsonRPCBlockRepository implements EvmBlockRepository {
private delegate: EvmBlockRepository;
@ -31,7 +31,7 @@ export class RateLimitedEvmJsonRPCBlockRepository implements EvmBlockRepository
factor: 1,
onRejection: (err: Error | any) => {
if (err.message?.startsWith("429 Too Many Requests")) {
this.logger.warn("Got 429 from solana RPC node. Retrying in 10 secs...");
this.logger.warn("Got 429 from evm RPC node. Retrying in 10 secs...");
return 10_000; // Wait 10 secs if we get a 429
} else {
return true; // Retry according to config

6
blockchain-watcher/src/infrastructure/repositories/solana/RateLimitedSolanaSlotRepository.ts
View File

@ -3,6 +3,7 @@ import { solana } from "../../../domain/entities";
import { SolanaSlotRepository } from "../../../domain/repositories";
import { Fallible, SolanaFailure, ErrorType } from "../../../domain/errors";
import winston from "../../../infrastructure/log";
import { Options } from "../common/rateLimitedOptions";
export class RateLimitedSolanaSlotRepository implements SolanaSlotRepository {
private delegate: SolanaSlotRepository;
@ -85,8 +86,3 @@ export class RateLimitedSolanaSlotRepository implements SolanaSlotRepository {
return this.breaker.fn(() => this.delegate.getTransactions(sigs, finality)).execute();
}
}
export type Options = {
period: number;
limit: number;
};

6
blockchain-watcher/src/infrastructure/repositories/sui/RateLimitedSuiJsonRPCBlockRepository.ts
View File

@ -1,10 +1,10 @@
import { Checkpoint, SuiEventFilter, TransactionFilter } from "@mysten/sui.js/client";
import { Circuit, Ratelimit, Retry, RetryMode } from "mollitia";
import { SuiTransactionBlockReceipt } from "../../../domain/entities/sui";
import { SuiRepository } from "../../../domain/repositories";
import { Options } from "../solana/RateLimitedSolanaSlotRepository";
import { Options } from "../common/rateLimitedOptions";
import { Range } from "../../../domain/entities";
import winston from "winston";
import { Checkpoint, SuiEventFilter, TransactionFilter } from "@mysten/sui.js/client";
export class RateLimitedSuiJsonRPCBlockRepository implements SuiRepository {
private delegate: SuiRepository;
@ -27,7 +27,7 @@ export class RateLimitedSuiJsonRPCBlockRepository implements SuiRepository {
factor: 1,
onRejection: (err: Error | any) => {
if (err.message?.startsWith("429 Too Many Requests")) {
this.logger.warn("Got 429 from solana RPC node. Retrying in 10 secs...");
this.logger.warn("Got 429 from sui RPC node. Retrying in 10 secs...");
return 10_000; // Wait 10 secs if we get a 429
} else {
return true; // Retry according to config

2
blockchain-watcher/src/infrastructure/rpc/http/InstrumentedHttpProvider.ts
View File

@ -18,7 +18,7 @@ export class InstrumentedHttpProvider {
private url: string;
health: ProviderHealthInstrumentation;
private logger: winston.Logger = winston.child({ module: "RateLimitedSolanaSlotRepository" });
private logger: winston.Logger = winston.child({ module: "InstrumentedHttpProvider" });
constructor(options: InstrumentedHttpProviderOptions) {
options?.initialDelay && (this.initialDelay = options.initialDelay);