
    NgI                     t   U d Z ddlZddlmZ ddlmZmZmZmZm	Z	m
Z
  eg d          Zee         ed<    G d de          Z G d	 d
e          Z G d de          Ze                    eej        ddf          Ze                    eej        ddf          Z G d de          Z G d de          ZdS )z0Models for WebSocket protocol versions 13 and 8.    N)IntEnum)AnyCallableFinal
NamedTupleOptionalcast)r   r      r
   WS_DEFLATE_TRAILINGc                   B    e Zd ZdZdZdZdZdZdZdZ	dZ
d	Zd
ZdZdZdZdS )WSCloseCodei  i  i  i  i  i  i  i  i  i  i  i  i  N)__name__
__module____qualname__OK
GOING_AWAYPROTOCOL_ERRORUNSUPPORTED_DATAABNORMAL_CLOSUREINVALID_TEXTPOLICY_VIOLATIONMESSAGE_TOO_BIGMANDATORY_EXTENSIONINTERNAL_ERRORSERVICE_RESTARTTRY_AGAIN_LATERBAD_GATEWAY     U/var/www/html/ai-engine/env/lib/python3.11/site-packages/aiohttp/_websocket/models.pyr   r   
   sS        	BJNLONOOKKKr   r   c                   R    e Zd ZdZdZdZdZdZdZdZ	dZ
d	ZeZeZeZeZeZe	Ze
ZeZd
S )	WSMsgTyper         	   
         i  i  N)r   r   r   CONTINUATIONTEXTBINARYPINGPONGCLOSECLOSINGCLOSEDERRORtextbinarypingpongcloseclosingclosederrorr   r   r    r"   r"      se        LDFDDE GFEDFDDEGFEEEr   r"   c                   l    e Zd ZU eed<   eed<   ee         ed<   ej	        dde
egef         defdZdS )		WSMessagetypedataextra)loadsr?   returnc                "     || j                   S )zAReturn parsed JSON data.

        .. versionadded:: 0.22
        )r=   )selfr?   s     r    jsonzWSMessage.json8   s    
 uTYr   N)r   r   r   r"   __annotations__r   r   strrC   r?   r   r   r   r    r;   r;   2   st         
OOO
IIIC=48J      XseSj1  3            r   r;   c                   <     e Zd ZdZdededdf fdZdefdZ xZS )WebSocketErrorz WebSocket protocol parser error.codemessager@   Nc                 Z    || _         t                                          ||           d S )N)rH   super__init__)rB   rH   rI   	__class__s      r    rL   zWebSocketError.__init__K   s*    	w'''''r   c                 B    t          t          | j        d                   S )Nr#   )r	   rE   args)rB   s    r    __str__zWebSocketError.__str__O   s    C1&&&r   )	r   r   r   __doc__intrE   rL   rP   __classcell__)rM   s   @r    rG   rG   H   ss        **(S (3 (4 ( ( ( ( ( (' ' ' ' ' ' ' ' 'r   rG   c                       e Zd ZdZdS )WSHandshakeErrorz#WebSocket protocol handshake error.N)r   r   r   rQ   r   r   r    rU   rU   S   s        ----r   rU   )rQ   rC   enumr   typingr   r   r   r   r   r	   bytesr   rD   r   r"   r;   tuple__new__r0   WS_CLOSED_MESSAGEr/   WS_CLOSING_MESSAGE	ExceptionrG   rU   r   r   r    <module>r^      s   6 6 6        C C C C C C C C C C C C C C C C$)E*B*B*B$C$C U5\ C C C    '           0         
      $ MM)i.>d-KLL ]]9y/@$.MNN ' ' ' ' 'Y ' ' '. . . . .y . . . . .r   