U
e5d @ sb d dl Zd dlZd dlZd dlZd dlZd dlZd dlZd dl m
Z
ddddddd d
d d d
dddddddgZ dZ dZ
dZdZdZdZe ejj dd ejj D Zd Zd Zed jZ ed j Z ed!Z ed"Z d#d$d%hZ!dAd'd(Z"G d)d* d*ej#j$Z%d+d, Z&e%fd-d.Z'G d/d dej(Z)G d0d dZ*z d dl+Z+W n e,k
r\ Y n X G d1d2 d2e*Z-e .d2 G d3d de/Z0G d4d de0Z1G d5d d e0Z2G d6d de0Z3G d7d de0Z4G d8d d e0Z5G d9d
d
e0Z6G d:d d e0Z7G d;d
d
e7Z8G dd de0Z;G d?d de0Ze0Z?dS )B 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.8/http/client.py
j s r i d s [^:\s][^:\r\n]*s \n(?![ \t])|\r(?![ \t\n])z[ - ]z[ - ]ZPATCHZPOSTZPUTdatac
C sh z | dW S tk
rb } z8t|j|j|j|jd| | |j|j |f d W 5 d }~X Y nX d S )Nlatin-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 sj | d }t|}g }d}| D ]@}|d | |krBd}n|d d sVd}|r$|| q$|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 sX g }| td }t|tkr&td|| t|tkrHtdt |dkrqTq|S )Nr+ header linezgot more than %d headers
)readline_MAXLINEr- r r0 _MAXHEADERSr )fpheadersr3 r r r
_read_headers s
rB c C s, t | }d|d}tjj|d|S )Nr<
iso-8859-1)_class)rB joindecodeemailparserZParserZparsestr)r@ rD rA Zhstringr r r
parse_headers s
rI 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& ZdBd(d)ZdCd*d+ZdD fd,d- Zd.d/ Zd0d1 Zd2d3 ZdEd4d5Zd6d7 Z d8d9 Z d:d; Z dd? Z Z!S )Fr r Nc C sR | d| _|| _|| _d | _| _t| _t| _t| _ t| _
t| _ t| _ t| _
d S )Nrb)Zmakefiler@
debuglevel_methodrA msg_UNKNOWNversionstatusreasonchunked
chunk_leftlength
will_close)r1 sockrK methodurlr r r __init__ s zHTTPResponse.__init__c C s t | jtd d}t|tkr*td| jdkrBtdt| |sNt dz|
d d\}}}W nF t k
r z|
d d\}}d}W n t k
r d}Y nX Y nX | d s|
t|z$t|}|d
k s|d krt|W n t k
r t|Y nX |||fS ) Nr+ rC z status liner zreply:z-Remote end closed connection without response zHTTP/r i )strr@ r= r> r- r rK printreprr split
ValueError
startswith _close_connr int)r1 r3 rO rP rQ r r r _read_status s2
zHTTPResponse._read_statusc C s | j d k rd S | \}}}|tkr&qHt| j}| jdkrDtd| ~q| | _| _| | _
|dkrnd| _ n| drd| _ nt
|t| j | _ | _| jdkr| j D ]\}}td|d | q| j d }|r| d
krd | _d | _nd | _| | _d | _| j d
}|rb| jsbzt|| _W n tk
rL d | _Y nX | jdk rhd | _nd | _|tks|tksd| krdk sn | j dkrd| _| js| js| jd krd | _d S )Nr zheaders:)zHTTP/1.0zHTTP/0.9
zHTTP/1. header:r* transfer-encodingrR TFcontent-lengthr HEAD) rA rd ZCONTINUErB r@ rK r] coderP striprQ rO ra r rI rM itemsgetr, rR rS _check_closerU rT rc r` Z
NO_CONTENTZ NOT_MODIFIEDrL ) r1 rO rP rQ Zskipped_headershdrvalZtr_encrT r r r begin5 sf
zHTTPResponse.beginc C sv | j d}| jdkr.|r*d| kr*dS dS | j dr>dS |rRd| krRdS | j d}|rrd| krrdS dS )NZ
connectionrf closeTFz
keep-alivezproxy-connection)rA ro rO r, )r1 ZconnZpconnr r r rp } s
zHTTPResponse._check_closec C s | j }d | _ | d S N)r@ rt )r1 r@ r r r rb s zHTTPResponse._close_connc s$ zt W 5 | j r | X d S ru )r@ rb superrt r1 __class__r r rt s zHTTPResponse.closec s t | jr| j d S ru )rv flushr@ rw rx r r rz s
zHTTPResponse.flushc C s dS )NTr rw r r r readable s zHTTPResponse.readablec C s
| j d kS ru )r@ rw r r r isclosed s zHTTPResponse.isclosedc C s | j d krdS | jdkr$| dS |d k rRt|}| |}t|d | S | jr`| S | j d krv| j
}n6z| | j }W n t k
r | Y nX d| _ | |S d S )Nr< rk r )
r@ rL rb bytearrayreadinto
memoryviewtobytesrR _readall_chunkedrT read
_safe_readr
)r1 amtbr2 sr r r r s*
zHTTPResponse.readc C s | j d krdS | jdkr$| dS | jr4| |S | jd k r^t|| jkr^t|d| j }| j |}|s||r|| n&| jd k r| j|8 _| js| |S )Nr rk ) r@ rL rb rR _readinto_chunkedrT r- r r~ )r1 r r2 r r r r~ s$
zHTTPResponse.readintoc C sr | j td }t|tkr$td|d}|dkrB|d | }z t|dW S tk
rl | Y nX d S )Nr+ z
chunk size ;r ) r@ r= r> r- r findrc r` rb )r1 r3 ir r r _read_next_chunk_size s
z"HTTPResponse._read_next_chunk_sizec C s: | j td }t|tkr$td|s*q6|dkr q6q d S )Nr+ z trailer liner9 )r@ r= r> r- r r1 r3 r r r _read_and_discard_trailer s z&HTTPResponse._read_and_discard_trailerc C sl | j }|sh|d k r | d z | }W n tk
rD tdY nX |dkrb| | d }|| _ |S )NrZ r< r )rS r r r` r
r rb )r1 rS r r r _get_chunk_left s
z HTTPResponse._get_chunk_leftc C sb g }z6| }|d krq0|| | d| _qd|W S tk
r\ td|Y nX d S Nr r< )r r0 r rS rE r
)r1 valuerS r r r r 8 s z HTTPResponse._readall_chunkedc C s d}t |}zv| }|d kr$|W S t||krN| |}|| | _|| W S |d | }| |}||d }||7 }d| _qW n( tk
r tt|d| Y nX d S )Nr )r r r- _safe_readintorS r
bytes)r1 r Z total_bytesZmvbrS r2 Ztemp_mvbr r r r F s"
z HTTPResponse._readinto_chunkedc C s. | j |}t||k r*t||t| |S ru )r@ r r- r
)r1 r r r r r r ^ s zHTTPResponse._safe_readc C s: t |}| j|}||k r6tt|d | || |S ru )r- r@ r~ r
r )r1 r r r2 r r r r j s
zHTTPResponse._safe_readintoc C s | j d ks| jdkrdS | jr(| |S | jd k rJ|dk sD|| jkrJ| j}| j |}|sh|rh| n | jd k r| jt|8 _|S Nrk r< r )r@ rL rR _read1_chunkedrT read1rb r- )r1 r2 resultr r r r r s
zHTTPResponse.read1c C s4 | j d ks| jdkrdS | jr(| |S | j |S )Nrk r< )r@ rL rR
_peek_chunkedpeek)r1 r2 r r r r s
zHTTPResponse.peekc s | j d ks| jdkrdS | jr*t |S | jd k rL|dk sF|| jkrL| j}| j |}|sj|rj| n | jd k r| jt|8 _|S r )r@ rL rR rv r= rT rb r- )r1 limitr rx r r r= s
zHTTPResponse.readlinec C sd | }|d ks|dkr dS d| kr0|ks6n |}| j|}| jt|8 _|s`td|S r )r r@ r rS r- r
)r1 r2 rS r r r r r s zHTTPResponse._read1_chunkedc C sD z | }W n tk
r" Y dS X |d kr0dS | j|d | S )Nr< )r r
r@ r )r1 r2 rS r r r r s zHTTPResponse._peek_chunkedc C s
| j S ru )r@ filenorw r r r r s zHTTPResponse.filenoc C sF | j d krt | j |p |}t|ts4t|ds8|S d|S d S )N__iter__z, )rA r Zget_all
isinstancer\ hasattrrE )r1 r& defaultrA r r r getheader s
zHTTPResponse.getheaderc C s | j d krt t| j S ru )rA r listrn rw r r r
getheaders s
zHTTPResponse.getheadersc C s | S ru r rw r r r r s zHTTPResponse.__iter__c C s | j S ru )rA rw r r r info s zHTTPResponse.infoc C s | j S ru )rX rw r r r geturl s
zHTTPResponse.geturlc C s | j S ru )rP rw r r r getcode s zHTTPResponse.getcode)r NN)N)r )r )r )N)"r5 r6 r7 rY rd rs rp rb rt rz r{ r| r r~ r r r r r r r r r r= r r r r r r r r r
__classcell__r r rx r r s<
!H
"
c @ s
e Zd ZdZdZeZeZdZ dZ
e dd Z e dd Z
d ejd d
fd d Zd7d
dZdd Zdd Zdd Zdd Zdd Zdd Zdd Zd d Zd8d d!Zd9d"d#Zd$d% Z d&d' Z d(d) Z d*d+ Z d,d- Z d:d d.d/d0Z!d i fd d.d1d2Z"d3d4 Z#d5d6 Z$d S );r rf zHTTP/1.1r+ r c C s t | tjS ru )r io
TextIOBase)streamr r r
_is_textIO s zHTTPConnection._is_textIOc C sf | d kr | tkrdS d S t| dr*d S zt| }|jW S tk
rN Y nX t| trbt| S d S )Nr r ) upper_METHODS_EXPECTING_BODYr r nbytes TypeErrorr r\ r- )bodyrW Zmvr r r _get_content_length s
z"HTTPConnection._get_content_lengthN c C sn || _ || _|| _d | _g | _d | _t| _d | _d | _ d | _
i | _ | ||\| _
| _| | j
tj| _d S ru )timeoutsource_address blocksizerV _buffer_HTTPConnection__response_CS_IDLE_HTTPConnection__staterL _tunnel_host _tunnel_port_tunnel_headers
_get_hostporthostport_validate_hostsocketZcreate_connection_create_connection)r1 r r r r r r r r rY 4 s zHTTPConnection.__init__c C s< | j rtd| ||\| _| _|r.|| _n
| j d S )Nz.Can't set up tunnel for established connection)rV RuntimeErrorr r r r clear)r1 r r rA r r r
set_tunnelJ s zHTTPConnection.set_tunnelc C s |d kr| d}| d}||krzt||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+ r[ znonnumeric port: '%s'r [r )rfindrc r` default_portr )r1 r r r jr r r r b s
z HTTPConnection._get_hostportc C s
|| _ d S ru )rK )r1 levelr r r set_debuglevelv s z HTTPConnection.set_debuglevelc C s d| j | jf }|d}| | | j D ](\}}d||f }|d}| | q.| d | j| j| jd}| \}} }
| t
j j kr|
td| |
f |jtd } t| tkrtd | sq| d
krq| jd krtd | qd S )
NzCONNECT %s:%d HTTP/1.0
asciiz%s: %s
r r: rW z Tunnel connection failed: %d %sr+ r8 r9 r rg )r r r sendr rn response_classrV rL rd http
HTTPStatusZOKrt OSErrorrm r@ r= r> r- r rK r] rF ) r1 Z connect_strZ
connect_bytesheaderr Z
header_strZ header_bytesresponserO rl messager3 r r r _tunnely s4
zHTTPConnection._tunnelc C sB | | j| jf| j| j| _| jtjtj d | j
r>| d S )Nr+ ) r r r r r rV Z
setsockoptr Z IPPROTO_TCPZ TCP_NODELAYr r rw r r r connect s
zHTTPConnection.connectc C sB t | _z | j}|r d | _| W 5 | j}|r s z/HTTPConnection._send_request..r r+ r zaccept-encodingr ri rh Fr z Unable to determine size of %rTzTransfer-EncodingrR zContent-Lengthr r ) frozensetr r rK r] r r\ rn r r( r ) r1 rW rX r rA r Z header_namesZskipsZcontent_lengthrq r r r r r s0
z HTTPConnection._send_requestc C s | j r| j rd | _ | jtks&| j r0t| j| jdkrR| j| j| j| jd}n| j| j| jd}zNz | W n t
k
r | Y nX t | _|j
r| n|| _ |W S | Y nX d S )Nr r )r r| r r r rK r rV rL rs ConnectionErrorrt r rU )r1 r r r r getresponse s.
zHTTPConnection.getresponse)NN)NF)FF)N)%r5 r6 r7 r r r r HTTP_PORTr r rK staticmethodr r r _GLOBAL_DEFAULT_TIMEOUTrY r r r r r rt r r r r r r r r r r r r r r r r r r r sL
&
6
.c sD e Zd ZeZdddejdfdddd fdd Z fddZ Z S )HTTPSConnectionNr )contextcheck_hostnamer c s t t| j||||| d |d k s2|d k s2|d k rHdd l}
|
dtd || _|| _|d krtt }|j
d k rtd|_
|j tj k} |d kr|j
}|r| std|s|r||| |j
d k rd|_
|| _|d k r|| j_
d S )N)r r zTkey_file, cert_file and check_hostname are deprecated, use a custom context instead.rZ TzMcheck_hostname needs a SSL context with either CERT_OPTIONAL or CERT_REQUIRED)rv r rY warningswarnDeprecationWarningkey_file cert_filesslZ _create_default_https_contextZpost_handshake_authZ verify_modeZ CERT_NONEr r` Zload_cert_chain_context) r1 r r r r r r r r r r Z will_verifyrx r r rY c s<
zHTTPSConnection.__init__c s6 t | jr| j}n| j}| jj| j|d| _d S )N)server_hostname)rv r r r r Z wrap_socketrV )r1 r rx r r r s
zHTTPSConnection.connect)
r5 r6 r7
HTTPS_PORTr r r rY r r r r rx r r \ s $r c @ s e Zd ZdS )r Nr5 r6 r7 r r r r r s c @ s e Zd ZdS )r Nr r r r r r s c @ s e Zd ZdS )r Nr r r r r r s c @ s e Zd Zdd ZdS )r c C s |f| _ || _d S ru )argsrO )r1 rO r r r rY s zUnknownProtocol.__init__Nr5 r6 r7 rY r r r r r s c @ s e Zd ZdS )r Nr r r r r r s c @ s e Zd ZdS )r Nr r r r r r s c @ s$ e Zd ZdddZdd ZejZdS )r
Nc C s |f| _ || _|| _d S ru )r partialexpected)r1 r! r" r r r rY s zIncompleteRead.__init__c C s2 | j d k rd| j }nd}d| jjt| j|f S )Nz, %i more expectedr[ z%s(%i bytes read%s))r" ry r5 r- r! )r1 er r r __repr__ s
zIncompleteRead.__repr__)N)r5 r6 r7 rY r$ r" __str__r r r r r
s
c @ s e Zd ZdS )r Nr r r r r r s c @ s e Zd ZdS )r
Nr r r r r r
s c @ s e Zd ZdS )r Nr r r r r r s c @ s e Zd ZdS )r Nr r r r r r s c @ s e Zd Zdd ZdS )r c C s |s t |}|f| _|| _d S ru )r^ r r3 r r r r rY s zBadStatusLine.__init__Nr r r r r r s c @ s e Zd Zdd ZdS )r c C s t | dt|f d S )Nz&got more than %d bytes when reading %s)r rY r> )r1 Z line_typer r r rY s zLineTooLong.__init__Nr r r r r r s c @ s e Zd Zdd ZdS )r c O s" t | d tj| f|| d S )Nr[ )r rY ConnectionResetError)r1 poskwr r r rY s zRemoteDisconnected.__init__Nr r r r r r s )r )@Z email.parserrG Z
email.messager r rer Zcollections.abcr Z urllib.parser __all__r r rN r r r globalsupdater __members__r r r> r? compile fullmatchr r r r r r r( r ZMessager) rB rI BufferedIOBaser r r ImportErrorr r0 Exceptionr r r r r r r
r r
r r r r r& r r r r r r G s
W 8