Function handleWebSocketRealtime

src/ws-realtime.ts:302–400

(
  ws: WebSocketConnection,
  fixtures: Fixture[],
  journal: Journal,
  defaults: {
    latency: number;
    chunkSize: number;
    replaySpeed?: number;
    model: string;
    logger: Logger;
    strict?: boolean;
    requestTransform?: (req: ChatCompletionRequest) => ChatCompletionRequest;
    testId?: string;
    upgradeHeaders?: import("node:http").IncomingHttpHeaders;
  },
)

// ─── Main handler ───────────────────────────────────────────────────────────

export function handleWebSocketRealtime(
  ws: WebSocketConnection,
  fixtures: Fixture[],
  journal: Journal,
  defaults: {
    latency: number;
    chunkSize: number;
    replaySpeed?: number;
    model: string;
    logger: Logger;
    strict?: boolean;
    requestTransform?: (req: ChatCompletionRequest) => ChatCompletionRequest;
    testId?: string;
    upgradeHeaders?: import("node:http").IncomingHttpHeaders;
  },
): void {
  const { logger } = defaults;
  const sessionId = realtimeId("sess");

  const isBeta = defaults.upgradeHeaders?.["openai-beta"]
    ? String(defaults.upgradeHeaders["openai-beta"]).includes("realtime=v1")
    : false;

  const session: SessionConfig = {
    model: defaults.model,
    modalities: ["text"],
    instructions: "",
    tools: [],
    voice: null,
    input_audio_format: null,
    output_audio_format: null,
    input_audio_noise_reduction: null,
    input_audio_transcription: null,
    turn_detection: null,
    temperature: 0.8,
    type: "conversation",
    reasoning: null,
  };

  const conversationItems: RealtimeItem[] = [];

  // Send session.created immediately on connect (GA format — shim flattens for Beta)
  sendEvent(
    ws,
    {
      type: "session.created",
      session: {
        id: sessionId,
        object: "realtime.session",
        model: session.model,
        expires_at: Math.floor(Date.now() / 1000) + 3600,
        modalities: session.modalities,
        instructions: session.instructions,
        tools: session.tools,
        tool_choice: "auto",
        temperature: session.temperature,
        max_response_output_tokens: "inf",
        audio: {