3
Lj* @ sn d dl Zd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m
Z
ddddddd d
d d d
dddddddgZ dZ dZ
dZdZdZdZe jejj dd ejjj D Zd Zd Zd Zejd j Z ejd!j Z ejd"Z ejd#Z!d$d%d&hZ"dBd(d)Z#G d*d+ d+ej$j%Z&d,d- Z'e&fd.d/Z(G d0d dej)Z*G d1d dZ+y d dl,Z,W n e-k
rh Y n X G d2d3 d3e+Z.e j/d3 G d4d de0Z1G d5d de1Z2G d6d d e1Z3G d7d de1Z4G d8d de1Z5G d9d d e1Z6G d:d
d
e1Z7G d;d d e1Z8G dd de8Z;G d?d de1Ze<Z?e1Z@dS )C N)urlsplit HTTPResponseHTTPConnection
HTTPException NotConnectedUnknownProtocolUnknownTransferEncodingUnimplementedFileModeIncompleteRead
InvalidURLImproperConnectionStateCannotSendRequestCannotSendHeaderResponseNotReady
BadStatusLine LineTooLongRemoteDisconnectederror responsesP i ZUNKNOWNZIdlezRequest-startedz Request-sentc C s i | ] }|j |qS )phrase).0vr r #/usr/lib64/python3.6/http/client.py
k s r i i d s [^:\s][^:\r\n]*s \n(?![ \t])|\r(?![ \t\n])z[ - ]z[ - ]ZPATCHZPOSTZPUTdatac C sf y
| j dS tk
r` } z:t|j|j|j|jd|j | |j|j |f d W Y d d }~X nX d S )Nzlatin-1z`%s (%.20r) is not valid Latin-1. Use %s.encode('utf-8') if you want to send it encoded in UTF-8.)encodeUnicodeEncodeErrorencodingobjectstartendtitle)r nameerrr r r _encode s
r' c @ s e Zd Zdd ZdS ) HTTPMessagec C sn |j d }t|}g }d}xL| j D ]@}|d | j |krDd}n|d d j sXd}|r&|j| q&W |S )N:r )lowerlenkeysisspaceappend)selfr% nZlstZhitliner r r getallmatchingheaders s
z!HTTPMessage.getallmatchingheadersN)__name__
__module__ __qualname__r3 r r r r r( s r( c C s\ g }xR| j td }t|tkr(td|j| t|tkrJtdt |dkrP qW |S )Nr* z header linezgot more than %d headers
)r7 r8 r9 )readline_MAXLINEr, r r/ _MAXHEADERSr )fpheadersr2 r r r
_read_headers s
r? c C s, t | }dj|jd}tjj|dj|S )Nr9 z
iso-8859-1)_class)r? joindecodeemailparserZParserZparsestr)r= r@ r> Zhstringr r r
parse_headers s
rE c s e Zd Zd@ddZdd Zdd Zd d
Zd d Z fd
dZ fddZ dd Z
dd Z dAddZ dd Z
dd Zdd Zd d Zd d Zd!d" Zd#d$ Zd%d& ZdCd(d)ZdEd*d+ZdG fd,d- Zd.d/ Zd0d1 Zd2d3 ZdHd4d5Zd6d7 Z d8d9 Z d:d; Z dd? Z Z!S )Ir r Nc C sR |j d| _|| _|| _d | _| _t| _t| _t| _ t| _
t| _ t| _ t| _
d S )Nrb)makefiler=
debuglevel_methodr> msg_UNKNOWNversionstatusreasonchunked
chunk_leftlength
will_close)r0 sockrH methodurlr r r __init__ s zHTTPResponse.__init__c C s t | jjtd d}t|tkr*td| jdkrBtdt| |sNt dy|j
d d\}}}W nF t k
r y|j
d d\}}d}W n t k
r d}Y nX Y nX |j d s| j
t|y$t|}|d
k s|d krt|W n t k
r t|Y nX |||fS ) Nr* z
iso-8859-1z status liner zreply:z-Remote end closed connection without response zHTTP/r i )strr= r: r; r, r rH printreprr split
ValueError
startswith _close_connr int)r0 r2 rL rM rN r r r _read_status s2
zHTTPResponse._read_statusc C s | j d k rd S x<| j \}}}|tkr(P t| j}| jdkrFtd| ~qW | | _| _|j | _
|dkrrd| _ n|j drd| _ nt
|t| j | _ | _| jdkrx&| j D ] }td|d | j j| qW | j jd
}|r|j d krd | _d | _nd
| _| j | _d | _| j jd}| j jd
}|rx| j rxyt|| _W n tk
rb d | _Y nX | jdk r~d | _nd | _|tks|tksd| kodk n s| jdkrd| _| j r| j r| jd krd | _d S )Nr zheaders:HTTP/1.0HTTP/0.9
zHTTP/1. zheader:r) ztransfer-encodingrO TFzcontent-lengthr HEAD)rb rc ) r> ra ZCONTINUEr? r= rH rZ coderM striprN rL r^ r rE rJ getr+ rO rP _check_closerR rQ r` r] Z
NO_CONTENTZ NOT_MODIFIEDrI )r0 rL rM rN Zskipped_headershdrZtr_encrQ r r r begin9 s\
zHTTPResponse.beginc C s | j jd}| jdkr:| j jd}|r6d|j kr6dS dS | j jdrJdS |r^d|j kr^dS | j jd}|r~d|j kr~dS dS )NZ
connectionre closeTFz
keep-alivezproxy-connection)r> rj rL r+ )r0 ZconnZpconnr r r rk s
zHTTPResponse._check_closec C s | j }d | _ |j d S )N)r= rn )r0 r= r r r r_ s zHTTPResponse._close_connc
s$ zt j W d | jr | j X d S )N)superrn r= r_ )r0 ) __class__r r rn s zHTTPResponse.closec s t j | jr| jj d S )N)ro flushr= )r0 )rp r r rq s
zHTTPResponse.flushc C s dS )NTr )r0 r r r readable s zHTTPResponse.readablec C s
| j d kS )N)r= )r0 r r r isclosed s zHTTPResponse.isclosedc C s | j d krdS | jdkr$| j dS |d k rRt|}| j|}t|d | j S | jr`| j S | j d krv| j j
}n6y| j | j }W n t k
r | j Y nX d| _ | j |S d S )Nr9 rg r )
r= rI r_ bytearrayreadinto
memoryviewtobytesrO _readall_chunkedrQ read
_safe_readr
)r0 amtbr1 sr r r ry s*
zHTTPResponse.readc C s | j d krdS | jdkr$| j dS | jr4| j|S | jd k r^t|| jkr^t|d| j }| j j|}| r~|r~| j n&| jd k r| j|8 _| js| j |S )Nr rg ) r= rI r_ rO _readinto_chunkedrQ r, rv ru )r0 r| r1 r r r ru s$
zHTTPResponse.readintoc C sp | j jtd }t|tkr$td|jd}|dkrB|d | }y
t|dS tk
rj | j Y nX d S )Nr* z
chunk size ;r ) r= r: r; r, r findr` r] r_ )r0 r2 ir r r _read_next_chunk_size
s
z"HTTPResponse._read_next_chunk_sizec C s> x8| j jtd }t|tkr&td|s,P |dkrP qW d S )Nr* z trailer line
r8 r9 )r r8 r9 )r= r: r; r, r )r0 r2 r r r _read_and_discard_trailer s z&HTTPResponse._read_and_discard_trailerc C sl | j }|sh|d k r | jd y | j }W n tk
rD tdY nX |dkrb| j | j d }|| _ |S )NrW r9 r )rP rz r r] r
r r_ )r0 rP r r r _get_chunk_left( s
z HTTPResponse._get_chunk_leftc C sd g }y8x,| j }|d krP |j| j| d| _qW dj|S tk
r^ tdj|Y nX d S )Nr r9 )r r/ rz rP rA r
)r0 valuerP r r r rx @ s
z HTTPResponse._readall_chunkedc C s d}t |}yvxp| j }|d kr$|S t||krL| j|}|| | _|| S |d | }| j|}||d }||7 }d| _qW W n( tk
r tt|d| Y nX d S )Nr )rv r r, _safe_readintorP r
bytes)r0 r| total_bytesmvbrP r1 temp_mvbr r r r~ N s$
z HTTPResponse._readinto_chunkedc C sX g }xH|dkrL| j jt|t}|s4tdj|||j| |t|8 }qW dj|S )Nr r9 )r= ry min MAXAMOUNTr
rA r/ r, )r0 r{ r} chunkr r r rz f s
zHTTPResponse._safe_readc C s d}t |}xt|t|k rtt|k r@|dt }| jj|}n | jj|}|sjtt|d| t|||d }||7 }qW |S )Nr )rv r, r r= ru r
r )r0 r| r r r r1 r r r r } s zHTTPResponse._safe_readintor* c C s | j d ks| jdkrdS | jr(| j|S | jd k rJ|dk sD|| jkrJ| j}y| j j|}W n* tk
r |dkrt | j jd}Y nX | r|r| j n | jd k r| jt|8 _|S )Nrg r9 r r i i @ ) r= rI rO _read1_chunkedrQ read1r] r_ r, )r0 r1 resultr r r r s"
zHTTPResponse.read1c C s4 | j d ks| jdkrdS | jr(| j|S | j j|S )Nrg r9 )r= rI rO
_peek_chunkedpeek)r0 r1 r r r r s
zHTTPResponse.peekc s | j d ks| jdkrdS | jr*t j|S | jd k rL|dk sF|| jkrL| j}| j j|}| rl|rl| j n | jd k r| jt|8 _|S )Nrg r9 r )r= rI rO ro r: rQ r_ r, )r0 limitr )rp r r r: s
zHTTPResponse.readlinec C sf | j }|d ks|dkr dS d| ko.|kn s8|}| jj|}| jt|8 _|sbtd|S )Nr r9 )r r= r rP r, r
)r0 r1 rP ry r r r r s zHTTPResponse._read1_chunkedc C sB y | j }W n tk
r dS X |d kr.dS | jj|d | S )Nr9 )r r
r= r )r0 r1 rP r r r r s zHTTPResponse._peek_chunkedc C s
| j j S )N)r= fileno)r0 r r r r s zHTTPResponse.filenoc C sH | j d krt | j j|p |}t|ts6t|d r:|S dj|S d S )N__iter__z, )r> r Zget_all
isinstancerY hasattrrA )r0 r% defaultr> r r r getheader s
zHTTPResponse.getheaderc C s | j d krt t| j j S )N)r> r listitems)r0 r r r
getheaders s
zHTTPResponse.getheadersc C s | S )Nr )r0 r r r r s zHTTPResponse.__iter__c C s | j S )N)r> )r0 r r r info s zHTTPResponse.infoc C s | j S )N)rU )r0 r r r geturl s
zHTTPResponse.geturlc C s | j S )N)rM )r0 r r r getcode s zHTTPResponse.getcode)r NN)N)r r )r r )r )N)"r4 r5 r6 rV ra rm rk r_ rn rq rr rs ry ru r r r rx r~ rz r r r r: r r r r r r r r r
__classcell__r r )rp r r s<
!K
"
c @ s e Zd ZdZdZeZeZdZ dZ
e dd Z e dd Z
d ejd fd
d Zd0d d
Zdd Zdd Zdd Zdd Zdd Zdd Zdd Zd d Zd1d d Zd2d!d"Zd#d$ Z d%d& Z d3d d'd(d)Z d i fd d'd*d+Z d,d- Z d.d/ Z!d S )4r re zHTTP/1.1r* r c C s t | tjS )N)r io
TextIOBase)streamr r r
_is_textIO0 s zHTTPConnection._is_textIOc C sd | d kr |j tkrdS d S t| dr*d S yt| }|jS tk
rL Y nX t| tr`t| S d S )Nr ry ) upper_METHODS_EXPECTING_BODYr rv nbytes TypeErrorr rY r, )bodyrT Zmvr r r _get_content_length6 s
z"HTTPConnection._get_content_lengthNc C s\ || _ || _d | _g | _d | _t| _d | _d | _d | _ i | _
| j ||\| _ | _
tj| _d S )N)timeoutsource_addressrS _buffer_HTTPConnection__response_CS_IDLE_HTTPConnection__staterI _tunnel_host _tunnel_port_tunnel_headers
_get_hostporthostportsocketZcreate_connection_create_connection)r0 r r r r r r r rV V s zHTTPConnection.__init__c C s< | j rtd| j||\| _| _|r.|| _n
| jj d S )Nz.Can't set up tunnel for established connection)rS RuntimeErrorr r r r clear)r0 r r r> r r r
set_tunneli s zHTTPConnection.set_tunnelc C s |d kr|j d}|j d}||kryt||d d }W nH tk
r ||d d dkrh| j}ntd||d d Y nX |d | }n| j}|r|d dkr|d dkr|dd }||fS )
Nr) ]r* rX znonnumeric port: '%s'r [r r )rfindr` r] default_portr )r0 r r r jr r r r s
z HTTPConnection._get_hostportc C s
|| _ d S )N)rH )r0 levelr r r set_debuglevel s z HTTPConnection.set_debuglevelc C s d| j | jf }|jd}| j| x6| jj D ](\}}d||f }|jd}| j| q0W | jd | j| j| jd}|j \}} }
| t
j j kr| j
td| |
j f xP|jjtd } t| tkrtd | sP | dkrP | jd krtd
| j qW d S )NzCONNECT %s:%d HTTP/1.0
asciiz%s: %s
zlatin-1
)rT z Tunnel connection failed: %d %sr* z header liner8 r9 r zheader:)r r8 r9 )r r r sendr r response_classrS rI ra http
HTTPStatusZOKrn OSErrorri r= r: r; r, r rH rZ rB ) r0 Z connect_strZ
connect_bytesheaderr Z
header_strZ header_bytesresponserL rh messager2 r r r _tunnel s2
zHTTPConnection._tunnelc C sB | j | j| jf| j| j| _| jjtjtj d | j
r>| j d S )Nr* ) r r r r r rS Z
setsockoptr Z IPPROTO_TCPZ TCP_NODELAYr r )r0 r r r connect s
zHTTPConnection.connectc C sB t | _z | j}|r d | _|j W d | j}|r r r r r r s zHTTPConnection.requestc C s t dd |D }i }d|kr&d|d< d|kr6d|d< | j||f| d|krd |krd
}| j||}|d kr|d k r| jd krtd | d
}| jdd q| jdt| nd
}x |j D ]\} }
| j| |
qW t|trt |d}| j
||d d S )Nc s s | ]}|j V qd S )N)r+ )r kr r r s z/HTTPConnection._send_request..r r* r zaccept-encodingr zcontent-lengthztransfer-encodingFr z Unable to determine size of %rTzTransfer-EncodingrO zContent-Lengthr )r ) frozensetr r rH rZ r rY r r r' r ) r0 rT rU r r> r Z header_namesZskipsZcontent_lengthrl r r r r r s0
z HTTPConnection._send_requestc C s | j r| j j rd | _ | jtks&| j r0t| j| jdkrR| j| j| j| jd}n| j| j| jd}yLy |j W n t
k
r | j Y nX t | _|j
r| j n|| _ |S |j Y nX d S )Nr )rT )r rs r r r rH r rS rI rm ConnectionErrorrn r rR )r0 r r r r getresponse) s,
zHTTPConnection.getresponse)NN)NF)FF)N)"r4 r5 r6 r r r r HTTP_PORTr r rH staticmethodr r r _GLOBAL_DEFAULT_TIMEOUTrV r r r r r rn r r r r r r r r r r r r r r r r & s<
'
6
.c sB e Zd ZeZdddejdfddd fdd Z fddZ Z S )HTTPSConnectionN)contextcheck_hostnamec s t t| j|||| |d k s.|d k s.|d k rDdd l} | jdtd || _|| _|d krptj }|j
d k rpd|_
|j tj k}
|d kr|j
}|r|
rtd|s|r|j|| |j
d k rd|_
|| _|| _d S )Nr zTkey_file, cert_file and check_hostname are deprecated, use a custom context instead.rW TzMcheck_hostname needs a SSL context with either CERT_OPTIONAL or CERT_REQUIRED)ro r rV warningswarnDeprecationWarningkey_file cert_filesslZ _create_default_https_contextZpost_handshake_authZ verify_modeZ CERT_NONEr r] Zload_cert_chain_context_check_hostname) r0 r r r r r r r r r Z will_verify)rp r r rV t s0
zHTTPSConnection.__init__c s t j | jr| j}n| j}| jj| j|d| _| jj r| jryt j
| jj | W n. t k
r | jj
tj | jj Y nX d S )N)server_hostname)ro r r r r Z wrap_socketrS r r r
Zmatch_hostnameZ getpeercert ExceptionZshutdownr Z SHUT_RDWRrn )r0 r
)rp r r r s
zHTTPSConnection.connect)
r4 r5 r6
HTTPS_PORTr r r rV r r r r )rp r r m s r c @ s e Zd ZdS )r N)r4 r5 r6 r r r r r s c @ s e Zd ZdS )r N)r4 r5 r6 r r r r r s c @ s e Zd ZdS )r N)r4 r5 r6 r r r r r s c @ s e Zd Zdd ZdS )r c C s |f| _ || _d S )N)argsrL )r0 rL r r r rV s zUnknownProtocol.__init__N)r4 r5 r6 rV r r r r r s c @ s e Zd ZdS )r N)r4 r5 r6 r r r r r s c @ s e Zd ZdS )r N)r4 r5 r6 r r r r r s c @ s& e Zd ZdddZdd Zdd ZdS ) r
Nc C s |f| _ || _|| _d S )N)r partialexpected)r0 r r r r r rV s zIncompleteRead.__init__c C s2 | j d k rd| j }nd}d| jjt| j|f S )Nz, %i more expectedrX z%s(%i bytes read%s))r rp r4 r, r )r0 er r r __repr__ s
zIncompleteRead.__repr__c C s t | S )N)r[ )r0 r r r __str__ s zIncompleteRead.__str__)N)r4 r5 r6 rV r r r r r r r
s
c @ s e Zd ZdS )r N)r4 r5 r6 r r r r r s c @ s e Zd ZdS )r
N)r4 r5 r6 r r r r r
s c @ s e Zd ZdS )r N)r4 r5 r6 r r r r r s c @ s e Zd ZdS )r N)r4 r5 r6 r r r r r s c @ s e Zd Zdd ZdS )r c C s |s t |}|f| _|| _d S )N)r[ r r2 )r0 r2 r r r rV s zBadStatusLine.__init__N)r4 r5 r6 rV r r r r r s c @ s e Zd Zdd ZdS )r c C s t j| dt|f d S )Nz&got more than %d bytes when reading %s)r rV r; )r0 Z line_typer r r rV s zLineTooLong.__init__N)r4 r5 r6 rV r r r r r s c @ s e Zd Zdd ZdS )r c O s" t j| d tj| f|| d S )NrX )r rV ConnectionResetError)r0 poskwr r r rV s zRemoteDisconnected.__init__N)r4 r5 r6 rV r r r r r s )r )AZ email.parserrC Z
email.messager r osrer r Z urllib.parser __all__r r rK r r r globalsupdater __members__r r r r; r< compile fullmatchr r r r r r r' r ZMessager( r? rE BufferedIOBaser r r
ImportErrorr r/ r r r r r r r r
r r
r r r r r r r r r r r G s
9 F =