File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/__pycache__/client_reqrep.cpython-310.pyc
Back
o ;j�� � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m Z m Z m Z d dl mZmZmZ d dlmZmZ d dlmZmZ d dlmZmZmZmZm Z m Z d dl Z d dl m Z m!Z!m"Z"m#Z# d dl$m%Z% d d l&m'Z'm(Z(m)Z)m*Z*m+Z+ d d l,m-Z-m.Z.m/Z/ d d l0m1Z1 d d l2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8 d dl9m:Z:m;Z; d dl<m=Z= d dl(m>Z>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZH d dl)mIZImJZJmKZKmLZLmMZM d dlNmOZO d dlPmQZQmRZRmSZSmTZTmUZUmVZV er�d dlWZWd dlWmXZX nz d dlWZWd dlWmXZX W n eY�y dZWeZZXY nw dZ[e�r'd dl\m]Z] d dl^m_Z_ d dl`maZa e3d�Zbe�cd�Zde�cd�Zee�cd ejf�Zgd ehfd d �Zie jjd d d d!�G d"d#� d#��ZkG d$d%� d%e�ZlG d&d'� d'el�ZmG d(d)� d)�ZneWdu�rxeWjXeoenepd�fZqneoepd�fZqd*e d+eoenf d,eodB d-e d+ d.erdB d e d+eoenf f d/d0�Zsetd1�ZuG d2d3� d3e�Zvd4ehd5ehd eofd6d7�ZwdAd9e+jxd:eyd dfd;d<�ZzG d=d>� d>eA�Z{G d?d@� d@�Z|dS )B� N)�Callable�Iterable�Mapping)�md5�sha1�sha256)�Morsel� SimpleCookie)�MappingProxyType� TracebackType)� TYPE_CHECKING�Any�Literal� NamedTuple�Optional�Union)� CIMultiDict�CIMultiDictProxy� MultiDict�MultiDictProxy)�URL� )�hdrs�helpers�http� multipart�payload)�parse_cookie_header�parse_set_cookie_headers� preserve_morsel_with_coded_value)�AbstractStreamWriter)�ClientConnectionError� ClientOSError�ClientResponseError�ContentTypeError� InvalidURL�ServerFingerprintMismatch)� HAS_BROTLI�HAS_ZSTD)�FormData) � _SENTINEL�BaseTimerContext� BasicAuth� HeadersMixin� TimerNoop�_basic_auth_no_warn�noop�reify�sentinel� set_exception� set_result)�SERVER_SOFTWARE� HttpVersion� HttpVersion10� HttpVersion11� StreamWriter)� StreamReader)�DEFAULT_JSON_DECODER� JSONDecoder� LooseCookies� LooseHeaders�Query� RawHeaders)� SSLContext)� ClientRequest�ClientResponse� RequestInfo� Fingerprint)� ClientSession)� Connection)�Trace�Connection closedz[^-!#$%&'*+.^_`|~0-9a-zA-Z]z!^application/(?:[\w.+-]+?\+)?jsonz\d+�returnc C s. ddg} t r | �d� tr| �d� d�| �S )N�gzip�deflate�brZzstd�, )r' �appendr( �join)� encodings� rR �I/opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/client_reqrep.py� _gen_default_accept_encoding^ s � rT T)Z auto_attribs�frozen�slotsc @ s. e Zd ZU edB ed< ded< edB ed< dS )�ContentDispositionN�typezMappingProxyType[str, str]� parameters�filename)�__name__� __module__� __qualname__�str�__annotations__rR rR rR rS rW j s rW c @ s. e Zd ZU eed< eed< ded< eed< dS )� _RequestInfo�url�method�CIMultiDictProxy[str]�headers�real_urlN)r[ r\ r] r r_ r^ rR rR rR rS r` q s r` c @ s2 e Zd ZefdededddeeB dd f dd�Zd S ) rD ra rb rd rc re rJ c C s$ t �| ||||tu r|f�S |f�S )zuCreate a new RequestInfo instance. For backwards compatibility, the real_url parameter is optional. )�tuple�__new__r2 )�clsra rb rd re rR rR rS rg z s ��zRequestInfo.__new__N)r[ r\ r] r2 r r^ r* rg rR rR rR rS rD x s ������rD c @ sP e Zd Zeeed�Zdeddfdd�Ze defdd��Z d e j ddfd d �Z dS ) rE )� � � � fingerprintrJ Nc C sH t |�}| j�|�}|std��|tu s|tu r td��|| _|| _d S )Nz fingerprint has invalid lengthz8md5 and sha1 are insecure and not supported. Use sha256.)�len�HASHFUNC_BY_DIGESTLEN�get� ValueErrorr r � _hashfunc� _fingerprint)�selfrl Z digestlenZhashfuncrR rR rS �__init__� s zFingerprint.__init__c C � | j S �N)rr �rs rR rR rS rl � � zFingerprint.fingerprint� transportc C s` |� d�sd S |� d�}|jdd�}| �|��� }|| jkr.|� d�^}}}t| j|||��d S )NZ sslcontextZ ssl_objectT)� binary_formZpeername)Zget_extra_info� getpeercertrq �digestrr r& )rs ry �sslobj�certZgot�host�port�_rR rR rS �check� s �zFingerprint.check)r[ r\ r] r r r rn �bytesrt �propertyrl �asyncioZ Transportr� rR rR rR rS rE � s � rE �sslrA � verify_ssl� ssl_contextrl c C s� | d u rd} |d ur |s t jdtdd� | dur td��d} |d ur4t jdtdd� | dur2td��|} |d urLt jdtdd� | durHtd��t|�} t| t�sYtd | �d ���| S ) NTz/verify_ssl is deprecated, use ssl=False instead� �� stacklevelzNverify_ssl, ssl_context, fingerprint and ssl parameters are mutually exclusiveFz2ssl_context is deprecated, use ssl=context insteadzCfingerprint is deprecated, use ssl=Fingerprint(fingerprint) insteadz9ssl should be SSLContext, bool, Fingerprint or None, got z instead.)�warnings�warn�DeprecationWarningrp rE � isinstance�SSL_ALLOWED_TYPES� TypeError)r� r� r� rl rR rR rS �_merge_ssl_params� sT ������ ��r� )�https�wssc @ sn e Zd ZU eed< edB ed< eed< eeB eB ed< e dB ed< e dB ed< edB ed< dZ edB ed < dS ) � ConnectionKeyr Nr� �is_sslr� �proxy� proxy_authZproxy_headers_hash�server_hostname) r[ r\ r] r^ r_ �int�boolrA rE r r, r� rR rR rR rS r� � s r� �response_content_type�expected_content_typec C s |dkr t �| �d uS || v S )N�application/json)�json_re�match)r� r� rR rR rS �_is_expected_content_type� s r� � r r� c C s( | j s| jstjdt|d� dS dS dS )z�Warn if the payload is not closed. Callers must check that the body is a Payload before calling this method. Args: payload: The payload to check stacklevel: Stack level for the warning (default 2 for direct callers) z�The previous request body contains unclosed resources. Use await request.update_body() instead of setting request.body directly to properly close resources and avoid leaks.r� N)Z autoclose�consumedr� r� �ResourceWarning)r r� rR rR rS �_warn_if_unclosed_payload s ��r� c @ s8 e Zd ZU dZedB ed< dZeed< dZe dB ed< dZ e ed< dZ e dB ed< dZee ed< dZed ed < dZeed < dZed ed < dZedB ed< dZee df dB ed< dZed ed< dZej dB ed< dZ ed ed< dZ dZ dZ dd� Z!e"d e ge f ed< dZ#ed ed < dZ$ee% ed < d Z&eed < dZ'ee(j)d ed < d!e d"e*d#d$d%ed d&e+d'e,d(e-d) d*e(j.d+dd,e%d-dfd.d/�Z/d�d0e0d-dfd1d2�Z1e2d-ed fd3d4��Z3e3j4d#ed d-dfd5d4��Z3e2d-efd6d7��Z5e2d�d9d:��Z6e2d-efd;d<��Z7e7j4d=ed-dfd>d<��Z7e8d-e*fd?d@��Z9e8d-e*fdAdB��Z:e8d-e*fdCdD��Z;e8d-e fdEdF��Z<e8d�dHdI��Z=e8d-efdJdK��Z>e8d-e,fdLdM��Z?e8d-e@dB fdNdO��ZAeBfdPeCd-dfdQdR�ZDd-e fdSdT�ZEe2d-ed fdUdV��ZFe8d-ed fdWdX��ZGe8d�dZd[��ZHd�d]d^�ZId�d_d`�ZJe2d-eKfdadb��ZLd�dcdd�ZMd-eCfdedf�ZNe2d-eKfdgdh��ZOd�didj�ZPd�dkdl�ZQd�dmdn�ZRd�dodp�ZSd�dqdr�ZTd�dsdt�ZUd-e fdudv�ZVd-e fdwdx�ZWd�dze dB d{e d-e fd|d}�ZXdeYd~d�dze dB d�eZd�e dB d-eCfd�d��Z[d�d�d��Z\d�e]e^ dB d�e^dB d�e_dB d-dfd�d��Z`dS )�rC N�version�status�reason�content�_body�_headersrR )rC .�_history� _raw_headersrG � _connection�_cookies.�_raw_cookie_headerszasyncio.Future[bool]� _continue�_source_tracebackrF �_sessionTFc G s dS )N�utf-8rR )r� rR rR rS �<lambda>1 s zClientResponse.<lambda>�_resolve_charset�asyncio.Task[None]�_ClientResponse__writer�_stream_writerr � _output_size�_upload_completerb ra �writerzasyncio.Task[None] | None� continue100�timer� request_info�tracesrH �loop�session� stream_writerrJ c C s� t |�tu sJ �|| _|| _|jr|�d �n|| _|d u r"| j| _n| | _ || _ |d ur/|| _ || _ |d ur8|nt � | _i | _|| _|| _| d urP| | _| j| _|�� r_t�t�d��| _d S d S )Nr )rX r rb � _real_url� raw_fragment� with_fragment�_url� output_sizer� r� �_writerr� � _request_infor. �_timer�_cache�_traces�_loopr� r� � get_debug� traceback� extract_stack�sys� _getframer� ) rs rb ra r� r� r� r� r� r� r� r� rR rR rS rt 8 s* �zClientResponse.__init__r� c C sL d | _ | jd ur| jj| _d | _| jd ur"| j�� s$| j�d � d S d S d S rv )r� r� r� r� r� �doner4 �rs r� rR rR rS �__reset_writerc s �z ClientResponse.__reset_writerc C ru )z�The writer task for streaming data. _writer is only provided for backwards compatibility for subclasses that may need to access it. )r� rw rR rR rS r� k s zClientResponse._writerc C sN | j dur | j �| j� || _ |du rdS |�� r | �� dS |�| j� dS )z'Set the writer task for streaming data.N)r� �remove_done_callback� _ClientResponse__reset_writerr� �add_done_callback�rs r� rR rR rS r� t s c C s | j dur | j jS | jS )z&Number of bytes sent for this request.N)r� r� r� rw rR rR rS r� � s zClientResponse.output_size�asyncio.Future[None]c C s2 | j du r| j�� | _ | jdu r| j �d� | j S )z�Future set when the request body has been fully sent. Already done when the request had no body or was written eagerly. N)r� r� � create_futurer� r4 rw rR rR rS �upload_complete� s z ClientResponse.upload_completec C sD | j d u r | jd urt� }|�t| j�� || _ | j S t� | _ | j S rv )r� r� r �updater �rs �cookiesrR rR rS r� � s �zClientResponse.cookiesr� c C s0 || _ |rtdd� |�� D ��| _d S d | _d S )Nc s s � | ]}|� � V qd S rv )Z OutputString)�.0ZmorselrR rR rS � <genexpr>� � � �z)ClientResponse.cookies.<locals>.<genexpr>)r� rf �valuesr� r� rR rR rS r� � s � c C ru rv )r� rw rR rR rS ra � rx zClientResponse.urlc C s t jdtdd� | jS )NzDeprecated, use .url #1654r� r� )r� r� r� r� rw rR rR rS �url_obj� s zClientResponse.url_objc C ru rv )r� rw rR rR rS re � rx zClientResponse.real_urlc C s | j jd usJ �| j jS rv )r� r rw rR rR rS r � s zClientResponse.hostrc c C ru rv )r� rw rR rR rS rd � rx zClientResponse.headersc C ru rv )r� rw rR rR rS � raw_headers� rx zClientResponse.raw_headersc C ru rv )r� rw rR rR rS r� � rx zClientResponse.request_infoc C sF | j �tj�}|d u r d S t�|�\}}t|�}t�|�}t|||�S rv ) r� ro r ZCONTENT_DISPOSITIONr Zparse_content_dispositionr Z content_disposition_filenamerW )rs �rawZdisposition_typeZ params_dct�paramsrZ rR rR rS �content_disposition� s z"ClientResponse.content_disposition� _warningsc C s� | j rd S | jd ur>| j�� | �� | j�� r@d| i}|jd| ��tfi |�� | dd�}| jr6| j|d< | j� |� d S d S d S )N�sourcezUnclosed response zUnclosed response)Zclient_response�messageZsource_traceback) �_closedr� �release�_cleanup_writerr� r� r� r� r� Zcall_exception_handler)rs r� �kwargs�contextrR rR rS �__del__� s �zClientResponse.__del__c C sj t �� }t| j�}| jr| j�dd��d�}nd}td|� d| j� d|� d�|d� t| j |d� |� � S ) N�ascii�backslashreplace�Nonez<ClientResponse(z) [� z]>)�file) �io�StringIOr^ ra r� �encode�decode�printr� rd �getvalue)rs �outZascii_encodable_urlZascii_encodable_reasonrR rR rS �__repr__� s ���zClientResponse.__repr__c C ru rv )r� rw rR rR rS � connection� rx zClientResponse.connectionc C ru )z2A sequence of of responses, if redirects occurred.)r� rw rR rR rS �history� s zClientResponse.history�)MultiDictProxy[MultiDictProxy[str | URL]]c C s� d� | j�dg ��}|stt� �S t� }t�d|�D ][}t�d|�}|d u r'q|�� \}}|�d�dd � }t� }|D ] } t�d| tj �}|d u rJq;|�� \} } } } |� | | � q;|� d|�} |� d | j � t |��� |� t| �t|�� qt|�S ) NrN �linkz ,(?=\s*<)z \s*<(.*)>(.*)�;r z%^\s*(\S*)\s*=\s*(['\"]?)(.*?)(\2)\s*$�relra )rP rd �getallr r �re�splitr� �groups�M�addro ra r r^ ) rs Z links_str�links�valr� ra Z params_strr� r �param�keyr� �valuerR rR rS r � s* zClientResponse.linksr c � s. �d| _ |j| _|| _| j�S z| j}|�� I dH \}}W n tjy: } zt| j | j |j |j |j d�|�d}~ww |j dk sJ|j dksJ|j dkrKn| jdurYt| jd� d| _qW d � n1 sdw Y |�| j� |j| _|j | _|j| _|j | _|j| _|| _| j �tjd� }r�t |�| _ | S ) zStart response processing.FTN�r� r� rd �d �� �e rR ) r� �protocolZ _protocolr� r� �readr ZHttpProcessingErrorr# r� r �coder� rd r� r4 Zon_eof� _response_eofr� r� r� r� r� r� r� r r Z SET_COOKIErf r� )rs r r r� r �excZ cookie_hdrsrR rR rS �start# sN ����� � � zClientResponse.startc C sD | j rd S | jo | jj}|d ur|jrd S d| _ | �� | �� d S �NT)r� r� r �upgradedr� �_release_connection)rs r rR rR rS r T s z ClientResponse._response_eofc C ru rv )r� rw rR rR rS �closeda rx zClientResponse.closedc C sV | j s| �� d| _| jd u s| j�� rd S | �� | jd ur)| j�� d | _d S d S r )� _released�_notify_contentr� r� � is_closedr� r� �closerw rR rR rS r" e s �zClientResponse.closec C s* | j s| �� d| _| �� | �� t� S r )r r r� r� r r0 rw rR rR rS r� r s zClientResponse.releasec C s d| j kS )z�Returns ``True`` if ``status`` is less than ``400``, ``False`` if not. This is **not** a check for ``200 OK`` but a check that the response status is under 400. i� )r� rw rR rR rS �ok| s zClientResponse.okc C sB | j s | jd us J �| js| �� t| j| j| j| j| jd��d S )Nr ) r# r� � _in_contextr� r# r� r r� rd rw rR rR rS �raise_for_status� s ��z ClientResponse.raise_for_statusc sD � j d ur � jd u r� j �� d � _ d S � j�� fdd�� d S d S )Nc s � � � S rv )r )�frw rR rS r� � s z4ClientResponse._release_connection.<locals>.<lambda>)r� r� r� r� rw rR rw rS r � s �z"ClientResponse._release_connectionc � �^ �| j d ur)z| j I d H W n tjy( tjdkr&t�� }r&|�� r&� Y nw | �� d S �N)r� � )r� r� �CancelledErrorr� � version_info� current_task� cancellingr �rs �taskrR rR rS �_wait_released� � � ���� z ClientResponse._wait_releasedc C s8 | j d ur | j �� | jd ur| jj| _d | _d | _d S rv )r� �cancelr� r� r� r� rw rR rR rS r� � s z ClientResponse._cleanup_writerc C s* | j }|r|�� d u rt|t� d| _d S r )r� � exceptionr3 � _CONNECTION_CLOSED_EXCEPTIONr )rs r� rR rR rS r � s z ClientResponse._notify_contentc � r' r( )r� r� r* r� r+ r, r- r� r. rR rR rS �wait_for_close� r1 z ClientResponse.wait_for_closec � s� �| j du r1z | j�� I dH | _ | jD ]}|�| j| j| j �I dH qW n ty0 | �� � w | j r8t d��| j o>| j j }|du sF|j sM| �� I dH | j S )zRead response payload.NrI )r� r� r r� Z send_response_chunk_receivedrb ra � BaseExceptionr" r r! r� r r r0 )rs �tracer rR rR rS r � s& � �� �zClientResponse.readc C s� | j �tjd��� }t�|�}|j�d�}|r3t� t t �� t � |�jW d � S 1 s.w Y |jdkrD|jdksB|jdkrDdS | jd u rMtd��| �| | j�S )N� �charsetZ application�jsonZrdapr� z7Cannot compute fallback encoding of a not yet read body)rd ro r � CONTENT_TYPE�lowerr Zparse_mimetyperY � contextlib�suppress� LookupErrorrp �codecs�lookup�namerX �subtyper� � RuntimeErrorr� )rs �ctypeZmimetype�encodingrR rR rS � get_encoding� s � �zClientResponse.get_encoding�strictrF �errorsc � s: �| j du r | �� I dH |du r| �� }| j j||d�S )z!Read response payload and decode.N)rI )r� r rG r� )rs rF rI rR rR rS �text� s � zClientResponse.textr� )rF �loads� content_typerK rL c � s� �| j du r | �� I dH |r-| j�tjd��� }t||�s-t| j | j | j d| | jd��| j � � }|s6dS |du r>| � � }||�|��S )z Read and decodes JSON response.Nr8 z3Attempt to decode JSON with unexpected mimetype: %sr )r� r rd ro r r; r< r� r$ r� r r� �striprG r� )rs rF rK rL rE �strippedrR rR rS r: � s& � � zClientResponse.jsonc � s �d| _ | S r )r$ rw rR rR rS � __aenter__ s �zClientResponse.__aenter__�exc_type�exc_val�exc_tbc � s" �d| _ | �� | �� I d H d S )NF)r$ r� r5 )rs rP rQ rR rR rR rS � __aexit__! s �zClientResponse.__aexit__rv )rJ r� )rJ rc )rJ r )r rG rJ rC �rJ N)NrH )rJ rC )ar[ r\ r] r� r6 r_ r� r� r� r^ r� r: r� r� r� r r� rf r� r@ r� r r� r r� r� r� r� � StackSummaryr� r� r r$ r� r r� r� r r� r� r� ZFuturer r+ rD �list�AbstractEventLooprt �objectr� r� r� �setterr� r� r� r1 ra r� re r rd r� r� rW r� r� r r� r� r r r r r r� r r" r� r# r% r r0 r� r r5 r rG rJ r; r< r: rO rX r6 r rS rR rR rR rS rC s� ������ � � � � �+ # 1 ���� � ! ����rC c 0 @ s: e Zd ZU ejejejejhZej ej ej hZ e� e �� ejh�Zejdeje� iZdZdejB ed< dZdZdZed ed< e � Z dZ dZ dZ ed ed< dddddde!j"ddd ddddddd ddd dd �d e#d e de$de%dB de&e# dB de'de(dB de)dB de!j*de#e+B dB de+dB de+de,j-dB de.d dB de dB d e)dB d e/dB d ed d e0e+B e1B d!e%dB d"e2d# dB d$e+d%e#dB f.d&d'�Z3dwd(e4d)dfd*d+�Z5d)e6dB fd,d-�Z7e8d)e9d fd.d/��Z:e8d)ed fd0d1��Z;e;j<dxd3d1��Z;d)e+fd4d5�Z=e8d)e>d6e+e1f fd7d8��Z?e8d)e@fd9d:��ZAe8d)e#fd;d<��ZBe8d)e6dB fd=d>��ZCe8d)ejeDd? B fd@dA��ZEeEj<dBe'd)dfdCdA��ZEe8d)eFfdDdE��ZGe8dydFdG��ZHd e d)dfdHdI�ZIde!j*e#B d)dfdJdK�ZJde%dB d)dfdLdM�ZKde&e# dB d)dfdNdO�ZLde(dB d)dfdPdQ�ZMde'd)dfdRdS�ZNdzdTdU�ZOd{de)dB d$e+d)dfdVdW�ZPd|dYe'dZe6d)dfd[d\�ZQdYe'd)dfd]d^�ZRdYe'd)dfd_d`�ZSd{dae+d)dfdbdc�ZTde dB d e)dB d!e%dB d)dfddde�ZU dwd2eVdfdgdhe6dB d)dfdidj�ZWd}dkdl�ZXdzdmdn�ZYdzdodp�ZZd e#d e dqe[d)dfdrds�Z\d e#d e ddtd)dfdudv�Z]dS )~rB z*/*Nr� r� �_ClientRequest__writerZGETzCIMultiDict[None]�_skip_auto_headersFT)r� rd �skip_auto_headers�datar� �authr� �compress�chunked� expect100r� �response_classr� r� r� r� r� � proxy_headersr� � trust_envr� rb ra r� rd r\ r] r� r^ r� r_ r` ra r� rb rC r� r� r� r� rF r� rc r� rH rd r� c C s� | d u rt �� } t�|� }r td|�d|�� �d���t|�tu s&J |��|d ur4t|�tu s4J |��tr<|d us<J �|| _ |rF|� |�}|| _ |j rQ|� d �n|| _|�� | _| | _| | _| | _d | _|d u rlt}n|}|| _|d urw|nt� | _|d ur�|nd| _|| _| �� r�t � t � d��| _ | �!| � | �"|� | �#|� | �$|� | �%|� | �&|� | �'||� | �(|||� | �)|� |d us�| j| j*vr�| �+� | �,| � |d u r�g | _-d S || _-d S )Nz+Method cannot contain non-token characters z (found at least �)Tr ).r� Zget_event_loop�_CONTAINS_CONTROL_CHAR_RE�searchrp �grouprX r r r� Z extend_query� original_urlr� r� ra �upperrb r` r_ r� �lengthrC rb r. r� �_sslr� r� r� r� r� r� r� �update_version� update_host�update_headers�update_auto_headers�update_cookies�update_content_encoding� update_auth� update_proxy�update_body_from_data� GET_METHODS�update_transfer_encoding�update_expect_continuer� )rs rb ra r� rd r\ r] r� r^ r� r_ r` ra r� rb r� r� r� r� r� rc r� rd r� r� Zreal_response_classrR rR rS rt S sZ �� zClientRequest.__init__r� rJ c C s d | _ d S rv �rZ r� rR rR rS r� � s z ClientRequest.__reset_writerc C s< t j| jvrdS | jt j }t�|�std|����t|�S )z�Extract and validate Content-Length header value. Returns parsed Content-Length value or None if not set. Raises ValueError if header exists but cannot be parsed as an integer. Nz Invalid Content-Length header: )r �CONTENT_LENGTHrd � _DIGITS_RE� fullmatchrp r� )rs Zcontent_length_hdrrR rR rS �_get_content_length� s z!ClientRequest._get_content_lengthc C s | j pt� S rv )r[ r rw rR rR rS r\ � s z ClientRequest.skip_auto_headersc C ru rv ry rw rR rR rS r� � rx zClientRequest._writerr� c C s. | j d ur | j �| j� || _ |�| j� d S rv )rZ r� � _ClientRequest__reset_writerr� r� rR rR rS r� � s c C s | j jtv S rv )ra �scheme� _SSL_SCHEMESrw rR rR rS r� � s zClientRequest.is_sslrA c C ru rv )rl rw rR rR rS r� � rx zClientRequest.sslc C sX | j }rtt|�� ��}nd }| j}t�t|jpd|j|j t v | j | j | j || jf�S )Nr8 )rc �hashrf �itemsra rg r� �raw_hostr� r r� rl r� r� r� )rs rc �hra rR rR rS �connection_key� s ��z ClientRequest.connection_keyc C s | j j}|d us J �|S rv )ra r� )rs �retrR rR rS r � s zClientRequest.hostc C s | j jS rv )ra r� rw rR rR rS r� � s zClientRequest.port� c C s | j pdS )z Request body.r� )r� rw rR rR rS �body� s zClientRequest.bodyr c C s0 | j durt| j dd� | j �� | �|� dS )a� Set request body with warning for non-autoclose payloads. WARNING: This setter must be called from within an event loop and is not thread-safe. Setting body outside of an event loop may raise RuntimeError when closing file-based payloads. DEPRECATED: Direct assignment to body is deprecated and will be removed in a future version. Use await update_body() instead for proper resource management. Nr� r� )r� r� Z_close� _update_body)rs r rR rR rS r� � s c C s$ t | j�}t�t| j| j|| jf�S rv )r rd rf rg rD ra rb ri )rs rd rR rR rS r� s �zClientRequest.request_infoc C ru )z�Return the ClientSession instance. This property provides access to the ClientSession that initiated this request, allowing middleware to make additional requests using the same session. )r� rw rR rR rS r� s zClientRequest.sessionc C s: |j st|��|js |jrt|jpd|jpd�| _dS dS )z8Update destination host, port and connection type (ssl).r8 N)r� r% Zraw_userZ raw_passwordr/ �user�passwordr^ )rs ra rR rR rS rn s �zClientRequest.update_hostc C sj t |t�r0dd� |�dd�D �}zt�t|d �t|d ��}W n ty/ td|� ��d�w || _dS )zdConvert request version to two elements tuple. parser HTTP version '1.1' => (1, 1) c S s g | ]}|� � �qS rR )rM )r� �partrR rR rS � <listcomp>+ s z0ClientRequest.update_version.<locals>.<listcomp>�.r r z#Can not parse http version number: N)r� r^ r r r6 r� rp r� )rs r� �vrR rR rS rm % s ��� z ClientRequest.update_versionc C s~ t � | _| jj}|dusJ �|| jtj< |sdS t|ttt f�r$|� � }|D ]\}}|tj v r5|| j|< q&| j� ||� q&dS )zUpdate request headers.N) r rd ra Zhost_port_subcomponentr ZHOSTr� �dictr r r� ZHOST_ALLr )rs rd r r r rR rR rS ro 4 s �z ClientRequest.update_headersc C s� |d ur t dd� t|�D ��| _| j�� }|�| j� n| j}| j�� D ] \}}||vr1|| j|< q$tj |vr?t | jtj < d S d S )Nc s s � | ]}|d fV qd S rv rR )r� �hdrrR rR rS r� O r� z4ClientRequest.update_auto_headers.<locals>.<genexpr>) r �sortedr[ rd �copy�extend�DEFAULT_HEADERSr� r Z USER_AGENTr5 )rs r\ Z used_headersr� r rR rR rS rp M s � � �z!ClientRequest.update_auto_headersc C s� |sdS t � }tj| jv r |�t| j�tjd��� | jtj= t|t�r)|� � }n|}|D ]\}}t|t �r=t |�||< q-|||< q-|j ddd�� � | jtj< dS )z Update request cookies header.Nr8 r )�header�sep)r r ZCOOKIErd r� r ro r� r r� r r �outputrM )rs r� �cZ iter_cookiesrB r rR rR rS rq ` s z ClientRequest.update_cookiesc C sb |sd| _ dS | j�tj�r| j rtd��dS | j r/t| j t�s#d| _ | j | jtj< d| _dS dS )z Set request content encoding.Nz9compress can not be set if Content-Encoding header is setrL T) r_ rd ro r ZCONTENT_ENCODINGrp r� r^ r` )rs r] rR rR rS rr x s �� �z%ClientRequest.update_content_encodingc C s\ | j �tjd��� }d|v r| jrtd��dS | jr,tj| j v r$td��d| j tj< dS dS )z!Analyze transfer-encoding header.r8 r` zDchunked can not be set if "Transfer-Encoding: chunked" header is setz6chunked can not be set if Content-Length header is setN)rd ro r �TRANSFER_ENCODINGr< r` rp rz )rs �terR rR rS rw � s �� ��z&ClientRequest.update_transfer_encodingc C sB |du r| j }|du r dS t|tj�std��|�� | jtj< dS )zSet basic auth.Nz%BasicAuth() tuple is required instead) r^ r� r r, r� r� rd r Z AUTHORIZATION)rs r^ rd rR rR rS rs � s zClientRequest.update_authr� r� � _stacklevelc C s* | j dur t| j |d� |du r*d| _ | j| jvr(| js(tj| jvr(d| jtj< dS t|t �r2|� n|}z t j j |dd�}W n t j yM t |�� }Y nw || _ | jsmtj| jvrm|j }durjt|�| jtj< nd| _|jsrJ �| j}| j}|j�� D ]\}} ||v s�|dur�||v r�q}| ||< q}dS )z Update request body from data.Nr� �0)Z dispositionT)r� r� rb rv r` r rz rd r� r) r ZPAYLOAD_REGISTRYro r? �sizer^ r[ r� ) rs r� r� Z maybe_payloadZ body_payloadr� rd Z skip_headersr r rR rR rS ru � s: � � �z#ClientRequest.update_body_from_datac C sd t j| jv r | jt j= | jrt j| jv r| jt j= | j|dd� |dus*| j| jvr0| �� dS dS )z/Update request body after its already been set.� )r� N) r rz rd r` r� ru rb rv rw �rs r� rR rR rS r� � s �zClientRequest._update_bodyc � s* �| j dur| j �� I dH | �|� dS )ac Update request body and close previous payload if needed. This method safely updates the request body by first closing any existing payload to prevent resource leaks, then setting the new body. IMPORTANT: Always use this method instead of setting request.body directly. Direct assignment to request.body will leak resources if the previous body contains file handles, streams, or other resources that need cleanup. Args: body: The new body content. Can be: - bytes/bytearray: Raw binary data - str: Text data (will be encoded using charset from Content-Type) - FormData: Form data that will be encoded as multipart/form-data - Payload: A pre-configured payload object - AsyncIterable: An async iterable of bytes chunks - File-like object: Will be read and sent as binary data - None: Clears the body Usage: # CORRECT: Use update_body await request.update_body(b"new request data") # WRONG: Don't set body directly # request.body = b"new request data" # This will leak resources! # Update with form data form_data = FormData() form_data.add_field('field', 'value') await request.update_body(form_data) # Clear body await request.update_body(None) Note: This method is async because it may need to close file handles or other resources associated with the previous payload. Always await this method to ensure proper cleanup. Warning: Setting request.body directly is highly discouraged and can lead to: - Resource leaks (unclosed file handles, streams) - Memory leaks (unreleased buffers) - Unexpected behavior with streaming payloads It is not recommended to change the payload type in middleware. If the body was already set (e.g., as bytes), it's best to keep the same type rather than converting it (e.g., to str) as this may result in unexpected behavior. See Also: - update_body_from_data: Synchronous body update without cleanup - body property: Direct body access (STRONGLY DISCOURAGED) N)r� r" r� r� rR rR rS � update_body� s � :zClientRequest.update_body�expectc C sN |r d| j tj< ntj| j v r| j tj �� dkrd}|r%| j�� | _d S d S )Nz 100-continueT)rd r ZEXPECTr< r� r� r� )rs r� rR rR rS rx " s �z$ClientRequest.update_expect_continuec C sd || _ |d u rd | _d | _d S |rt|tj�std��|| _|d ur-t|ttf�s-t |�}|| _d S )Nz,proxy_auth must be None or BasicAuth() tuple) r� r� rc r� r r, rp r r r )rs r� r� rc rR rR rS rt . s � zClientRequest.update_proxy�connrG �content_lengthc � s< �| j dur|�� |�� I dH | j I dH |j}|dus J �z| jdur0| j�||�I dH W n_ tyd } z'|}|jdupFt|t j � }|rSt |jd| j ���}t |||� W Y d}~dS d}~w t jyp |�� � ty� } zt |td|�d|���|� W Y d}~dS d}~ww |�� I dH |�� dS )a: Write the request body to the connection stream. This method handles writing different types of request bodies: 1. Payload objects (using their specialized write_with_length method) 2. Bytes/bytearray objects 3. Iterable body content Args: writer: The stream writer to write the body to conn: The connection being used for this request content_length: Optional maximum number of bytes to write from the body (None means write the entire body) The method properly handles: - Waiting for 100-Continue responses if required - Content length constraints for chunked encoding - Error handling for network issues, cancellation, and other exceptions - Signaling EOF and timeout management Raises: ClientOSError: When there's an OS-level error writing the body ClientConnectionError: When there's a general connection error asyncio.CancelledError: When the operation is cancelled Nz Can not write request body for z4Failed to send bytes into the underlying connection z: )r� Z send_headersZdrainr r� Zwrite_with_length�OSError�errnor� r� � TimeoutErrorr" ra r3 r* r" � Exceptionr! � write_eof� start_timeout)rs r� r� r� r Zunderlying_excZ reraised_excZexc_is_not_timeoutrR rR rS � write_bytesD sT � ! � � �������� zClientRequest.write_bytesc � sJ �| j tjkr| jj}|d usJ �|� d| jj� �}n| jr(| �� s(t| j�}n| jj }|j }|d us5J �t || j | j rFt�| j| j | j�nd | j rTt�| j| j | j�nd d�}| jra|�| j� | jd urj|�� | j | jv r�| jd u s{tj| jvr�tj| jvr�d| jtj< | j}tj| jvr�|j j r�|t kr�d| jtj< n |t kr�d| jtj< | j � d|� d|j � d|j!� �}|�"|| j�I d H | j#s�| j$d us�|j%r�| �&||| �'� �}t(j)d kr�t*j+|| j d d �} n| j �,|�} | �-� r�d } n| | _.n |�/� |�0� d } | j1} | d u�s J �| | j | j2| | j$| j3| j4| j | j | j5|d � | _6| j6S ) N�:)Z on_chunk_sentZon_headers_sentzapplication/octet-streamr" z keep-aliver� z HTTP/r� )r� � T)r� Z eager_start)r� r� r� r� r� r� r� r� )7rb r Z METH_CONNECTra Zhost_subcomponentr� r� r� r^ Z raw_path_qsr r9 r� r� � functools�partial�_on_chunk_request_sent�_on_headers_request_sentr_ Zenable_compressionr` Zenable_chunking� POST_METHODSr[ r; rd r� Z CONNECTIONZ _connectorZ force_closer8 r7 �major�minorZ write_headersr� r� Zwriting_pausedr� r} r� r+ r� ZTaskZ create_taskr� r� r� Zset_eofrb ri r� r� r� �response) rs r� Z connect_host�pathr r� r� Z status_line�coror/ rb rR rR rS �send� s� � ��� � � zClientRequest.sendc � sf �| j d ur1z | j I d H W d S tjy0 tjdkr't�� }r*|�� r-� Y d S Y d S Y d S w d S r( )rZ r� r* r� r+ r, r- r. rR rR rS r" � s � �����zClientRequest.closec C s: | j d ur| j�� s| j �� | j �| j� d | _ d S d S rv )rZ r� r! r2 r� r~ rw rR rR rS � terminate s �zClientRequest.terminate�chunkc � �& �| j D ] }|�|||�I d H qd S rv )r� Zsend_request_chunk_sent)rs rb ra r� r7 rR rR rS r� s � �z$ClientRequest._on_chunk_request_sentzCIMultiDict[str]c � r� rv )r� Zsend_request_headers)rs rb ra rd r7 rR rR rS r� s � �z&ClientRequest._on_headers_request_sentrv )r� r� rJ N)rJ rF rT )F)r� )r� rG rJ rC )^r[ r\ r] r ZMETH_GETZ METH_HEADZ METH_OPTIONSZ METH_TRACErv Z METH_PATCHZ METH_POSTZMETH_PUTr� �unionZ METH_DELETEZ ALL_METHODSZACCEPTZACCEPT_ENCODINGrT r� r� r �Payloadr_ r^ r� rZ r r ra rb r� r[ r r8 r^ r? r> r r r= r, r6 r� r� rW rX r+ rA rE rV rt rX r~ r� r} r� r r\ r� rY r� r r� r� r� r r� r r� rD r� r� rn rm ro rp rq rr rw rs ru r� r� rx rt r r� r� r" r� r� r� r� rR rR rR rS rB / s8 �� ����� �� � � � � ��� ����� �� �� �O )> ��� ����� � R d ����rB )r� )}r� r@ r= r� r� r r� r� r� �collections.abcr r r �hashlibr r r Z http.cookiesr r �typesr r �typingr r r r r r �attrZ multidictr r r r Zyarlr r8 r r r r r Z_cookie_helpersr r r �abcr Zclient_exceptionsr! r" r# r$ r% r& Zcompression_utilsr' r( Zformdatar) r* r+ r, r- r. r/ r0 r1 r2 r3 r4 r5 r6 r7 r8 r9 Zstreamsr: Ztypedefsr; r< r= r> r? r@ r� rA � ImportErrorrX �__all__�clientrF Z connectorrG �tracingrH r4 �compilerf r� �ASCIIr{ r^ rT �srW r` rD rE r� rX r� r� r� � frozensetr� r� r� r� r� r� rC rB rR rR rR rS �<module> s� 4 � ���� �7 �� �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings