o
    KK&h>                     @  s  d dl mZ d dlZd dlZd dlZd dlZd dlmZ d dlm	Z	m
Z
mZ ddlmZmZ ddlmZmZmZmZmZmZ g dZe
d	Zd
ddmddZdnddZedZdoddZedZdpd!d"Zed#Zed$Zdpd%d&Z ed'Z!ed(Z"dqd*d+Z#drd/d0Z$dsd2d3Z%dtd5d6Z&ed7Z'dud9d:Z(dvd<d=Z)dwd?d@Z*dxdBdCZ+dydEdFZ,e,Z-dzdKdLZ.d{dOdPZ/e/Z0d|dRdSZ1d}dUdVZ2e2Z3d~dYdZZ4e4Z5dd\d]Z6dd_d`Z7edaZ8dpdbdcZ9ddddeZ:ddgdhZ;ddkdlZ<dS )    )annotationsN)Sequence)CallableTypeVarcast   )InvalidHeaderFormatInvalidHeaderValue)ConnectionOptionExtensionHeaderExtensionNameExtensionParameterSubprotocolUpgradeProtocol)
build_hostparse_connectionparse_upgradeparse_extensionbuild_extensionparse_subprotocolbuild_subprotocolvalidate_subprotocolsbuild_www_authenticate_basicparse_authorization_basicbuild_authorization_basicTF)always_include_porthoststrportintsecureboolr   returnc                C  s^   zt | }W n	 ty   Y nw |jdkrd|  d} |s&||r#dndkr-|  d| } | S )z#
    Build a ``Host`` header.

       []i  P   :)	ipaddress
ip_address
ValueErrorversion)r   r   r!   r   address r.   E/var/www/html/venv/lib/python3.10/site-packages/websockets/headers.pyr   '   s   
r   headerpos
str | Nonec                 C  s   |t | krdS | | 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)r0   r1   r.   r.   r/   
peek_aheadI   s   	r4   z[\t ]*c                 C  s    t | |}|dus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_rematchend)r0   r1   r6   r.   r.   r/   	parse_OWSX   s   
r8   z[-!#$%&\'*+.^_`|~0-9a-zA-Z]+header_nametuple[str, int]c                 C  2   t | |}|du rt|d| || | fS )z
    Parse a token from ``header`` at the given position.

    Return the token value and the new position.

    Raises:
        InvalidHeaderFormat: On invalid inputs.

    Nzexpected token)	_token_rer6   r   groupr7   r0   r1   r9   r6   r.   r.   r/   parse_tokenj      
r?   zC"(?:[\x09\x20-\x21\x23-\x5b\x5d-\x7e]|\\[\x09\x20-\x7e\x80-\xff])*"z\\([\x09\x20-\x7e\x80-\xff])c                 C  sB   t | |}|du rt|d| |td| dd | fS )z
    Parse a quoted string from ``header`` at the given position.

    Return the unquoted value and the new position.

    Raises:
        InvalidHeaderFormat: On invalid inputs.

    Nzexpected quoted stringz\1r   )_quoted_string_rer6   r   _unquote_resubr=   r7   r>   r.   r.   r/   parse_quoted_string   s   
 rE   z[\x09\x20-\x7e\x80-\xff]*z([\x22\x5c])valuec                 C  s.   t | }|du rtddtd|  d S )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_rerD   )rF   r6   r.   r.   r/   build_quoted_string   s   
rK   
parse_item(Callable[[str, int, str], tuple[T, int]]list[T]c                 C  s   t ||dkrt||d }t ||dksg }	 | |||\}}|| t||}|t|kr1n3t ||dkr@t||d }nt|d||t ||dkr\t||d }t ||dksN|t|krcnq|t|kslJ |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.

    ,r   Tzexpected comma)r4   r8   appendr3   r   )rL   r0   r1   r9   itemsitemr.   r.   r/   
parse_list   s*   

