403Webshell
Server IP : 46.101.140.223  /  Your IP : 216.73.217.61
Web Server : nginx/1.22.1
System : Linux debian-s-1vcpu-1gb-fra1-01 6.1.0-49-amd64 #1 SMP PREEMPT_DYNAMIC Debian 6.1.174-1 (2026-05-26) x86_64
User : deploy-others ( 1001)
PHP Version : 8.2.33
Disable Function : NONE
MySQL : OFF  |  cURL : ON  |  WGET : ON  |  Perl : ON  |  Python : OFF  |  Sudo : ON  |  Pkexec : OFF
Directory :  /lib/python3/dist-packages/websocket/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :


[ Back ]     

Current File : /lib/python3/dist-packages/websocket/__pycache__/_app.cpython-311.pyc
�

���a�:���dZ	ddlZddlZddlZddlZddlZddlmZddlm	Z	m
Z
ddlTddlm
Z
dgZGd	�d
��ZGd�d��ZGd
�d��ZdS)z

�N�)�ABNF)�	WebSocket�getdefaulttimeout)�*)�_logging�WebSocketAppc��eZdZdZd�Zd�ZdS)�
Dispatcherz
    Dispatcher
    c�"�||_||_dS�N��app�ping_timeout��selfrrs   �0/usr/lib/python3/dist-packages/websocket/_app.py�__init__zDispatcher.__init__)������(�����c�J�|jjr�tj��}|�|jjjtj��|�|j��}|r|��sdS|��|�	��|jj��dSdSr
)
r�keep_running�	selectors�DefaultSelector�register�sock�
EVENT_READ�selectr�close)rr�
read_callback�check_callback�sel�rs      r�readzDispatcher.read-s����h�#�		��+�-�-�C��L�L����+�Y�-A�B�B�B��
�
�4�,�-�-�A��
�$�}�����E��N�����I�I�K�K�K��h�#�		�		�		�		�		rN)�__name__�
__module__�__qualname__�__doc__rr$�rrrr%s<��������)�)�)�
�
�
�
�
rrc�$�eZdZdZd�Zd�Zd�ZdS)�
SSLDispatcherz
    SSLDispatcher
    c�"�||_||_dSr
rrs   rrzSSLDispatcher.__init__>rrc��|jjr:|���}|r|��sdS|��|jj�8dSdSr
)rrr)rrr r!r#s     rr$zSSLDispatcher.readBsh���h�#�	����
�
�A��
�$�}�����E��N�����h�#�	�	�	�	�	rc�Z�|jjj}|���r|gStj��}|�|tj��|�|j��}|�	��t|��dkr|ddSdS)Nr)rr�pendingrrrrrrr�len)rrr"r#s    rrzSSLDispatcher.selectJs����x�}�!���<�<�>�>�	��7�N��'�)�)�����T�9�/�0�0�0��J�J�t�(�)�)���	�	�����q�6�6�A�:�:��Q�4��7�N��:rN)r%r&r'r(rr$rr)rrr+r+:sK��������)�)�)��������rr+c�r�eZdZdZ							dd�Zejfd�Zd�Zd�Z									dd�Z
d�Zd
�Zd�Z
dS)r	z_
    Higher level of APIs are provided. The interface is like JavaScript WebSocket object.
    NTc��||_|�|ng|_||_||_||_||_||_||_||_||_	|	|_
