| Server IP : 192.250.235.158 / Your IP : 216.73.216.143 Web Server : LiteSpeed System : Linux s4099.sgp1.stableserver.net 5.14.0-503.21.1.el9_5.x86_64 #1 SMP PREEMPT_DYNAMIC Sun Jan 12 09:45:05 EST 2025 x86_64 User : vmxfzbqj ( 1905) PHP Version : 8.3.31 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /lib/python3.9/site-packages/supervisor/__pycache__/ |
Upload File : |
a
0�gv � @ s� d dl Z d dlZd dlmZ d dlmZ d dlmZ d dlmZ d dlmZ d dlm Z
dZ d Z e e Z
G d
d � d e�ZG d d
� d
e
j�ZdS )� N)�as_bytes)� as_string)� encodestring)�PY2)�urlparse)� asynchat_25�
�
c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
S )�Listenerc C s d S �N� )�self�url�statusr r �:/usr/lib/python3.9/site-packages/supervisor/http_client.pyr s zListener.statusc C s t j�d||f � d S )Nz%s %s
)�sys�stderr�write)r
r �errorr r r r s zListener.errorc C s d S r r )r
r �name�valuer r r �response_header s zListener.response_headerc C s d S r r �r
r r r r �done s z
Listener.donec C s� z t |�}W n ty& d| }Y n0 ztj�|� W n8 typ trXtj�|� ndtjj }t|��Y n0 tj� � d S )NzUndecodable: %rz<Unable to write Unicode to stdout because it has encoding %s)
r �UnicodeDecodeErrorr �stdoutr �UnicodeEncodeErrorr �encoding�
ValueError�flush)r
r �dataZsdata�sr r r �feed s �z
Listener.feedc C s d S r r r r r r �close4 s zListener.closeN) �__name__�
__module__� __qualname__r r r r r" r# r r r r r
s r
c @ s� e Zd Zd'dd�Zd(dd�Zdd� Zd d
� Zd d � Zd
d� Zdd� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� ZdS ))� HTTPHandler� Nc C st t j�| ||� || _d| _d| _| �t� d| _| j | _
d| _ d| _ d| _
d| _d | _|| _|| _d | _d| _d S )NzSupervisor HTTP Client� r F)�asynchat�
async_chat�__init__�listener�
user_agent�buffer�set_terminator�CRLF� connected� status_line�part�
chunk_sizeZ
chunk_readZ length_read�lengthr �username�passwordr �
error_handled)r
r- r7 r8 Zconn�mapr r r r, 8 s
zHTTPHandler.__init__c
C s� | j d urtd��|| | _ t�| j �\}}}}}}|dvr@t�|| _d|v rh|�dd�\} }
t|
�}
n|} d}
|| _|
| _|dkr�| } | � t
j t
j � | �
| | jf� n.|dkr�|dd � } | � t
jt
j � | �
| � d S ) NzAlready doing a get)�http�unix�:� �P r; r< � )r �AssertionErrorr �NotImplementedError�host�split�int�path�portZ
create_socket�socketZAF_INETZ SOCK_STREAMZconnectZAF_UNIX)
r
Z serverurlrF �schemerC Z path_ignored�params�query�fragment�hostnamerG ZipZ
socketnamer r r �getQ s0
�
zHTTPHandler.getc C s0 | j �| j� d| _| �� | j�� d| _d S )Nr ZCLOSED)r- r# r r2 Z del_channelrH �r
r r r r# m s
zHTTPHandler.closec C s | � d||f � | � t� d S )Nz%s: %s)�pushr1 �r
r r r r r �headert s zHTTPHandler.headerc C s^ | j r
d S ds| jrZt�� \}}}d||f }| j�| j|� | j| _| � � d| _ ~~~d S )Nr> z Cannot connect, error: %s (%s)T)
r9 r2 r �exc_infor- r r �ignorer4 r# )r
�t�v�tb�msgr r r � handle_errorx s
zHTTPHandler.handle_errorc C s� d| _ d}d}| �d|| j|f � | �t� | �d| j� | �dd� | �dd � | �d
| j� | jr�d | j| jf }t t
t |���� � }| �d d
| � | �t� | �t� d S )Nr> ZGETzHTTP/1.1z%s %s %sZHostzAccept-EncodingZchunkedZAcceptz*/*z
User-agentz%s:%sZ
AuthorizationzBasic %s)
r2 rP rF r1 rR rC r. r8 r7 r r r �strip)r
�method�versionZauthr r r �handle_connect� s
zHTTPHandler.handle_connectc C s | j �| j|� d S r )r- r" r )r
r r r r r" � s zHTTPHandler.feedc C s. | j | | _ | j| jkr*| �| j � d| _ d S �Nr) )r/ r4 �bodyr" )r
�bytesr r r �collect_incoming_data� s z!HTTPHandler.collect_incoming_datac C s | � � d| _d S r^ )r4 r/ rO r r r �found_terminator� s z HTTPHandler.found_terminatorc C s
d| _ d S r^ )r/ rO r r r rT � s zHTTPHandler.ignorec C s� | j }|�d d�\}}}t|�}|�d�s2t|��| j�| j|� |dkrT| j| _ n(| j
| _ d| }| j� | j|� | � � |||fS )N� s HTTP/�� zCannot read, status code %s)
r/ rD rE �
startswithr r- r r �headersr4 rT r r# )r
�liner\ r �reasonrX r r r r3 � s
zHTTPHandler.status_linec C s� | j }|s4| jdkr | j| _q�| j| _| �| j� nV|�dd�\}}|r�|r�|�� }|� � }|dkrl|| _n|dkr~t
|�| _| � ||� d S )Ns chunked� :r> s transfer-encodings content-length) r/ r � chunked_sizer4 r_ r0 r6 rD �lowerrZ rE r )r
rg r r r r r rf � s
zHTTPHandler.headersc C s | j �| j||� d S r )r- r r rQ r r r r � s zHTTPHandler.response_headerc C s | � � | �� d S r )r r# rO r r r r_ � s zHTTPHandler.bodyc C s | j �| j� d S r )r- r r rO r r r r � s zHTTPHandler.donec C sV | j }|sd S t|�� d d�}|dkr2| j| _n| �|� | j| _| j|7 _d S )Nr � )r/ rE rD �trailerr4 r0 � chunked_bodyr6 )r
rg r5 r r r rj � s
zHTTPHandler.chunked_sizec C s& | j }| �t� | j| _| �|� d S r )r/ r0 r1 rj r4 r" �r
rg r r r rn � s
zHTTPHandler.chunked_bodyc C s" | j }|tkr | �� | �� d S r )r/ r1 r r# ro r r r rm � s zHTTPHandler.trailer)r( NNN)r( )r$ r% r& r, rN r# rR rY r] r" ra rb rT r3 rf r r_ r rj rn rm r r r r r' 7 s, �
r' )r rH Zsupervisor.compatr r r r r Zsupervisor.medusar r* ZCRZLFr1 �objectr
r+ r' r r r r �<module> s &