Module

_ws_handler

WebSocket connection handler — HTTP/1.1 upgrade lifecycle.

Extracted fromworker.pyto keep protocol-specific connection handling separate from the core Worker lifecycle. The worker delegates to handle_websocket()when it detects an HTTP/1.1 WebSocket upgrade.

Connection flow:

H1 request → detect ``Connection: Upgrade`` + ``Upgrade: websocket``
→ build ASGI ``websocket`` scope → 101 Switching Protocols
→ wsproto frame loop → app(scope, receive, send)
3Functions

Functions

_permessage_deflate_offer 1 str | None ▼
Return the client's ``permessage-deflate`` extension offer segment. Scans ever…
def _permessage_deflate_offer(headers: tuple[tuple[bytes, bytes], ...]) -> str | None

Return the client'spermessage-deflateextension offer segment.

Scans everySec-WebSocket-Extensionsheader for a comma-separated permessage-deflatetoken and returns that single extension segment (token plus any;-delimited parameters) so it can be fed verbatim to wsproto's RFC 7692 negotiation. ReturnsNonewhen the client did not offer permessage-deflate.

Parameters
Name Type Description
headers tuple[tuple[bytes, bytes], ...]
Returns
str | None
_client_requested_permessage_deflate 1 bool ▼
Return True when the client offered permessage-deflate.
def _client_requested_permessage_deflate(headers: tuple[tuple[bytes, bytes], ...]) -> bool
Parameters
Name Type Description
headers tuple[tuple[bytes, bytes], ...]
Returns
bool
handle_websocket 11 None ▼
Handle a WebSocket connection after HTTP/1.1 upgrade detection. **Lifecycle:**…
async
async def handle_websocket(app: ASGIApp, config: ServerConfig, logger: logging.Logger, request: RequestReceived, reader: asyncio.StreamReader, writer: asyncio.StreamWriter, client: tuple[str, int], server: tuple[str, int], client_str: str, *, worker_id: int | None = None, lifespan_state: dict[str, Any] | None = None) -> None

Handle a WebSocket connection after HTTP/1.1 upgrade detection.

Lifecycle:

  1. Build ASGIwebsocketscope
    1. Pushwebsocket.connectto the receive queue
    2. Run the ASGI app — it sendswebsocket.accept(or close)
    3. Read WebSocket frames and feed to receive queue
    4. App sendswebsocket.send / websocket.close
    5. Clean up when either side disconnects
Parameters
Name Type Description
app ASGIApp

The ASGI application callable.
config ServerConfig

Immutable server configuration.
logger logging.Logger

Logger scoped to the worker.
request RequestReceived

The parsed HTTP request that triggered the upgrade.
reader asyncio.StreamReader

Asyncio stream reader for the connection.
writer asyncio.StreamWriter

Asyncio stream writer for the connection.
client tuple[str, int]

(host, port)of the remote peer.
server tuple[str, int]

(host, port)of the local endpoint.
client_str str

Formatted"host:port"string for logging.
worker_id int | None Default:None
lifespan_state dict[str, Any] | None Default:None