diff --git a/server/pyproject.toml b/server/pyproject.toml index ca41b330..65e94865 100644 --- a/server/pyproject.toml +++ b/server/pyproject.toml @@ -51,6 +51,7 @@ dependencies = [ "pyyaml", "tomli; python_version < \"3.11\"", "uvicorn", + "websockets>=14.0", ] [project.urls] diff --git a/server/src/api/lifecycle.py b/server/src/api/lifecycle.py index 51819294..94dfe85d 100644 --- a/server/src/api/lifecycle.py +++ b/server/src/api/lifecycle.py @@ -19,12 +19,19 @@ All business logic is delegated to the service layer that backs each operation. """ -from typing import List, Optional +import logging +from collections.abc import Mapping +from typing import List, Optional, cast +import anyio import httpx -from fastapi import APIRouter, Header, Query, Request, status +import websockets +from websockets.asyncio.client import ClientConnection +from websockets.typing import Origin +from fastapi import APIRouter, Header, Query, Request, WebSocket, status from fastapi.exceptions import HTTPException from fastapi.responses import Response, StreamingResponse +from starlette.websockets import WebSocketDisconnect from src.api.schema import ( CreateSandboxRequest, @@ -59,13 +66,238 @@ "cookie", } +WEBSOCKET_HANDSHAKE_HEADERS = { + "origin", + "sec-websocket-extensions", + "sec-websocket-key", + "sec-websocket-protocol", + "sec-websocket-version", +} + # Initialize router router = APIRouter(tags=["Sandboxes"]) +logger = logging.getLogger(__name__) # Initialize service based on configuration from config.toml (defaults to docker) sandbox_service = create_sandbox_service() +def _build_proxy_target_url( + endpoint: Endpoint, + full_path: str, + query_string: str, + *, + websocket: bool = False, +) -> str: + """Build the backend URL from an endpoint plus optional path/query suffix.""" + scheme = "ws" if websocket else "http" + base = endpoint.endpoint.rstrip("/") + normalized_path = full_path.lstrip("/") + url = f"{scheme}://{base}" + if normalized_path: + url = f"{url}/{normalized_path}" + if query_string: + url = f"{url}?{query_string}" + return url + + +def _filter_proxy_headers( + headers: Mapping[str, str], + endpoint_headers: Optional[dict[str, str]] = None, + *, + extra_excluded: Optional[set[str]] = None, +) -> dict[str, str]: + """Drop transport/auth headers while preserving app-level headers.""" + excluded = set(HOP_BY_HOP_HEADERS) | set(SENSITIVE_HEADERS) + if extra_excluded: + excluded.update(extra_excluded) + + forwarded: dict[str, str] = {} + for key, value in headers.items(): + key_lower = key.lower() + if key_lower != "host" and key_lower not in excluded: + forwarded[key] = value + + if endpoint_headers: + forwarded.update(endpoint_headers) + return forwarded + + +async def _proxy_http_request( + request: Request, + sandbox_id: str, + port: int, + full_path: str, +) -> StreamingResponse: + endpoint = sandbox_service.get_endpoint(sandbox_id, port) + target_url = _build_proxy_target_url(endpoint, full_path, request.url.query) + client: httpx.AsyncClient = request.app.state.http_client + + try: + upgrade_header = request.headers.get("Upgrade", "") + if upgrade_header.lower() == "websocket": + raise HTTPException( + status_code=400, detail="Websocket upgrade is not supported yet" + ) + + headers = _filter_proxy_headers(request.headers, endpoint.headers) + req = client.build_request( + method=request.method, + url=target_url, + headers=headers, + content=request.stream(), + ) + + resp = await client.send(req, stream=True) + + return StreamingResponse( + content=resp.aiter_bytes(), + status_code=resp.status_code, + headers=resp.headers, + ) + except httpx.ConnectError as e: + raise HTTPException( + status_code=502, + detail=f"Could not connect to the backend sandbox {endpoint}: {e}", + ) from e + except HTTPException: + raise + except Exception as e: + raise HTTPException( + status_code=500, detail=f"An internal error occurred in the proxy: {e}" + ) from e + + +async def _relay_client_messages( + websocket: WebSocket, + backend: ClientConnection, + cancel_scope: anyio.CancelScope, +) -> None: + try: + while True: + message = await websocket.receive() + if message["type"] == "websocket.receive": + if message.get("text") is not None: + await backend.send(message["text"]) + elif message.get("bytes") is not None: + await backend.send(message["bytes"]) + elif message["type"] == "websocket.disconnect": + await backend.close( + code=message.get("code", status.WS_1000_NORMAL_CLOSURE), + reason=message.get("reason") or "", + ) + return + except WebSocketDisconnect as exc: + await backend.close(code=exc.code, reason=getattr(exc, "reason", "") or "") + finally: + cancel_scope.cancel() + + +async def _relay_backend_messages( + websocket: WebSocket, + backend: ClientConnection, + cancel_scope: anyio.CancelScope, +) -> None: + try: + while True: + payload = await backend.recv() + if isinstance(payload, bytes): + await websocket.send_bytes(payload) + else: + await websocket.send_text(payload) + except websockets.ConnectionClosed as exc: + try: + await websocket.close( + code=exc.code or status.WS_1000_NORMAL_CLOSURE, + reason=exc.reason or "", + ) + except RuntimeError: + pass + finally: + cancel_scope.cancel() + + +async def _proxy_websocket_request( + websocket: WebSocket, + sandbox_id: str, + port: int, + full_path: str, +) -> None: + try: + endpoint = sandbox_service.get_endpoint(sandbox_id, port) + except HTTPException as exc: + logger.warning( + "Rejecting websocket proxy request for sandbox=%s port=%s: %s", + sandbox_id, + port, + exc.detail, + ) + await websocket.close(code=status.WS_1011_INTERNAL_ERROR) + return + + target_url = _build_proxy_target_url( + endpoint, + full_path, + websocket.url.query, + websocket=True, + ) + headers = _filter_proxy_headers( + websocket.headers, + endpoint.headers, + extra_excluded=WEBSOCKET_HANDSHAKE_HEADERS, + ) + subprotocols = list(websocket.scope.get("subprotocols", [])) + origin = cast(Origin | None, websocket.headers.get("origin")) + + try: + async with websockets.connect( + target_url, + additional_headers=headers or None, + subprotocols=subprotocols or None, + origin=origin, + ) as backend: + await websocket.accept(subprotocol=backend.subprotocol) + async with anyio.create_task_group() as task_group: + task_group.start_soon( + _relay_client_messages, + websocket, + backend, + task_group.cancel_scope, + ) + task_group.start_soon( + _relay_backend_messages, + websocket, + backend, + task_group.cancel_scope, + ) + except websockets.InvalidStatus as exc: + logger.warning( + "Backend websocket handshake failed for sandbox=%s port=%s: %s", + sandbox_id, + port, + exc, + ) + await websocket.close(code=status.WS_1008_POLICY_VIOLATION) + except OSError as exc: + logger.warning( + "Could not connect websocket proxy for sandbox=%s port=%s: %s", + sandbox_id, + port, + exc, + ) + await websocket.close(code=status.WS_1011_INTERNAL_ERROR) + except Exception: + logger.exception( + "Unexpected websocket proxy failure for sandbox=%s port=%s", + sandbox_id, + port, + ) + try: + await websocket.close(code=status.WS_1011_INTERNAL_ERROR) + except RuntimeError: + pass + + # ============================================================================ # Sandbox CRUD Operations # ============================================================================ @@ -419,66 +651,44 @@ async def get_sandbox_endpoint( @router.api_route( - "/sandboxes/{sandbox_id}/proxy/{port}/{full_path:path}", + "/sandboxes/{sandbox_id}/proxy/{port}", methods=["GET", "POST", "PUT", "DELETE", "PATCH"], ) -async def proxy_sandbox_endpoint_request(request: Request, sandbox_id: str, port: int, full_path: str): - """ - Receives all incoming requests, determines the target sandbox from path parameter, - and asynchronously proxies the request to it. - """ +async def proxy_sandbox_endpoint_root(request: Request, sandbox_id: str, port: int): + """Proxy HTTP requests targeting the backend root path.""" + return await _proxy_http_request(request, sandbox_id, port, "") - endpoint = sandbox_service.get_endpoint(sandbox_id, port) - - target_host = endpoint.endpoint - query_string = request.url.query - target_url = ( - f"http://{target_host}/{full_path}?{query_string}" - if query_string - else f"http://{target_host}/{full_path}" - ) - client: httpx.AsyncClient = request.app.state.http_client +@router.api_route( + "/sandboxes/{sandbox_id}/proxy/{port}/{full_path:path}", + methods=["GET", "POST", "PUT", "DELETE", "PATCH"], +) +async def proxy_sandbox_endpoint_request( + request: Request, + sandbox_id: str, + port: int, + full_path: str, +): + """Proxy HTTP requests to sandbox-backed services.""" + return await _proxy_http_request(request, sandbox_id, port, full_path) - try: - upgrade_header = request.headers.get("Upgrade", "") - if upgrade_header.lower() == "websocket": - raise HTTPException(status_code=400, detail="Websocket upgrade is not supported yet") - - # Filter headers - headers = {} - for key, value in request.headers.items(): - key_lower = key.lower() - if ( - key_lower != "host" - and key_lower not in HOP_BY_HOP_HEADERS - and key_lower not in SENSITIVE_HEADERS - ): - headers[key] = value - req = client.build_request( - method=request.method, - url=target_url, - headers=headers, - content=request.stream(), - ) +@router.websocket("/sandboxes/{sandbox_id}/proxy/{port}") +async def proxy_sandbox_endpoint_root_websocket( + websocket: WebSocket, + sandbox_id: str, + port: int, +): + """Proxy websocket requests targeting the backend root path.""" + await _proxy_websocket_request(websocket, sandbox_id, port, "") - resp = await client.send(req, stream=True) - return StreamingResponse( - content=resp.aiter_bytes(), - status_code=resp.status_code, - headers=resp.headers, - ) - except httpx.ConnectError as e: - raise HTTPException( - status_code=502, - detail=f"Could not connect to the backend sandbox {endpoint}: {e}", - ) - except HTTPException: - # Preserve explicit HTTP exceptions raised above (e.g. websocket upgrade not supported). - raise - except Exception as e: - raise HTTPException( - status_code=500, detail=f"An internal error occurred in the proxy: {e}" - ) +@router.websocket("/sandboxes/{sandbox_id}/proxy/{port}/{full_path:path}") +async def proxy_sandbox_endpoint_request_websocket( + websocket: WebSocket, + sandbox_id: str, + port: int, + full_path: str, +): + """Proxy websocket requests to sandbox-backed services.""" + await _proxy_websocket_request(websocket, sandbox_id, port, full_path) diff --git a/server/tests/test_routes_proxy.py b/server/tests/test_routes_proxy.py index 0ba168f0..e62442af 100644 --- a/server/tests/test_routes_proxy.py +++ b/server/tests/test_routes_proxy.py @@ -12,6 +12,9 @@ # See the License for the specific language governing permissions and # limitations under the License. +import asyncio +from typing import Any, cast + import httpx from fastapi.testclient import TestClient @@ -54,6 +57,51 @@ async def send(self, req, stream: bool = True): return self.response +def _set_http_client(client: TestClient, fake_client: _FakeAsyncClient) -> None: + cast(Any, client.app).state.http_client = fake_client + + +class _FakeBackendWebSocket: + def __init__(self, message: str = "backend-ready", subprotocol: str | None = "claw.v1"): + self.message = message + self.subprotocol = subprotocol + self.sent: list[str | bytes] = [] + self.close_calls: list[tuple[int, str]] = [] + self._delivered = False + + async def send(self, payload: str | bytes) -> None: + self.sent.append(payload) + + async def recv(self) -> str: + if not self._delivered: + self._delivered = True + return self.message + await asyncio.Future() + raise AssertionError("unreachable") + + async def close(self, code: int = 1000, reason: str = "") -> None: + self.close_calls.append((code, reason)) + + +class _FakeWebSocketConnector: + def __init__(self, backend: _FakeBackendWebSocket): + self.backend = backend + self.calls: list[dict] = [] + + def __call__(self, uri: str, **kwargs): + self.calls.append({"uri": uri, **kwargs}) + backend = self.backend + + class _ContextManager: + async def __aenter__(self): + return backend + + async def __aexit__(self, exc_type, exc, tb): + return False + + return _ContextManager() + + def test_proxy_forwards_filtered_headers_and_query( client: TestClient, auth_headers: dict, @@ -74,7 +122,7 @@ def get_endpoint(sandbox_id: str, port: int) -> Endpoint: headers={"x-backend": "yes"}, chunks=[b"proxy-ok"], ) - client.app.state.http_client = fake_client + _set_http_client(client, fake_client) headers = { **auth_headers, @@ -109,6 +157,44 @@ def get_endpoint(sandbox_id: str, port: int) -> Endpoint: assert lowered_headers.get("x-trace") == "trace-1" +def test_proxy_root_path_forwards_endpoint_headers_and_query( + client: TestClient, + auth_headers: dict, + monkeypatch, +) -> None: + class StubService: + @staticmethod + def get_endpoint(sandbox_id: str, port: int) -> Endpoint: + assert sandbox_id == "sbx-123" + assert port == 44772 + return Endpoint( + endpoint="10.57.1.91:40109/base", + headers={"OpenSandbox-Ingress-To": "sbx-123-44772"}, + ) + + monkeypatch.setattr(lifecycle, "sandbox_service", StubService()) + + fake_client = _FakeAsyncClient() + fake_client.response = _FakeStreamingResponse(chunks=[b"root-ok"]) + _set_http_client(client, fake_client) + + response = client.get( + "/v1/sandboxes/sbx-123/proxy/44772", + params={"q": "search"}, + headers={**auth_headers, "X-Trace": "trace-root"}, + ) + + assert response.status_code == 200 + assert response.content == b"root-ok" + assert fake_client.built is not None + assert fake_client.built["url"] == "http://10.57.1.91:40109/base?q=search" + lowered_headers = { + key.lower(): value for key, value in fake_client.built["headers"].items() + } + assert lowered_headers["opensandbox-ingress-to"] == "sbx-123-44772" + assert lowered_headers["x-trace"] == "trace-root" + + def test_proxy_rejects_websocket_upgrade( client: TestClient, auth_headers: dict, @@ -120,7 +206,7 @@ def get_endpoint(sandbox_id: str, port: int) -> Endpoint: return Endpoint(endpoint="10.57.1.91:40109") monkeypatch.setattr(lifecycle, "sandbox_service", StubService()) - client.app.state.http_client = _FakeAsyncClient() + _set_http_client(client, _FakeAsyncClient()) response = client.get( "/v1/sandboxes/sbx-123/proxy/44772/ws", @@ -142,7 +228,7 @@ def get_endpoint(sandbox_id: str, port: int) -> Endpoint: return Endpoint(endpoint="10.57.1.91:40109") monkeypatch.setattr(lifecycle, "sandbox_service", StubService()) - client.app.state.http_client = _FakeAsyncClient() + _set_http_client(client, _FakeAsyncClient()) response = client.post( "/v1/sandboxes/sbx-123/proxy/44772/ws", @@ -154,6 +240,57 @@ def get_endpoint(sandbox_id: str, port: int) -> Endpoint: assert response.json()["message"] == "Websocket upgrade is not supported yet" +def test_proxy_websocket_relays_messages_and_forwards_safe_headers( + client: TestClient, + auth_headers: dict, + monkeypatch, +) -> None: + class StubService: + @staticmethod + def get_endpoint(sandbox_id: str, port: int) -> Endpoint: + assert sandbox_id == "sbx-123" + assert port == 44772 + return Endpoint( + endpoint="10.57.1.91:40109/proxy/44772", + headers={"OpenSandbox-Ingress-To": "sbx-123-44772"}, + ) + + monkeypatch.setattr(lifecycle, "sandbox_service", StubService()) + backend = _FakeBackendWebSocket() + connector = _FakeWebSocketConnector(backend) + monkeypatch.setattr(lifecycle.websockets, "connect", connector) + + with client.websocket_connect( + "/v1/sandboxes/sbx-123/proxy/44772/ws?token=abc", + headers={ + **auth_headers, + "Authorization": "Bearer top-secret", + "Cookie": "sid=secret", + "Origin": "https://ui.example.com", + "X-Trace": "trace-ws", + }, + subprotocols=["claw.v1"], + ) as websocket: + assert websocket.receive_text() == "backend-ready" + websocket.send_text("client-ready") + + assert backend.sent == ["client-ready"] + assert backend.close_calls[0][0] == 1000 + + call = connector.calls[0] + assert call["uri"] == "ws://10.57.1.91:40109/proxy/44772/ws?token=abc" + assert call["origin"] == "https://ui.example.com" + assert call["subprotocols"] == ["claw.v1"] + lowered_headers = { + key.lower(): value for key, value in (call["additional_headers"] or {}).items() + } + assert "authorization" not in lowered_headers + assert "cookie" not in lowered_headers + assert "origin" not in lowered_headers + assert lowered_headers["opensandbox-ingress-to"] == "sbx-123-44772" + assert lowered_headers["x-trace"] == "trace-ws" + + def test_proxy_maps_connect_error_to_502( client: TestClient, auth_headers: dict, @@ -167,7 +304,7 @@ def get_endpoint(sandbox_id: str, port: int) -> Endpoint: monkeypatch.setattr(lifecycle, "sandbox_service", StubService()) fake_client = _FakeAsyncClient() fake_client.raise_connect_error = True - client.app.state.http_client = fake_client + _set_http_client(client, fake_client) response = client.get( "/v1/sandboxes/sbx-123/proxy/44772/healthz", @@ -191,7 +328,7 @@ def get_endpoint(sandbox_id: str, port: int) -> Endpoint: monkeypatch.setattr(lifecycle, "sandbox_service", StubService()) fake_client = _FakeAsyncClient() fake_client.raise_generic_error = True - client.app.state.http_client = fake_client + _set_http_client(client, fake_client) response = client.get( "/v1/sandboxes/sbx-123/proxy/44772/healthz", diff --git a/server/uv.lock b/server/uv.lock index 075539b8..54207cb2 100644 --- a/server/uv.lock +++ b/server/uv.lock @@ -427,6 +427,7 @@ dependencies = [ { name = "pyyaml" }, { name = "tomli", marker = "python_full_version < '3.11'" }, { name = "uvicorn" }, + { name = "websockets" }, ] [package.dev-dependencies] @@ -449,6 +450,7 @@ requires-dist = [ { name = "pyyaml" }, { name = "tomli", marker = "python_full_version < '3.11'" }, { name = "uvicorn" }, + { name = "websockets", specifier = ">=14.0" }, ] [package.metadata.requires-dev] @@ -986,3 +988,71 @@ sdist = { url = "https://files.pythonhosted.org/packages/2c/41/aa4bf9664e4cda14c wheels = [ { url = "https://files.pythonhosted.org/packages/34/db/b10e48aa8fff7407e67470363eac595018441cf32d5e1001567a7aeba5d2/websocket_client-1.9.0-py3-none-any.whl", hash = "sha256:af248a825037ef591efbf6ed20cc5faa03d3b47b9e5a2230a529eeee1c1fc3ef", size = 82616, upload-time = "2025-10-07T21:16:34.951Z" }, ] + +[[package]] +name = "websockets" +version = "16.0" +source = { registry = "https://pypi.org/simple" } +sdist = { url = "https://files.pythonhosted.org/packages/04/24/4b2031d72e840ce4c1ccb255f693b15c334757fc50023e4db9537080b8c4/websockets-16.0.tar.gz", hash = "sha256:5f6261a5e56e8d5c42a4497b364ea24d94d9563e8fbd44e78ac40879c60179b5", size = 179346, upload-time = "2026-01-10T09:23:47.181Z" } +wheels = [ + { url = "https://files.pythonhosted.org/packages/20/74/221f58decd852f4b59cc3354cccaf87e8ef695fede361d03dc9a7396573b/websockets-16.0-cp310-cp310-macosx_10_9_universal2.whl", hash = "sha256:04cdd5d2d1dacbad0a7bf36ccbcd3ccd5a30ee188f2560b7a62a30d14107b31a", size = 177343, upload-time = "2026-01-10T09:22:21.28Z" }, + { url = "https://files.pythonhosted.org/packages/19/0f/22ef6107ee52ab7f0b710d55d36f5a5d3ef19e8a205541a6d7ffa7994e5a/websockets-16.0-cp310-cp310-macosx_10_9_x86_64.whl", hash = "sha256:8ff32bb86522a9e5e31439a58addbb0166f0204d64066fb955265c4e214160f0", size = 175021, upload-time = "2026-01-10T09:22:22.696Z" }, + { url = "https://files.pythonhosted.org/packages/10/40/904a4cb30d9b61c0e278899bf36342e9b0208eb3c470324a9ecbaac2a30f/websockets-16.0-cp310-cp310-macosx_11_0_arm64.whl", hash = "sha256:583b7c42688636f930688d712885cf1531326ee05effd982028212ccc13e5957", size = 175320, upload-time = "2026-01-10T09:22:23.94Z" }, + { url = "https://files.pythonhosted.org/packages/9d/2f/4b3ca7e106bc608744b1cdae041e005e446124bebb037b18799c2d356864/websockets-16.0-cp310-cp310-manylinux1_x86_64.manylinux_2_28_x86_64.manylinux_2_5_x86_64.whl", hash = "sha256:7d837379b647c0c4c2355c2499723f82f1635fd2c26510e1f587d89bc2199e72", size = 183815, upload-time = "2026-01-10T09:22:25.469Z" }, + { url = "https://files.pythonhosted.org/packages/86/26/d40eaa2a46d4302becec8d15b0fc5e45bdde05191e7628405a19cf491ccd/websockets-16.0-cp310-cp310-manylinux2014_aarch64.manylinux_2_17_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:df57afc692e517a85e65b72e165356ed1df12386ecb879ad5693be08fac65dde", size = 185054, upload-time = "2026-01-10T09:22:27.101Z" }, + { url = "https://files.pythonhosted.org/packages/b0/ba/6500a0efc94f7373ee8fefa8c271acdfd4dca8bd49a90d4be7ccabfc397e/websockets-16.0-cp310-cp310-musllinux_1_2_aarch64.whl", hash = "sha256:2b9f1e0d69bc60a4a87349d50c09a037a2607918746f07de04df9e43252c77a3", size = 184565, upload-time = "2026-01-10T09:22:28.293Z" }, + { url = "https://files.pythonhosted.org/packages/04/b4/96bf2cee7c8d8102389374a2616200574f5f01128d1082f44102140344cc/websockets-16.0-cp310-cp310-musllinux_1_2_x86_64.whl", hash = "sha256:335c23addf3d5e6a8633f9f8eda77efad001671e80b95c491dd0924587ece0b3", size = 183848, upload-time = "2026-01-10T09:22:30.394Z" }, + { url = "https://files.pythonhosted.org/packages/02/8e/81f40fb00fd125357814e8c3025738fc4ffc3da4b6b4a4472a82ba304b41/websockets-16.0-cp310-cp310-win32.whl", hash = "sha256:37b31c1623c6605e4c00d466c9d633f9b812ea430c11c8a278774a1fde1acfa9", size = 178249, upload-time = "2026-01-10T09:22:32.083Z" }, + { url = "https://files.pythonhosted.org/packages/b4/5f/7e40efe8df57db9b91c88a43690ac66f7b7aa73a11aa6a66b927e44f26fa/websockets-16.0-cp310-cp310-win_amd64.whl", hash = "sha256:8e1dab317b6e77424356e11e99a432b7cb2f3ec8c5ab4dabbcee6add48f72b35", size = 178685, upload-time = "2026-01-10T09:22:33.345Z" }, + { url = "https://files.pythonhosted.org/packages/f2/db/de907251b4ff46ae804ad0409809504153b3f30984daf82a1d84a9875830/websockets-16.0-cp311-cp311-macosx_10_9_universal2.whl", hash = "sha256:31a52addea25187bde0797a97d6fc3d2f92b6f72a9370792d65a6e84615ac8a8", size = 177340, upload-time = "2026-01-10T09:22:34.539Z" }, + { url = "https://files.pythonhosted.org/packages/f3/fa/abe89019d8d8815c8781e90d697dec52523fb8ebe308bf11664e8de1877e/websockets-16.0-cp311-cp311-macosx_10_9_x86_64.whl", hash = "sha256:417b28978cdccab24f46400586d128366313e8a96312e4b9362a4af504f3bbad", size = 175022, upload-time = "2026-01-10T09:22:36.332Z" }, + { url = "https://files.pythonhosted.org/packages/58/5d/88ea17ed1ded2079358b40d31d48abe90a73c9e5819dbcde1606e991e2ad/websockets-16.0-cp311-cp311-macosx_11_0_arm64.whl", hash = "sha256:af80d74d4edfa3cb9ed973a0a5ba2b2a549371f8a741e0800cb07becdd20f23d", size = 175319, upload-time = "2026-01-10T09:22:37.602Z" }, + { url = "https://files.pythonhosted.org/packages/d2/ae/0ee92b33087a33632f37a635e11e1d99d429d3d323329675a6022312aac2/websockets-16.0-cp311-cp311-manylinux1_x86_64.manylinux_2_28_x86_64.manylinux_2_5_x86_64.whl", hash = "sha256:08d7af67b64d29823fed316505a89b86705f2b7981c07848fb5e3ea3020c1abe", size = 184631, upload-time = "2026-01-10T09:22:38.789Z" }, + { url = "https://files.pythonhosted.org/packages/c8/c5/27178df583b6c5b31b29f526ba2da5e2f864ecc79c99dae630a85d68c304/websockets-16.0-cp311-cp311-manylinux2014_aarch64.manylinux_2_17_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:7be95cfb0a4dae143eaed2bcba8ac23f4892d8971311f1b06f3c6b78952ee70b", size = 185870, upload-time = "2026-01-10T09:22:39.893Z" }, + { url = "https://files.pythonhosted.org/packages/87/05/536652aa84ddc1c018dbb7e2c4cbcd0db884580bf8e95aece7593fde526f/websockets-16.0-cp311-cp311-musllinux_1_2_aarch64.whl", hash = "sha256:d6297ce39ce5c2e6feb13c1a996a2ded3b6832155fcfc920265c76f24c7cceb5", size = 185361, upload-time = "2026-01-10T09:22:41.016Z" }, + { url = "https://files.pythonhosted.org/packages/6d/e2/d5332c90da12b1e01f06fb1b85c50cfc489783076547415bf9f0a659ec19/websockets-16.0-cp311-cp311-musllinux_1_2_x86_64.whl", hash = "sha256:1c1b30e4f497b0b354057f3467f56244c603a79c0d1dafce1d16c283c25f6e64", size = 184615, upload-time = "2026-01-10T09:22:42.442Z" }, + { url = "https://files.pythonhosted.org/packages/77/fb/d3f9576691cae9253b51555f841bc6600bf0a983a461c79500ace5a5b364/websockets-16.0-cp311-cp311-win32.whl", hash = "sha256:5f451484aeb5cafee1ccf789b1b66f535409d038c56966d6101740c1614b86c6", size = 178246, upload-time = "2026-01-10T09:22:43.654Z" }, + { url = "https://files.pythonhosted.org/packages/54/67/eaff76b3dbaf18dcddabc3b8c1dba50b483761cccff67793897945b37408/websockets-16.0-cp311-cp311-win_amd64.whl", hash = "sha256:8d7f0659570eefb578dacde98e24fb60af35350193e4f56e11190787bee77dac", size = 178684, upload-time = "2026-01-10T09:22:44.941Z" }, + { url = "https://files.pythonhosted.org/packages/84/7b/bac442e6b96c9d25092695578dda82403c77936104b5682307bd4deb1ad4/websockets-16.0-cp312-cp312-macosx_10_13_universal2.whl", hash = "sha256:71c989cbf3254fbd5e84d3bff31e4da39c43f884e64f2551d14bb3c186230f00", size = 177365, upload-time = "2026-01-10T09:22:46.787Z" }, + { url = "https://files.pythonhosted.org/packages/b0/fe/136ccece61bd690d9c1f715baaeefd953bb2360134de73519d5df19d29ca/websockets-16.0-cp312-cp312-macosx_10_13_x86_64.whl", hash = "sha256:8b6e209ffee39ff1b6d0fa7bfef6de950c60dfb91b8fcead17da4ee539121a79", size = 175038, upload-time = "2026-01-10T09:22:47.999Z" }, + { url = "https://files.pythonhosted.org/packages/40/1e/9771421ac2286eaab95b8575b0cb701ae3663abf8b5e1f64f1fd90d0a673/websockets-16.0-cp312-cp312-macosx_11_0_arm64.whl", hash = "sha256:86890e837d61574c92a97496d590968b23c2ef0aeb8a9bc9421d174cd378ae39", size = 175328, upload-time = "2026-01-10T09:22:49.809Z" }, + { url = "https://files.pythonhosted.org/packages/18/29/71729b4671f21e1eaa5d6573031ab810ad2936c8175f03f97f3ff164c802/websockets-16.0-cp312-cp312-manylinux1_x86_64.manylinux_2_28_x86_64.manylinux_2_5_x86_64.whl", hash = "sha256:9b5aca38b67492ef518a8ab76851862488a478602229112c4b0d58d63a7a4d5c", size = 184915, upload-time = "2026-01-10T09:22:51.071Z" }, + { url = "https://files.pythonhosted.org/packages/97/bb/21c36b7dbbafc85d2d480cd65df02a1dc93bf76d97147605a8e27ff9409d/websockets-16.0-cp312-cp312-manylinux2014_aarch64.manylinux_2_17_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:e0334872c0a37b606418ac52f6ab9cfd17317ac26365f7f65e203e2d0d0d359f", size = 186152, upload-time = "2026-01-10T09:22:52.224Z" }, + { url = "https://files.pythonhosted.org/packages/4a/34/9bf8df0c0cf88fa7bfe36678dc7b02970c9a7d5e065a3099292db87b1be2/websockets-16.0-cp312-cp312-musllinux_1_2_aarch64.whl", hash = "sha256:a0b31e0b424cc6b5a04b8838bbaec1688834b2383256688cf47eb97412531da1", size = 185583, upload-time = "2026-01-10T09:22:53.443Z" }, + { url = "https://files.pythonhosted.org/packages/47/88/4dd516068e1a3d6ab3c7c183288404cd424a9a02d585efbac226cb61ff2d/websockets-16.0-cp312-cp312-musllinux_1_2_x86_64.whl", hash = "sha256:485c49116d0af10ac698623c513c1cc01c9446c058a4e61e3bf6c19dff7335a2", size = 184880, upload-time = "2026-01-10T09:22:55.033Z" }, + { url = "https://files.pythonhosted.org/packages/91/d6/7d4553ad4bf1c0421e1ebd4b18de5d9098383b5caa1d937b63df8d04b565/websockets-16.0-cp312-cp312-win32.whl", hash = "sha256:eaded469f5e5b7294e2bdca0ab06becb6756ea86894a47806456089298813c89", size = 178261, upload-time = "2026-01-10T09:22:56.251Z" }, + { url = "https://files.pythonhosted.org/packages/c3/f0/f3a17365441ed1c27f850a80b2bc680a0fa9505d733fe152fdf5e98c1c0b/websockets-16.0-cp312-cp312-win_amd64.whl", hash = "sha256:5569417dc80977fc8c2d43a86f78e0a5a22fee17565d78621b6bb264a115d4ea", size = 178693, upload-time = "2026-01-10T09:22:57.478Z" }, + { url = "https://files.pythonhosted.org/packages/cc/9c/baa8456050d1c1b08dd0ec7346026668cbc6f145ab4e314d707bb845bf0d/websockets-16.0-cp313-cp313-macosx_10_13_universal2.whl", hash = "sha256:878b336ac47938b474c8f982ac2f7266a540adc3fa4ad74ae96fea9823a02cc9", size = 177364, upload-time = "2026-01-10T09:22:59.333Z" }, + { url = "https://files.pythonhosted.org/packages/7e/0c/8811fc53e9bcff68fe7de2bcbe75116a8d959ac699a3200f4847a8925210/websockets-16.0-cp313-cp313-macosx_10_13_x86_64.whl", hash = "sha256:52a0fec0e6c8d9a784c2c78276a48a2bdf099e4ccc2a4cad53b27718dbfd0230", size = 175039, upload-time = "2026-01-10T09:23:01.171Z" }, + { url = "https://files.pythonhosted.org/packages/aa/82/39a5f910cb99ec0b59e482971238c845af9220d3ab9fa76dd9162cda9d62/websockets-16.0-cp313-cp313-macosx_11_0_arm64.whl", hash = "sha256:e6578ed5b6981005df1860a56e3617f14a6c307e6a71b4fff8c48fdc50f3ed2c", size = 175323, upload-time = "2026-01-10T09:23:02.341Z" }, + { url = "https://files.pythonhosted.org/packages/bd/28/0a25ee5342eb5d5f297d992a77e56892ecb65e7854c7898fb7d35e9b33bd/websockets-16.0-cp313-cp313-manylinux1_x86_64.manylinux_2_28_x86_64.manylinux_2_5_x86_64.whl", hash = "sha256:95724e638f0f9c350bb1c2b0a7ad0e83d9cc0c9259f3ea94e40d7b02a2179ae5", size = 184975, upload-time = "2026-01-10T09:23:03.756Z" }, + { url = "https://files.pythonhosted.org/packages/f9/66/27ea52741752f5107c2e41fda05e8395a682a1e11c4e592a809a90c6a506/websockets-16.0-cp313-cp313-manylinux2014_aarch64.manylinux_2_17_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:c0204dc62a89dc9d50d682412c10b3542d748260d743500a85c13cd1ee4bde82", size = 186203, upload-time = "2026-01-10T09:23:05.01Z" }, + { url = "https://files.pythonhosted.org/packages/37/e5/8e32857371406a757816a2b471939d51c463509be73fa538216ea52b792a/websockets-16.0-cp313-cp313-musllinux_1_2_aarch64.whl", hash = "sha256:52ac480f44d32970d66763115edea932f1c5b1312de36df06d6b219f6741eed8", size = 185653, upload-time = "2026-01-10T09:23:06.301Z" }, + { url = "https://files.pythonhosted.org/packages/9b/67/f926bac29882894669368dc73f4da900fcdf47955d0a0185d60103df5737/websockets-16.0-cp313-cp313-musllinux_1_2_x86_64.whl", hash = "sha256:6e5a82b677f8f6f59e8dfc34ec06ca6b5b48bc4fcda346acd093694cc2c24d8f", size = 184920, upload-time = "2026-01-10T09:23:07.492Z" }, + { url = "https://files.pythonhosted.org/packages/3c/a1/3d6ccdcd125b0a42a311bcd15a7f705d688f73b2a22d8cf1c0875d35d34a/websockets-16.0-cp313-cp313-win32.whl", hash = "sha256:abf050a199613f64c886ea10f38b47770a65154dc37181bfaff70c160f45315a", size = 178255, upload-time = "2026-01-10T09:23:09.245Z" }, + { url = "https://files.pythonhosted.org/packages/6b/ae/90366304d7c2ce80f9b826096a9e9048b4bb760e44d3b873bb272cba696b/websockets-16.0-cp313-cp313-win_amd64.whl", hash = "sha256:3425ac5cf448801335d6fdc7ae1eb22072055417a96cc6b31b3861f455fbc156", size = 178689, upload-time = "2026-01-10T09:23:10.483Z" }, + { url = "https://files.pythonhosted.org/packages/f3/1d/e88022630271f5bd349ed82417136281931e558d628dd52c4d8621b4a0b2/websockets-16.0-cp314-cp314-macosx_10_15_universal2.whl", hash = "sha256:8cc451a50f2aee53042ac52d2d053d08bf89bcb31ae799cb4487587661c038a0", size = 177406, upload-time = "2026-01-10T09:23:12.178Z" }, + { url = "https://files.pythonhosted.org/packages/f2/78/e63be1bf0724eeb4616efb1ae1c9044f7c3953b7957799abb5915bffd38e/websockets-16.0-cp314-cp314-macosx_10_15_x86_64.whl", hash = "sha256:daa3b6ff70a9241cf6c7fc9e949d41232d9d7d26fd3522b1ad2b4d62487e9904", size = 175085, upload-time = "2026-01-10T09:23:13.511Z" }, + { url = "https://files.pythonhosted.org/packages/bb/f4/d3c9220d818ee955ae390cf319a7c7a467beceb24f05ee7aaaa2414345ba/websockets-16.0-cp314-cp314-macosx_11_0_arm64.whl", hash = "sha256:fd3cb4adb94a2a6e2b7c0d8d05cb94e6f1c81a0cf9dc2694fb65c7e8d94c42e4", size = 175328, upload-time = "2026-01-10T09:23:14.727Z" }, + { url = "https://files.pythonhosted.org/packages/63/bc/d3e208028de777087e6fb2b122051a6ff7bbcca0d6df9d9c2bf1dd869ae9/websockets-16.0-cp314-cp314-manylinux1_x86_64.manylinux_2_28_x86_64.manylinux_2_5_x86_64.whl", hash = "sha256:781caf5e8eee67f663126490c2f96f40906594cb86b408a703630f95550a8c3e", size = 185044, upload-time = "2026-01-10T09:23:15.939Z" }, + { url = "https://files.pythonhosted.org/packages/ad/6e/9a0927ac24bd33a0a9af834d89e0abc7cfd8e13bed17a86407a66773cc0e/websockets-16.0-cp314-cp314-manylinux2014_aarch64.manylinux_2_17_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:caab51a72c51973ca21fa8a18bd8165e1a0183f1ac7066a182ff27107b71e1a4", size = 186279, upload-time = "2026-01-10T09:23:17.148Z" }, + { url = "https://files.pythonhosted.org/packages/b9/ca/bf1c68440d7a868180e11be653c85959502efd3a709323230314fda6e0b3/websockets-16.0-cp314-cp314-musllinux_1_2_aarch64.whl", hash = "sha256:19c4dc84098e523fd63711e563077d39e90ec6702aff4b5d9e344a60cb3c0cb1", size = 185711, upload-time = "2026-01-10T09:23:18.372Z" }, + { url = "https://files.pythonhosted.org/packages/c4/f8/fdc34643a989561f217bb477cbc47a3a07212cbda91c0e4389c43c296ebf/websockets-16.0-cp314-cp314-musllinux_1_2_x86_64.whl", hash = "sha256:a5e18a238a2b2249c9a9235466b90e96ae4795672598a58772dd806edc7ac6d3", size = 184982, upload-time = "2026-01-10T09:23:19.652Z" }, + { url = "https://files.pythonhosted.org/packages/dd/d1/574fa27e233764dbac9c52730d63fcf2823b16f0856b3329fc6268d6ae4f/websockets-16.0-cp314-cp314-win32.whl", hash = "sha256:a069d734c4a043182729edd3e9f247c3b2a4035415a9172fd0f1b71658a320a8", size = 177915, upload-time = "2026-01-10T09:23:21.458Z" }, + { url = "https://files.pythonhosted.org/packages/8a/f1/ae6b937bf3126b5134ce1f482365fde31a357c784ac51852978768b5eff4/websockets-16.0-cp314-cp314-win_amd64.whl", hash = "sha256:c0ee0e63f23914732c6d7e0cce24915c48f3f1512ec1d079ed01fc629dab269d", size = 178381, upload-time = "2026-01-10T09:23:22.715Z" }, + { url = "https://files.pythonhosted.org/packages/06/9b/f791d1db48403e1f0a27577a6beb37afae94254a8c6f08be4a23e4930bc0/websockets-16.0-cp314-cp314t-macosx_10_15_universal2.whl", hash = "sha256:a35539cacc3febb22b8f4d4a99cc79b104226a756aa7400adc722e83b0d03244", size = 177737, upload-time = "2026-01-10T09:23:24.523Z" }, + { url = "https://files.pythonhosted.org/packages/bd/40/53ad02341fa33b3ce489023f635367a4ac98b73570102ad2cdd770dacc9a/websockets-16.0-cp314-cp314t-macosx_10_15_x86_64.whl", hash = "sha256:b784ca5de850f4ce93ec85d3269d24d4c82f22b7212023c974c401d4980ebc5e", size = 175268, upload-time = "2026-01-10T09:23:25.781Z" }, + { url = "https://files.pythonhosted.org/packages/74/9b/6158d4e459b984f949dcbbb0c5d270154c7618e11c01029b9bbd1bb4c4f9/websockets-16.0-cp314-cp314t-macosx_11_0_arm64.whl", hash = "sha256:569d01a4e7fba956c5ae4fc988f0d4e187900f5497ce46339c996dbf24f17641", size = 175486, upload-time = "2026-01-10T09:23:27.033Z" }, + { url = "https://files.pythonhosted.org/packages/e5/2d/7583b30208b639c8090206f95073646c2c9ffd66f44df967981a64f849ad/websockets-16.0-cp314-cp314t-manylinux1_x86_64.manylinux_2_28_x86_64.manylinux_2_5_x86_64.whl", hash = "sha256:50f23cdd8343b984957e4077839841146f67a3d31ab0d00e6b824e74c5b2f6e8", size = 185331, upload-time = "2026-01-10T09:23:28.259Z" }, + { url = "https://files.pythonhosted.org/packages/45/b0/cce3784eb519b7b5ad680d14b9673a31ab8dcb7aad8b64d81709d2430aa8/websockets-16.0-cp314-cp314t-manylinux2014_aarch64.manylinux_2_17_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:152284a83a00c59b759697b7f9e9cddf4e3c7861dd0d964b472b70f78f89e80e", size = 186501, upload-time = "2026-01-10T09:23:29.449Z" }, + { url = "https://files.pythonhosted.org/packages/19/60/b8ebe4c7e89fb5f6cdf080623c9d92789a53636950f7abacfc33fe2b3135/websockets-16.0-cp314-cp314t-musllinux_1_2_aarch64.whl", hash = "sha256:bc59589ab64b0022385f429b94697348a6a234e8ce22544e3681b2e9331b5944", size = 186062, upload-time = "2026-01-10T09:23:31.368Z" }, + { url = "https://files.pythonhosted.org/packages/88/a8/a080593f89b0138b6cba1b28f8df5673b5506f72879322288b031337c0b8/websockets-16.0-cp314-cp314t-musllinux_1_2_x86_64.whl", hash = "sha256:32da954ffa2814258030e5a57bc73a3635463238e797c7375dc8091327434206", size = 185356, upload-time = "2026-01-10T09:23:32.627Z" }, + { url = "https://files.pythonhosted.org/packages/c2/b6/b9afed2afadddaf5ebb2afa801abf4b0868f42f8539bfe4b071b5266c9fe/websockets-16.0-cp314-cp314t-win32.whl", hash = "sha256:5a4b4cc550cb665dd8a47f868c8d04c8230f857363ad3c9caf7a0c3bf8c61ca6", size = 178085, upload-time = "2026-01-10T09:23:33.816Z" }, + { url = "https://files.pythonhosted.org/packages/9f/3e/28135a24e384493fa804216b79a6a6759a38cc4ff59118787b9fb693df93/websockets-16.0-cp314-cp314t-win_amd64.whl", hash = "sha256:b14dc141ed6d2dde437cddb216004bcac6a1df0935d79656387bd41632ba0bbd", size = 178531, upload-time = "2026-01-10T09:23:35.016Z" }, + { url = "https://files.pythonhosted.org/packages/72/07/c98a68571dcf256e74f1f816b8cc5eae6eb2d3d5cfa44d37f801619d9166/websockets-16.0-pp311-pypy311_pp73-macosx_10_15_x86_64.whl", hash = "sha256:349f83cd6c9a415428ee1005cadb5c2c56f4389bc06a9af16103c3bc3dcc8b7d", size = 174947, upload-time = "2026-01-10T09:23:36.166Z" }, + { url = "https://files.pythonhosted.org/packages/7e/52/93e166a81e0305b33fe416338be92ae863563fe7bce446b0f687b9df5aea/websockets-16.0-pp311-pypy311_pp73-macosx_11_0_arm64.whl", hash = "sha256:4a1aba3340a8dca8db6eb5a7986157f52eb9e436b74813764241981ca4888f03", size = 175260, upload-time = "2026-01-10T09:23:37.409Z" }, + { url = "https://files.pythonhosted.org/packages/56/0c/2dbf513bafd24889d33de2ff0368190a0e69f37bcfa19009ef819fe4d507/websockets-16.0-pp311-pypy311_pp73-manylinux1_x86_64.manylinux_2_28_x86_64.manylinux_2_5_x86_64.whl", hash = "sha256:f4a32d1bd841d4bcbffdcb3d2ce50c09c3909fbead375ab28d0181af89fd04da", size = 176071, upload-time = "2026-01-10T09:23:39.158Z" }, + { url = "https://files.pythonhosted.org/packages/a5/8f/aea9c71cc92bf9b6cc0f7f70df8f0b420636b6c96ef4feee1e16f80f75dd/websockets-16.0-pp311-pypy311_pp73-manylinux2014_aarch64.manylinux_2_17_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:0298d07ee155e2e9fda5be8a9042200dd2e3bb0b8a38482156576f863a9d457c", size = 176968, upload-time = "2026-01-10T09:23:41.031Z" }, + { url = "https://files.pythonhosted.org/packages/9a/3f/f70e03f40ffc9a30d817eef7da1be72ee4956ba8d7255c399a01b135902a/websockets-16.0-pp311-pypy311_pp73-win_amd64.whl", hash = "sha256:a653aea902e0324b52f1613332ddf50b00c06fdaf7e92624fbf8c77c78fa5767", size = 178735, upload-time = "2026-01-10T09:23:42.259Z" }, + { url = "https://files.pythonhosted.org/packages/6f/28/258ebab549c2bf3e64d2b0217b973467394a9cea8c42f70418ca2c5d0d2e/websockets-16.0-py3-none-any.whl", hash = "sha256:1637db62fad1dc833276dded54215f2c7fa46912301a24bd94d45d46a011ceec", size = 171598, upload-time = "2026-01-10T09:23:45.395Z" }, +]