Format: application/x-python-code
1 o
2
3 7'h�4 � @ s d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZddl m
4 Z
5 ddl m Z m
6 Z
7 mZmZmZ ddlmZmZmZ ddlmZmZ ddlmZ d d
8 lmZ e� d �Z ej ejej ej f Z!G d d
9 � d
10 ej"�Z#G dd� de�Z$G dd� d�Z%G dd� de
11 �Z&dS )� )� annotationsN� )�
12 NetworkStream)�ConnectionNotAvailable�LocalProtocolError�RemoteProtocolError�
13 WriteError�map_exceptions)�Origin�Request�Response)�Lock�ShieldCancellation)�Trace� )�ConnectionInterfacezhttpcore.http11c @ s e Zd ZdZdZdZdZdS )�HTTPConnectionStater r r � N)�__name__�
14 __module__� __qualname__�NEW�ACTIVE�IDLE�CLOSED� r r �KC:\Users\shubh\Videos\agent\nova\Lib\site-packages\httpcore/_sync/http11.pyr $ s
15 r c @ s� e Zd ZdZdZ dCdDd d
16 �ZdEdd�ZdFdd�ZdFdd�ZdCdGdd�Z dHd d �Z
17 dId d!�Z dCdJd#d$�Z dKd%d&�Z
18 dKd'd(�ZdLd*d+�ZdMd,d-�ZdMd.d/�ZdMd0d1�ZdMd2d3�ZdNd5d6�ZdNd7d8�ZdOd9d:�Z dPdQdAdB�ZdS )R�HTTP11Connectioni i � N�originr
19 �streamr �keepalive_expiry� float | None�return�Nonec C sF || _ || _|| _d | _tj| _t� | _d| _ t
20 j t
21 j | j
22 d�| _d S )Nr )Zour_roleZmax_incomplete_event_size)�_origin�_network_stream�_keepalive_expiry�
23 _expire_atr r �_stater
24 � _state_lock�_request_count�h11�
25 ConnectionZCLIENT�MAX_INCOMPLETE_EVENT_SIZE�
26 _h11_state)�selfr r r r r r �__init__/ s �zHTTP11Connection.__init__�requestr r c C s` | � |jj�std|jj� d| j� ���| j�# | jtjtj fv r0| j
27 d7 _
28 tj | _d | _ nt
29 � �W d � n1 s=w Y z�d|i}z@tdt||��}| jdi |�� W d � n1 sbw Y tdt||��}| jdi |�� W d � n1 s�w Y W n ty� Y nw tdt||�� }| jdi |��\}}}}}||||f|_W d � n1 s�w Y | j} |dks�|jd kr�d
30 | kr�d k r�n nt| |�} t||t| |�||| d �d
31 �W S t�y/ }
32 z:t� �, tdt|�� }| � � W d � n1 �s w Y W d � |
33 �W d � |
34 �1 �s$w Y |
35 �d }
36 ~
37 ww )Nz Attempted to send request to z on connection to r r1 Zsend_request_headersZsend_request_bodyZreceive_response_headers�e s CONNECT�� i, )� http_version�
38 reason_phrase�network_stream)�status�headers�content�
39 extensions�response_closedr ) �can_handle_request�urlr � RuntimeErrorr$ r) r( r r r r* r r' r r �logger�_send_request_headers�_send_request_bodyr �_receive_response_headers� return_valuer% �method�HTTP11UpgradeStreamr �HTTP11ConnectionByteStream�
40 BaseExceptionr �_response_closed) r/ r1 �kwargs�tracer4 r7 r5 r8 �
41 trailing_datar6 �excr r r �handle_requestA s� ��� �� � �� ���� �"
42 ��
43
44 �
45 ��
46 ����z HTTP11Connection.handle_requestc C sr |j �di �}|�dd �}ttjti�� tj|j|jj|j d�}W d � n1 s+w Y | j
47 ||d� d S )N�timeout�write)rD �targetr8 �rN ) r: �getr r+ r r rD r= rP r8 � _send_event�r/ r1 �timeoutsrN �eventr r r r@ � s � �z&HTTP11Connection._send_request_headersc C sh |j �di �}|�dd �}t|jtj�sJ �|jD ]}tj|d�}| j||d� q| jt� � |d� d S )NrN rO )�datarQ )
48 r: rR �
49 isinstancer �typing�Iterabler+ �DatarS � EndOfMessage)r/ r1 rU rN �chunkrV r r r rA � s
50 z#HTTP11Connection._send_request_bodyrV � h11.EventrN c C s, | j �|�}|d ur| jj||d� d S d S )NrQ )r. �sendr% rO )r/ rV rN Z
51 bytes_to_sendr r r rS � s �z HTTP11Connection._send_event�:tuple[bytes, int, bytes, list[tuple[bytes, bytes]], bytes]c C s� |j �di �}|�dd �} | j|d�}t|tj�rn
52 t|tj�r'|jdkr'nqd|j }|j �
53 � }| j j \}}||j|j
54 ||fS )NrN �readTrQ r2 s HTTP/)r: rR �_receive_eventrX r+ r ZInformationalResponse� status_coder4 r8 � raw_itemsr. rK �reason) r/ r1 rU rN rV r4 r8 rK �_r r r rB � s
55 �
56 �
57
58
59 z*HTTP11Connection._receive_response_headers�typing.Iterator[bytes]c c s\ � |j �di �}|�dd �} | j|d�}t|tj�r"t|j�V n t|tjtj f�r-d S q)NrN ra TrQ )
60 r: rR rb rX r+ r[ �bytesrW r\ ZPAUSEDrT r r r �_receive_response_body� s � �z'HTTP11Connection._receive_response_body� h11.Event | type[h11.PAUSED]c C s� t tjti��
61 | j�� }W d � n1 sw Y |tju rC| jj| j|d�}|dkr<| jj tj
62 kr<d}t|��| j� |� n|S q)NTrQ � z/Server disconnected without sending a response.) r r+ r r. Z
63 next_eventZ NEED_DATAr% ra �READ_NUM_BYTES� their_stateZ
64 SEND_RESPONSEZ receive_data)r/ rN rV rW �msgr r r rb � s �
65 � �z HTTP11Connection._receive_eventc C s� | j �< | jjtju r+| jjtju r+tj| _| j� � | j
66 d ur*t � � }|| j
67 | _
68 n | �� W d � d S W d � d S 1 sBw Y d S �N)r) r. Z our_stater+ ZDONErm r r r( Zstart_next_cycler& �time� monotonicr' �close)r/ �nowr r r rH � s
69
70 �
71 ��" z!HTTP11Connection._response_closedc C s t j| _| j�� d S ro )r r r( r% rr �r/ r r r rr � s zHTTP11Connection.close�boolc C s
72 || j kS ro )r$ �r/ r r r r r< s
73 z#HTTP11Connection.can_handle_requestc C � | j tjkS ro �r( r r rt r r r � is_available s z HTTP11Connection.is_availablec C s< t �� }| jd uo
74 || jk}| jtjko| j�d�}|p |S )NZ is_readable)rp rq r' r( r r r% �get_extra_info)r/ rs Zkeepalive_expiredZserver_disconnectedr r r � has_expired s
75 �z HTTP11Connection.has_expiredc C rw ro rx rt r r r �is_idle � zHTTP11Connection.is_idlec C rw ro )r( r r rt r r r � is_closed# r} zHTTP11Connection.is_closed�strc C s$ t | j�}|�d| jj� d| j� �S )Nz , HTTP/1.1, �, Request Count: )r r$ r( �namer* rv r r r �info& s
76
77 ��zHTTP11Connection.infoc C s6 | j j}t| j�}d|� d|�d| jj� d| j� d� S )N�<z [z, r� z]>)� __class__r r r$ r( r� r* )r/ �
78 class_namer r r r �__repr__- s
79 ��zHTTP11Connection.__repr__c C s | S ro r rt r r r � __enter__8 s zHTTP11Connection.__enter__�exc_type�type[BaseException] | None� exc_value�BaseException | None� traceback�types.TracebackType | Nonec C s | � � d S ro )rr )r/ r� r� r� r r r �__exit__; s zHTTP11Connection.__exit__ro )r r
80 r r r r! r" r# )r1 r r" r )r1 r r" r# )rV r^ rN r! r" r# )r1 r r" r` )r1 r r" rg )rN r! r" rj �r" r# )r r
81 r" ru )r" ru )r" r )r" r )NNN)r� r� r� r� r� r� r" r# )r r r rl r- r0 rM r@ rA rS rB ri rb rH rr r< ry r{ r| r~ r� r� r� r� r r r r r + s6 �
82
83 K
84
85
86 �
87
88
89
90
91
92
93
94
95
96
97 �r c @ s* e Zd Zddd�Zdd
98 d �Zdd d
99 �ZdS )rF �
100 connectionr r1 r r" r# c C s || _ || _d| _d S )NF)� _connection�_request�_closed)r/ r� r1 r r r r0 E s
101 z#HTTP11ConnectionByteStream.__init__rg c c s� � d| j i}z,tdt| j |�� | jjdi |��D ]}|V qW d � W d S 1 s+w Y W d S tyX } zt� �
102 | �� W d � |�1 sMw Y |�d }~ww )Nr1 Zreceive_response_bodyr )r� r r? r� ri rG r rr )r/ rI r] rL r r r �__iter__J s" �
103 �&�
104
105 ����z#HTTP11ConnectionByteStream.__iter__c C sN | j s%d| _ tdt| j�� | j�� W d � d S 1 s w Y d S d S )NTr; )r� r r? r� r� rH rt r r r rr X s "��z HTTP11ConnectionByteStream.closeN)r� r r1 r r" r# )r" rg r� )r r r r0 r� rr r r r r rF D s
106
107 rF c @ sR e Zd Zd dd�Zd!d"dd�Zd!d#dd�Zd$dd�Z d%d&dd�Zd'd d �Zd S )(rE r r � leading_datarh r" r# c C s || _ || _d S ro )�_stream�
108 _leading_data)r/ r r� r r r r0 ` s
109 z HTTP11UpgradeStream.__init__N� max_bytes�intrN r! c C s6 | j r| j d |� }| j |d � | _ |S | j�||�S ro )r� r� ra )r/ r� rN �bufferr r r ra d s
110 zHTTP11UpgradeStream.readr� c C s | j �||� d S ro )r� rO )r/ r� rN r r r rO l s zHTTP11UpgradeStream.writec C s | j �� d S ro )r� rr rt r r r rr o s zHTTP11UpgradeStream.close� ssl_context�ssl.SSLContext�server_hostname�
111 str | Nonec C s | j �|||�S ro )r� � start_tls)r/ r� r� rN r r r r� r s z HTTP11UpgradeStream.start_tlsr� r �
112 typing.Anyc C s | j �|�S ro )r� rz )r/ r� r r r rz z r} z"HTTP11UpgradeStream.get_extra_info)r r r� rh r" r# ro )r� r� rN r! r" rh )r� rh rN r! r" r# r� )NN)r� r� r� r� rN r! r" r )r� r r" r� ) r r r r0 ra rO rr r� rz r r r r rE _ s
113
114 �rE )'�
115 __future__r �enum�logging�sslrp �typesrY r+ Z_backends.baser � _exceptionsr r r r r Z_modelsr
116 r r Z_synchronizationr
117 r �_tracer Z
118 interfacesr � getLoggerr? �Unionr[ r\ Z H11SendEvent�IntEnumr r rF rE r r r r �<module> s6
119 ��