import { Logger, ResolveOnce, Result, URI } from "@adviser/cement";
import { type AnyBlock, type AnyLink, type CommitOpts, type DataSaveOpts, type DbMeta, type WALStore as WALStore, type WALState, type LoadHandler, type CryptoAction, type Loadable, type CarClockHead, type DbMetaEvent, type MetaStore, type DataAndMetaStore, type CarStore, type FileStore, SerdeGateway, SerdeGatewayInterceptor, CommitQueueIf } from "@fireproof/core-types-blockstore";
import { Falsy, StoreType, SuperThis } from "@fireproof/core-types-base";
import { InterceptorGateway } from "@fireproof/core-gateways-base";
export interface StoreOpts {
    readonly gateway: SerdeGateway;
    readonly gatewayInterceptor?: SerdeGatewayInterceptor;
    readonly loader: Loadable;
}
export interface BaseStoreOpts {
    readonly gateway: InterceptorGateway;
    readonly loader: Loadable;
}
export declare abstract class BaseStoreImpl {
    abstract readonly storeType: StoreType;
    private _url;
    readonly logger: Logger;
    readonly sthis: SuperThis;
    readonly gateway: InterceptorGateway;
    get realGateway(): SerdeGateway;
    readonly opts: StoreOpts;
    readonly loader: Loadable;
    readonly myId: string;
    constructor(sthis: SuperThis, url: URI, opts: BaseStoreOpts, logger: Logger);
    url(): URI;
    readonly _id: ResolveOnce<string, void>;
    id(): string;
    readonly _onStarted: ((dam: DataAndMetaStore) => void)[];
    onStarted(fn: (dam: DataAndMetaStore) => void): void;
    readonly _onClosed: (() => void)[];
    onClosed(fn: () => void): void;
    abstract close(): Promise<Result<void>>;
    ready(): Promise<void>;
    keyedCrypto(): Promise<CryptoAction>;
    start(dam: DataAndMetaStore): Promise<Result<URI>>;
}
export declare function createDbMetaEvent(sthis: SuperThis, dbMeta: DbMeta, parents: CarClockHead): Promise<DbMetaEvent>;
export declare class MetaStoreImpl extends BaseStoreImpl implements MetaStore {
    readonly storeType: string;
    readonly subscribers: Map<string, LoadHandler[]>;
    parents: CarClockHead;
    constructor(sthis: SuperThis, url: URI, opts: BaseStoreOpts);
    private updateParentsFromDbMetas;
    cnt: number;
    stream(branch?: string): ReadableStream<DbMeta[]>;
    save(meta: DbMeta, branch?: string): Promise<Result<void>>;
    close(): Promise<Result<void>>;
    destroy(): Promise<Result<void>>;
}
declare abstract class DataStoreImpl extends BaseStoreImpl {
    constructor(sthis: SuperThis, url: URI, opts: BaseStoreOpts, logger: Logger);
    load(cid: AnyLink): Promise<AnyBlock>;
    save(car: AnyBlock, opts?: DataSaveOpts): Promise<void>;
    remove(cid: AnyLink): Promise<Result<void>>;
    close(): Promise<Result<void>>;
    destroy(): Promise<Result<void>>;
}
export declare class CarStoreImpl extends DataStoreImpl implements CarStore {
    readonly storeType: string;
    constructor(sthis: SuperThis, url: URI, opts: BaseStoreOpts);
}
export declare class FileStoreImpl extends DataStoreImpl implements FileStore {
    readonly storeType: string;
    constructor(sthis: SuperThis, url: URI, opts: BaseStoreOpts);
}
export declare class WALStoreImpl extends BaseStoreImpl implements WALStore {
    readonly storeType: string;
    readonly _ready: ResolveOnce<void, void>;
    readonly walState: WALState;
    readonly processing?: Promise<void>;
    readonly processQueue: CommitQueueIf<unknown>;
    constructor(sthis: SuperThis, url: URI, opts: BaseStoreOpts);
    ready(): Promise<void>;
    enqueue(dbMeta: DbMeta, opts: CommitOpts): Promise<void>;
    enqueueFile(fileCid: AnyLink, publicFile?: boolean): Promise<void>;
    process(): Promise<void>;
    _doProcess(): Promise<void>;
    load(): Promise<WALState | Falsy>;
    save(state: WALState): Promise<void>;
    close(): Promise<Result<undefined, Error>>;
    destroy(): Promise<Result<void, Error>>;
}
export {};