import { type MethodRegistry } from '@kokuin/token';
import type { StoreProvider } from '@kubun/db';
import type { CatalogDraft, CatalogPullPreview, CatalogPullResult, CatalogUpstreamUnavailableReason, ResolveCatalogPullParams } from '@kubun/graphql';
import { type SignedRecord } from '@kubun/records';
import type { CatalogDraftState, CatalogHeadPayload, CatalogVersionPayload, CatalogVersionRef } from '@kubun/store-graph';
import type { CatalogAPIDeps, CatalogListing } from './catalog-contract.js';
import { TransactionFatalError } from './errors.js';
export type { CatalogPullPreview, CatalogPullResult, ResolveCatalogPullParams, } from '@kubun/graphql';
export declare class CatalogPullStaleError extends TransactionFatalError {
    get code(): string;
    constructor();
}
export type CatalogPullUnavailableErrorParams = {
    reason: CatalogUpstreamUnavailableReason;
    reclone?: boolean;
    cause?: unknown;
};
export declare class CatalogPullUnavailableError extends TransactionFatalError {
    #private;
    get reason(): CatalogUpstreamUnavailableReason;
    get reclone(): boolean;
    constructor(params: CatalogPullUnavailableErrorParams);
}
/**
 * The copy a sequential member-by-member loop would return, asking a few members
 * at once: the earliest member in list order that answers or throws decides, so a
 * later member's answer or error is ignored once an earlier one does. A decided
 * loser's signal aborts; an ask that ignores it is still dropped rather than
 * awaited. A transaction-bound provider asks one member at a time.
 */
export declare function firstMemberCopy<T, R>(provider: StoreProvider, members: ReadonlyArray<T>, ask: (member: T, signal: AbortSignal) => Promise<R | null | undefined>): Promise<R | null>;
export type CatalogPullBaseParams = {
    provider: StoreProvider;
    catalogID: string;
    head: CatalogHeadPayload;
    draft: CatalogDraftState | null;
    methods: MethodRegistry | undefined;
};
export type CatalogPullBase = {
    ref: CatalogVersionRef;
    record: SignedRecord;
    payload: CatalogVersionPayload;
};
export declare function catalogPullBase(params: CatalogPullBaseParams): Promise<CatalogPullBase>;
type CatalogPullAPIDeps = CatalogAPIDeps & {
    ownedHead(provider: StoreProvider, id: string): Promise<CatalogHeadPayload>;
    requireOwner(provider: StoreProvider, owner: string): Promise<unknown>;
    listing(provider: StoreProvider, id: string): Promise<CatalogListing>;
    draftView(provider: StoreProvider, draft: CatalogDraftState, head: CatalogHeadPayload): Promise<CatalogDraft>;
};
export declare function createCatalogPullAPI(deps: CatalogPullAPIDeps): {
    previewCatalogPull: (id: string) => Promise<CatalogPullPreview>;
    resolveCatalogPull: (params: ResolveCatalogPullParams) => Promise<CatalogPullResult>;
};