Format: application/x-python-code
1 o
2
3 .'h� � @ s\ U d dl Z d dlmZmZmZmZmZmZmZm Z m
4 Z
5 ddl m Z m
6 Z
7 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
8 �(d
9 ��Z)e �'d �Z*d ee+ d
10 ee+ fdd�Z,d ee+ d
11 eee+e+f fdd�Z-e �'e�(d
12 ��Z.ded
13 ee fdd�Z/e �'e�(d
14 ��Z0ded
15 e
16 eedf fdd�Z1G dd� d�Z2e �'e �(d
17 ��Z3G dd� d�Z4G dd � d �Z5ded
18 dfd d �Z6ee
19 e e$ ee e$ e e$ f f e
20 ed ef ee7ed ef f f f Z8ee fe/e e fe1e e fe1eefe6ee fe6eefe6e efe6e e fe6e efe6e e4e2e5d �i
21 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)�
22 ReceiveBuffer)�CLIENT�CLOSED�DONE�IDLE�
23 MUST_CLOSE� SEND_BODY�
24 SEND_RESPONSE�SERVER)�LocalProtocolError�RemoteProtocolError�Sentinel�validate�READERS�asciis [ \t]+�lines�returnc c s� � t | �}d }|D ]2}t�|�}|r2|d u rtd��t|t�s#t|�}|d7 }|||�� d � 7 }q |d ur9|V |}q |d urE|V d S d S )Nz%continuation line at start of headers� )�iter� obs_fold_re�matchr �
25 isinstance� bytearray�end)r$ �it�last�liner) � r0 �BC:\Users\shubh\Videos\agent\nova\Lib\site-packages\h11/_readers.py�_obsolete_line_fold+ s$ �
26
27
28 �r2 c c s4 � t | �D ]}tt|d|�}|d |d fV qd S )Nzillegal header line: {!r}�
29 field_nameZ field_value)r2 r! �header_field_re)r$ r/ �matchesr0 r0 r1 �_decode_header_lines@ s
30 � �r6 �bufc C sj | � � }|d u r| �� rtd��d S |std��tt|d d|d �}tdtt|dd � ��dd�|��S ) N�illegal request linezno request line receivedr zillegal request line: {!r}r T)�headers�_parsedr0 )�maybe_extract_lines�+is_next_line_obviously_invalid_request_liner r! �request_line_rer �listr6 )r7 r$ r5 r0 r0 r1 �maybe_read_from_IDLE_clientK s ���r? c C s� | � � }|d u r| �� rtd��d S |std��tt|d d|d �}|d d u r+dn|d }|d d u r7dn|d }t|d �}|d
31 k rGtnt}|tt |d d � ��d |||d
32 �S )Nr8 zno response line receivedr zillegal status line: {!r}� http_versions 1.1�reason� � status_code�� r T)r9 r: rC rA r@ )
33 r; r< r r! �status_line_re�intr r r> r6 )r7 r$ r5 r@ rA rC �class_r0 r0 r1 �$maybe_read_from_SEND_RESPONSE_server^ s* � ��rH c @ sH e Zd Zdeddfdd�Zdedeeedf fdd�Z de
34 fd d
35 �Z dS ) �ContentLengthReader�lengthr% Nc C s || _ || _d S �N)�_length�
36 _remaining)�selfrJ r0 r0 r1 �__init__{ s
37 z ContentLengthReader.__init__r7 c C sD | j dkrt� S |�| j �}|d u rd S | j t|�8 _ t|d�S )Nr ��data)rM r �maybe_extract_at_most�lenr �rN r7 rQ r0 r0 r1 �__call__ s
38
39 z ContentLengthReader.__call__c C s t d�| j| j | j���)Nz]peer closed connection without sending complete message body (received {} bytes, expected {}))r �formatrL rM �rN r0 r0 r1 �read_eof� s ��z ContentLengthReader.read_eof) �__name__�
40 __module__� __qualname__rF rO r r
41 r r rU r rX r0 r0 r0 r1 rI z s rI c @ s@ e Zd Zd
42 dd�Zdedeeedf fdd�Zde fdd �Z
43 dS ) �
44 ChunkedReaderr% Nc C s d| _ d| _d| _d S )Nr F)�_bytes_in_chunk�_bytes_to_discard�_reading_trailerrW r0 r0 r1 rO � s
45 zChunkedReader.__init__r7 c C s< | j r|�� }|d u r
46 d S ttt|��d�S | jdkr7|�| j�}|d u r'd S | jt|�8 _| jdkr7d S | jdks>J �| jdkrl|� � }|d u rMd S t
47 t |d|�}t |d dd�| _| jdkrid| _ | |�S d}nd}| jdksuJ �|�| j�}|d u r�d S | jt|�8 _| jdkr�d | _d}nd}t
48 |||d
49 �S ) N)r9 r zillegal chunk header: {!r}�
50 chunk_size� )�baseTF� )rQ � chunk_start� chunk_end)r_ r; r r> r6 r^ rR rS r] Zmaybe_extract_next_liner! �chunk_header_rerF r )rN r7 r$ rQ r r5 rd re r0 r0 r1 rU � sN
51
52
53 �
54
55 zChunkedReader.__call__c C s t d��)NzVpeer closed connection without sending complete message body (incomplete chunked read))r rW r0 r0 r1 rX � s �zChunkedReader.read_eof)r% N) rY rZ r[ rO r r
56 r r rU r rX r0 r0 r0 r1 r\ � s
57 .r\ c @ s0 e Zd Zdedee fdd�Zdefdd�ZdS )� Http10Readerr7 r% c C s |� d�}|d u r d S t|d�S )Ni�ɚ;rP )rR r rT r0 r0 r1 rU � s
58
59 zHttp10Reader.__call__c C s t � S rK )r rW r0 r0 r1 rX � s zHttp10Reader.read_eofN) rY rZ r[ r r r rU r rX r0 r0 r0 r1 rg � s rg c C s | rt d��d S )NzGot data when expecting EOF)r )r7 r0 r0 r1 �expect_nothing� s rh .)�chunkedzcontent-lengthzhttp/1.0);�re�typingr r r r r r r r r
60 Z_abnfr r
61 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? rE rH rI rf r\ rg rh �strZ ReadersTyper" �__annotations__r0 r0 r0 r1 �<module> sb
62 , (
63
64 �
65 ��
66 � > "����