import { StatefulEventSubscriber } from '../../stateful-event-subscriber'; import { DeepReadonly } from 'ts-essentials'; import { Address, Log, Logger } from '../../types'; import { IDexHelper } from '../../dex-helper'; import { Interface } from '@ethersproject/abi'; type PoolState = { isSwapAndArbitragePaused: boolean; }; export declare class FluidDexEventPool extends StatefulEventSubscriber { readonly parentName: string; readonly poolAddress: string; protected network: number; protected dexHelper: IDexHelper; handlers: { [event: string]: (event: any, state: DeepReadonly, log: Readonly) => DeepReadonly | null; }; logDecoder: (log: Log) => any; addressesSubscribed: Address[]; protected poolIface: Interface; constructor(parentName: string, poolAddress: string, network: number, dexHelper: IDexHelper, logger: Logger); /** * The function is called every time any of the subscribed * addresses release log. The function accepts the current * state, updates the state according to the log, and returns * the updated state. * @param state - Current state of event subscriber * @param log - Log released by one of the subscribed addresses * @returns Updates state of the event subscriber after the log */ processLog(state: DeepReadonly, log: Readonly): Promise | null>; handleLogPauseSwapAndArbitrage(): PoolState; handleLogUnpauseSwapAndArbitrage(): PoolState; getStateOrGenerate(blockNumber: number, readonly?: boolean): Promise>; /** * The function generates state using on-chain calls. This * function is called to regenerate state if the event based * system fails to fetch events and the local state is no * more correct. * @param blockNumber - Blocknumber for which the state should * should be generated * @returns state of the event subscriber at blocknumber */ generateState(blockNumber: number): Promise>; } export {};