import type { ConnectorProxy } from './connector-proxy.js';
import type { IntegrationEndpointMethod, JsonValue, TriggerKeySnapshot } from '../browser/project-change.js';
export declare const maximumIntegrationBodyBytes: number;
export declare const maximumIntegrationDeliveryPages = 5;
export type IntegrationReceiveResult = {
    readonly checkpoint?: JsonValue;
    readonly continue?: boolean;
    readonly dedupeKey?: string;
    readonly outcome: 'event';
    readonly payload: Readonly<Record<string, JsonValue>>;
} | {
    readonly checkpoint?: JsonValue;
    readonly continue?: boolean;
    readonly outcome: 'ignored';
    readonly reason: string;
} | {
    readonly body: string;
    readonly contentType: string;
    readonly headers?: Readonly<Record<string, string>>;
    readonly outcome: 'respond';
    readonly status: number;
};
export interface IntegrationStateContext {
    readonly checkpoint: JsonValue;
    readonly subscription: Readonly<Record<string, JsonValue>>;
    readonly saveCheckpoint: (checkpoint: JsonValue) => Promise<void>;
    readonly saveSubscription: (subscription: Readonly<Record<string, JsonValue>>, reconcileAt: Date) => Promise<void>;
}
export interface IntegrationReceiveContext {
    readonly admit: boolean;
    readonly allow?: () => Promise<boolean>;
    readonly bindingId: string;
    readonly callbackSecret: string;
    readonly config: Readonly<Record<string, JsonValue>>;
    readonly connector: ConnectorProxy;
    readonly current: boolean;
    readonly header: (name: string) => string | undefined;
    readonly method: IntegrationEndpointMethod;
    readonly now: Date;
    readonly payload: JsonValue;
    readonly query: (name: string) => string | undefined;
    readonly state?: IntegrationStateContext;
}
export interface IntegrationReconcileContext {
    readonly active: boolean;
    readonly callbackSecret: string;
    readonly config: Readonly<Record<string, JsonValue>>;
    readonly connector: ConnectorProxy;
    readonly endpointUrl: string;
    readonly now: Date;
    readonly signal?: AbortSignal;
    readonly state?: IntegrationStateContext;
}
export interface IntegrationReconcileResult {
    readonly outcome: 'pending' | 'ready';
}
export interface IntegrationDefinition {
    readonly initialState?: {
        readonly checkpoint: JsonValue;
        readonly subscription: Readonly<Record<string, JsonValue>>;
    };
    readonly receive: (context: IntegrationReceiveContext) => IntegrationReceiveResult | Promise<IntegrationReceiveResult>;
    readonly reconcile: (context: IntegrationReconcileContext) => Promise<IntegrationReconcileResult>;
    readonly snapshot: TriggerKeySnapshot & {
        readonly type: 'integration';
    };
}
export declare class IntegrationConnectionError extends Error {
    readonly name = "IntegrationConnectionError";
}
export declare class PermanentIntegrationError extends Error {
    readonly name = "PermanentIntegrationError";
}
export declare class TransientIntegrationError extends Error {
    readonly name = "TransientIntegrationError";
}
export declare function integrationEndpointId(url: URL): string | undefined;
export declare function integrationCallbackSecret(callbackKey: string | undefined, endpointId: string): Promise<string>;
export declare function integrationOccurrenceId(bindingId: string, runtimeVersion: number, definitionKey: string, dedupeKey: string | null): Promise<string>;
export interface IntegrationConformanceFixture {
    readonly config: Readonly<Record<string, JsonValue>>;
    readonly connectionId: string;
    readonly definition: Pick<IntegrationDefinition, 'initialState' | 'receive' | 'reconcile'>;
    readonly publishedAt: string;
}
export interface IntegrationConformanceState {
    readonly checkpoint: JsonValue | null;
    readonly health: 'healthy' | 'initializing';
    readonly payloads: readonly JsonValue[];
    readonly receiveCalls: number;
    readonly reconcileCalls: number;
    readonly runtimeVersion: number;
    readonly subscription: Readonly<Record<string, JsonValue>> | null;
}
export interface IntegrationConformanceHarness {
    readonly callbackSecret: string;
    readonly endpointUrl: string;
    dispose(): Promise<void>;
    reconcile(at: string): Promise<void>;
    republish(at: string): Promise<void>;
    request(request: Request): Promise<Response>;
    restart(): Promise<void>;
    retire(at: string): Promise<void>;
    state(): Promise<IntegrationConformanceState>;
}
export interface IntegrationConformanceCase {
    readonly fixture: IntegrationConformanceFixture;
    readonly name: string;
    verify(harness: IntegrationConformanceHarness): Promise<void>;
}
export declare const integrationConformanceCases: readonly IntegrationConformanceCase[];