rS   tuple[ConnectionOption, int]c                 C     t | ||\}}tt||fS )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?   r   r
   r0   r1   r9   rR   r.   r.   r/   parse_connection_option      rW   list[ConnectionOption]c                 C     t t| ddS )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)rS   rW   r0   r.   r.   r/   r         r   z>[-!#$%&\'*+.^_`|~0-9a-zA-Z]+(?:/[-!#$%&\'*+.^_`|~0-9a-zA-Z]+)?tuple[UpgradeProtocol, int]c                 C  s8   t | |}|du rt|d| |tt| | fS )z
    Parse an Upgrade protocol from ``header`` at the given position.

    Return the protocol value and the new position.

    Raises:
        InvalidHeaderFormat: On invalid inputs.

    Nzexpected protocol)_protocol_rer6   r   r   r   r=   r7   r>   r.   r.   r/   parse_upgrade_protocol  s   r`   list[UpgradeProtocol]c                 C  rZ   )z
    Parse an ``Upgrade`` header.

    Return a list of HTTP protocols.

    Args:
        header: Value of the ``Upgrade`` header.

    Raises:
        InvalidHeaderFormat: On invalid inputs.

    r   Upgrade)rS   r`   r\   r.   r.   r/   r     r]   r   tuple[ExtensionParameter, int]c                 C  s   t | ||\}}t| |}d}t| |dkrJt| |d }t| |dkr=|}t| ||\}}t|du r<t|d| |nt | ||\}}t| |}||f|fS )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=r   rG   zinvalid quoted header content)r?   r8   r4   rE   r<   rI   r   )r0   r1   r9   namerF   
pos_beforer.   r.   r/   parse_extension_item_param.  s    

rg   tuple[ExtensionHeader, int]c                 C  st   t | ||\}}t| |}g }t| |dkr1t| |d }t| ||\}}|| t| |dkstt||f|fS )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?   r8   r4   rg   rP   r   r   )r0   r1   r9   re   
parameters	parameterr.   r.   r/   parse_extension_itemR  s   

rl   list[ExtensionHeader]c                 C  rZ   )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.

    r   zSec-WebSocket-Extensions)rS   rl   r\   r.   r.   r/   r   k  s   r   re   r   rj   Sequence[ExtensionParameter]c                 C  s    d tt| gdd |D  S )zc
    Build an extension definition.

    This is the reverse of :func:`parse_extension_item`.

    z; c                 S  s*   g | ]\}}|d u r|n| d| qS )Nrd   r.   ).0re   rF   r.   r.   r/   
<listcomp>  s    z(build_extension_item.<locals>.<listcomp>)joinr   r   )re   rj   r.   r.   r/   build_extension_item  s   	
rr   
extensionsSequence[ExtensionHeader]c                 C  s   d dd | D S )zl
    Build a ``Sec-WebSocket-Extensions`` header.

    This is the reverse of :func:`parse_extension`.

    , c                 s  s    | ]
\}}t ||V  qd S )N)rr   )ro   re   rj   r.   r.   r/   	<genexpr>  s    
z"build_extension.<locals>.<genexpr>rq   )rs   r.   r.   r/   r     s   
r   tuple[Subprotocol, int]c                 C  rU   )z
    Parse a subprotocol from ``header`` at the given position.

    Return the subprotocol value and the new position.

    Raises:
        InvalidHeaderFormat: On invalid inputs.

    )r?   r   r   rV   r.   r.   r/   parse_subprotocol_item  rX   ry   list[Subprotocol]c                 C  rZ   )z
    Parse a ``Sec-WebSocket-Protocol`` header.

    Return a list of WebSocket subprotocols.

    Raises:
        InvalidHeaderFormat: On invalid inputs.

    r   zSec-WebSocket-Protocol)rS   ry   r\   r.   r.   r/   r     s   
