Function processFrame

server.js:221–283

(raw)

  });

  const processFrame = async (raw) => {
    if (closed) return;

    if (typeof raw !== "string") {
      emitErrorEvent(ws, "invalid_frame_type", "Only text WebSocket frames are supported");
      requestClose(1003, "binary_not_supported");
      return;
    }

    let frame;
    try {
      frame = JSON.parse(raw);
    } catch (err) {
      emitErrorEvent(
        ws,
        "invalid_json",
        `Invalid JSON frame: ${err && err.message ? err.message : "parse error"}`
      );
      return;
    }

    if (!frame || typeof frame !== "object") {
      emitErrorEvent(ws, "invalid_frame", "Frame must be a JSON object");
      return;
    }

    if (frame.type !== "response.create") {
      emitErrorEvent(
        ws,
        "unsupported_event_type",
        `Only type=response.create is supported; received: ${frame.type ?? "(missing)"}`
      );
      return;
    }

    const { type: _type, ...rawBody } = frame;
    const body = { ...rawBody };
    // body.model wins over query; only fill from query when body lacks a model
    // (LiteLLM/other compat). Drop transport-only fields.
    if (queryModel && (body.model === undefined || body.model === null || body.model === "")) {
      body.model = queryModel;
    }

    log("info", "ws_request_started", {
      model: typeof body.model === "string" ? body.model : null,
      payloadBytes: Buffer.byteLength(raw, "utf8"),
      hasPreviousResponseId: typeof body.previous_response_id === "string",
    });

    await forwardToInternalHttp(
      ws,
      req,
      body,
      responsesWsSessionId,
      (clientReq) => {
        currentInternalReq = clientReq;
      },
      requestClose