d|_||_d|_
d|_d|_|
|_dS)a�	
        WebSocketApp initialization

        Parameters
        ----------
        url: str
            Websocket url.
        header: list or dict
            Custom header for websocket handshake.
        on_open: function
            Callback object which is called at opening websocket.
            on_open has one argument.
            The 1st argument is this class object.
        on_message: function
            Callback object which is called when received data.
            on_message has 2 arguments.
            The 1st argument is this class object.
            The 2nd argument is utf-8 data received from the server.
        on_error: function
            Callback object which is called when we get error.
            on_error has 2 arguments.
            The 1st argument is this class object.
            The 2nd argument is exception object.
        on_close: function
            Callback object which is called when connection is closed.
            on_close has 3 arguments.
            The 1st argument is this class object.
            The 2nd argument is close_status_code.
            The 3rd argument is close_msg.
        on_cont_message: function
            Callback object which is called when a continuation
            frame is received.
            on_cont_message has 3 arguments.
            The 1st argument is this class object.
            The 2nd argument is utf-8 string which we get from the server.
            The 3rd argument is continue flag. if 0, the data continue
            to next frame data
        on_data: function
            Callback object which is called when a message received.
            This is called before on_message or on_cont_message,
            and then on_message or on_cont_message is called.
            on_data has 4 argument.
            The 1st argument is this class object.
            The 2nd argument is utf-8 string which we get from the server.
            The 3rd argument is data type. ABNF.OPCODE_TEXT or ABNF.OPCODE_BINARY will be came.
            The 4th argument is continue flag. If 0, the data continue
        keep_running: bool
            This parameter is obsolete and ignored.
        get_mask_key: function
            A callable function to get new mask keys, see the
            WebSocket.set_mask_key's docstring for more information.
        cookie: str
            Cookie value.
        subprotocols: list
            List of available sub protocols. Default is None.
        NFr)�url�header�cookie�on_open�
on_message�on_data�on_error�on_close�on_ping�on_pong�on_cont_messager�get_mask_keyr�last_ping_tm�last_pong_tm�subprotocols)rr3r4r6r7r9r:r;r<r=rr>r5rAr8s               rrzWebSocketApp.__init__^s���~��� &� 2�f�f����������$������ ��
� ��
�������.���!���(�����	�������(����rc�p�|jr|j�||��dkrtd���dS)a
        send message

        Parameters
        ----------
        data: str
            Message to send. If you set opcode to OPCODE_TEXT,
            data must be utf-8 string or unicode.
        opcode: int
            Operation code of data. Default is OPCODE_TEXT.
        rzConnection is already closed.N)r�send�"WebSocketConnectionClosedException)r�data�opcodes   rrCzWebSocketApp.send�sE���y�	1�D�I�N�N�4��8�8�A�=�=�4�/�1�1�
1�>�=rc�X�d|_|jr|jjdi|��d|_dSdS)z-
        Close websocket connection.
        FNr))rrr)r�kwargss  rrzWebSocketApp.close�sE��"����9�	��D�I�O�%�%�f�%�%�%��D�I�I�I�	�	rc�R�|�|��s�tj��|_|jr[	|j�|��n?#t
