| Server IP : 118.27.122.248 / Your IP : 216.73.216.63 Web Server : Apache System : Linux web0264.sh.tyo1 4.18.0-553.79.1.lve.el7h.x86_64 #1 SMP Wed Oct 15 16:34:46 UTC 2025 x86_64 User : c9415830 ( 11735) PHP Version : 8.4.17 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/alt/python37/lib64/python3.7/site-packages/aiohttp/__pycache__/ |
Upload File : |
B
�Z�_Zf � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
m Z d dl m
Z
d dlmZmZ d dlmZmZmZmZmZmZmZmZmZmZ d dl m Z m Z ddl m Z m!Z! dd l"m#Z# dd
l$m%Z%m&Z&m'Z'm(Z( dd l)m*Z*m+Z+m,Z,m-Z- dd l!m.Z. dd
l/m0Z0m1Z1 dZ2e�r<ddl3m4Z4 ee5ef Z6nej"jZ6e%�sTdej7d< G dd� dej8�Z9G dd� de6e&�Z:G dd� de:�Z;e(fddddddej<d�eee5 ee= e>ee5 ee1 e5e0e;d� d d �Z?dS ) � N)�Executor)� parsedate)�Morsel� SimpleCookie)
�
TYPE_CHECKING�Any�Dict�Iterator�Mapping�MutableMapping�Optional�Tuple�Union�cast)� CIMultiDict�istr� )�hdrs�payload)�AbstractStreamWriter)�PY_38� HeadersMixin�rfc822_formatted_time�sentinel)� RESPONSES�SERVER_SOFTWARE�
HttpVersion10�
HttpVersion11)�Payload)� JSONEncoder� LooseHeaders)�
ContentCoding�StreamResponse�Response�
json_response)� BaseRequestZSameSite�samesitec @ s e Zd ZdZdZdZdS )r! �deflate�gzip�identityN)�__name__�
__module__� __qualname__r' r( r) � r- r- �G/opt/alt/python37/lib64/python3.7/site-packages/aiohttp/web_response.pyr! 4 s r! c
s� e Zd ZdZdddd�eee ee dd�dd�Ze e
d�d d
��Z e d d�d d
��Z e ed�dd��Z
e e
d�dd��Ze e
d�dd��Ze ed�dd��Zdefeee eeeeef f dd�dd�Ze ee
d�dd��Zdd�dd �Ze ed�d d ��Ze ed�d d ��Zdpee dd!�d"d#�Zdqeee
ef dd$�d%d&�Z e d'd�d(d)��Z e d*d�d+d,��Z dddd-ddddd.�eeee ee eeeef eee
ee
ee ee dd/� d0d1�Z dd-d2�eee edd3�d4d5�Z e ee d�� fd6d7� �Z!e!j"ee dd8�d9d7��Z!e ed�� fd:d;� �Z#e#j"edd8�d<d;��Z#e ee d�� fd=d>� �Z$e$j"ee dd8�d?d>��Z$e ee%j% d�d@dA��Z&e&j"eeee'e%j%ef dd8�dBdA��Z&e(j)fe*ddC�dDdE�Z+eddF�dGdH�Z,dIddJ�dKdL�Z-dIee. dJ�dMdN�Z/dIe.dJ�dOdP�Z0dd�dQdR�Z1dd�dSdT�Z2e3ddU�dVdW�Z4dd�dXdY�Z5dre3ddU�d[d\�Z6ed�d]d^�Z7ee8d_�d`da�Z9ee8ddb�dcdd�Z:edd_�dedf�Z;ed�dgdh�Z<e=e d�didj�Z>ed�dkdl�Z?e@e
dm�dndo�ZA� ZBS )sr" T�� N)�status�reason�headers)r0 r1 r2 �returnc C sp d | _ d | _d| _d| _d | _t� | _d | _d | _d| _ d| _
i | _ |d k rXt |�| _
nt � | _
| �||� d S )NFr )�_body� _keep_alive�_chunked� _compression�_compression_forcer �_cookies�_req�_payload_writer� _eof_sent� _body_length�_stater �_headers�
set_status)�selfr0 r1 r2 r- r- r. �__init__G s zStreamResponse.__init__)r3 c C s
| j d k S )N)r; )rA r- r- r. �preparedb s zStreamResponse.preparedzasyncio.Task[None]c C s t | jdd �S )N�task)�getattrr: )rA r- r- r. rD f s zStreamResponse.taskc C s | j S )N)�_status)rA r- r- r. r0 j s zStreamResponse.statusc C s | j S )N)r6 )rA r- r- r. �chunkedn s zStreamResponse.chunkedc C s | j S )N)r7 )rA r- r- r. � compressionr s zStreamResponse.compressionc C s | j S )N)�_reason)rA r- r- r. r1 v s zStreamResponse.reason)r0 r1 �
_RESPONSESr3 c C sV | j rtd��t|�| _|d krLy|| j d }W n tk
rJ d}Y nX || _d S )NzGCannot change the response status code after the headers have been sentr � )rC �AssertionError�intrF � ExceptionrI )rA r0 r1 rJ r- r- r. r@ z s
zStreamResponse.set_statusc C s | j S )N)r5 )rA r- r- r. �
keep_alive� s zStreamResponse.keep_alivec C s
d| _ d S )NF)r5 )rA r- r- r. � force_close� s zStreamResponse.force_closec C s | j S )N)r= )rA r- r- r. � body_length� s zStreamResponse.body_lengthc C s t �dt� | jst�| jjS )Nzoutput_length is deprecated)�warnings�warn�DeprecationWarningr; rL � buffer_size)rA r- r- r. �
output_length� s
z StreamResponse.output_length)�
chunk_sizer3 c C s2 d| _ tj| jkrtd��|dk r.t�dt� dS )z,Enables automatic chunked transfer encoding.Tz>You can't enable chunked encoding when a content length is setNz Chunk size is deprecated #1615)r6 r �CONTENT_LENGTHr? � RuntimeErrorrR rS rT )rA rW r- r- r. �enable_chunked_encoding� s z&StreamResponse.enable_chunked_encoding)�forcer3 c C sT t |�tkr*|rtjntj}t�dt� n|dk rDt|t�sDt d��d| _
|| _ dS )z&Enables response compression encoding.z+Using boolean for force is deprecated #3318Nz1force should one of None, bool or ContentEncodingT) �type�boolr! r' r) rR rS rT �
isinstancerL r7 r8 )rA r[ r- r- r. �enable_compression� s
z!StreamResponse.enable_compressionzCIMultiDict[str]c C s | j S )N)r? )rA r- r- r. r2 � s zStreamResponse.headerszSimpleCookie[str]c C s | j S )N)r9 )rA r- r- r. �cookies� s zStreamResponse.cookies�/)�expires�domain�max_age�path�secure�httponly�versionr& ) �name�valuerb rc rd re rf rg rh r& r3 c
C s� | j �|�} | dk r,| jdkr,| j �|d� || j |< | j | } |dk rR|| d< n| �d�dkrf| d= |dk rv|| d< |dk r�t|�| d< nd| kr�| d= || d< |dk r�|| d< |dk r�|| d < | dk r�| | d
< |
dk r�|
| d < 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.
NrK rb z Thu, 01 Jan 1970 00:00:00 GMTrc zmax-agere rf rg rh r& )r9 �getZ coded_value�pop�str)
rA ri rj rb rc rd re rf rg rh r& �old�cr- r- r. �
set_cookie� s0
zStreamResponse.set_cookie)rc re )ri rc re r3 c C s( | j �|d� | j|ddd||d� dS )zBDelete cookie.
Creates new empty expired cookie.
NrK r z Thu, 01 Jan 1970 00:00:00 GMT)rd rb rc re )r9 rl rp )rA ri rc re r- r- r. �
del_cookie� s zStreamResponse.del_cookiec s t � jS )N)�super�content_length)rA )� __class__r- r. rs s z StreamResponse.content_length)rj r3 c C sD |d k r0t |�}| jr td��t|�| jtj< n| j�tjd � d S )Nz<You can't set content length when chunked encoding is enable)rM r6 rY rm r? r rX rl )rA rj r- r- r. rs s c s t � jS )N)rr � content_type)rA )rt r- r. ru s zStreamResponse.content_typec C s | j t|�| _| �� d S )N)ru rm �
_content_type� _generate_content_type_header)rA rj r- r- r. ru s
c s t � jS )N)rr �charset)rA )rt r- r. rx # s zStreamResponse.charsetc C sZ | j }|dkrtd��| jd k s$t�|d kr<| j�dd � nt|��� | jd< | �� d S )Nzapplication/octet-streamzYSetting charset for application/octet-stream doesn't make sense, setup content_type firstrx )ru rY �
_content_dictrL rl rm �lowerrw )rA rj �ctyper- r- r. rx ( s c C sF | j �tj�}|dk rBt|�}|dk rBtj|dd� dtjji�S dS )zuThe value of Last-Modified HTTP header, or None.
This header is represented as a `datetime` object.
N� Ztzinfo)r? rk r �
LAST_MODIFIEDr �datetimeZtimezoneZutc)rA ZhttpdateZ timetupler- r- r. �
last_modified7 s z StreamResponse.last_modifiedc C s� |d kr| j �tjd � nlt|ttf�rJt�dt� t
� |���| j tj< n<t|t j �rpt�d|�
� �| j tj< nt|t�r�|| j tj< d S )Nz%a, %d %b %Y %H:%M:%S GMT)r? rl r r} r^ rM �float�timeZstrftimeZgmtime�mathZceilr~ Z utctimetuplerm )rA rj r- r- r. r D s
)� CONTENT_TYPEr3 c C s^ | j d k st�| jd k s t�d�dd� | j �� D ��}|rJ| jd | }n| j}|| j|< d S )Nz; c s s | ]\}}|� d |� �V qdS )�=Nr- )�.0�k�vr- r- r. � <genexpr>Z s z?StreamResponse._generate_content_type_header.<locals>.<genexpr>)ry rL rv �join�itemsr? )rA r� Zparamsr{ r- r- r. rw U s z,StreamResponse._generate_content_type_header)�codingr3 c � sH |t jkrD| jd k st�|j| jtj< | j�|j� | j� tj
d � d S )N) r! r) r; rL rj r? r �CONTENT_ENCODINGr_ ZpopallrX )rA r� r- r- r. �_do_start_compressiona s
z$StreamResponse._do_start_compressionr% )�requestr3 c � s^ | j r| �| j �I d H n@|j�tjd��� }x*tD ]"}|j|kr4| �|�I d H d S q4W d S )NrK ) r8 r� r2 rk r ZACCEPT_ENCODINGrz r! rj )rA r� Zaccept_encodingr� r- r- r. �_start_compressionj s
z!StreamResponse._start_compressionc � s* | j r
d S | jd k r| jS | �|�I d H S )N)r< r; �_start)rA r� r- r- r. �preparet s
zStreamResponse.preparec � sB || _ |j }| _| �� I d H |�| �I d H | �� I d H |S )N)r: r; �_prepare_headersZ
_prepare_hook�_write_headers)rA r� �writerr- r- r. r� | s zStreamResponse._startc � s� | j }|d k st�| j}|d k s$t�| j}|d kr8|j}|| _|j}| j}x4| j�� D ]&}|j dd�dd � }|�
t j |� qVW | j
r�| �|�I d H | jr�|tkr�td�|j���|�� d|t j< t j|kr�|t j= nr| j�rL| j|_|jd k�r.|tk�r(|�� d|t j< t j|k�r,|t j= nd}n |tk�rL| jdk�rL|t j= |�t jd� |�t j t � � |�t j t � t j |k�r�|�r�|t!k�r�d |t j < n|tk�r�d
|t j < d S ) NrK )�headerr z@Using chunked encoding is forbidden for HTTP/{0.major}.{0.minor}rG F)�d �e �f �g �� zapplication/octet-streamz
keep-alive�close)"r: rL r; r5 rO rh r? r9 �values�output�addr Z
SET_COOKIEr7 r� r6 r rY �formatZenable_chunkingZTRANSFER_ENCODINGrX �
_length_checkrs �lengthr0 �
setdefaultr� ZDATEr ZSERVERr Z
CONNECTIONr )rA r� r� rO rh r2 Zcookierj r- r- r. r� � sX
z StreamResponse._prepare_headersc � s^ | j }|d k st�| j}|d k s$t�|j}d�|d |d | j| j�}|�|| j�I d H d S )NzHTTP/{}.{} {} {}r r ) r: rL r; rh r� rF rI Z
write_headersr? )rA r� r� rh Z status_liner- r- r. r� � s z StreamResponse._write_headers)�datar3 c � sV t |tttf�s tdt|� ��| jr.td��| jd kr@td��| j� |�I d H d S )Nz#data argument must be byte-ish (%r)z%Cannot call write() after write_eof()z$Cannot call write() before prepare())
r^ �bytes� bytearray�
memoryviewrL r\ r< rY r; �write)rA r� r- r- r. r� � s
zStreamResponse.writec � sD | j rtd��| jd k s td��tjdtdd� | j�� I d H d S )NzEOF has already been sentz Response has not been startedz2drain method is deprecated, use await resp.write()� )�
stacklevel)r< rL r; rR rS rT �drain)rA r- r- r. r� � s zStreamResponse.drain� c � sn t |tttf�s tdt|� ��| jr*d S | jd k s<td��| j�|�I d H d| _d | _ | jj
| _ d | _d S )Nz#data argument must be byte-ish (%r)z Response has not been startedT) r^ r� r� r� rL r\ r< r; � write_eofr: Z output_sizer= )rA r� r- r- r. r� � s
zStreamResponse.write_eofc C s\ | j r d}n2| jr:| jd k s t�| jj� d| jj� d�}nd}d| jj� d| j� d|� d�S )N�eof� z not prepared�<�>) r< rC r: rL �methodre rt r* r1 )rA �infor- r- r. �__repr__� s zStreamResponse.__repr__)�keyr3 c C s
| j | S )N)r> )rA r� r- r- r. � __getitem__� s zStreamResponse.__getitem__)r� rj r3 c C s || j |< d S )N)r> )rA r� rj r- r- r. � __setitem__� s zStreamResponse.__setitem__c C s | j |= d S )N)r> )rA r� r- r- r. � __delitem__ s zStreamResponse.__delitem__c C s
t | j�S )N)�lenr> )rA r- r- r. �__len__ s zStreamResponse.__len__c C s
t | j�S )N)�iterr> )rA r- r- r. �__iter__ s zStreamResponse.__iter__c C s t t| ��S )N)�hash�id)rA r- r- r. �__hash__ s zStreamResponse.__hash__)�otherr3 c C s | |kS )Nr- )rA r� r- r- r. �__eq__ s zStreamResponse.__eq__)N)N)r� )Cr* r+ r, r� rM r rm r rB �propertyr] rC rD r0 rG rH r1 r r
r
r@ rO rP rQ rV rZ r r! r_ r2 r` rp rq rs �setterru rx r~ r r� r r� r rw r� r� r r� r� r� r� r� r� r� r� r� r r� r� r� r� r r� r� �objectr� �
__classcell__r- r- )rt r. r" C s� >(
:
r" c sV e Zd Zdddddddddd� eeee ee ee ee ee ee ee dd�
� fdd�Z e
ee e e
f d�dd ��Zejejejfe eedd
�d d ��Ze
ee d�d d
��Zejedd�dd
��Ze
ee d�� fdd� �Zejee dd�dd��Zd"e dd�� fdd�
Zded�� fdd� Zedd �d d �Zedd �� fd d!� Z� Z S )#r# Nr/ ) �bodyr0 r1 �textr2 ru rx �zlib_executor_size�
zlib_executor)
r� r0 r1 r� r2 ru rx r� r� r3 c s^ |d k r|d k rt d��|d kr(t� }
nt|t�s<t|�}
n|}
|d k rXd|krXt d��|d k r�tj|
kr||sr|r�t d��nRt|t�s�tdt|� ��|d kr�d}|d kr�d}|d | |
tj< |�|�}d }nNtj|
kr�|d k s�|d k r�t d��n*|d k �r |d k �r|d| 7 }||
tj< t � j
|||
d � |d k �rB|| _ n|| _ d | _
|| _| | _d S )
Nz&body and text are not allowed togetherrx z,charset must not be in content_type argumentzPpassing both Content-Type header and content_type or charset params is forbiddenz text argument must be str (%r)z
text/plainzutf-8z
; charset=)r0 r1 r2 )�
ValueErrorr r^ r r� rm � TypeErrorr\ �encoderr rB r� r� �_compressed_body�_zlib_executor_size�_zlib_executor) rA r� r0 r1 r� r2 ru rx r� r� Z real_headers)rt r- r. rB sL
zResponse.__init__)r3 c C s | j S )N)r4 )rA r- r- r. r� Y s z
Response.body)r� r� rX r3 c C s� |d krd | _ d| _n�t|ttf�r2|| _ d| _n�ytj�|� | _ }W n& tjk
rn t dt
|� ��Y nX d| _| j }| j s�||kr�|j
}|d k r�t|�||< ||kr�|j||< |jr�x&|j�� D ]\}}||kr�|||< q�W d | _d S )NFzUnsupported body type %rT)r4 �
_body_payloadr^ r� r� r ZPAYLOAD_REGISTRYrk � LookupErrorr� r\ r? r6 �sizerm ru r2 r� r� )rA r� r� rX r2 r� r� rj r- r- r. r� ] s.
c C s | j d krd S | j �| jp d�S )Nzutf-8)r4 �decoderx )rA r- r- r. r� � s
z
Response.text)r� r3 c C s` |d ks"t |t�s"tdt|� ��| jdkr2d| _| jd krBd| _|�| j�| _d| _d | _ d S )Nz text argument must be str (%r)zapplication/octet-streamz
text/plainzutf-8F)
r^ rm rL r\ ru rx r� r4 r� r� )rA r� r- r- r. r� � s
c sX | j r
d S tj| jkr t� jS | jd k r2t| j�S | jr<d S | j d k rPt| j �S dS d S )Nr )
r6 r rX r? rr rs r� r� r� r4 )rA )rt r- r. rs � s
zResponse.content_length)rj r3 c C s t d��d S )Nz#Content length is set automatically)rY )rA rj r- r- r. rs � s r� )r� r3 c � s� | j r
d S | jd kr | j}n| j}|r4td|����| jd k sBt�| jd k sPt�|d k r�| jjtjksp| j dkr�t
� � � I d H q�| j r�t
t|�}|�| j�I d H t
� � � I d H q�t
� � t
t|��I d H nt
� � � I d H d S )Nz data arg is not supported, got )r� i0 )r< r� r4 rL r: r; �_methodr Z METH_HEADrF rr r� r� r r r� r� )rA r� r� r )rt r- r. r� � s"
zResponse.write_eofr% )r� r3 c � sX | j sFtj| jkrF| jsF| jd k r:tt| j��| jtj< n d| jtj< t� � |�I d H S )N�0)
r6 r rX r? r� r4 rm r� rr r� )rA r� )rt r- r. r� � s
zResponse._start)� zlib_moder3 c C sB |dks t �tj|d�}| j}|d k s*t �|�|�|�� | _d S )Nr )Zwbits)rL �zlib� compressobjr4 �compress�flushr� )rA r� r� �body_inr- r- r. �_compress_body� s
zResponse._compress_body)r� r3 c � s� | j s | jr t� �|�I d H S |tjkr�|tjkr<dtj ntj}| j }|d k sTt
�| j d k r�t |�| j kr�t
�� �| j| j|�I d H n
| �|� | j}|d k s�t
�|j| jtj< tt |��| jtj< d S )N� )r� r6 rr r� r! r) r( r� Z MAX_WBITSr4 rL r� r� �asyncioZget_event_loopZrun_in_executorr� r� r� rj r? r r� rm rX )rA r� r� r� Zbody_out)rt r- r. r� � s
z Response._do_start_compression)r� ) r* r+ r, r rM r rm r r rB r� r r� r r� r� r r� rX r r� rs r� r r� r� r! r� r� r- r- )rt r. r# s8 4: #
r# r/ zapplication/json)r� r� r0 r1 r2 ru �dumps) r� r� r� r0 r1 r2 ru r� r3 c C s6 | t k r"|s|rtd��n|| �}t||||||d�S )Nz3only one of data, text, or body should be specified)r� r� r0 r1 r2 ru )r r� r# )r� r� r� r0 r1 r2 ru r� r- r- r. r$ � s
r$ )@r� Zcollections.abc� collectionsr~ �enumZjsonr� r� rR r� �concurrent.futuresr Z email.utilsr Z http.cookiesr r �typingr r r r r
r r r
r r Z multidictr r rK r r �abcr Zhelpersr r r r Zhttpr r r r r Ztypedefsr r �__all__Z web_requestr% rm Z BaseClassZ _reserved�Enumr! r" r# r� r� rM r$ r- r- r- r. �<module> sT 0
R f(