/**
 * @license
 * Copyright 2026 Steven Roussey <sroussey@gmail.com>
 * SPDX-License-Identifier: Apache-2.0
 */
import { DataPortSchemaObject, FromSchema, TypedArraySchemaOptions } from "@workglow/util/schema";
import { BaseTabularStorage, ClientProvidedKeysOption } from "./BaseTabularStorage";
import type { AnyTabularStorage, AutoGeneratedKeys, CoveringIndexQueryOptions, DeleteSearchCriteria, InsertEntity, Page, PageRequest, QueryOptions, SearchCriteria, SimplifyPrimaryKey, TabularChangePayload, TabularSubscribeOptions } from "./ITabularStorage";
export declare const HTTP_TABULAR_PROXY_REPOSITORY: import("@workglow/util").ServiceToken<AnyTabularStorage>;
/**
 * Fetch-shaped function used to forward operations to the server. The signature
 * matches the DOM `fetch` so a real browser fetch, an in-process Hono `app.fetch`,
 * or the Electron `window.desktop.api` shim all work without adaptation.
 */
export type HttpTabularProxyFetch = (path: string, init?: RequestInit) => Promise<Response>;
export interface HttpTabularProxyOptions<Schema extends DataPortSchemaObject, PrimaryKeyNames extends ReadonlyArray<keyof Schema["properties"]>> {
    readonly fetch: HttpTabularProxyFetch;
    readonly table: string;
    readonly schema: Schema;
    readonly primaryKey: PrimaryKeyNames;
    readonly indexes?: readonly (keyof Schema["properties"] | readonly (keyof Schema["properties"])[])[];
    /** Optional base path. Defaults to `/api/storage`. Trailing slashes are stripped. */
    readonly basePath?: string;
    /** Forwarded to BaseTabularStorage. Defaults to "if-missing". */
    readonly clientProvidedKeys?: ClientProvidedKeysOption;
}
/**
 * Storage adapter that forwards every {@link ITabularStorage} operation as
 * `POST {basePath}/{table}/{op}` through an injected fetch impl.
 *
 * Transport is the fetch impl's concern — this class doesn't know whether the
 * request crosses a socket (dev), a `MessageChannelMain` port (Electron prod),
 * or runs in-process against `app.fetch` (tests / web mode).
 *
 * Wire format is JSON: values must be JSON-serialisable. Schemas using
 * `Uint8Array` (blob) or `bigint` columns are NOT supported through this
 * proxy — those types don't round-trip through `JSON.stringify`/`res.json()`.
 * Add a field-aware (de)serializer here if a binary-valued schema ever needs
 * to go over the proxy.
 */
export declare class HttpTabularProxyStorage<Schema extends DataPortSchemaObject, PrimaryKeyNames extends ReadonlyArray<keyof Schema["properties"]>, Entity = FromSchema<Schema, TypedArraySchemaOptions>, PrimaryKey = SimplifyPrimaryKey<Entity, PrimaryKeyNames>, Value = Omit<Entity, PrimaryKeyNames[number] & keyof Entity>, InsertType = InsertEntity<Entity, AutoGeneratedKeys<Schema>>> extends BaseTabularStorage<Schema, PrimaryKeyNames, Entity, PrimaryKey, Value, InsertType> {
    protected readonly fetchImpl: HttpTabularProxyFetch;
    protected readonly table: string;
    protected readonly basePath: string;
    private pollingManager;
    constructor(opts: HttpTabularProxyOptions<Schema, PrimaryKeyNames>);
    protected url(op: string): string;
    /** Throws on non-2xx, propagating the server's `{ error }` body when present. */
    protected call<T>(op: string, body: unknown): Promise<T>;
    put(value: InsertType): Promise<Entity>;
    putBulk(values: InsertType[]): Promise<Entity[]>;
    get(key: PrimaryKey): Promise<Entity | undefined>;
    delete(key: PrimaryKey | Entity): Promise<void>;
    getBulk(keys: readonly PrimaryKey[]): Promise<Entity[]>;
    query(criteria: SearchCriteria<Entity>, options?: QueryOptions<Entity>): Promise<Entity[] | undefined>;
    getAll(options?: QueryOptions<Entity>): Promise<Entity[] | undefined>;
    size(): Promise<number>;
    count(criteria?: SearchCriteria<Entity>): Promise<number>;
    deleteAll(): Promise<void>;
    deleteSearch(criteria: DeleteSearchCriteria<Entity>): Promise<void>;
    getOffsetPage(offset: number, limit: number): Promise<Entity[] | undefined>;
    getPage(request?: PageRequest<Entity>): Promise<Page<Entity>>;
    queryPage(criteria: SearchCriteria<Entity>, request?: PageRequest<Entity>): Promise<Page<Entity>>;
    queryIndex<K extends keyof Entity & string>(criteria: SearchCriteria<Entity>, options: CoveringIndexQueryOptions<Entity, K>): Promise<Pick<Entity, K>[]>;
    subscribeToChanges(callback: (change: TabularChangePayload<Entity>) => void, options?: TabularSubscribeOptions): () => void;
    destroy(): void;
}
//# sourceMappingURL=HttpTabularProxyStorage.d.ts.map