r   subprotocolsSequence[Subprotocol]c                 C  s
   d | S )zl
    Build a ``Sec-WebSocket-Protocol`` header.

    This is the reverse of :func:`parse_subprotocol`.

    ru   rw   )r{   r.   r.   r/   r     s   
r   Nonec                 C  sJ   t | ts	tdt | trtd| D ]}t|s"td| qdS )zT
    Validate that ``subprotocols`` is suitable for :func:`build_subprotocol`.

    zsubprotocols must be a listz&subprotocols must be a list, not a strzinvalid subprotocol: N)
isinstancer   	TypeErrorr   r<   rI   r+   )r{   subprotocolr.   r.   r/   r     s   


r   realmc                 C  s    t | } t d}d|  d| S )z
    Build a ``WWW-Authenticate`` header for HTTP Basic Auth.

    Args:
        realm: Identifier of the protection space.

    zUTF-8zBasic realm=z
, charset=)rK   )r   charsetr.   r.   r/   r     s   	r   z[A-Za-z0-9-._~+/]+=*c                 C  r;   )z
    Parse a token68 from ``header`` at the given position.

    Return the token value and the new position.

    Raises:
        InvalidHeaderFormat: On invalid inputs.

    Nzexpected token68)_token68_rer6   r   r=   r7   r>   r.   r.   r/   parse_token68  r@   r   c                 C  s   |t | k rt|d| |dS )z8
    Check that parsing reached the end of header.

    ztrailing dataN)r3   r   )r0   r1   r9   r.   r.   r/   	parse_end  s   r   tuple[str, str]c                 C  s   t | dd\}}| dkrtdd| t| |dkr$tdd| ||d7 }t| |d\}}t| |d zt|	 
 }W n tjyO   tddd	w z|d
d\}}W ||fS  tyj   tdd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   Authorizationbasiczunsupported scheme:  zexpected space after schemer   z#expected base64-encoded credentialsNr(   z&expected username:password credentials)r?   lowerr	   r4   r   r   r   base64	b64decodeencodedecodebinasciiErrorsplitr+   )r0   schemer1   basic_credentials	user_passusernamepasswordr.   r.   r/   r     sD   r   r   r   c                 C  s4   d| vsJ |  d| }t |  }d| S )z
    Build an ``Authorization`` header for HTTP Basic Auth.

    This is the reverse of :func:`parse_authorization_basic`.

    r(   zBasic )r   	b64encoder   r   )r   r   r   r   r.   r.   r/   r   ?  s   r   )
r   r   r   r    r!   r"   r   r"   r#   r   )r0   r   r1   r    r#   r2   )r0   r   r1   r    r#   r    )r0   r   r1   r    r9   r   r#   r:   )rF   r   r#   r   )
rL   rM   r0   r   r1   r    r9   r   r#   rN   )r0   r   r1   r    r9   r   r#   rT   )r0   r   r#   rY   )r0   r   r1   r    r9   r   r#   r^   )r0   r   r#   ra   )r0   r   r1   r    r9   r   r#   rc   )r0   r   r1   r    r9   r   r#   rh   )r0   r   r#   rm   )re   r   rj   rn   r#   r   )rs   rt   r#   r   )r0   r   r1   r    r9   r   r#   rx   )r0   r   r#   rz   )r{   r|   r#   r   )r{   r|   r#   r}   )r   r   r#   r   )r0   r   r1   r    r9   r   r#   r}   )r0   r   r#   r   )r   r   r   r   r#   r   )=
__future__r   r   r   r)   recollections.abcr   typingr   r   r   
exceptionsr   r	   r
   r   r   r   r   r   __all__r   r   r4   compiler5   r8   r<   r?   rB   rC   rE   rH   rJ   rK   rS   rW   r   r_   r`   r   rg   rl   r   parse_extension_listrr   r   build_extension_listry   r   parse_subprotocol_listr   build_subprotocol_listr   r   r   r   r   r   r   r.   r.   r.   r/   <module>   sj     

"










B




$












	0