$r2}t
jd�|����Yd}~dSd}~wwxYw|�|����dSdS)Nz send_ping routine terminated: {})	�wait�timer?r�ping�	Exceptionr�warning�format)r�interval�event�payload�exs     r�
_send_pingzWebSocketApp._send_ping�s����*�*�X�&�&�	� $�	���D���y�
���I�N�N�7�+�+�+�+�� �����$�%G�%N�%N�r�%R�%R�S�S�S��E�E�E�E�E����������*�*�X�&�&�	�	�	�	�	s�A�
B
�'B�B
r�Fc�h���������dkrtd���|�|dkrtd����r|r|�krtd���|sg}|si}�jrtd���d�d�_d�_d�_d���fd�	�	t�j||�jdu|
d�	���_�j�t�����j�
�j�j�j
||||	�j||||�
��|
s�����}
���j��|rLt%j���t%j�j|�|f����d�_������fd�}��fd
�}|
��jj||��dS#t2t4t6f$r[}���j|��t;|t6��r����t;|t4��cYd}~Sd}~wwxYw)a�
        Run event loop for WebSocket framework.

        This loop is an infinite loop and is alive while websocket is available.

        Parameters
        ----------
        sockopt: tuple
            Values for socket.setsockopt.
            sockopt must be tuple
            and each element is argument of sock.setsockopt.
        sslopt: dict
            Optional dict object for ssl socket option.
        ping_interval: int or float
            Automatically send "ping" command
            every specified period (in seconds).
            If set to 0, no ping is sent periodically.
        ping_timeout: int or float
            Timeout (in seconds) if the pong message is not received.
        ping_payload: str
            Payload message to send with each ping.
        http_proxy_host: str
            HTTP proxy host name.
        http_proxy_port: int or str
            HTTP proxy port. If not set, set to 80.
        http_no_proxy: list
            Whitelisted host names that don't use the proxy.
        skip_utf8_validation: bool
            skip utf8 validation.
        host: str
            update host header.
        origin: str
            update origin header.
        dispatcher: Dispatcher object
            customize reading data from socket.
        suppress_origin: bool
            suppress outputting origin header.

        Returns
        -------
        teardown: bool
            False if caught KeyboardInterrupt, True if other exception was raised during a loop
        NrzEnsure ping_timeout > 0zEnsure ping_interval >= 0z#Ensure ping_interval > ping_timeoutzsocket is already openedTc�P���r<����r(��������d�_�jr�j�����|r|nd��\}}d�_���j||��dS)a
            Tears down the connection.

            Parameters
            ----------
            close_frame: ABNF frame
                If close_frame is set, the on_close handler is invoked
                with the statusCode and reason from the provided frame.
            FN)	�is_alive�set�joinrrr�_get_close_args�	_callbackr:)�close_frame�close_status_code�close_reasonrQr�threads   ���r�teardownz*WebSocketApp.run_forever.<locals>.teardowns�����
