Edit File: 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 &
Back to File Manager