import { AsyncOrSync, DeepReadonly } from 'ts-essentials';
import { Log, Logger } from './types';
import { BlockHeader } from 'web3-eth';
import { EventSubscriber } from './dex-helper/iblock-manager';
import { IDexHelper } from './dex-helper';
export type InitializeStateOptions<State> = {
    state?: DeepReadonly<State>;
    initCallback?: (state: DeepReadonly<State>) => void;
    forceRegenerate?: boolean;
};
export declare abstract class StatefulEventSubscriber<State> implements EventSubscriber {
    readonly parentName: string;
    protected dexHelper: IDexHelper;
    protected logger: Logger;
    private masterPoolNeeded;
    mapKey: string;
    protected state: DeepReadonly<State> | null;
    protected stateBlockNumber: number;
    protected stateHistory: {
        [blockNumber: number]: DeepReadonly<State>;
    };
    protected invalid: boolean;
    protected inactive: boolean;
    isTracking: () => boolean;
    isInactive: () => boolean;
    isInvalid: () => boolean;
    addressesSubscribed: string[];
    cacheName: string;
    name: string;
    isInitialized: boolean;
    private _aggregatedLogMessages;
    private _lastPublishedTimeMs;
    constructor(parentName: string, _name: string, dexHelper: IDexHelper, logger: Logger, masterPoolNeeded?: boolean, mapKey?: string);
    getStateBlockNumber(): Readonly<number>;
    initialize(blockNumber: number, options?: InitializeStateOptions<State>): Promise<void>;
    updatePoolState(blockNumber: number): Promise<void>;
    protected getPoolIdentifierData(): void;
    protected abstract processLog(state: DeepReadonly<State>, log: Readonly<Log>, blockHeader: Readonly<BlockHeader>): AsyncOrSync<DeepReadonly<State> | null>;
    protected processBlockLogs(state: DeepReadonly<State>, logs: Readonly<Log>[], blockHeader: Readonly<BlockHeader>): Promise<DeepReadonly<State> | null>;
    abstract generateState(blockNumber?: number | 'latest'): AsyncOrSync<DeepReadonly<State>>;
    restart(blockNumber: number): void;
    update(logs: Readonly<Log>[], blockHeaders: Readonly<{
        [blockNumber: number]: Readonly<BlockHeader>;
    }>): Promise<void>;
    rollback(blockNumber: number): void;
    inactivate(): void;
    invalidate(): void;
    getState(minBlockNumber: number): DeepReadonly<State> | null;
    getStaleState(): DeepReadonly<State> | null;
    _setState(state: DeepReadonly<State> | null, blockNumber: number, reason?: string): void;
    _logBatchTypicalMessages(message: string, level: 'warn' | 'info', publishPeriod?: number): void;
    setState(state: DeepReadonly<State>, blockNumber: number, reason?: string): void;
}