o
0i @ sR d dl Zd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z
d dl m Z g dZ
dZdZdZdZdZd Ze ejj d
d ejj D Zd Zd
ZdZ e dj Z e dj Z!e dZ"e dZ#h dZ$d?ddZ%G dd dej&j'Z(dd Z)e(fdd Z*G d d d ej+Z,G d d d Z-zd dl.Z.W n e/y Y nw G d!d" d"e-Z0e
1d" G d#d$ d$e2Z3G d%d& d&e3Z4G d'd( d(e3Z5G d)d* d*e3Z6G d+d, d,e3Z7G d-d. d.e3Z8G d/d0 d0e3Z9G d1d2 d2e3Z:G d3d4 d4e:Z;G d5d6 d6e:ZG d;d< d d>e@e>ZAe3ZBdS )@ N)urlsplit) HTTPResponseHTTPConnection
HTTPException NotConnectedUnknownProtocolUnknownTransferEncodingUnimplementedFileModeIncompleteRead
InvalidURLImproperConnectionStateCannotSendRequestCannotSendHeaderResponseNotReady
BadStatusLine LineTooLongRemoteDisconnectederror responsesP i ZUNKNOWNZIdlezRequest-startedz Request-sentc C s i | ]}||j qS )phrase).0vr r 2/opt/alt/python310/lib64/python3.10/http/client.py
l s r i d i s [^:\s][^:\r\n]*s \n(?![ \t])|\r(?![ \t\n])z[ - ]z[ - ]> ZPOSTZPUTZPATCHdatac
C s\ z| dW S ty- } zt|j|j|j|jd| | |j|j |f d d }~ww )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 @ e Zd Zdd ZdS ) HTTPMessagec C sl | d }t|}g }d}| D ] }|d | |kr"d}n
|d d s,d}|r3|| q|S )N:r )lowerlenkeysisspaceappend)selfr& nZlstZhitliner r r getallmatchingheaders s
z!HTTPMessage.getallmatchingheadersN)__name__
__module__ __qualname__r5 r r r r r* s r* c C s\ g } | td }t|tkrtd|| t|tkr&tdt |dv r- |S q)NTr, header linezgot more than %d headers
)readline_MAXLINEr. r r1 _MAXHEADERSr )fpheadersr4 r r r
_read_headers s
rC c C s. t | }d|d}tjj|d|S )Nr=
iso-8859-1)_class)rC joindecodeemailparserZParserZparsestr)rA rE rB Zhstringr r r
parse_headers s rJ 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 ZdAd d Zd!d" Zd#d$ Zd%d& ZdBd(d)ZdBd*d+ZdB fd,d- Zd.d/ Zd0d1 Zd2d3 ZdAd4d5Zd6d7 Z d8d9 Z d:d; Z dd? Z Z!S )Cr r Nc C sR | d| _|| _|| _d | _| _t| _t| _t| _ t| _
t| _ t| _ t| _
d S )Nrb)ZmakefilerA
debuglevel_methodrB msg_UNKNOWNversionstatusreasonchunked
chunk_leftlength
will_close)r2 sockrL methodurlr r r __init__ s
zHTTPResponse.__init__c C s t | jtd d}t|tkrtd| jdkr!tdt| |s't dz |
d d\}}}W n! t yS z |
d d\}}d}W n t yP d}Y nw Y nw | d sa|
t|zt|}|d
k sn|d krrt|W n t y~ t|w |||fS ) Nr, rD z status liner zreply:z-Remote end closed connection without response zHTTP/r i )strrA r> r? r. r rL printreprr split
ValueError
startswith _close_connr int)r2 r4 rP rQ rR r r r _read_status s<
zHTTPResponse._read_statusc C s | j d urd S | \}}}|tkrnt| j}| jdkr#td| ~q| | _| _| | _
|dv r8d| _ n
| drAd| _ nt
|t| j | _ | _| jdkre| j D ] \}}td|d | qX| j d
}|rz| d krzd| _d | _nd | _| | _d | _| j d
}|r| jszt|| _W n ty d | _Y n
w | jdk rd | _nd | _|tks|tksd| krdk sn | j dkrd| _| js| js| jd u rd| _d S d S d S d S )NTr zheaders:)zHTTP/1.0zHTTP/0.9
zHTTP/1. header:r+ transfer-encodingrS Fcontent-lengthr HEAD) rB re ZCONTINUErC rA rL r^ coderQ striprR rP rb r rJ rN itemsgetr- rS rT _check_closerV rU rd ra Z
NO_CONTENTZ NOT_MODIFIEDrM ) r2 rP rQ rR Zskipped_headershdrvalZtr_encrU r r r begin< sf
zHTTPResponse.beginc C sv | j d}| jdkr|rd| v rdS dS | j dr dS |r)d| v r)dS | j d}|r9d| v r9dS dS )NZ
connectionrg closeTFz
keep-alivezproxy-connection)rB rp rP r- )r2 ZconnZpconnr r r rq s
zHTTPResponse._check_closec C s | j }d | _ | d S N)rA ru )r2 rA r r r rc s zHTTPResponse._close_connc s6 zt W | jr| d S d S | jr| w w rv )superru rA rc r2 __class__r r ru s
zHTTPResponse.closec s" t | jr| j d S d S rv )rw flushrA rx ry r r r{ s
zHTTPResponse.flushc C s dS )NTr rx r r r readable s zHTTPResponse.readablec C s | j d u S rv )rA rx r r r isclosed s
zHTTPResponse.isclosedc C s | j d u rdS | jdkr| dS | jr| |S |d urS| jd ur,|| jkr,| j}| j |}|s<|r<| |S | jd urQ| jt|8 _| jsQ| |S | jd u r^| j }nz| | j}W n t yr | w d| _| |S )Nr= rl r )
rA rM rc rS
_read_chunkedrU readr.
_safe_readr
)r2 amtsr r r r s>
zHTTPResponse.readc C s | j d u rdS | jdkr| dS | jr| |S | jd ur0t|| jkr0t|d| j }| j |}|s@|r@| |S | jd urS| j|8 _| jsS| |S )Nr rl ) rA rM rc rS _readinto_chunkedrU r.
memoryviewreadinto)r2 br3 r r r r s(
zHTTPResponse.readintoc C sh | j td }t|tkrtd|d}|dkr!|d | }zt|dW S ty3 | w )Nr, z
chunk size ;r ) rA r> r? r. r findrd ra rc )r2 r4 ir r r _read_next_chunk_size s
z"HTTPResponse._read_next_chunk_sizec C s< | j td }t|tkrtd|sd S |dv r d S q)NTr, z trailer liner: )rA r> r? r. r r2 r4 r r r _read_and_discard_trailer! s z&HTTPResponse._read_and_discard_trailerc C sf | j }|s1|d ur| d z| }W n ty tdw |dkr.| | d }|| _ |S )Nr[ r= r )rT r r ra r
r rc )r2 rT r r r _get_chunk_left/ s
z HTTPResponse._get_chunk_leftc C s g }z: | }|d u r
n*|d ur#||kr#|| | || | _n|| | |d ur3||8 }d| _qd|W S tyJ td|w )NTr r= )r r1 r rT rF r
)r2 r valuerT r r r r~ G s&
zHTTPResponse._read_chunkedc C s d}t |}z: | }|d u r|W S t||kr(| |}|| | _|| W S |d | }| |}||d }||7 }d| _q tyQ tt|d| w )Nr )r r r. _safe_readintorT r
bytes)r2 r Z total_bytesZmvbrT r3 Ztemp_mvbr r r r ] s(
z HTTPResponse._readinto_chunkedc C s t |t}| j|}t||kr|S t||k r#t||t| t|}|dd t ||| }| | j| |
|krI| S ||7 }|
|k r^t| ||
q/)Nr r[ ) min_MIN_READ_BUF_SIZErA r r. r
ioBytesIOseekwritetellgetvalue)r2 r Zcursizer Zdeltar r r r u s$
zHTTPResponse._safe_readc C s< t |}| j|}||k r tt|d | || |S rv )r. rA r r
r )r2 r r r3 r r r r s zHTTPResponse._safe_readintoc C s | j d u s | jdkr
dS | jr| |S | jd ur&|dk s#|| jkr&| j}| j |}|s6|r6| |S | jd urD| jt|8 _|S Nrl r= r )rA rM rS _read1_chunkedrU read1rc r. )r2 r3 resultr r r r s
zHTTPResponse.read1c C s4 | j d u s
| jdkr dS | jr| |S | j |S )Nrl r= )rA rM rS
_peek_chunkedpeek)r2 r3 r r r r s
zHTTPResponse.peekc s | j d u s
| jdkr dS | jrt |S | jd ur&|dk s#|| jkr&| j}| j |}|s6|r6| |S | jd urD| jt|8 _|S r )rA rM rS rw r> rU rc r. )r2 limitr ry r r r> s
zHTTPResponse.readlinec C sd | }|d u s |dkrdS d| kr|ksn |}| j|}| jt|8 _|s0td|S )Nr r= )r rA r rT r. r
)r2 r3 rT r r r r r s zHTTPResponse._read1_chunkedc C sB z| }W n
ty Y dS w |d u rdS | j|d | S )Nr= )r r
rA r )r2 r3 rT r r r r s zHTTPResponse._peek_chunkedc C s
| j S rv )rA filenorx r r r r
zHTTPResponse.filenoc C sD | j d u r t | j |p|}t|tst|ds |S d|S )N__iter__z, )rB r Zget_all
isinstancer] hasattrrF )r2 r& defaultrB r r r getheader s
zHTTPResponse.getheaderc C s | j d u r t t| j S rv )rB r listro rx r r r
getheaders s
zHTTPResponse.getheadersc C s | S rv r rx r r r r s zHTTPResponse.__iter__c C | j S rv )rB rx r r r info s zHTTPResponse.infoc C r rv )rY rx r r r geturl s zHTTPResponse.geturlc C r rv )rQ rx r r r getcode# s zHTTPResponse.getcode)r NNrv )r )"r6 r7 r8 rZ re rt rq rc ru r{ 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 ry r r s>
!H
("
r 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!Z d9d"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 rg zHTTP/1.1r, r c C s t | tjS rv )r r
TextIOBase)streamr r r
_is_textIO4 s zHTTPConnection._is_textIOc C sf | d u r| tv r
dS d S t| drd S zt| }|jW S ty' Y nw t| tr1t| S d S )Nr r ) upper_METHODS_EXPECTING_BODYr r nbytes TypeErrorr r] r. )bodyrX 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 rv )timeoutsource_address blocksizerW _buffer_HTTPConnection__response_CS_IDLE_HTTPConnection__staterM _tunnel_host _tunnel_port_tunnel_headers
_get_hostporthostport_validate_hostsocketZcreate_connection_create_connection)r2 r r r r r r r r rZ Z s zHTTPConnection.__init__c C s@ | j rtd| ||\| _| _|r|| _d S | j d S )Nz.Can't set up tunnel for established connection)rW RuntimeErrorr r r r clear)r2 r r rB r r r
set_tunnelp s
zHTTPConnection.set_tunnelc C s |d u r`| d}| d}||krIz t||d d }W n# tyA ||d d dkr3| j}n td||d d Y nw |d | }n| j}|r`|d dkr`|d dkr`|dd }||fS ) Nr+ ]r, r\ znonnumeric port: '%s'r [r )rfindrd ra default_portr )r2 r r r jr r r r s"
z HTTPConnection._get_hostportc C s
|| _ d S rv )rL )r2 levelr r r set_debuglevel r z HTTPConnection.set_debuglevelc
C s d| j d| jf }|g}| j D ]\}}|| d| dd q|d | d| ~| j| j | j
d}| \}}}|t j
jkrZ| td | d
| |jtd } t| tkrmtd
| sqd S | dv rwd S | jdkrtd| q[)Ns CONNECT %s:%d HTTP/1.0
asciiz:
r r; r= rX zTunnel connection failed: Tr, r9 r: r rh )r r r r ro r1 sendrF response_classrW rM re http
HTTPStatusZOKru OSErrorrn rA r> r? r. r rL r^ rG )
r2 connectrB headerr responserP rm messager4 r r r _tunnel s2
zHTTPConnection._tunnelc
C s t d| | j| j | | j| jf| j| j| _z | jt j
t j d W n t y> } z
|j
t
jkr4 W Y d }~nd }~ww | jrH| d S d S )Nzhttp.client.connectr, )sysauditr r r r r rW Z
setsockoptr Z IPPROTO_TCPZ TCP_NODELAYr errnoZ ENOPROTOOPTr r r2 er r r r s zHTTPConnection.connectc C s` t | _z | j}|rd | _| W | j}|r d | _| d S d S | j}|r/d | _| w w rv )r r rW ru r )r2 rW r r r r ru s$
zHTTPConnection.closec C s" | j d u r| jr| nt | jdkr tdt| t|dr\| jdkr+td | |}|r;| jdkr;td | | j
}|sG d S |rN| d}t
d| | | j | q s z/HTTPConnection._send_request..r r, r zaccept-encodingr rj ri Fr z Unable to determine size of %rTzTransfer-EncodingrS zContent-Lengthr r ) frozensetr r rL r^ r r] ro r r( r ) r2 rX rY r rB r Z header_namesZskipsZcontent_lengthrr r r r r r s4
z HTTPConnection._send_requestc C s | j r | j r d | _ | jtks| j rt| j| jdkr*| j| j| j| jd}n | j| j| jd}z&z| W n t
yF | w t | _|j
rT| |W S || _ |W S | )Nr r )r r} r r r rL r rW rM rt ConnectionErrorru r rV )r2 r r r r getresponseG s4
zHTTPConnection.getresponse)NN)NF)FFrv )%r6 r7 r8 r r r r HTTP_PORTr r rL staticmethodr r r _GLOBAL_DEFAULT_TIMEOUTrZ r r r r r ru r r r r r r r r r r r r r r r r r r r * sL
(
6
.r c sF e Zd Z eZdddejdfdddd fdd Z fddZ Z S )HTTPSConnectionNr )contextcheck_hostnamer c s t t| j||||| d |d us|d us|d ur$dd l}
|
dtd || _|| _|d u rEt }| j
dkr=| dg |j d urEd|_ |j
tjk} |d u rR|j}|rZ| sZtd|s^|rl||| |j d urld|_ || _|d ury|| j_d S d S ) N)r r zTkey_file, cert_file and check_hostname are deprecated, use a custom context instead.r[ rg zhttp/1.1TzMcheck_hostname needs a SSL context with either CERT_OPTIONAL or CERT_REQUIRED)rw r" rZ warningswarnDeprecationWarningkey_file cert_filesslZ _create_default_https_contextr Zset_alpn_protocolsZpost_handshake_authZ verify_modeZ CERT_NONEr$ ra Zload_cert_chain_context) r2 r r r( r) r r r# r$ r r% Z will_verifyry r r rZ s>
zHTTPSConnection.__init__c s8 t | jr
| j}n| j}| jj| j|d| _d S )N)server_hostname)rw r r r r+ Z wrap_socketrW )r2 r, ry r r r s
zHTTPSConnection.connect)
r6 r7 r8
HTTPS_PORTr r r! rZ r r r r ry r r" s 'r" c @ e Zd ZdS )r Nr6 r7 r8 r r r r r s r c @ r. )r Nr/ r r r r r r c @ r. )r Nr/ r r r r r r0 r c @ r) )r c C s |f| _ || _d S rv )argsrP )r2 rP r r r rZ s
zUnknownProtocol.__init__Nr6 r7 r8 rZ r r r r r r c @ r. )r Nr/ r r r r r r0 r c @ r. )r Nr/ r r r r r r0 r c @ s$ e Zd ZdddZdd ZejZdS )r
Nc C s |f| _ || _|| _d S rv )r1 partialexpected)r2 r4 r5 r r r rZ s
zIncompleteRead.__init__c C s2 | j d ur d| j }nd}d| jjt| j|f S )Nz, %i more expectedr\ z%s(%i bytes read%s))r5 rz r6 r. r4 r r r r __repr__ s
zIncompleteRead.__repr__rv )r6 r7 r8 rZ r6 r" __str__r r r r r
s
r
c @ r. )r Nr/ r r r r r r0 r c @ r. )r
Nr/ r r r r r
r0 r
c @ r. )r Nr/ r r r r r r0 r c @ r. )r Nr/ r r r r r r0 r c @ r) )r c C s |st |}|f| _|| _d S rv )r_ r1 r4 r r r r rZ s
zBadStatusLine.__init__Nr2 r r r r r r3 r c @ r) )r c C s t | dt|f d S )Nz&got more than %d bytes when reading %s)r rZ r? )r2 Z line_typer r r rZ s
zLineTooLong.__init__Nr2 r r r r r r3 r c @ r) )r c O s( t | d tj| g|R i | d S )Nr\ )r rZ ConnectionResetError)r2 poskwr r r rZ s zRemoteDisconnected.__init__Nr2 r r r r r r3 r )r )CZ email.parserrH Z
email.messager r r rer r Zcollections.abcr Z urllib.parser __all__r r- rO r r r globalsupdater __members__r r r? r@ r compile fullmatchr r r r r
r r( r ZMessager* rC rJ BufferedIOBaser r r* ImportErrorr" r1 Exceptionr r r r r r r
r r
r r r r r8 r r r r r r s F
: `
;