import { Interface } from '@ethersproject/abi'; import { DeepReadonly } from 'ts-essentials'; import { Log, Logger } from '../../../types'; import { StatefulEventSubscriber } from '../../../stateful-event-subscriber'; import { IDexHelper } from '../../../dex-helper/idex-helper'; import { DirectionalFeeConfig, DirectionalFeeHookState } from './directionalFeeHook'; import { StableSurgeConfig, StableSurgeHookState } from './stableSurgeHook'; import { AkronHookState, AkronConfig } from './akronHook'; export type HookState = DirectionalFeeHookState | StableSurgeHookState | AkronHookState; export type HookStateMap = { [address: string]: HookState; }; export type HookConfig = DirectionalFeeConfig | StableSurgeConfig | AkronConfig; export type HooksConfigMap = { [hookAddress: string]: HookConfig[]; }; /** * This will handle events/state for each supported hook contract. State is used during swap calculations. * Each hook should have its own implementation file for state typing, fetching state and handling events. */ export declare class BalancerEventHook extends StatefulEventSubscriber { readonly parentName: string; protected network: number; protected dexHelper: IDexHelper; handlers: { [event: string]: (event: any, state: DeepReadonly, log: Readonly, logger: Logger) => DeepReadonly | null; }; interfaces: Interface[]; logDecoder: (log: Log) => any; addressesSubscribed: string[]; hooksConfigMap: HooksConfigMap; constructor(parentName: 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 */ protected processLog(state: DeepReadonly, log: Readonly): DeepReadonly | null; /** * 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>; updateHookState(): Promise; }