] @ sH d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m
Z
d d d d d d d d
d d d
d d d d d d d g Z d Z d Z
d Z d Z d Z d Z e j e j j d d e j j j D Z d Z d Z d Z e j d j Z e j d! j Z e j d" Z d# d$ d% h Z! d& d' d( Z" Gd) d* d* e j# j$ Z% e% d+ d, Z& Gd- d d e j' Z( Gd. d d Z) y d d l* Z* Wn e+ k
rYn$ XGd/ d0 d0 e) Z, e j- d0 Gd1 d d e. Z/ Gd2 d d e/ Z0 Gd3 d d e/ Z1 Gd4 d d e/ Z2 Gd5 d d e/ Z3 Gd6 d d e/ Z4 Gd7 d
d
e/ Z5 Gd8 d d e/ Z6 Gd9 d
d
e6 Z7 Gd: d d e6 Z8 Gd; d d e6 Z9 Gd< d d e/ Z: Gd= d d e/ Z; Gd> d d e< e: Z= e/ Z> d S)? N)urlsplit HTTPResponseHTTPConnection
HTTPException NotConnectedUnknownProtocolUnknownTransferEncodingUnimplementedFileModeIncompleteRead
InvalidURLImproperConnectionStateCannotSendRequestCannotSendHeaderResponseNotReady
BadStatusLine LineTooLongRemoteDisconnectederror responsesP i ZUNKNOWNZIdlezRequest-startedz Request-sentc C s i | ] } | j | q S )phrase).0vr r +/opt/alt/python35/lib64/python3.5/client.py
<dictcomp>k s r i i d s [^:\s][^:\r\n]*s \n(?![ \t])|\r(?![ \t\n])z[ - ]ZPATCHZPOSTPUTdatac C s y | j d SWno t k
r } zO t | j | j | j | j d | j | | j | j | f d WYd d } ~ Xn Xd 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 Z d Z d d Z d S) HTTPMessagec C s | j d } t | } g } d } xh | j D]Z } | d | j | k r` d } n | d d j s| d } | r5 | j | q5 W| S)N:r )lowerlenkeysisspaceappend)selfr& nZlstZhitliner r r getallmatchingheaders s
z!HTTPMessage.getallmatchingheadersN)__name__
__module__ __qualname__r4 r r r r r) s r) c C s g } xq | j t d } t | t k r: t d | j | t | t k ri t d t | d k r Pq Wd j | j d } t j
j d | j | S)
Nr+ z header linezgot more than %d headers
z
iso-8859-1_class)r8 r9 r: )
readline_MAXLINEr- r r0 _MAXHEADERSr joindecodeemailparserZParserZparsestr)fpr; headersr3 Zhstringr r r
parse_headers s
rE c s e Z d Z d d d d d Z d d Z d d Z d d
Z d d Z f d
d Z f d d Z d d Z
d d Z d d d Z d d Z
d d Z d d Z d d Z d d Z d! d" Z d# d$ Z d% d& Z d@ d( d) Z dA d* d+ Z dB f d, d- Z d. d/ Z d0 d1 Z d2 d3 Z d d4 d5 Z d6 d7 Z d8 d9 Z d: d; Z d< d= Z d> d? Z S)Cr r Nc C sw | j d | _ | | _ | | _ d | _ | _ t | _ t | _ t | _ t | _
t | _ t | _ t | _
d S)Nrb)makefilerC
debuglevel_methodrD msg_UNKNOWNversionstatusreasonchunked
chunk_leftlength
will_close)r1 sockrH methodurlr r r __init__ s zHTTPResponse.__init__c C si t | j j t d d } t | t k r= t d | j d k r_ t d t | | sq t d y | j
d d \ } } } WnO t k
r y" | j
d d \ } } d } Wn t k
r d } Yn XYn X| j d s| j
t | y4 t | } | d
k s.| d k r:t | Wn t k
r[t | Yn X| | | f S) Nr+ z
iso-8859-1z status liner zreply:z-Remote end closed connection without response zHTTP/r i )strrC r< r= r- r rH printreprr split
ValueError
startswith _close_connr int)r1 r3 rL rM rN r r r _read_status s2
zHTTPResponse._read_statusc C s | j d k r d Sx | j \ } } } | t k r8 Pxg | j j t d } t | t k ro t d | j } | s P| j d k r; t
d | q; Wq W| | _ | _ | j | _
| d k r d | _ n' | j d r d | _ n t | t | j | _ | _ | j d k rSx$ | j D] } t
d | d
d q6W| j j d } | r| j d
k rd | _ d | _ n d | _ | j | _ d | _ | j j d } | j j d } | r3| j r3y t | | _ Wn t k
rd | _ Yq<X| j d k r<d | _ n d | _ | t k s| t k sd | k okd k n s| j d k rd | _ | j r| j r| j d k rd | _ d S)Nr+ z header liner zheader:HTTP/1.0HTTP/0.9
zHTTP/1. r$ ztransfer-encodingrO TFzcontent-lengthr HEAD)rb rc ) rD ra ZCONTINUErC r< r= r- r striprH rZ coderM rN rL r^ r rE rJ getr, rO rP _check_closerR rQ r` r] Z
NO_CONTENTZ NOT_MODIFIEDrI )r1 rL rM rN skiphdrZtr_encrQ r r r begin, sf
zHTTPResponse.beginc C s | j j d } | j d k rS | j j d } | rO d | j k rO d Sd S| j j d ri d S| r d | j k r d S| j j d } | r d | j k r d Sd S)N
connectionre closeTFz
keep-alivezproxy-connection)rD rk rL r, )r1 connZpconnr r r rl | s zHTTPResponse._check_closec C s | j } d | _ | j d S)N)rC rq )r1 rC r r r r_ s zHTTPResponse._close_connc
s, z t j Wd | j r' | j Xd S)N)superrq rC r_ )r1 ) __class__r r rq s zHTTPResponse.closec s' t j | j r# | j j d S)N)rs flushrC )r1 )rt r r ru s
zHTTPResponse.flushc C s d S)NTr )r1 r r r readable s zHTTPResponse.readablec C s
| j d k S)N)rC )r1 r r r isclosed s zHTTPResponse.isclosedc C s | j d k r d S| j d k r0 | j d S| d k rq t | } | j | } t | d | j S| j r | j S| j d k r | j j
} nA y | j | j } Wn t k
r | j Yn Xd | _ | j | Sd S)Nr: rh r )
rC rI r_ bytearrayreadinto
memoryviewtobytesrO _readall_chunkedrQ read
_safe_readr
)r1 amtbr2 sr r r r} s*
zHTTPResponse.readc C s | j d k r d S| j d k r0 | j d S| j rF | j | S| j d k r t | | j k r t | d | j } | j j | } | r | r | j n1 | j d k r | j | 8_ | j s | j | S)Nr rh ) rC rI r_ rO _readinto_chunkedrQ r- rz ry )r1 r r2 r r r ry s$
zHTTPResponse.readintoc C s | j j t d } t | t k r4 t d | j d } | d k r_ | d | } y t | d SWn t k
r | j Yn Xd S)Nr+ z
chunk size ;r ) rC r< r= r- r findr` r] r_ )r1 r3 ir r r _read_next_chunk_size s
z"HTTPResponse._read_next_chunk_sizec C sS xL | j j t d } t | t k r7 t d | s> P| d k r Pq Wd S)Nr+ z trailer line
r: )r r r: )rC r< r= r- r )r1 r3 r r r _read_and_discard_trailer
s z&HTTPResponse._read_and_discard_trailerc C s | j } | s | d k r( | j d y | j } Wn t k
rX t d Yn X| d k r | j | j d } | | _ | S)NrW r: r )rP r~ r r] r
r r_ )r1 rP r r r _get_chunk_left s
z HTTPResponse._get_chunk_leftc C s g } yP x< | j } | d k r% P| j | j | d | _ q Wd j | SWn' t k
r t d j | Yn Xd S)Nr r: )r r0 r~ rP r? r
)r1 valuerP r r r r| 3 s
z HTTPResponse._readall_chunkedc C s d } t | } y x | j } | d k r4 | St | | k rj | j | } | | | _ | | S| d | } | j | } | | d } | | 7} d | _ q WWn. t k
r t t | d | Yn Xd S)Nr )rz r r- _safe_readintorP r
bytes)r1 r total_bytesmvbrP r2 temp_mvbr r r r A s$
z HTTPResponse._readinto_chunkedc C s| g } xf | d k rn | j j t | t } | sN t d j | | | j | | t | 8} q Wd j | S)Nr r: )rC r} min MAXAMOUNTr
r? r0 r- )r1 r r chunkr r r r~ Y s
zHTTPResponse._safe_readc C s d } t | } x | t | k r t t | k r^ | d t } | j j | } n | j j | } | s t t | d | t | | | d } | | 7} q W| S)Nr )rz r- r rC ry r
r )r1 r r r r r2 r r r r p s %zHTTPResponse._safe_readintor+ c C s | j d k s | j d k r" d S| j r8 | j | S| j d k rk | d k sb | | j k rk | j } y | j j | } Wn3 t k
r | d k r | j j d } Yn X| r | r | j n$ | j d k r | j t | 8_ | S)Nrh r: r r i i @ ) rC rI rO _read1_chunkedrQ read1r] r_ r- )r1 r2 resultr r r r s"
*
zHTTPResponse.read1c C sH | j d k s | j d k r" d S| j r8 | j | S| j j | S)Nrh r: )rC rI rO
_peek_chunkedpeek)r1 r2 r r r r s
zHTTPResponse.peekc s | j d k s | j d k r" d S| j r; t j | S| j d k rn | d k se | | j k rn | j } | j j | } | r | r | j n$ | j d k r | j t | 8_ | S)Nrh r: r )rC rI rO rs r< rQ r_ r- )r1 limitr )rt r r r< s *
zHTTPResponse.readlinec C s | j } | d k s$ | d k r( d Sd | k o? | k n sJ | } | j j | } | j t | 8_ | s t d | S)Nr r: )r rC r rP r- r
)r1 r2 rP r} r r r r s zHTTPResponse._read1_chunkedc C sS y | j } Wn t k
r( d SYn X| d k r9 d S| j j | d | S)Nr: )r r
rC r )r1 r2 rP r r r r s
zHTTPResponse._peek_chunkedc C s
| j j S)N)rC fileno)r1 r r r r s zHTTPResponse.filenoc C sd | j d k r t | j j | p- | } t | t sO t | d rS | Sd j | Sd S)N__iter__z, )rD r Zget_all
isinstancerY hasattrr? )r1 r& defaultrD r r r getheader s zHTTPResponse.getheaderc C s+ | j d k r t t | j j S)N)rD r listitems)r1 r r r
getheaders s zHTTPResponse.getheadersc C s | S)Nr )r1 r r r r s zHTTPResponse.__iter__c C s | j S)N)rD )r1 r r r info s zHTTPResponse.infoc C s | j S)N)rU )r1 r r r geturl s zHTTPResponse.geturlc C s | j S)N)rM )r1 r r r getcode s zHTTPResponse.getcoder r )!r5 r6 r7 rV ra ro rl r_ rq ru rv rw r} ry r r r r| r r~ r r r r< r r r r r r r r r r r )rt r r s< ! P
c @ s< e Z d Z d Z d Z e Z e Z d Z d Z
d e j d d d Z
d d d d Z d
d Z d d
Z d d Z d d Z d d Z d d Z d d Z d d d Z d d d d Z d d Z d d Z d! d" Z d d# d$ Z d i d% d& Z d' d( Z d) d* Z d+ d, Z d S)-r re zHTTP/1.1r+ r Nc C s | | _ | | _ d | _ g | _ d | _ t | _ d | _ d | _ d | _ i | _
| j | | \ | _ | _
t j | _ d S)N)timeoutsource_addressrS _buffer_HTTPConnection__response_CS_IDLE_HTTPConnection__staterI _tunnel_host _tunnel_port_tunnel_headers
_get_hostporthostportsocketcreate_connection_create_connection)r1 r r r r r r r rV s zHTTPConnection.__init__c C sV | j r t d | j | | \ | _ | _ | rE | | _ n
| j j d S)Nz.Can't set up tunnel for established connection)rS RuntimeErrorr r r r clear)r1 r r rD r r r
set_tunnel
s zHTTPConnection.set_tunnelc C s | d k r | j d } | j d } | | k r y t | | d d } WnV t k
r | | d d d k r | j } n t d | | d d Yn X| d | } n | j } | r | d d k r | d d k r | d d } | | f S)
Nr* ]r+ rX znonnumeric port: '%s'r [r r )rfindr` r] default_portr )r1 r r r jr r r r " s
# &z HTTPConnection._get_hostportc C s
| | _ d S)N)rH )r1 levelr r r set_debuglevel6 s z HTTPConnection.set_debuglevelc C sh d | j | j f } | j d } | j | xI | j j D]8 \ } } d | | f } | j d } | j | qB W| j d | j | j d | j } | j \ } } }
| t
j j k r | j
t d | |
j f xn | j j t d } t | t k r*t d | s1P| d k r>P| j d k r t d
| j q Wd S)NzCONNECT %s:%d HTTP/1.0
asciiz%s: %s
zlatin-1
rT z Tunnel connection failed: %d %sr+ z header line
r: r zheader:)r r r: )r r r sendr r response_classrS rI ra http
HTTPStatusZOKrq OSErrorri rC r< r= r- r rH rZ r@ ) r1 Z connect_strZ
connect_bytesheaderr Z
header_strZ header_bytesresponserL rj messager3 r r r _tunnel9 s2
zHTTPConnection._tunnelc C s] | j | j | j f | j | j | _ | j j t j t j d | j
rY | j d S)Nr+ ) r r r r r rS
setsockoptr IPPROTO_TCP TCP_NODELAYr r )r1 r r r connectX s
$ zHTTPConnection.connectc C sY t | _ z& | j } | r. d | _ | j Wd | j } | rT d | _ | j Xd S)N)r r rS rq r )r1 rS r r r r rq a s zHTTPConnection.closec C s | j d k r. | j r% | j n t | j d k rP t d t | d } t | d r| j d k r~ t d d } y
| j } Wn t k
r Yn, Xd | k r d } | j d k r t d x? | j
| } | s P| r | j d
} | j j | q Wd Sy | j j | Wn^ t
k
rt | t j rqx7 | D] } | j j | qTWn t
d t | Yn Xd S) Nr zsend:i r} zsendIng a read()ableFr Tz encoding file using iso-8859-1z
iso-8859-1z9data should be a bytes-like object or an iterable, got %r)rS auto_openr r rH rZ r[ r modeAttributeErrorr} r sendall TypeErrorr collectionsIterabletype)r1 r blocksizer r Z datablockdr r r r o sF
zHTTPConnection.sendc C s | j j | d S)N)r r0 )r1 r r r r _output s zHTTPConnection._outputc C s\ | j j d d j | j } | j d d =| j | | d k rX | j | d S)Nr: s
)r: r: )r extendr? r )r1 message_bodyrJ r r r _send_output s
zHTTPConnection._send_outputFc
C s | j r! | j j r! d | _ | j t k r< t | _ n t | j | | _ | p] d } | j | d | | | j f } | j | j
| | j d k r | sd } | j d r t
| \ } } } } } | r.y | j d } Wn! t k
r| j d } Yn X| j d | n | j rL| j } | j }
n | j } | j }
y | j d } Wn! t k
r| j d } Yn X| j d d
k rd | d } |
| j k r| j d | n) | j d } | j d d
| |
f | s | j d d n d S)N/z%s %s %sre rX r r ZidnaZHostr* r [ ]z%s:%szAccept-Encodingidentity)r rw r r _CS_REQ_STARTEDr
rI _validate_path
_http_vsn_strr _encode_request _http_vsnr^ r r r putheaderr r r r r r r@ ) r1 rT rU skip_hostskip_accept_encodingrequestZnetlocnilZ
netloc_encr r Zhost_encr r r
putrequest sN
zHTTPConnection.putrequestc C s
| j d S)Nr )r )r1 r r r r r 1 s z HTTPConnection._encode_requestc C sC t j | } | r? d j d | j t } t | d S)NzJURL can't contain control characters. {url!r} (found at least {matched!r})Zmatched)!_contains_disallowed_url_pchar_researchformatgrouplocalsr )r1 rU matchrJ r r r r 5 s
z HTTPConnection._validate_pathc G s | j t k r t t | d r6 | j d } t | sU t d | f t | } x t | D] \ } } t | d r | j d | | <n( t | t
r t | j d | | <t | | rn t d | | f qn Wd j
| } | d | } | j | d S)Nr r zInvalid header name %rzlatin-1zInvalid header value %rs
s : )r r r r r _is_legal_header_namer] r enumerater r` rY _is_illegal_header_valuer? r )r1 r valuesr Z one_valuer r r r r @ s" zHTTPConnection.putheaderc C s5 | j t k r t | _ n t | j | d S)N)r r _CS_REQ_SENTr r )r1 r r r r
endheaders\ s zHTTPConnection.endheadersc C s | j | | | | d S)N)
_send_request)r1 rT rU bodyrD r r r r k s zHTTPConnection.requestc C s d } | j t k } | d k r3 | r3 d } n | d k r y t t | } Wnh t k
r y" t t j | j j } Wn1 t t
f k
r | j d k r t d Yn XYn X| d k r | j
d | d S)N0r z
Cannot stat!!zContent-Length)upper_METHODS_EXPECTING_BODYrY r- r osfstatr st_sizer r rH rZ r )r1 r rT ZthelenZmethod_expects_bodyr r r _set_content_lengtho s
" z"HTTPConnection._set_content_lengthc C s t j d d | D } i } d | k r8 d | d <d | k rN d | d <| j | | | d | k r} | j | | x* | j D] \ } } | j | | q Wt | t r t | d } | j | d S)
Nc S s g | ] } | j q Sr )r, )r kr r r
<listcomp> s z0HTTPConnection._send_request.<locals>.<listcomp>r r+ r zaccept-encodingr zcontent-lengthr )
dictfromkeysr r r r r rY r( r ) r1 rT rU r rD Z header_namesZskipsrn r r r r r s
z HTTPConnection._send_requestc C s | j r! | j j r! d | _ | j t k s9 | j rH t | j | j d k r{ | j | j | j d | j } n | j | j d | j } y` y | j Wn t
k
r | j Yn Xt | _ | j
r | j n | | _ | SWn | j Yn Xd S)Nr rT )r rw r r r rH r rS rI ro ConnectionErrorrq r rR )r1 r r r r getresponse s,
zHTTPConnection.getresponse) r5 r6 r7 r r r r HTTP_PORTr r rH r _GLOBAL_DEFAULT_TIMEOUTrV r r r r r rq r r r r r r r r r r r r r r r r r s6 0 | c sX e Z d Z e Z d d d e j d d d d d f d d Z f d d Z S)HTTPSConnectionNcontextcheck_hostnamec
s t t | j | | | | | | _ | | _ | d k rI t j } | j t j k } | d k rp | j } | r | r t
d | s | r | j | | | | _ | | _
d S)NzMcheck_hostname needs a SSL context with either CERT_OPTIONAL or CERT_REQUIRED)rs r rV key_file cert_filesslZ _create_default_https_contextZ verify_modeZ CERT_NONEr
r] Zload_cert_chain_context_check_hostname)
r1 r r r r r r r r
Z will_verify)rt r r rV s
zHTTPSConnection.__init__c s t j | j r" | j } n | j } | j j | j d | | _ | j j r | j r y t j
| j j | Wn5 t k
r | j j
t j | j j Yn Xd S)Nserver_hostname)rs r r r r Z wrap_socketrS r
r r Zmatch_hostnameZ getpeercert Exceptionshutdownr SHUT_RDWRrq )r1 r )rt r r r s
zHTTPSConnection.connect) r5 r6 r7
HTTPS_PORTr r r
rV r r r )rt r r s r c @ s e Z d Z d S)r N)r5 r6 r7 r r r r r s c @ s e Z d Z d S)r N)r5 r6 r7 r r r r r s c @ s e Z d Z d S)r N)r5 r6 r7 r r r r r s c @ s e Z d Z d d Z d S)r c C s | f | _ | | _ d S)N)argsrL )r1 rL r r r rV s zUnknownProtocol.__init__N)r5 r6 r7 rV r r r r r s c @ s e Z d Z d S)r N)r5 r6 r7 r r r r r " s c @ s e Z d Z d S)r N)r5 r6 r7 r r r r r % s c @ s7 e Z d Z d d d Z d d Z d d Z d S)r
Nc C s" | f | _ | | _ | | _ d S)N)r partialexpected)r1 r r r r r rV ) s zIncompleteRead.__init__c C sE | j d k r d | j } n d } d | j j t | j | f S)Nz, %i more expectedrX z%s(%i bytes read%s))r rt r5 r- r )r1 er r r __repr__- s
zIncompleteRead.__repr__c C s
t | S)N)r[ )r1 r r r __str__4 s zIncompleteRead.__str__)r5 r6 r7 rV r r r r r r r
( s c @ s e Z d Z d S)r N)r5 r6 r7 r r r r r 7 s c @ s e Z d Z d S)r
N)r5 r6 r7 r r r r r
: s c @ s e Z d Z d S)r N)r5 r6 r7 r r r r r = s c @ s e Z d Z d S)r N)r5 r6 r7 r r r r r @ s c @ s e Z d Z d d Z d S)r c C s+ | s t | } | f | _ | | _ d S)N)r[ r r3 )r1 r3 r r r rV D s zBadStatusLine.__init__N)r5 r6 r7 rV r r r r r C s c @ s e Z d Z d d Z d S)r c C s t j | d t | f d S)Nz&got more than %d bytes when reading %s)r rV r= )r1 Z line_typer r r rV K s zLineTooLong.__init__N)r5 r6 r7 rV r r r r r J s c @ s e Z d Z d d Z d S)r c O s' t j | d t j | | | d S)NrX )r rV ConnectionResetError)r1 poskwr r r rV P s zRemoteDisconnected.__init__N)r5 r6 r7 rV r r r r r O s )?Z email.parserrA Z
email.messager ior rer 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 ZMessager) rE BufferedIOBaser r r ImportErrorr r0 r r r r r r r r
r r
r r r r r r r r r r r <module>G sv
0