Ë
    è×ïiˆ  ã                   ó¸  — d dl Z d dlZd dlZddl­ ddl­ ddl­ 	 ej                  ej                  dfgZ e	ed«      r(ej                  ej                  ej                  df«        e	ed«      r(ej                  ej                  ej                  df«        e	ed«      r(ej                  ej                  ej                  df«        e	ed	«      r(ej                  ej                  ej                  d
f«       dag d¢Z G d„ d«      Zdexs eddfd„Zdexs efd„Zdej                  dedefd„Zdej                  defd„Zdej                  dedefd„Zy)é    Né   )Ú*ÚSO_KEEPALIVEÚTCP_KEEPIDLEé   ÚTCP_KEEPINTVLé
   ÚTCP_KEEPCNTé   )ÚDEFAULT_SOCKET_OPTIONÚsock_optÚsetdefaulttimeoutÚgetdefaulttimeoutÚrecvÚ	recv_lineÚsendc                   ó    — e Zd Zdededdfd„Zy)r   ÚsockoptÚssloptÚreturnNc                 ó>   — |€g }|€i }|| _         || _        d | _        y ©N)r   r   Útimeout)Úselfr   r   s      úK/var/www/html/aiagents/fe/lib/python3.12/site-packages/websocket/_socket.pyÚ__init__zsock_opt.__init__.   s+   € Øˆ?ØˆGØˆ>ØˆFØˆŒØˆŒØˆ�ó    )Ú__name__Ú
__module__Ú__qualname__ÚlistÚdictr   © r   r   r   r   ,   s   „ ð ð ¨dð °tô r   r   r   r   c                 ó   — | a y)zž
    Set the global timeout setting to connect.

    Parameters
    ----------
    timeout: int or float
        default socket timeout time (in seconds)
    N©Ú_default_timeout)r   s    r   r   r   8   s
   € ð Ñr   c                  ó   — t         S )zŸ
    Get default timeout

    Returns
    ----------
    _default_timeout: int or float
        Return the global timeout setting (in seconds) to connect.
    r%   r#   r   r   r   r   E   s
   € ô Ðr   ÚsockÚbufsizec                 óš  ‡ ‡— ‰ st        d«      ‚ˆˆ fd„}	 ‰ j                  «       dk(  r‰ j                  ‰«      }n |«       }|st        d«      ‚|S # t        $ r t	        d«      ‚t
        j                  $ r}t        |«      }t	        |«      ‚d }~wt        $ r0}t        |«      }t        |t        «      rd|v rt	        |«      ‚‚ d }~ww xY w)Núsocket is already closed.c                  óÎ  •— 	 ‰j                  ‰«      S # t        $ r Y nQt        j                  $ r<} t	        | «      }|t
        j                  k7  r|t
        j                  k7  r‚ Y d } ~ nd } ~ ww xY wt        j                  «       }|j                  ‰t        j                  «       |j                  ‰j                  «       «      }|j                  «        |r‰j                  ‰«      S y r   )r   ÚSSLWantReadErrorÚsocketÚerrorÚextract_error_codeÚerrnoÚEAGAINÚEWOULDBLOCKÚ	selectorsÚDefaultSelectorÚregisterÚ
