import { Context, Effect, Layer, Stream } from "effect";
import type { Abi } from "viem";
import type { ClientNotFoundError, EventWatchError } from "../core/index.js";
import type { BackfillParams, DecodedEvent, WatchParams } from "../events/index.js";
import { EventBackfill, EventStream } from "../events/index.js";
import type { StorageError } from "../platform/browser/storage/index.js";
import type { ContractEventName } from "../types/index.js";
export type StreamCursor = {
    chainId: number;
    address: string;
    eventName: string;
    lastBlockNumber: bigint;
    lastLogIndex: number;
    updatedAt: number;
};
export type CursorStoreError = StorageError;
export type CursorStorage = {
    readonly get: (key: string) => Effect.Effect<StreamCursor | null, CursorStoreError>;
    readonly set: (key: string, cursor: StreamCursor) => Effect.Effect<void, CursorStoreError>;
    readonly delete: (key: string) => Effect.Effect<void, CursorStoreError>;
};
declare const CursorStore_base: Context.TagClass<CursorStore, "ew3/CursorStore", CursorStorage>;
export declare class CursorStore extends CursorStore_base {
}
export declare const InMemoryCursorStoreLive: Layer.Layer<CursorStore, never, never>;
export declare const makeCursorKey: (chainId: number, address: string, eventName: string) => string;
export type CursorStreamShape = {
    readonly watchWithCursor: <TAbi extends Abi, TEventName extends ContractEventName<TAbi>>(params: WatchParams<TAbi, TEventName> & {
        cursorKey: string;
    }) => Effect.Effect<Stream.Stream<DecodedEvent<TAbi, TEventName>, EventWatchError | StorageError>, ClientNotFoundError | StorageError>;
    readonly syncWithCursor: <TAbi extends Abi, TEventName extends ContractEventName<TAbi>>(params: BackfillParams<TAbi, TEventName> & {
        cursorKey: string;
    }) => Effect.Effect<Stream.Stream<DecodedEvent<TAbi, TEventName>, EventWatchError | StorageError>, ClientNotFoundError | StorageError>;
};
declare const CursorStream_base: Context.TagClass<CursorStream, "ew3/CursorStream", CursorStreamShape>;
export declare class CursorStream extends CursorStream_base {
}
export declare const CursorStreamLive: Layer.Layer<CursorStream, never, EventBackfill | CursorStore | EventStream>;
export {};
//# sourceMappingURL=cursor.d.ts.map