lvguanjun / copilot_share Goto Github PK

// 
import httpx
from starlette.responses import StreamingResponse

async def proxy_request(request: Request, target_url: str) -> StreamingResponse:
    """
    Send a proxy request to the target URL.

    :param request: The request object to proxy.
    :param target_url: The target URL to proxy the request to.
    :return: A streaming response from the target server.
    """
    request_headers = dict(request.headers)
    request_headers.pop("Host", None)
    request_body = await request.body()
    request_method = request.method

    async with httpx.AsyncClient() as client:
        resp = await client.request(
            request_method,
            target_url,
            headers=request_headers,
            data=request_body,
            stream=True
        )

        return StreamingResponse(
            resp.aiter_bytes(),
            headers=resp.headers,
            status_code=resp.status_code
        )