EVENT_READÚselectÚ
gettimeoutÚclose)ÚexcÚ
error_codeÚselÚrr)   r(   s       €€r   Ú_recvzrecv.<locals>._recvU   s¶   ø€ ð	Ø—9‘9˜WÓ%Ð%øÜò 	ÙÜ�|‰|ò 	Ü+¨CÓ0ˆJØœUŸ\™\Ò)¨j¼E×<MÑ<MÒ.MØÿøð	úô
 ×'Ñ'Ó)ˆØ�‰�Tœ9×/Ñ/Ô0à�J‰J�t—‘Ó(Ó)ˆØ�	‰	ŒáØ—9‘9˜WÓ%Ð%ð s   ƒ ”	A-ŸA-±2A(Á(A-r   zConnection timed outú	timed outz#Connection to remote host was lost.)Ú"WebSocketConnectionClosedExceptionr9   r   ÚTimeoutErrorÚWebSocketTimeoutExceptionr.   r   Úextract_err_messageÚSSLErrorÚ
isinstanceÚstr)r(   r)   r?   Úbytes_ÚeÚmessages   ``    r   r   r   Q   sÎ   ù€ ÙÜ0Ð1LÓMÐMõ&ð&Ø�?‰?Ó Ò!Ø—Y‘Y˜wÓ'‰Fá“WˆFñ Ü0Ø1ó3ð 	3ð €Møô! ò @Ü'Ð(>Ó?Ð?Ü�>‰>ò 1Ü% aÓ(ˆÜ'¨Ó0Ð0ûÜò Ü% aÓ(ˆÜ�gœsÔ#¨°wÑ(>Ü+¨GÓ4Ð4àûðús#   —,A Á&C
Á8BÂC
Â+CÃC
c                 ór   — g }	 t        | d«      }|j                  |«       |dk(  rnŒ$dj                  |«      S )Nr   ó   
r   )r   ÚappendÚjoin)r(   ÚlineÚcs      r   r   r   €   s?   € Ø€DØ
Ü��q‹MˆØ�‰�AŒØ�Š:Øð	 ð
 �8‰8�D‹>Ðr   Údatac                 ó–  ‡ ‡— t        ‰t        «      r‰j                  d«      Š‰ st        d«      ‚ˆˆ fd„}	 ‰ j	                  «       dk(  r‰ j                  ‰«      S  |«       S # t        j                  $ r}t        |«      }t        |«      ‚d }~wt        $ r0}t        |«      }t        |t        «      rd|v rt        |«      ‚‚ d }~ww xY w)Nzutf-8r+   c                  óÔ  •— 	 ‰j                  ‰«      S # t        $ r Y nTt        j                  $ r?} t	        | «      }|€‚ |t
        j                  k7  r|t
        j                  k7  r‚ Y d } ~ nd } ~ ww xY wt        j                  «       }|j                  ‰t        j                  «       |j                  ‰j                  «       «      }|j                  «        |r‰j                  ‰«      S y r   )r   ÚSSLWantWriteErrorr.   r/   r0   r1   r2   r3   r4   r5   r6   ÚEVENT_WRITEr8   r9   r:   )r;   r<   r=   ÚwrQ   r(   s       €€r   Ú_sendzsend.<locals>._send‘   s½   ø€ ð		Ø—9‘9˜T“?Ð"øÜ ò 	ÙÜ�|‰|ò 	Ü+¨CÓ0ˆJØÐ!ØØœUŸ\™\Ò)¨j¼E×<MÑ<MÒ.MØÿøð	úô ×'Ñ'Ó)ˆØ�‰�Tœ9×0Ñ0Ô1à�J‰J�t—‘Ó(Ó)ˆØ�	‰	ŒáØ—9‘9˜T“?Ð"ð s   ƒ ”	A0ŸA0±5A+Á+A0r   r@   )rF   rG   ÚencoderA   r9   r   r.   r   rD   rC   Ú	Exception)r(   rQ   rW   rI   rJ   s   ``   r   r   r   Š   s³   ù€ Ü�$œÔØ�{‰{˜7Ó#ˆáÜ0Ð1LÓMÐMõ#ð*Ø�?‰?Ó Ò!Ø—9‘9˜T“?Ð"á“7ˆNøÜ�>‰>ò 1Ü% aÓ(ˆÜ'¨Ó0Ð0ûÜò Ü% aÓ(ˆÜ�gœsÔ#¨°wÑ(>Ü+¨GÓ4Ð4àûðús)   ¸#A# ÁA# Á#CÁ6BÂCÂ+CÃC)r1   r4   r.   Ú_exceptionsÚ_ssl_compatÚ_utilsÚSOL_TCPÚTCP_NODELAYr   ÚhasattrrM   Ú
SOL_SOCKETr   r   r   r
   r&   Ú__all__r   ÚintÚfloatr   r   Úbytesr   r   r   r#   r   r   ú<module>re      sp  ðÛ Û Û ä Ü Ü ðð& !Ÿ.™.¨&×*<Ñ*<¸aÐ@ÐAÐ Ù
ˆ6�>Ô"Ø× Ñ  &×"3Ñ"3°V×5HÑ5HÈ!Ð!LÔMÙ
ˆ6�>Ô"Ø× Ñ  &§.¡.°&×2EÑ2EÀrÐ!JÔKÙ
ˆ6�?Ô#Ø× Ñ  &§.¡.°&×2FÑ2FÈÐ!KÔLÙ
ˆ6�=Ô!Ø× Ñ  &§.¡.°&×2DÑ2DÀaÐ!HÔIàÐ ò(€÷	ñ 	ð
˜sš| eð 
°ó 
ð	˜3š< %ó 	ð,ˆv�}‰}ð , sð ,¨uó ,ð^�F—M‘Mð  eó ð)ˆv�}‰}ð ) Eð )¨cô )r   