�&�/�/�+�+�
��	�	�������
�
�
� %�D���y�
"��	���!�!�!�.2�.B�.B�*�4����/6�/6�+��|��D�I�
�N�N�4�=�*;�\�J�J�J�J�Jr)�sockopt�sslopt�fire_cont_frame�skip_utf8_validation�enable_multithread)r4r5�http_proxy_host�http_proxy_port�
http_no_proxy�http_proxy_authrA�host�origin�suppress_origin�
proxy_type)�target�argsc�6���js
���S�j�d��\}}|tjkr�|��S|tjkr"���j|j���n|tj	kr9tj
���_���j|j��n�|tj
krZ�jrS���j|j|j|j�����j|j|j��ni|j}|tjkr|�d��}���j||jd�����j|��dS)NT�utf-8)rr�recv_data_framer�OPCODE_CLOSE�OPCODE_PINGr\r;rE�OPCODE_PONGrKr@r<�OPCODE_CONTr=r8rF�fin�OPCODE_TEXT�decoder7)�op_code�framerErras   ��rr$z&WebSocketApp.run_forever.<locals>.readKst����(�&�#�8�:�:�%�!%��!:�!:�4�!@�!@�����d�/�/�/�#�8�E�?�?�*��� 0�0�0��N�N�4�<���<�<�<�<��� 0�0�0�(,�	���D�%��N�N�4�<���<�<�<�<��� 0�0�0�T�5I�0��N�N�4�<���#(�<���<�<�<��N�N�4�#7�#(�:�u�y�:�:�:�:�!�:�D��$�"2�2�2�#�{�{�7�3�3���N�N�4�<��u�|�T�J�J�J��N�N�4�?�D�9�9�9��trc�����ratj���jz
�k}�j�jz
dk}�j�jz
�k}�jr|r|s|rtd���dS)Nrzping/pong timed outT)rKr?r@�WebSocketTimeoutException)�has_timeout_expired�$has_pong_not_arrived_after_last_ping�has_pong_arrived_too_laterrs   ��r�checkz'WebSocketApp.run_forever.<locals>.checkes���� �O�*.�)�+�+��8I�*I�L�*X�'�;?�;L�t�O`�;`�cd�;d�8�04�0A�D�DU�0U�Xd�0d�-��)�O�/�O�A�O�E^�O�8�8M�N�N�N��trr
)�WebSocketExceptionrrr?r@rr>r=�
settimeoutr�connectr3r4r5rA�create_dispatcherr\r6�	threading�Event�ThreadrT�daemon�startr$rM�KeyboardInterrupt�
SystemExitr9�
isinstance)rrbrc�
ping_intervalr�ping_payloadrgrhrirjrerkrl�
dispatcherrmrnr$r��erQrar`s`   `              @@@r�run_foreverzWebSocketApp.run_forever�s��������h�#���(9�(9�$�%>�?�?�?��$���):�):�$�%@�A�A�A��	L�M�	L�m�|�.K�.K�$�%J�K�K�K��	��G��	��F��9�	A�$�%?�@�@�@��� ���������	K�	K�	K�	K�	K�	K�	K�	K�0G	8�!��!�7�6� $� 4�D� @�%9�#'�	)�)�)�D�I�

�I� � �!2�!4�!4�5�5�5��I�������T�[� /� /�}� /�d�>O��&�/�%�

�
'�
'�
'��
B�!�3�3�L�A�A�
��N�N�4�<�(�(�(��
�!��)�)��"�)��?�-���1U�W�W�W�� $��
�������
�
�
�
�
�
�4

�

�

�

�

�

�
�O�O�D�I�N�D�%�8�8�8�8�8���,�j�9�	8�	8�	8��N�N�4�=�!�,�,�,��!�Z�(�(�
���H�J�J�J�!�!�%6�7�7�7�7�7�7�7�7�7�����
	8���s �D2F?�?H1�AH,�&H1�,H1c�|�|pd}|j���rt||��St||��S)N�
)r�is_sslr+r)rr�timeouts   rr�zWebSocketApp.create_dispatcherzsB���$�"���9�����	0� ��w�/�/�/��$��(�(�(rc���|jr|sddgS|jr\t|j��dkrDd|jdz|jdz}|jdd��d��}||gSddgS)z�
        _get_close_args extracts the close code and reason from the close body
        if it exists (RFC6455 says WebSocket Connection Close Code is optional)
        N��rrrr)r:rEr0rz)rr]r^�reasons    rr[zWebSocketApp._get_close_args�s����}�	 �K�	 ��$�<����	 ��K�$4� 5� 5�� :� :� #�k�&6�q�&9� 9�K�<L�Q�<O� O�� �%�a�b�b�)�0�0��9�9�F�%�v�.�.��$�<�rc���|ro	||g|�R�dS#t$rV}tjd�||����|jr|�||��Yd}~dSYd}~dSd}~wwxYwdS)Nzerror from callback {}: {})rMr�errorrOr9)r�callbackrpr�s    rr\zWebSocketApp._callback�s����	+�
+����%��%�%�%�%�%�%���
+�
+�
+���;�B�B�8�Q�O�O�P�P�P��=�+��M�M�$��*�*�*�*�*�*�*�*�*�+�+�+�+�+�+�����
+����		+�	+s�	�
A/�AA*�*A/)
NNNNNNNNTNNNN)NNrNrUNNNNFNNNFN)r%r&r'r(rrryrCrrTr�r�r[r\r)rrr	r	Ys���������$(�9=�6:�!%�>B�"��
P)�P)�P)�P)�d!%� 0�1�1�1�1�"������04�26�!#�:>�8<�).�7;�6:�d8�d8�d8�d8�L)�)�)� � � �&+�+�+�+�+r)r(r�sysr�rK�	traceback�_abnfr�_corerr�_exceptionsrUr�__all__rr+r	r)rr�<module>r�s*�����$����
�
�
�
�������������������/�/�/�/�/�/�/�/������������
����������*��������>C+�C+�C+�C+�C+�C+�C+�C+�C+�C+r

Youez - 2016 - github.com/yon3zu
LinuXploit