import { Static, TSchema, Type } from "typebox";
//#region src/schemas/protocol.d.ts
export declare const DOOM_PROTOCOL_ERROR_CODE: {
  readonly aborted: 'ABORTED';
  readonly invalidMessage: 'INVALID_MESSAGE';
  readonly providerError: 'PROVIDER_ERROR';
  readonly timeout: 'TIMEOUT';
};
export interface EventBusLike {
  emit(event: string, data: unknown): void;
  on(event: string, handler: (data: unknown) => void): () => void;
}
export declare const ProtocolErrorSchema: Type.TObject<{
  code: Type.TString;
  message: Type.TString;
  retryable: Type.TOptional<Type.TBoolean>;
}>;
export type ProtocolErrorPayload = Static<typeof ProtocolErrorSchema>;
export declare class DoomProtocolError extends Error {
  readonly code: string;
  readonly retryable: boolean;
  constructor(payload: ProtocolErrorPayload);
}
export declare class DoomProtocolValidationError extends DoomProtocolError {
  constructor(channel: string, details: string);
}
export interface ProtocolIdentity {
  source: string;
  sessionId: string;
}
export interface NotificationDefinition<TPayload extends TSchema> {
  channel: string;
  kind: string;
  payload: TPayload;
}
export interface RequestReplyDefinition<TRequest extends TSchema, TResponse extends TSchema> {
  requestChannel: string;
  responseChannel: string;
  errorChannel: string;
  requestKind: string;
  responseKind: string;
  request: TRequest;
  response: TResponse;
}
export interface RequestOptions {
  signal?: AbortSignal;
  timeoutMs?: number;
  /** Ignore correlated replies from any source except this exact provider. */
  expectedSource?: string;
}
export interface ProtocolRuntimeOptions extends ProtocolIdentity {
  bus: EventBusLike;
  defaultTimeoutMs?: number;
  createMessageId?: () => string;
  duplicateWindow?: number;
}
export interface ProtocolRuntime {
  notify<TPayload extends TSchema>(definition: NotificationDefinition<TPayload>, payload: Static<TPayload>): void;
  onNotification<TPayload extends TSchema>(definition: NotificationDefinition<TPayload>, handler: (payload: Static<TPayload>, identity: ProtocolIdentity) => void | Promise<void>): () => void;
  request<TRequest extends TSchema, TResponse extends TSchema>(definition: RequestReplyDefinition<TRequest, TResponse>, payload: Static<TRequest>, options?: RequestOptions): Promise<Static<TResponse>>;
  provide<TRequest extends TSchema, TResponse extends TSchema>(definition: RequestReplyDefinition<TRequest, TResponse>, handler: (payload: Static<TRequest>, identity: ProtocolIdentity) => Static<TResponse> | Promise<Static<TResponse>>): () => void;
}
export declare function defineNotification<TPayload extends TSchema>(definition: {
  channel: `doom:${string}:${string}:v1:${string}`;
  kind: string;
  payload: TPayload;
}): NotificationDefinition<TPayload>;
export declare function defineRequestReply<TRequest extends TSchema, TResponse extends TSchema>(definition: {
  channels: {
    request: `doom:${string}:${string}:v1:${string}`;
    response: `doom:${string}:${string}:v1:${string}`;
    error: `doom:${string}:${string}:v1:${string}`;
  };
  kinds: {
    request: string;
    response: string;
  };
  request: TRequest;
  response: TResponse;
}): RequestReplyDefinition<TRequest, TResponse>;
export declare const defineJob: typeof defineRequestReply;
export declare function createProtocolRuntime(options: ProtocolRuntimeOptions): ProtocolRuntime;
//#endregion
//# sourceMappingURL=protocol.d.cts.map