File: //usr/local/lib/python3.10/dist-packages/aiohttp/__pycache__/web_response.cpython-310.pyc
o
���gp � @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
m Z d dl m
Z
d dlmZ d dlmZmZmZmZmZmZmZmZ d dlmZmZ ddl m Z m Z dd l m Z dd
l!m"Z" dd l#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z- dd l m.Z.m/Z/m0Z0 dd
l m1Z1 ddl2m3Z3m4Z4 dd� e
D �Z5dZ6dZ7er�ddl8m9Z9 ee:ef Z;nej jZ;G dd� dej<�Z=dd� e=D �Z>G dd� de;e'�Z?G dd� de?�Z@e+fdddddd ejAd �d ed ee: d eeB d!eCd"ee: d#ee4 d$e:d%e3d&e@fd'd(�ZDdS ))� N)�Executor)�
HTTPStatus)� SimpleCookie)�
TYPE_CHECKING�Any�Dict�Iterator�MutableMapping�Optional�Union�cast)� CIMultiDict�istr� )�hdrs�payload)�AbstractStreamWriter)�ZLibCompressor)
�ETAG_ANY�QUOTED_ETAG_RE�ETag� HeadersMixin�must_be_empty_body�parse_http_date�rfc822_formatted_time�sentinel� should_remove_content_length�validate_etag_value)�SERVER_SOFTWARE�
HttpVersion10�
HttpVersion11)�Payload)� JSONEncoder� LooseHeadersc C s i | ]}|j |j�qS � )�value�phrase)�.0� http_statusr$ r$ �?/usr/local/lib/python3.10/dist-packages/aiohttp/web_response.py�
<dictcomp>- s r* i )�
ContentCoding�StreamResponse�Response�
json_response)� BaseRequestc @ s e Zd ZdZdZdZdS )r+ �deflate�gzip�identityN)�__name__�
__module__� __qualname__r0 r1 r2 r$ r$ r$ r) r+ < s r+ c C s i | ]}|j |�qS r$ �r% )r' �codingr$ r$ r) r* F s c s> e Zd ZU edeeef ed< dZdZ dZ
e e ed< dZ
e ed< dZe ed< ejZeed< dZe e ed < dZe d
ed < dZe e ed < dZe ed
< dZe e ed< dZdZe e ed< ddddd�dede e de e de e e ddf
dd�Z e!de fdd��Z"e!d�d d ��Z#e!defd d ��Z$e!de fd!d"��Z%e!de fd#d$��Z&e!de fd%d&��Z' d�dede e ddfd'd(�Z(dede e ddfd)d*�Z)e!de e fd+d,��Z*d�d-d.�Z+e!defd/d0��Z,e!defd1d2��Z-d�d3e e ddfd4d5�Z.dejfd6e ee ef d7eddfd8d9�Z/e!d�d;d<��Z0e!de fd=d>��Z1dddd?ddddd@�dAe dBe dCe e dDe e dEe eee f dFe dGe e dHe e dIe e dJe e ddfdKdL�Z2dd?ddddM�dAe dDe e dFe dGe e dHe e dJe e ddfdNdO�Z3e!de e f� fdPdQ� �Z4e4j5dBe e ddfdRdQ��Z4e!de f� fdSdT� �Z6e6j5dBe ddfdUdT��Z6e!de e f� fdVdW� �Z7e7j5dBe e ddfdXdW��Z7e!de e8j8 fdYdZ��Z9e9j5dBe eee:e8j8e f ddfd[dZ��Z9e!de e; fd\d]��Z<e<j5dBe ee;e f ddfd^d]��Z<e=j>fd_e?ddfd`da�Z@dbeddfdcdd�ZAd�dfdg�ZBded
de e fdhdi�ZCded
defdjdk�ZDd�dldm�ZEd�dndo�ZFdpeeeeGf ddfdqdr�ZHd�dsdt�ZId�dpeddfdvdw�ZJde fdxdy�ZKdze deLfd{d|�ZMdze dBeLddfd}d~�ZNdze ddfdd��ZOdefd�d��ZPdeQe fd�d��ZRdefd�d��ZSd�eTde fd�d��ZU� ZVS )�r, N�_bodyT� _keep_aliveF�_chunked� _compression�_compression_strategy�_compression_forcer/ �_req�_payload_writer� _eof_sent�_must_be_empty_bodyr �_cookies�� )�status�reason�headers�
_real_headersrD rE rF rG �returnc C sB i | _ |dur || _n|durt|�| _nt� | _| �||� dS )a; Initialize a new stream response object.
_real_headers is an internal parameter used to pass a pre-populated
headers object. It is used by the `Response` class to avoid copying
the headers when creating a new response object. It is not intended
to be used by external code.
N)�_state�_headersr
� _set_status)�selfrD rE rF rG r$ r$ r) �__init__^ s zStreamResponse.__init__c C s | j p| jd uS �N)r@ r? �rL r$ r$ r) �preparedx s zStreamResponse.prepared� Optional[asyncio.Task[None]]c C s | j r| j jS d S rN )r> �taskrO r$ r$ r) rR | s zStreamResponse.taskc C � | j S rN )�_statusrO r$ r$ r) rD � � zStreamResponse.statusc C rS rN )r: rO r$ r$ r) �chunked� rU zStreamResponse.chunkedc C rS rN )r; rO r$ r$ r) � compression� rU zStreamResponse.compressionc C rS rN )�_reasonrO r$ r$ r) rE � rU zStreamResponse.reasonc C s | j rJ d��| �||� d S )NzGCannot change the response status code after the headers have been sent)rP rK �rL rD rE r$ r$ r) �
set_status� s
��zStreamResponse.set_statusc C s< t |�| _|d u rt�| jd�}nd|v rtd��|| _d S )N� �
zReason cannot contain \n)�intrT �REASON_PHRASES�get�
ValueErrorrX rY r$ r$ r) rK � s
zStreamResponse._set_statusc C rS rN �r9 rO r$ r$ r) �
keep_alive� rU zStreamResponse.keep_alivec C s
d| _ d S )NFra rO r$ r$ r) � force_close� �
zStreamResponse.force_closec C rS rN )� _body_lengthrO r$ r$ r) � body_length� rU zStreamResponse.body_lengthc C s t �dt� | js J �| jjS )Nzoutput_length is deprecated)�warnings�warn�DeprecationWarningr? � buffer_sizerO r$ r$ r) �
output_length� s
z StreamResponse.output_length�
chunk_sizec C s2 t j| jv r
td��|durt�dt� d| _dS )z,Enables automatic chunked transfer encoding.z>You can't enable chunked encoding when a content length is setNz Chunk size is deprecated #1615T)r �CONTENT_LENGTHrJ � RuntimeErrorrg rh ri r: )rL rl r$ r$ r) �enable_chunked_encoding� s �
z&StreamResponse.enable_chunked_encoding�force�strategyc C sX t |t�r|r
tjntj}t�dt� n
|dur!t |t�s!J d��d| _|| _ || _
dS )z&Enables response compression encoding.z+Using boolean for force is deprecated #3318Nz1force should one of None, bool or ContentEncodingT) �
isinstance�boolr+ r0 r2 rg rh ri r; r= r< )rL rp rq r$ r$ r) �enable_compression� s
���
z!StreamResponse.enable_compression�CIMultiDict[str]c C rS rN )rJ rO r$ r$ r) rF � rU zStreamResponse.headersc C s | j d u r t� | _ | j S rN )rB r rO r$ r$ r) �cookies� s
zStreamResponse.cookies�/)�expires�domain�max_age�path�secure�httponly�version�samesite�namer% rx ry rz r{ r| r} r~ r c C s� | j du r t� | _ || j |< | j | } |dur || d< n
| �d�dkr&| d= |dur.|| d< |dur9t|�| d< nd| v r@| d= || d< |durL|| d< |durT|| d< | dur\| | d < |
durf|
| d
< dS dS ) z�Set or update response cookie.
Sets new cookie or updates existent with new value.
Also updates only those params which are not None.
Nrx � Thu, 01 Jan 1970 00:00:00 GMTry zmax-ager{ r| r} r~ r )rB r r_ �str) rL r� r% rx ry rz r{ r| r} r~ r �cr$ r$ r) �
set_cookie� s0
�zStreamResponse.set_cookie)ry r{ r| r} r c C s8 | j dur | j �|d� | j|ddd|||||d� dS )zBDelete cookie.
Creates new empty expired cookie.
Nr[ r r� )rz rx ry r{ r| r} r )rB �popr� )rL r� ry r{ r| r} r r$ r$ r) �
del_cookie s
�zStreamResponse.del_cookiec � t � jS rN )�super�content_lengthrO �� __class__r$ r) r� - � z StreamResponse.content_lengthc C sF |d urt |�}| jrtd��t|�| jtj< d S | j�tjd � d S )Nz<You can't set content length when chunked encoding is enable)r] r: rn r� rJ r rm r� �rL r% r$ r$ r) r� 2 s �c r� rN )r� � content_typerO r� r$ r) r� > r� zStreamResponse.content_typec C s | j t|�| _| �� d S rN )r� r� �
_content_type� _generate_content_type_headerr� r$ r$ r) r� C s
c r� rN )r� �charsetrO r� r$ r) r� I r� zStreamResponse.charsetc C sZ | j }|dkr td��| jd usJ �|d u r | j�dd � n t|��� | jd< | �� d S )N�application/octet-streamzYSetting charset for application/octet-stream doesn't make sense, setup content_type firstr� )r� rn �
_content_dictr� r� �lowerr� )rL r% �ctyper$ r$ r) r� N s � c C s t | j�tj��S )zuThe value of Last-Modified HTTP header, or None.
This header is represented as a `datetime` object.
)r rJ r_ r �
LAST_MODIFIEDrO r$ r$ r) �
last_modified] s z StreamResponse.last_modifiedc C s� |d u r| j �tjd � d S t|ttf�r't�dt� t
� |���| j tj< d S t|t j �r;t�d|�
� �| j tj< d S t|t�rH|| j tj< d S d S )Nz%a, %d %b %Y %H:%M:%S GMT)rJ r� r r� rr r] �float�time�strftime�gmtime�math�ceil�datetime� utctimetupler� r� r$ r$ r) r� e s � �
�c C sZ | j �tj�}|s d S |tkrttd�S t�|�}|s d S |�dd�\}}tt |�|d�S )Nr6 r � )�is_weakr% )
rJ r_ r �ETAGr r r � fullmatch�grouprs )rL � quoted_value�matchr� r% r$ r$ r) �etagv s
�zStreamResponse.etagc C s� |d u r| j �tjd � d S t|t�r|tks!t|t�r)|jtkr)t| j tj< d S t|t�r>t |� d|� d�| j tj< d S t|t�rgt|jt�rgt |j� |j
rXd|j� d�nd|j� d�}|| j tj< d S t dt |�� d���)N�"zW/"zUnsupported etag type: z . etag must be str, ETag or None)
rJ r� r r� rr r� r r r% r r� r` �type)rL r% � hdr_valuer$ r$ r) r� � s" �
"�� CONTENT_TYPEc C s^ | j d usJ �| jd usJ �d�dd� | j �� D ��}|r%| jd | }n| j}|| j|< d S )Nz; c s s" � | ] \}}|� d |� �V qdS )�=Nr$ )r' �k�vr$ r$ r) � <genexpr>� s � z?StreamResponse._generate_content_type_header.<locals>.<genexpr>)r� r� �join�itemsrJ )rL r� �paramsr� r$ r$ r) r� � s z,StreamResponse._generate_content_type_headerr7 c � sR �|t ju rd S | jd usJ �|j| jtj< | j�|j| j� | j� tj
d � d S rN ) r+ r2 r? r% rJ r �CONTENT_ENCODINGrt r< �popallrm )rL r7 r$ r$ r) �_do_start_compression� s �
�z$StreamResponse._do_start_compression�requestc � sf �| j r| �| j �I d H d S |j�tjd��� }t�� D ]\}}||v r0| �|�I d H d S q d S )Nr[ ) r= r� rF r_ r �ACCEPT_ENCODINGr� �CONTENT_CODINGSr� )rL r� �accept_encodingr% r7 r$ r$ r) �_start_compression� s ���z!StreamResponse._start_compressionc � s< �| j rd S | jd ur| jS t|j| j�| _| �|�I d H S rN )r@ r? r �methodrD rA �_start)rL r� r$ r$ r) �prepare� s �
zStreamResponse.preparec � sD �|| _ |j }| _| �� I d H |�| �I d H | �� I d H |S rN )r> r? �_prepare_headers�
_prepare_hook�_write_headers)rL r� �writerr$ r$ r) r� � s � zStreamResponse._startc � s� �| j }|d us
J �| j}|d usJ �| j}|d u r |j}|| _|j}| j}| jrB| j�� D ]}|jdd�dd � }|� t
j |� q.| j rM| �
|�I d H | jri|tkr\td�|j���| jsh|�� d|t
j< n"| jr�| j|_|jd u r�|tkr�| js�|�� d|t
j< n| js�d}| jr�t
j|v r�t|j| j�r�|t
j= t
j|v r�|t
j= n| jr�|jn| jdkr�|� t
j d� |� t
j t � � |� t
j t!� t
j"|vr�|r�|t#kr�d |t
j"< d S d S |tkr�d
|t
j"< d S d S d S ) Nr[ )�headerr z@Using chunked encoding is forbidden for HTTP/{0.major}.{0.minor}rV Fr r� z
keep-alive�close)$r> r? r9 rb r~ rJ rB �values�output�addr �
SET_COOKIEr; r� r: r rn �formatrA �enable_chunking�TRANSFER_ENCODING�
_length_checkr� �lengthrm r r� rD �
setdefaultr� �DATEr �SERVERr �
CONNECTIONr )rL r� r� rb r~ rF �cookier% r$ r$ r) r� � st � �
�
� �
�
��z StreamResponse._prepare_headersc � sl �| j }|d us
J �| j}|d usJ �|j}d|d � d|d � d| j� d| j� �}|�|| j�I d H d S )NzHTTP/r �.r � )r> r? r~ rT rX �
write_headersrJ )rL r� r� r~ � status_liner$ r$ r) r� s � (z StreamResponse._write_headers�datac � sX �t |tttf�sJ dt|� ��| jrtd��| jd u r!td��| j�|�I d H d S )N�#data argument must be byte-ish (%r)z%Cannot call write() after write_eof()z$Cannot call write() before prepare()) rr �bytes� bytearray�
memoryviewr� r@ rn r? �write�rL r� r$ r$ r) r� s �
�
�
zStreamResponse.writec � sF �| j rJ d��| jd usJ d��tjdtdd� | j�� I d H d S )NzEOF has already been sent� Response has not been startedz2drain method is deprecated, use await resp.write()r� )�
stacklevel)r@ r? rg rh ri �drainrO r$ r$ r) r� ( s ��zStreamResponse.drain� c � sp �t |tttf�sJ dt|� ��| jrd S | jd us J d��| j�|�I d H d| _d | _| jj | _
d | _d S )Nr� r� T) rr r� r� r� r� r@ r? � write_eofr> � output_sizere r� r$ r$ r) r� 2 s �
�
�
zStreamResponse.write_eofc C s\ | j rd}n| jr | jd usJ �| jj� d| jj� d�}nd}d| jj� d| j� d|� d�S )N�eofr� z not prepared�<�>)r@ rP r> r� r{ r� r3 rE )rL �infor$ r$ r) �__repr__B s zStreamResponse.__repr__�keyc C s
| j | S rN �rI �rL r� r$ r$ r) � __getitem__L rd zStreamResponse.__getitem__c C s || j |< d S rN r� )rL r� r% r$ r$ r) � __setitem__O s zStreamResponse.__setitem__c C s | j |= d S rN r� r� r$ r$ r) � __delitem__R � zStreamResponse.__delitem__c C �
t | j�S rN )�lenrI rO r$ r$ r) �__len__U rd zStreamResponse.__len__c C r� rN )�iterrI rO r$ r$ r) �__iter__X rd zStreamResponse.__iter__c C s t t| ��S rN )�hash�idrO r$ r$ r) �__hash__[ r� zStreamResponse.__hash__�otherc C s | |u S rN r$ )rL r� r$ r$ r) �__eq__^ s zStreamResponse.__eq__)rH rQ rN )rH N)rH ru )r� r/ rH N�r� )Wr3 r4 r5 r r� r� r! �__annotations__r� r8 r9 r
rs r: r; �zlib�Z_DEFAULT_STRATEGYr< r] r= r+ r> r? r r@ rA re rB r r� r# r
rM �propertyrP rR rD rV rW rE rZ rK rb rc rf rk ro rt rF rv r� r� r� �setterr� r� r� r� r� r r� r r� r r� r� r� r� r� r� r� r� r� r� r� r� r r� r� r� r� r r� r� �objectr� �
__classcell__r$ r$ r� r) r, M sT
����
�
� ���
�
���
�
������� �
� � �
�5�������
� � � ��
�
A
r, c sd e Zd ZU dZee ed< dddddddddd� dededee dee d ee
d
ee d ee d ee d
ee ddf� fdd�Z e
deeeef fdd��Zejdeddfdd��Ze
dee fdd��Zejde ddfdd��Ze
dee fdd��Zejdee ddfdd��Zd&d eddf� fd d �
Zd d def� fd!d"� Zd#eddf� fd$d%� Z� ZS )'r- N�_compressed_bodyrC ) �bodyrD rE �textrF r� r� �zlib_executor_size�
zlib_executorr rD rE r rF r� r� r r rH c sR |d ur |d ur t d��|d u rt� }
n t|t�s t|�}
n|}
|d ur,d|v r,t d��|d urhtj|
v r>|s9|r=t d��nOt|t�sKtdt|� ��|d u rQd}|d u rWd}|d | |
tj< |�|�}d }n%tj|
v rz|d usu|d uryt d��n|d ur�|d ur�|d| 7 }||
tj< t � j
|||
d � |d ur�|| _ n|| _ || _
| | _d S )
Nz&body and text are not allowed togetherr� z,charset must not be in content_type argumentzPpassing both Content-Type header and content_type or charset params is forbidden� text argument must be str (%r)�
text/plain�utf-8z
; charset=)rD rE rG )r` r
rr r r� r� � TypeErrorr� �encoder� rM r r �_zlib_executor_size�_zlib_executor) rL r rD rE r rF r� r� r r � real_headersr� r$ r) rM f sR
��
��
zResponse.__init__c C rS rN )r8 rO r$ r$ r) r � rU z
Response.bodyc C s� |d u rd | _ nJt|ttf�r|| _ n?z tj�|� | _ }W n tjy. tdt |� ��w | j
}t j |vr=|j
|t j < |jrR|j�� D ] \}}||vrQ|||< qEd | _d S )NzUnsupported body type %r)r8 rr r� r� r �PAYLOAD_REGISTRYr_ � LookupErrorr` r� rJ r r� r� rF r� r )rL r rF r� r% r$ r$ r) r � s$ �
�
c C s | j d u rd S | j �| jpd�S )Nr )r8 �decoder� rO r$ r$ r) r � s
z
Response.textc C sZ |d u st |t�sJ dt|� ��| jdkrd| _| jd u r!d| _|�| j�| _d | _d S )Nr r� r r )rr r� r� r� r� r
r8 r )rL r r$ r$ r) r � s
�
�
c C sb | j rd S tj| jv rt| jtj �S | jd ur t| j�S t| jt �r%d S | jd ur/t| j�S dS )Nr )
r: r rm rJ r] r r� rr r8 r! rO r$ r$ r) r� � s
zResponse.content_lengthr% c C s t d��)Nz#Content length is set automatically)rn r� r$ r$ r) r� � s r� r� c � s� �| j rd S | jd u r| j}n| j}|rJ d|����| jd us"J �| jd us)J �|d u s0| jr:t� �� I d H d S t| jt �rT| j�
| j�I d H t� �� I d H d S t� �t t |��I d H d S )Nz data arg is not supported, got )
r@ r r8 r> r? rA r� r� rr r! r� r r� )rL r� r r� r$ r) r� � s �
zResponse.write_eofr� r/ c � s� �t j| jv rt|j| j�r| jt j= n;| jsOt| jt �r.| jj
d ur-t | jj
�| jt j< n!| jr6t | j�nd}|dksG| jdkrO|jt j
vrOt |�| jt j< t� �|�I d H S )N�0i0 )r rm rJ r r� rD r: rr r8 r! �sizer� r� �
METH_HEAD_ALLr� r� )rL r� �body_lenr� r$ r) r� s �
� �zResponse._startr7 c � s� �| j s
t| jt�rt� �|�I d H S |tju rd S t|j | j
| j d�}| jd us+J �| j
d u rCt | j�t
krCt�dt | j�� d�� |�| j�I d H |�� | _|j | jtj< tt | j��| jtj< d S )N)�encoding�max_sync_chunk_size�executorz2Synchronous compression of large response bodies (z� bytes) might block the async event loop. Consider providing a custom value to zlib_executor_size/zlib_executor response properties or disabling compression on it.)r: rr r8 r! r� r� r+ r2 r r% r r r� �LARGE_BODY_SIZErg rh �compress�flushr rJ r r� r� rm )rL r7 �
compressorr� r$ r) r� s* �
����z Response._do_start_compressionr� )r3 r4 r5 r r
r� r� r r] r� r# r rM r� r r! r r� r r� r� r r� r+ r� r r$ r$ r� r) r- b s^
������� �
� � �C
r- rC zapplication/json)r r rD rE rF r� �dumpsr� r r rD rE rF r� r rH c C s4 | t ur|s|r td��|| �}t||||||d�S )Nz3only one of data, text, or body should be specified)r r rD rE rF r� )r r` r- )r� r r rD rE rF r� r r$ r$ r) r. 1 s �r. )E�asyncio�collections.abc� collectionsr� �enum�jsonr� r� rg r� �concurrent.futuresr �httpr � http.cookiesr �typingr r r r r r
r r � multidictr
r r[ r r �abcr �compression_utilsr �helpersr r r r r r r r r r r r r r! �typedefsr" r# r^ r �__all__� web_requestr/ r� � BaseClass�Enumr+ r� r, r- r r� r] r. r$ r$ r$ r) �<module> s� ( 0
Q��������� �
