import { Dispatcher } from '../dispatcher.js';
import { PinStore } from '../store/pin-store.js';
import { ExecutionQueue } from './execution-queue.js';
import { ConflictResolution } from '../conflict-resolution.js';
import { AnchorService, CreateOpts, LoadOpts, InternalOpts, UpdateOpts, RunningStateLike, DiagnosticsLogger } from '@dustil/common';
import { RunningState } from './running-state.js';
import type { CID } from 'multiformats/cid';
import { Subscription } from 'rxjs';
import { SnapshotState } from './snapshot-state.js';
import { CommitID, StreamID } from '@dustil/streamid';
import { LocalIndexApi } from '../indexing/local-index-api.js';
import { AnchorRequestStore } from '../store/anchor-request-store.js';
export declare class StateManager {
    private readonly dispatcher;
    private readonly pinStore;
    private readonly anchorRequestStore;
    private readonly executionQ;
    anchorService: AnchorService;
    conflictResolution: ConflictResolution;
    private readonly logger;
    private readonly fromMemoryOrStore;
    private readonly load;
    private readonly indexStreamIfNeeded;
    private readonly _index;
    private readonly syncedPinnedStreams;
    constructor(dispatcher: Dispatcher, pinStore: PinStore, anchorRequestStore: AnchorRequestStore, executionQ: ExecutionQueue, anchorService: AnchorService, conflictResolution: ConflictResolution, logger: DiagnosticsLogger, fromMemoryOrStore: (streamId: StreamID) => Promise<RunningState | undefined>, load: (streamId: StreamID, opts?: LoadOpts | CreateOpts) => Promise<RunningState>, indexStreamIfNeeded: any, _index: LocalIndexApi | undefined);
    wasPinnedStreamSynced(streamId: StreamID): boolean;
    sync(state$: RunningState, timeoutMillis: number, hint?: CID): Promise<void>;
    markPinnedAndSynced(streamId: StreamID): void;
    atCommit(state$: RunningStateLike, commitId: CommitID): Promise<SnapshotState>;
    atTime(state$: RunningStateLike, timestamp: number): Promise<SnapshotState>;
    applyWriteOpts(state$: RunningState, opts: CreateOpts | UpdateOpts): Promise<void>;
    _handleTip(state$: RunningState, cid: CID, opts?: InternalOpts): Promise<boolean>;
    private _updateStateIfPinned;
    publishTip(state$: RunningState): void;
    handlePubsubUpdate(streamId: StreamID, tip: CID, model?: StreamID): Promise<void>;
    applyCommit(streamId: StreamID, commit: any, opts: CreateOpts | UpdateOpts): Promise<RunningState>;
    private _handleAnchorCommit;
    anchor(state$: RunningState): Promise<void>;
    confirmAnchorResponse(state$: RunningState): Subscription;
    private _saveAnchorRequestForState;
    private _processAnchorResponse;
}
//# sourceMappingURL=state-manager.d.ts.map