o mh>@sddlmZddlZddlZddlZddlZddlmZmZm Z m Z ddl m Z ddlm Z mZmZmZmZmZgdZe dZdiddZdjddZedZdkddZedZdlddZedZed Zdld!d"Zed#Zed$Z dmd&d'Z!dnd+d,Z"dod.d/Z#dpd1d2Z$ed3Z%dqd5d6Z&drd8d9Z'dsd;d<Z(dtd>d?Z)dudAdBZ*e*Z+dvdGdHZ,dwdKdLZ-e-Z.dxdNdOZ/dydQdRZ0e0Z1dzdUdVZ2e2Z3d{dXdYZ4d|d[d\Z5ed]Z6dld^d_Z7d}d`daZ8d~dcddZ9ddgdhZ:dS)) annotationsN)CallableSequenceTypeVarcast) exceptions)ConnectionOptionExtensionHeader ExtensionNameExtensionParameter SubprotocolUpgradeProtocol) build_hostparse_connection parse_upgradeparse_extensionbuild_extensionparse_subprotocolbuild_subprotocolvalidate_subprotocolsbuild_www_authenticate_basicparse_authorization_basicbuild_authorization_basicThoststrportintsecureboolreturncCsZzt|}Wn tyYn w|jdkrd|d}||r!dndkr+|d|}|S)z# Build a ``Host`` header. []iP:) ipaddress ip_address ValueErrorversion)rrraddressr,J/var/www/html/zoom/venv/lib/python3.10/site-packages/websockets/headers.pyr&s   rheaderpos str | NonecCs|t|krdS||S)z Return the next character from ``header`` at the given position. Return :obj:`None` at the end of ``header``. We never need to peek more than one character ahead. N)len)r.r/r,r,r- peek_aheadBs r2z[\t ]*cCs t||}|dus J|S)z Parse optional whitespace from ``header`` at the given position. Return the new position. The whitespace itself isn't returned because it isn't significant. N)_OWS_rematchend)r.r/r4r,r,r- parse_OWSQs r6z[-!#$%&\'*+.^_`|~0-9a-zA-Z]+ header_nametuple[str, int]cC4t||}|durt|d||||fS)z Parse a token from ``header`` at the given position. Return the token value and the new position. Raises: InvalidHeaderFormat: On invalid inputs. Nzexpected token) _token_rer4rInvalidHeaderFormatgroupr5r.r/r7r4r,r,r- parse_tokencs r>zC"(?:[\x09\x20-\x21\x23-\x5b\x5d-\x7e]|\\[\x09\x20-\x7e\x80-\xff])*"z\\([\x09\x20-\x7e\x80-\xff])cCsDt||}|durt|d||td|dd|fS)z Parse a quoted string from ``header`` at the given position. Return the unquoted value and the new position. Raises: InvalidHeaderFormat: On invalid inputs. Nzexpected quoted stringz\1r)_quoted_string_rer4rr; _unquote_resubr<r5r=r,r,r-parse_quoted_string{s  rCz[\x09\x20-\x7e\x80-\xff]*z ([\x22\x5c])valuecCs.t|}|dur tddtd|dS)zh Format ``value`` as a quoted string. This is the reverse of :func:`parse_quoted_string`. Nz-invalid characters for quoted-string encoding"z\\\1) _quotable_re fullmatchr) _quote_rerB)rDr4r,r,r-build_quoted_strings rI parse_item(Callable[[str, int, str], tuple[T, int]]list[T]cCst||dkrt||d}t||dksg} ||||\}}||t||}|t|kr1n4t||dkr@t||d}nt|d||t||dkr]t||d}t||dksO|t|krdnq|t|ksmJ|S)a Parse a comma-separated list from ``header`` at the given position. This is appropriate for parsing values with the following grammar: 1#item ``parse_item`` parses one item. ``header`` is assumed not to start or end with whitespace. (This function is designed for parsing an entire header value and :func:`~websockets.http.read_headers` strips whitespace from values.) Return a list of items. Raises: InvalidHeaderFormat: On invalid inputs. ,rTzexpected comma)r2r6appendr1rr;)rJr.r/r7itemsitemr,r,r- parse_lists.    rQtuple[ConnectionOption, int]cCt|||\}}tt||fS)z Parse a Connection option from ``header`` at the given position. Return the protocol value and the new position. Raises: InvalidHeaderFormat: On invalid inputs. )r>rr r.r/r7rPr,r,r-parse_connection_option rUlist[ConnectionOption]cCtt|ddS)z Parse a ``Connection`` header. Return a list of HTTP connection options. Args header: value of the ``Connection`` header. Raises: InvalidHeaderFormat: On invalid inputs. r Connection)rQrUr.r,r,r-r rz>[-!#$%&\'*+.^_`|~0-9a-zA-Z]+(?:/[-!#$%&\'*+.^_`|~0-9a-zA-Z]+)?tuple[UpgradeProtocol, int]cCs:t||}|durt|d||tt||fS)z Parse an Upgrade protocol from ``header`` at the given position. Return the protocol value and the new position. Raises: InvalidHeaderFormat: On invalid inputs. Nzexpected protocol) _protocol_rer4rr;rrr<r5r=r,r,r-parse_upgrade_protocol s r^list[UpgradeProtocol]cCrX)z Parse an ``Upgrade`` header. Return a list of HTTP protocols. Args: header: Value of the ``Upgrade`` header. Raises: InvalidHeaderFormat: On invalid inputs. rUpgrade)rQr^rZr,r,r-rr[rtuple[ExtensionParameter, int]cCst|||\}}t||}d}t||dkrKt||d}t||dkr>|}t|||\}}t|dur=t|d||nt|||\}}t||}||f|fS)z Parse a single extension parameter from ``header`` at the given position. Return a ``(name, value)`` pair and the new position. Raises: InvalidHeaderFormat: On invalid inputs. N=rrEzinvalid quoted header content)r>r6r2rCr:rGrr;)r.r/r7namerD pos_beforer,r,r-parse_extension_item_param-s    retuple[ExtensionHeader, int]cCstt|||\}}t||}g}t||dkr1t||d}t|||\}}||t||dkstt||f|fS)a Parse an extension definition from ``header`` at the given position. Return an ``(extension name, parameters)`` pair, where ``parameters`` is a list of ``(name, value)`` pairs, and the new position. Raises: InvalidHeaderFormat: On invalid inputs. ;r)r>r6r2rerNrr )r.r/r7rc parameters parameterr,r,r-parse_extension_itemQs  rjlist[ExtensionHeader]cCrX)a Parse a ``Sec-WebSocket-Extensions`` header. Return a list of WebSocket extensions and their parameters in this format:: [ ( 'extension name', [ ('parameter name', 'parameter value'), .... ] ), ... ] Parameter values are :obj:`None` when no value is provided. Raises: InvalidHeaderFormat: On invalid inputs. rzSec-WebSocket-Extensions)rQrjrZr,r,r-rjsrrcr rhlist[ExtensionParameter]cCs dtt|gdd|DS)zc Build an extension definition. This is the reverse of :func:`parse_extension_item`. z; cSs*g|]\}}|dur |n|d|qS)Nrbr,).0rcrDr,r,r- sz(build_extension_item..)joinrr)rcrhr,r,r-build_extension_items rp extensionsSequence[ExtensionHeader]cCsddd|DS)zl Build a ``Sec-WebSocket-Extensions`` header. This is the reverse of :func:`parse_extension`. , css|] \}}t||VqdS)N)rp)rmrcrhr,r,r- s z"build_extension..ro)rqr,r,r-rs rtuple[Subprotocol, int]cCrS)z Parse a subprotocol from ``header`` at the given position. Return the subprotocol value and the new position. Raises: InvalidHeaderFormat: On invalid inputs. )r>rr rTr,r,r-parse_subprotocol_itemrVrwlist[Subprotocol]cCrX)z Parse a ``Sec-WebSocket-Protocol`` header. Return a list of WebSocket subprotocols. Raises: InvalidHeaderFormat: On invalid inputs. rzSec-WebSocket-Protocol)rQrwrZr,r,r-rs r subprotocolsSequence[Subprotocol]cCs d|S)zl Build a ``Sec-WebSocket-Protocol`` header. This is the reverse of :func:`parse_subprotocol`. rsru)ryr,r,r-rs rNonecCsJt|ts tdt|trtd|D]}t|s"td|qdS)zT Validate that ``subprotocols`` is suitable for :func:`build_subprotocol`. zsubprotocols must be a listz&subprotocols must be a list, not a strzinvalid subprotocol: N) isinstancer TypeErrorrr:rGr))ry subprotocolr,r,r-rs   rrealmcCs t|}td}d|d|S)z Build a ``WWW-Authenticate`` header for HTTP Basic Auth. Args: realm: Identifier of the protection space. zUTF-8z Basic realm=z , charset=)rI)rcharsetr,r,r-rs rz[A-Za-z0-9-._~+/]+=*cCr9)z Parse a token68 from ``header`` at the given position. Return the token value and the new position. Raises: InvalidHeaderFormat: On invalid inputs. Nzexpected token68) _token68_rer4rr;r<r5r=r,r,r- parse_token68s rcCs |t|krt|d||dS)z8 Check that parsing reached the end of header. z trailing dataN)r1rr;)r.r/r7r,r,r- parse_ends rtuple[str, str]cCst|dd\}}|dkrtdd|t||dkr&tdd|||d7}t||d\}}t||dz t |  }Wnt j yRtddd wz |d d\}}W||fStyntdd d w) a! Parse an ``Authorization`` header for HTTP Basic Auth. Return a ``(username, password)`` tuple. Args: header: Value of the ``Authorization`` header. Raises: InvalidHeaderFormat: On invalid inputs. InvalidHeaderValue: On unsupported inputs. r Authorizationbasiczunsupported scheme:  zexpected space after schemerz#expected base64-encoded credentialsNr&z&expected username:password credentials)r>lowerrInvalidHeaderValuer2r;rrbase64 b64decodeencodedecodebinasciiErrorsplitr))r.schemer/basic_credentials user_passusernamepasswordr,r,r-rsD   rrrcCs4d|vsJ|d|}t|}d|S)z Build an ``Authorization`` header for HTTP Basic Auth. This is the reverse of :func:`parse_authorization_basic`. r&zBasic )r b64encoderr)rrrrr,r,r-r@s r)rrrrrr r!r)r.rr/rr!r0)r.rr/rr!r)r.rr/rr7rr!r8)rDrr!r) rJrKr.rr/rr7rr!rL)r.rr/rr7rr!rR)r.rr!rW)r.rr/rr7rr!r\)r.rr!r_)r.rr/rr7rr!ra)r.rr/rr7rr!rf)r.rr!rk)rcr rhrlr!r)rqrrr!r)r.rr/rr7rr!rv)r.rr!rx)ryrzr!r)ryrzr!r{)rrr!r)r.rr/rr7rr!r{)r.rr!r)rrrrr!r); __future__rrrr'retypingrrrrrr r r r r r__all__rrr2compiler3r6r:r>r@rArCrFrHrIrQrUrr]r^rrerjrparse_extension_listrprbuild_extension_listrwrparse_subprotocol_listrbuild_subprotocol_listrrrrrrrr,r,r,r-sf               D     $            0