Function handle_responses

uncommon_route/proxy.py:5842–5919

(request: Request)

        )

    async def handle_responses(request: Request) -> Response:
        raw = await request.json()
        previous_response_id = str(raw.get("previous_response_id") or "").strip()
        previous_messages = None
        if previous_response_id:
            previous_messages = _responses_history.get(previous_response_id)
            if previous_messages is None:
                return JSONResponse(
                    {
                        "error": {
                            "message": f"Unknown previous_response_id: {previous_response_id}",
                            "type": "invalid_request_error",
                        },
                    },
                    status_code=400,
                )

        body, chat_messages = responses_to_openai_chat_request(
            raw,
            previous_messages=previous_messages,
            default_model=VIRTUAL_MODEL_IDS[_routing_store.default_mode()],
        )
        response_id = f"resp_{uuid.uuid4().hex[:24]}"
        upstream_resp = await _handle_chat_core(
            body, request, endpoint_name="responses", source_body=raw,
        )

        if upstream_resp.status_code != 200:
            return upstream_resp

        if isinstance(upstream_resp, StreamingResponse):
            adapter = OpenAIChatToResponsesStreamAdapter(
                request_body=raw,
                response_id=response_id,
            )

            async def responses_sse() -> AsyncGenerator[bytes, None]:
                async for chunk in upstream_resp.body_iterator:
                    adapter.feed(chunk)
                events, assistant_message = adapter.finalize()
                if assistant_message is not None:
                    _responses_history[response_id] = json.loads(
                        json.dumps(chat_messages + [assistant_message])
                    )
                for event in events:
                    yield event

            headers = {
                key: value
                for key, value in upstream_resp.headers.items()
                if key.lower() not in {"content-length", "content-type"}
            }
            return StreamingResponse(
                responses_sse(),
                media_type="text/event-stream",
                headers=headers,
            )