export function acquireConversation(
  ctx: ConformanceRunContext,
  n: number,
  namePrefix: string,
): Effect.Effect<ConversationFixture, string, Scope.Scope>

export interface ConversationActor {
  readonly agent: TestAgent;
  readonly client: AgentTestClient;

  /**
   * Per-client historical notification buffer: `subscribe`
   * only emits frames arriving AFTER materialisation, so a sequential
   * `send → read snapshot` races the response frame. The buffer
   * is fed by a long-lived
   * `subscribeAll()` pump installed at `acquireClient` time, so frames that
   * arrived between the triggering RPC and the read are still observable.
   * This mirrors `@moltzap/server-core/test-utils → connectTestClient` (the
   * `makeNotificationBuffer` JSDoc below covers the design).
   */
  readonly notifications: NotificationBuffer;
}

export interface ConversationFixture {
  readonly owner: ConversationActor;
  readonly participants: readonly ConversationActor[];
  readonly conversationId: ConversationId;

  /**
   * The app-principal `AppConnection` bound as the conversation's
   * moderator. App-admin RPCs head their `requires` with `AppPrincipal`, so
   * they route through THIS client, not the agent `owner`. `owner` drives
   * `agent/conversation/create` + `agent/message/send`.
   */
  readonly moderatorClient: AppTestClient;
}

export const DELIVERY_CATEGORY = "delivery"

export const DELIVERY_DEFAULT_PROPERTY_NUM_RUNS = 3

export const DELIVERY_DEFAULT_TIMEOUT_MS = 5000

export const DELIVERY_PROPERTIES: ReadonlyArray<
  (ctx: ConformanceRunContext) => void
> = [registerFanOutCardinality, registerStoreAndReplay, registerPayloadOpacity]

export function deliveryViolation(
  name: string,
  reason: string,
): PropertyInvariantViolation

export function fixtureN(requested: number): number

export interface NotificationBuffer {
  readonly snapshot: Ref.Ref<
    ReadonlyArray<NotificationDelivery<AnyNotificationDefinition>>
  >;
  readonly closed: Ref.Ref<boolean>;
}

export function registerFanOutCardinality(ctx: ConformanceRunContext): void

export function registerPayloadOpacity(ctx: ConformanceRunContext): void

export function registerStoreAndReplay(ctx: ConformanceRunContext): void