U
|
M ±d¿ ã @ sR U d dl Z d dlmZmZmZmZmZmZmZm Z m
|
Z
|
ddl m Z m Z mZmZ ddlmZmZmZmZmZ ddlmZ ddlmZmZmZm Z m Z m Z m Z m Z ddl!m"Z"m#Z#m$Z$m%Z% d gZ&e 'e (d
|
¡¡Z)e 'd ¡Z*ee+ ee+ d d dZ,ee+ eee+e+f d ddZ-e 'e (d
|
¡¡Z.eee dddZ/e 'e (d
|
¡¡Z0ee
|
eedf dddZ1G dd dZ2e 'e (d
|
¡¡Z3G dd dZ4G dd dZ5eddd d Z6ee
|
e e$ ee e$ e e$ f f e
|
ed ef ee7ed ef f f f Z8ee fe/e e fe1e e fe1eefe6ee fe6eefe6e efe6e e fe6e efe6e e4e2e5d i
|
Z9e8e:d < dS ) é N) ÚAnyÚCallableÚDictÚIterableÚNoReturnÚOptionalÚTupleÚTypeÚUnioné )Ú chunk_headerÚ header_fieldÚ request_lineÚ status_line)ÚDataÚ EndOfMessageÚInformationalResponseÚRequestÚResponse)Ú ReceiveBuffer)ÚCLIENTÚCLOSEDÚDONEÚIDLEÚ
|
MUST_CLOSEÚ SEND_BODYÚ SEND_RESPONSEÚSERVER)ÚLocalProtocolErrorÚRemoteProtocolErrorÚSentinelÚvalidateÚREADERSÚasciis [ \t]+)ÚlinesÚreturnc c s t | }d }|D ]d}t |¡}|rb|d kr2tdt|tsDt|}|d7 }||| ¡ d
7 }q|d k rp|V |}q|d k r|V d S )Nz%continuation line at start of headersó )ÚiterÚ obs_fold_reÚmatchr Ú
|
isinstanceÚ bytearrayÚend)r$ ÚitÚlastÚliner) © r0 úCd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\h11/_readers.pyÚ_obsolete_line_fold+ s
|
|
r2 c c s2 t | D ]$}tt|d|}|d |d fV qd S )Nzillegal header line: {!r}Ú
|
field_nameZ field_value)r2 r! Úheader_field_re)r$ r/ Úmatchesr0 r0 r1 Ú_decode_header_lines@ s r6 ©Úbufr% c C sj | ¡ }|d kr$| ¡ r tdd S |s0tdtt|d d|d }tf tt|dd
dd|S )Núillegal request linezno request line receivedr zillegal request line: {!r}r T)ÚheadersÚ_parsed)Úmaybe_extract_linesÚ+is_next_line_obviously_invalid_request_liner r! Úrequest_line_rer Úlistr6 )r8 r$ r5 r0 r0 r1 Úmaybe_read_from_IDLE_clientK s& ÿ ÿÿr@ c C s´ | ¡ }|d kr$| ¡ r tdd S |s0tdtt|d d|d }|d d krVdn|d }|d d krndn|d }t|d }|d
|
k rtnt}|tt |d d
d |||d S )Nr9 zno response line receivedr zillegal status line: {!r}Ú http_versions 1.1Úreasonó Ú status_codeéÈ r T)r: r; rD rB rA )
|
r< r= r r! Ústatus_line_reÚintr r r? r6 )r8 r$ r5 rA rB rD Úclass_r0 r0 r1 Ú$maybe_read_from_SEND_RESPONSE_server^ s* ÿ ÿûrI c @ sD e Zd ZeddddZeeeedf dddZ e
|
dd d
|
Z dS ) ÚContentLengthReaderN)Úlengthr% c C s || _ || _d S ©N)Ú_lengthÚ
|
_remaining)ÚselfrK r0 r0 r1 Ú__init__{ s z ContentLengthReader.__init__r7 c C sD | j dkrt S | | j ¡}|d kr(d S | j t|8 _ t|dS )Nr ©Údata)rN r Úmaybe_extract_at_mostÚlenr ©rO r8 rR r0 r0 r1 Ú__call__ s
|
z ContentLengthReader.__call__©r% c C s t d | j| j | j¡d S )Nz]peer closed connection without sending complete message body (received {} bytes, expected {}))r ÚformatrM rN ©rO r0 r0 r1 Úread_eof s
|
þÿz ContentLengthReader.read_eof) Ú__name__Ú
|
__module__Ú __qualname__rG rP r r
|
r r rV r rZ r0 r0 r0 r1 rJ z s rJ c @ sB e Zd ZddddZeeeedf dddZe ddd Z
|
dS )
|
Ú ChunkedReaderNrW c C s d| _ d| _d| _d S )Nr F)Ú_bytes_in_chunkÚ_bytes_to_discardÚ_reading_trailerrY r0 r0 r1 rP s zChunkedReader.__init__r7 c C s@ | j r,| ¡ }|d krd S ttt|dS | jdkrn| | j¡}|d krNd S | jt|8 _| jdkrnd S | jdks|t| j dkrØ|
|
¡ }|d krd S t t |d|}t |d dd| _ | j dkrÒd| _ | |S d}nd}| j dksêt| | j ¡}|d krd S | j t|8 _ | j dkr.d | _d}nd}t|||d
|
S ) N)r: r zillegal chunk header: {!r}Ú
|
chunk_sizeé )ÚbaseTFé )rR Ú chunk_startÚ chunk_end)ra r< r r? r6 r` rS rT ÚAssertionErrorr_ Zmaybe_extract_next_liner! Úchunk_header_rerG r )rO r8 r$ rR r r5 rf rg r0 r0 r1 rV sN
|
|
|
ü
|
|
zChunkedReader.__call__c C s t dd S )NzVpeer closed connection without sending complete message body (incomplete chunked read))r rY r0 r0 r1 rZ Ë s ÿzChunkedReader.read_eof) r[ r\ r] rP r r
|
r r rV r rZ r0 r0 r0 r1 r^ s .r^ c @ s. e Zd Zeee dddZedddZdS )Ú Http10Readerr7 c C s | d¡}|d krd S t|dS )NiÿÉ;rQ )rS r rU r0 r0 r1 rV Ó s
|
zHttp10Reader.__call__rW c C s t S rL )r rY r0 r0 r1 rZ Ù s zHttp10Reader.read_eofN) r[ r\ r] r r r rV r rZ r0 r0 r0 r1 rj Ò s rj c C s | r t dd S )NzGot data when expecting EOF)r )r8 r0 r0 r1 Úexpect_nothingÝ s rk .)Úchunkedzcontent-lengthzhttp/1.0);ÚreÚtypingr r r r r r r r r
|
Z_abnfr r r r Z_eventsr r r r r Z_receivebufferr Ú_stater r r r r r r r Z_utilr r r r! Ú__all__ÚcompileÚencoder4 r( Úbytesr2 r6 r> r@ rF rI rJ ri r^ rj rk ÚstrZ ReadersTyper" Ú__annotations__r0 r0 r0 r1 Ú<module> sl , (
|
|
þ þ > "ÿÿ ýö
|
