import { CID } from 'multiformats/cid';
import { Observable } from 'rxjs';
import { AnchorProof, AnchorService, AnchorServiceResponse, AnchorValidator, AnchorCommit } from '@dustil/common';
import { Ceramic } from '../../ceramic.js';
import { StreamID } from '@dustil/streamid';
import type { DagJWS } from 'dids';
declare class Candidate {
    readonly cid: CID;
    readonly streamId?: StreamID;
    readonly log?: CID[];
    constructor(cid: CID, streamId?: StreamID, log?: CID[]);
    get key(): string;
}
interface InMemoryAnchorConfig {
    anchorDelay?: number;
    anchorOnRequest?: boolean;
    verifySignatures?: boolean;
}
export declare class InMemoryAnchorService implements AnchorService, AnchorValidator {
    #private;
    constructor(_config: InMemoryAnchorConfig);
    init(): Promise<void>;
    getSupportedChains(): Promise<Array<string>>;
    anchor(): Promise<void>;
    failPendingAnchors(): Promise<void>;
    startProcessingPendingAnchors(): Promise<void>;
    _findCandidates(): Promise<Candidate[]>;
    _groupCandidatesByStreamId(candidates: Candidate[]): Promise<Record<string, Candidate[]>>;
    _selectValidCandidates(groupedCandidates: Record<string, Candidate[]>): Candidate[];
    _failCandidate(candidate: Candidate, message?: string): void;
    _startProcessingCandidate(candidate: Candidate, message?: string): void;
    _loadCommitHistory(commitId: CID, streamId: StreamID): Promise<CID[]>;
    set ceramic(ceramic: Ceramic);
    get url(): string;
    requestAnchor(streamId: StreamID, tip: CID): Observable<AnchorServiceResponse>;
    pollForAnchorResponse(streamId: StreamID, tip: CID): Observable<AnchorServiceResponse>;
    _storeRecord(record: Record<string, unknown>): Promise<CID>;
    _publishAnchorCommit(streamId: StreamID, commit: AnchorCommit): Promise<CID>;
    _process(leaf: Candidate): Promise<void>;
    verifySignedCommit(envelope: DagJWS): Promise<string>;
    validateChainInclusion(proof: AnchorProof): Promise<number>;
}
export {};
//# sourceMappingURL=in-memory-anchor-service.d.ts.map