File: //lib/python3.6/site-packages/supervisor/__pycache__/http_client.cpython-36.pyc
3
�k�`v � @ 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.6/http_client.pyr s zListener.statusc C s t jjd||f � d S )Nz%s %s
)�sys�stderr�write)r r
�errorr r r r s zListener.errorc C s d S )Nr )r r
�name�valuer r r �response_header s zListener.response_headerc C s d S )Nr )r r
r r r �done s z
Listener.donec C s� y t |�}W n tk
r( d| }Y nX ytjj|� W n: tk
rt tr\tjj|� ndtjj }t|��Y nX tjj � 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 )Nr )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 jj| ||� || _d| _d| _| jt� 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+ r5 r6 Zconn�mapr r r r* 8 s
zHTTPHandler.__init__c
C s� | j d k rtd��|| | _ tj| j �\}}}}}}|dkr@t�|| _d|krh|jdd�\} }
t|
�}
n|} d}
|| _|
| _|dkr�| } | j t
j t
j � | j
| | jf� n.|dkr�|dd � } | j t
jt
j � | j
| � d S ) NzAlready doing a get�http�unix�:� �P � )r9 r: )r
�AssertionErrorr �NotImplementedError�host�split�int�path�portZ
create_socket�socketZAF_INETZ SOCK_STREAMZconnectZAF_UNIX)
r Z serverurlrD �schemerA Z path_ignoredZparamsZqueryZfragmentZhostnamerE ZipZ
socketnamer r r �getQ s.
zHTTPHandler.getc C s0 | j j| j� d| _| j� | jj� d| _d S )Nr ZCLOSED)r+ r! r
r0 Z del_channelrF )r r r r r! m s
zHTTPHandler.closec C s | j d||f � | j t� d S )Nz%s: %s)�pushr/ )r r r r r r �headert s zHTTPHandler.headerc C s^ | j r
d S ds| jrZtj� \}}}d||f }| jj| j|� | j| _| j � d| _ ~~~d S )Nr< z Cannot connect, error: %s (%s)T)
r7 r0 r �exc_infor+ r r
�ignorer2 r! )r �t�v�tb�msgr r r � handle_errorx s
zHTTPHandler.handle_errorc C s� d| _ d}d}| jd|| j|f � | jt� | jd| j� | jdd� | jdd � | jd
| j� | jr�d | j| jf }t t
t |���j � }| jd d
| � | jt� | jt� d S )Nr< ZGETzHTTP/1.1z%s %s %sZHostzAccept-EncodingZchunkedZAcceptz*/*z
User-agentz%s:%sZ
AuthorizationzBasic %s)
r0 rI rD r/ rJ rA r, r6 r5 r r r �strip)r �method�versionZauthr r r �handle_connect� s
zHTTPHandler.handle_connectc C s | j j| j|� d S )N)r+ r r
)r r r r r r � s zHTTPHandler.feedc C s. | j | | _ | j| jkr*| j| j � d| _ d S )Nr' )r- r2 �bodyr )r �bytesr r r �collect_incoming_data� s z!HTTPHandler.collect_incoming_datac C s | j � d| _d S )Nr' )r2 r- )r r r r �found_terminator� s z HTTPHandler.found_terminatorc C s
d| _ d S )Nr' )r- )r r r r rL � s zHTTPHandler.ignorec C s� | j }|jd d�\}}}t|�}|jd�s2t|��| jj| j|� |dkrT| j| _ n(| j
| _ d| }| jj | j|� | j � |||fS )N� s HTTP/�� zCannot read, status code %s)
r- rB rC �
startswithr r+ r r
�headersr2 rL r r! )r �linerT r �reasonrP r r r r1 � s
zHTTPHandler.status_linec C s� | j }|s4| jdkr | j| _q�| j| _| j| j� nV|jdd�\}}|r�|r�|j� }|j � }|dkrl|| _n|dkr~t
|�| _| j ||� d S )Ns chunked� :r< s transfer-encodings content-length) r- r � chunked_sizer2 rV r. r4 rB �lowerrR rC r )r r^ r r r r r r] � s
zHTTPHandler.headersc C s | j j| j||� d S )N)r+ r r
)r r r r r r r � s zHTTPHandler.response_headerc C s | j � | j� d S )N)r r! )r r r r rV � s zHTTPHandler.bodyc C s | j j| j� d S )N)r+ r r
)r r r r r � s zHTTPHandler.donec C sV | j }|sd S t|j� d d�}|dkr2| j| _n| j|� | j| _| j|7 _d S )Nr � )r- rC rB �trailerr2 r. � chunked_bodyr4 )r r^ r3 r r r ra � s
zHTTPHandler.chunked_sizec C s& | j }| jt� | j| _| j|� d S )N)r- r. r/ ra r2 r )r r^ r r r re � s
zHTTPHandler.chunked_bodyc C s" | j }|tkr | j� | j� d S )N)r- r/ r r! )r r^ r r r rd � s zHTTPHandler.trailer)r& NNN)r& )r" r# r$ r* rH r! rJ rQ rU r rX rY rL r1 r] r rV r ra re rd r r r r r% 7 s*
r% )r rF Zsupervisor.compatr r r r r Zsupervisor.medusar r( ZCRZLFr/ �objectr
r) r% r r r r �<module> s &