File: //usr/local/CyberCP/lib64/python3.10/site-packages/websocket/__pycache__/_http.cpython-310.pyc
o
�h2 � @ s� d Z ddlZddlZddlZddlmZ ddlmZm Z m
Z
ddl m Z m
Z
mZ ddlmZmZmZ ddlmZmZ dd lmZmZ g d
�Zzdd lT dd lm Z dd
l m Z dZ W n dZ G dd� de �Z!G dd� de �Z"G dd� de �Z#Y G dd� d�Z$de%de&fdd�Z'de%fd d �Z(d e)d e*de&fd d!�Z+d"d#� Z,d$ejd%e-fd&d'�Z.d$ejd(e-fd)d*�Z/d$ejd e)dejfd+d,�Z0d$ejde&fd-d.�Z1dS )/a_
_http.py
websocket - WebSocket client library for Python
Copyright 2024 engn33r
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
� N)� encodebytes� )�WebSocketAddressException�WebSocketException�WebSocketProxyException)�debug�dump�trace)�DEFAULT_SOCKET_OPTION� recv_line�send)�HAVE_SSL�ssl)�get_proxy_info� parse_url)�
proxy_info�connect� read_headers)�*)� ProxyType)�ProxyTFc @ � e Zd ZdS )�
ProxyErrorN��__name__�
__module__� __qualname__� r r �B/usr/local/CyberCP/lib/python3.10/site-packages/websocket/_http.pyr - � r c @ r )�ProxyTimeoutErrorNr r r r r r 0 r r c @ r )�ProxyConnectionErrorNr r r r r r! 3 r r! c @ s e Zd Zdd� ZdS )r c K s� |� dd �| _| jr8|� dd�| _|� dd �| _|� dd �| _|� dd�| _|� dd �| _| jd vr6td
��d S d| _d | _d | _d| _d S ) N�http_proxy_host�http_proxy_portr �http_proxy_auth�
http_no_proxy�
proxy_type�http�http_proxy_timeout)r' �socks4�socks4a�socks5�socks5hz7Only http, socks4, socks5 proxy protocols are supported)�get�
proxy_host�
proxy_port�auth�no_proxy�proxy_protocol�
proxy_timeoutr )�self�optionsr r r �__init__8 s
��
zproxy_info.__init__N)r r r r6 r r r r r 7 s r �url�returnc C s� t std��t| �\}}}}|jdkrd}tj}n |jdkr$d}tj}n|jdkr/d}tj}n
|jdkr9d}tj}tj||j t
|j �|j rJ|j d nd |j rS|j d nd |d
�} | j
|||jd �}
|rqtrmt|
|j|�}
ntd ��|
|||ffS )
Nz>Python Socks is needed for SOCKS proxying but is not availabler) Fr* Tr+ r, r r )r& �host�port�username�password�rdns)�timeout�SSL not available.)�HAVE_PYTHON_SOCKSr r r2 r �SOCKS4�SOCKS5r �creater. �intr/ r0 r r3 r
� _ssl_socket�sslopt) r7 r5 �proxy�hostnamer: �resource� is_securer= r& �ws_proxy�sockr r r �_start_proxied_socketR s> �
� rM c C s� |j r|s|jdkrt| ||�S t| �\}}}}|r!||||ffS t||||�\}} }
|s7td|� d|� ���d } z)t||j|j�} | rKt | |||
�} |r[t
rWt | |j |�} ntd��| |||ffW S | rl| �
� � )Nr' zHost not found.: �:r? )r. r2 rM r �_get_addrinfo_listr � _open_socket�sockoptr> �_tunnelr
rE rF �close) r7 r5 rG �socketrH �
port_from_urlrI rJ �
addrinfo_list� need_tunnelr0 rL r r r r } s0
�r r: rJ c
C s� t | ||j|j|j|j�\}}}z*|s$t�| |dtjtj�}|dd fW S |r(|p)d}t�||dtjtj�}|d|fW S tj yK } zt
|��d }~ww )Nr F�P T) r r. r/ r0 r1 rT � getaddrinfo� SOCK_STREAM�SOL_TCP�gaierrorr ) rH r: rJ rG �phost�pport�pauthrV �er r r rO � s.
�� � ��rO c
C s d }| D ]}|d d� \}}}t � |||�}|�|� tD ]} |j| � q |D ]} |j| � q'|d }
d }|s�z
|�|
� W |S t jy� } z4|�� t|
d �| _z
t j
t j t j f} W n t
yn t j
t j f} Y nw | j | vrv| �| }W Y d } ~ q5d } ~ ww q|r�|�|S )N� � r )rT �
settimeoutr
�
setsockoptr �errorrS �str� remote_ip�errno� ECONNREFUSED�WSAECONNREFUSED� ENETUNREACH�AttributeError)
rV rQ r> �err�addrinfo�family�socktype�protorL �opts�addressre � eConnRefusedr r r rP � sL
�� �
��rP rL rF c
C s~ |� dd �}|s�t�|� dtj��}tj� dd �|_|� dtj�tjkrH|� dd �}|� dd �}|s4|r<|j||d� n t |d�rH|�
tj j � |� d d �r_|�
|d |� d
d �|� d d �� |� dtj�tjkrw|� d d
�swd
|_tj|_n|� d d�|_|� dtj�|_d|v r�|�|d � d|v r�|d \}}} |�
||| � d|v r�|�|d � |j| |� dd�|� dd�|d�S )N�context� ssl_version�
SSLKEYLOGFILE� cert_reqs�ca_certs� ca_cert_path)�cafile�capath�load_default_certs�certfile�keyfiler< �check_hostnameFT�ciphers�
cert_chain�
ecdh_curve�do_handshake_on_connect�suppress_ragged_eofs)r� r� �server_hostname)r- r �
SSLContext�PROTOCOL_TLS_CLIENT�os�environ�keylog_filename� CERT_NONE�load_verify_locations�hasattrr} �Purpose� SERVER_AUTH�load_cert_chainr� � verify_mode�
CERT_REQUIRED� set_ciphers�set_ecdh_curve� wrap_socket)
rL rF rH r� ru r{ r| r~ r r< r r r �_wrap_sni_socket� sJ
� �
�r� � user_ssloptc C s� dt ji}|�|� tj�d�}|r%tj�|�r%|�dd �d u r%||d< n|r9tj�|�r9|�dd �d u r9||d< |�dd �rC|d }|�dd�}t | |||�} | S )Nrx �WEBSOCKET_CLIENT_CA_BUNDLEry rz r� r� T)
r r� �updater� r� r- �path�isfile�isdirr� )rL r� rH rF � cert_pathr� r r r rE ! s(
�
�
�
� rE c
C s� t d� d|� d|� d�}|d|� d|� d�7 }|rE|d rE|d }|d r/|d|d � �7 }t|�� ��� �� �d d
�}|d |� d�7 }|d7 }td |� t| |� z t| �\}}}W n t yn } zt
t | ���d } ~ ww |d
krzt
d|� ���| S )NzConnecting proxy...zCONNECT rN z HTTP/1.1
zHost: z
r r �
� zProxy-Authorization: Basic zrequest header�� z!failed CONNECT via proxy status: ) r � base64encode�encode�strip�decode�replacer r r � Exceptionr rf )
rL r9 r: r0 �connect_header�auth_str� encoded_str�status�_r` r r r rR < s*
��rR c C s� d }d }i }t d� t| �}|�d��� }|snSt |� |s6|�dd�}t|d �}t|�dkr5|d }n5|�dd�}t|�dkrFtd��|\}}|�� d krc|� d �rc|� d �d
|�� |d < n|�� ||�� < q t d � |||fS ) Nz--- response header ---Tzutf-8� � r rN zInvalid headerz
set-cookiez; z-----------------------)
r r r� r� �splitrD �lenr �lowerr- ) rL r� �status_message�headers�line� status_info�kv�key�valuer r r r X s4 � �
r )2�__doc__rh r� rT �base64r r� � _exceptionsr r r �_loggingr r r �_socketr
r r � _ssl_compatr
r �_urlr r �__all__�python_socks._errors�python_socks._typesr �python_socks.syncr r@ r� r r r! r rf �tuplerM r rD �boolrO rP �dictr� rE rR r r r r r �<module> s< +% +4