87 lines
3.0 KiB
TypeScript
87 lines
3.0 KiB
TypeScript
|
import type { Provider, BlockTag, Block, TransactionResponse, BaseContract, ContractEventName, EventLog } from 'ethers';
|
||
|
|
export interface BatchBlockServiceConstructor {
|
||
|
|
provider: Provider;
|
||
|
|
onProgress?: BatchBlockOnProgress;
|
||
|
|
concurrencySize?: number;
|
||
|
|
batchSize?: number;
|
||
|
|
shouldRetry?: boolean;
|
||
|
|
retryMax?: number;
|
||
|
|
retryOn?: number;
|
||
|
|
}
|
||
|
|
export type BatchBlockOnProgress = ({ percentage, currentIndex, totalIndex, }: {
|
||
|
|
percentage: number;
|
||
|
|
currentIndex?: number;
|
||
|
|
totalIndex?: number;
|
||
|
|
}) => void;
|
||
|
|
/**
|
||
|
|
* Fetch blocks from web3 provider on batches
|
||
|
|
*/
|
||
|
|
export declare class BatchBlockService {
|
||
|
|
provider: Provider;
|
||
|
|
onProgress?: BatchBlockOnProgress;
|
||
|
|
concurrencySize: number;
|
||
|
|
batchSize: number;
|
||
|
|
shouldRetry: boolean;
|
||
|
|
retryMax: number;
|
||
|
|
retryOn: number;
|
||
|
|
constructor({ provider, onProgress, concurrencySize, batchSize, shouldRetry, retryMax, retryOn, }: BatchBlockServiceConstructor);
|
||
|
|
getBlock(blockTag: BlockTag): Promise<Block>;
|
||
|
|
createBatchRequest(batchArray: BlockTag[][]): Promise<Block[]>[];
|
||
|
|
getBatchBlocks(blocks: BlockTag[]): Promise<Block[]>;
|
||
|
|
}
|
||
|
|
/**
|
||
|
|
* Fetch transactions from web3 provider on batches
|
||
|
|
*/
|
||
|
|
export declare class BatchTransactionService {
|
||
|
|
provider: Provider;
|
||
|
|
onProgress?: BatchBlockOnProgress;
|
||
|
|
concurrencySize: number;
|
||
|
|
batchSize: number;
|
||
|
|
shouldRetry: boolean;
|
||
|
|
retryMax: number;
|
||
|
|
retryOn: number;
|
||
|
|
constructor({ provider, onProgress, concurrencySize, batchSize, shouldRetry, retryMax, retryOn, }: BatchBlockServiceConstructor);
|
||
|
|
getTransaction(txHash: string): Promise<TransactionResponse>;
|
||
|
|
createBatchRequest(batchArray: string[][]): Promise<TransactionResponse[]>[];
|
||
|
|
getBatchTransactions(txs: string[]): Promise<TransactionResponse[]>;
|
||
|
|
}
|
||
|
|
export interface BatchEventServiceConstructor {
|
||
|
|
provider: Provider;
|
||
|
|
contract: BaseContract;
|
||
|
|
onProgress?: BatchEventOnProgress;
|
||
|
|
concurrencySize?: number;
|
||
|
|
blocksPerRequest?: number;
|
||
|
|
shouldRetry?: boolean;
|
||
|
|
retryMax?: number;
|
||
|
|
retryOn?: number;
|
||
|
|
}
|
||
|
|
export type BatchEventOnProgress = ({ percentage, type, fromBlock, toBlock, count, }: {
|
||
|
|
percentage: number;
|
||
|
|
type?: ContractEventName;
|
||
|
|
fromBlock?: number;
|
||
|
|
toBlock?: number;
|
||
|
|
count?: number;
|
||
|
|
}) => void;
|
||
|
|
export type EventInput = {
|
||
|
|
fromBlock: number;
|
||
|
|
toBlock: number;
|
||
|
|
type: ContractEventName;
|
||
|
|
};
|
||
|
|
/**
|
||
|
|
* Fetch events from web3 provider on bulk
|
||
|
|
*/
|
||
|
|
export declare class BatchEventsService {
|
||
|
|
provider: Provider;
|
||
|
|
contract: BaseContract;
|
||
|
|
onProgress?: BatchEventOnProgress;
|
||
|
|
concurrencySize: number;
|
||
|
|
blocksPerRequest: number;
|
||
|
|
shouldRetry: boolean;
|
||
|
|
retryMax: number;
|
||
|
|
retryOn: number;
|
||
|
|
constructor({ provider, contract, onProgress, concurrencySize, blocksPerRequest, shouldRetry, retryMax, retryOn, }: BatchEventServiceConstructor);
|
||
|
|
getPastEvents({ fromBlock, toBlock, type }: EventInput): Promise<EventLog[]>;
|
||
|
|
createBatchRequest(batchArray: EventInput[]): Promise<EventLog[]>[];
|
||
|
|
getBatchEvents({ fromBlock, toBlock, type }: EventInput): Promise<EventLog[]>;
|
||
|
|
}
|