import { CID } from 'multiformats/cid';
import { DiagnosticsLogger, IpfsApi, ServiceLogger } from '@dustil/common';
import { StreamID } from '@dustil/streamid';
import { Repository } from './state-management/repository.js';
import { PubsubMessage, QueryMessage, ResponseMessage, UpdateMessage } from './pubsub/pubsub-message.js';
import { Subscription } from 'rxjs';
import { MessageBus } from './pubsub/message-bus.js';
import lru from 'lru_map';
import { TaskQueue } from './pubsub/task-queue.js';
import type { ShutdownSignal } from './shutdown-signal.js';
export declare class Dispatcher {
    readonly _ipfs: IpfsApi;
    private readonly topic;
    readonly repository: Repository;
    private readonly _logger;
    private readonly _pubsubLogger;
    private readonly _shutdownSignal;
    readonly tasks: TaskQueue;
    private readonly _ipfsTimeout;
    readonly messageBus: MessageBus;
    readonly dagNodeCache: lru.LRUMap<string, any>;
    private readonly pubsubCache;
    constructor(_ipfs: IpfsApi, topic: string, repository: Repository, _logger: DiagnosticsLogger, _pubsubLogger: ServiceLogger, _shutdownSignal: ShutdownSignal, maxQueriesPerSecond: number, tasks?: TaskQueue, _ipfsTimeout?: number);
    storeCommit(data: any, streamId?: StreamID): Promise<CID>;
    retrieveCommit(cid: CID | string, streamId: StreamID): Promise<any>;
    retrieveFromIPFS(cid: CID | string, path?: string): Promise<any>;
    cidExistsInLocalIPFSStore(cid: CID | string): Promise<boolean>;
    private _getFromIpfs;
    _restrictCommitSize(cid: CID | string): Promise<void>;
    publishTip(streamId: StreamID, tip: CID, model?: StreamID): Subscription;
    handleMessage(message: PubsubMessage): Promise<void>;
    _handleTip(tip: CID, streamId: StreamID, model?: StreamID): Promise<void>;
    _handleUpdateMessage(message: UpdateMessage): Promise<void>;
    _handleQueryMessage(message: QueryMessage): Promise<void>;
    _handleResponseMessage(message: ResponseMessage): Promise<void>;
    close(): Promise<void>;
    private publish;
}
//# sourceMappingURL=dispatcher.d.ts.map