Edit File: web_response.cpython-37.opt-1.pyc
B �k�a�k � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl m Z d dl m Z mZ d dlmZmZmZmZmZmZmZmZmZmZ d dlmZm Z ddl m Z m Z ddl m!Z! dd l"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+ dd l,m-Z-m.Z.m/Z/m0Z0 dd l m1Z1 dd l2m3Z3m4Z4 d Z5e�rDddl6m7Z7 ee8ef Z9nej jZ9e$�s\de j:d< G dd� dej;�Z<G dd� de9e'�Z=G dd� de=�Z>e*fddddddej?d�eee8 ee@ eAee8 ee4 e8e3e>d� dd �ZBdS ) � N)�Executor)�Morsel� SimpleCookie) � TYPE_CHECKING�Any�Dict�Iterator�Mapping�MutableMapping�Optional�Tuple�Union�cast)� CIMultiDict�istr� )�hdrs�payload)�AbstractStreamWriter) �ETAG_ANY�PY_38�QUOTED_ETAG_RE�ETag� HeadersMixin�parse_http_date�rfc822_formatted_time�sentinel�validate_etag_value)� 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- � r1 r1 �G/opt/alt/python37/lib64/python3.7/site-packages/aiohttp/web_response.pyr% = 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 ��Zdsee dd!�d"d#�Zdteee 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 ee( d�dCdD��Z)e)j"eee(ef dd8�dEdD��Z)e*j+fe,ddF�dGdH�Z-eddI�dJdK�Z.dLddM�dNdO�Z/dLee0 dM�dPdQ�Z1dLe0dM�dRdS�Z2dd�dTdU�Z3dd�dVdW�Z4e5ddX�dYdZ�Z6dd�d[d\�Z7due5ddX�d^d_�Z8ed�d`da�Z9ee:db�dcdd�Z;ee:dde�dfdg�Z<eddb�dhdi�Z=ed�djdk�Z>e?e d�dldm�Z@ed�dndo�ZAeBe dp�dqdr�ZC� ZDS )vr& T�� N)�status�reason�headers)r4 r5 r6 �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)�selfr4 r5 r6 r1 r1 r2 �__init__P s zStreamResponse.__init__)r7 c C s | j d k S )N)r? )rE r1 r1 r2 �preparedk s zStreamResponse.preparedz Optional[asyncio.Task[None]]c C s | j r| j jS d S d S )N)r> �task)rE r1 r1 r2 rH o s zStreamResponse.taskc C s | j S )N)�_status)rE r1 r1 r2 r4 v s zStreamResponse.statusc C s | j S )N)r: )rE r1 r1 r2 �chunkedz s zStreamResponse.chunkedc C s | j S )N)r; )rE r1 r1 r2 � compression~ s zStreamResponse.compressionc C s | j S )N)�_reason)rE r1 r1 r2 r5 � s zStreamResponse.reason)r4 r5 � _RESPONSESr7 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 � )rG �AssertionError�intrI � ExceptionrL )rE r4 r5 rM r1 r1 r2 rD � s zStreamResponse.set_statusc C s | j S )N)r9 )rE r1 r1 r2 � keep_alive� s zStreamResponse.keep_alivec C s d| _ d S )NF)r9 )rE r1 r1 r2 � force_close� s zStreamResponse.force_closec C s | j S )N)rA )rE r1 r1 r2 � body_length� s zStreamResponse.body_lengthc C s t �dt� | jst�| jjS )Nzoutput_length is deprecated)�warnings�warn�DeprecationWarningr? rO � buffer_size)rE r1 r1 r2 � output_length� s z StreamResponse.output_length)� chunk_sizer7 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)r: r �CONTENT_LENGTHrC � RuntimeErrorrU rV rW )rE rZ r1 r1 r2 �enable_chunked_encoding� s z&StreamResponse.enable_chunked_encoding)�forcer7 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- rU rV rW � isinstancerO r; r< )rE r^ r1 r1 r2 �enable_compression� s z!StreamResponse.enable_compressionzCIMultiDict[str]c C s | j S )N)rC )rE r1 r1 r2 r6 � s zStreamResponse.headerszSimpleCookie[str]c C s | j S )N)r= )rE r1 r1 r2 �cookies� s zStreamResponse.cookies�/)�expires�domain�max_age�path�secure�httponly�versionr* ) �name�valuere rf rg rh ri rj rk r* r7 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. NrN re z Thu, 01 Jan 1970 00:00:00 GMTrf zmax-agerh ri rj rk r* )r= �getZ coded_value�pop�str) rE rl rm re rf rg rh ri rj rk r* �old�cr1 r1 r2 � set_cookie� s0 zStreamResponse.set_cookie)rf rh )rl rf rh r7 c C s( | j �|d� | j|ddd||d� dS )zBDelete cookie. Creates new empty expired cookie. NrN r z Thu, 01 Jan 1970 00:00:00 GMT)rg re rf rh )r= ro rs )rE rl rf rh r1 r1 r2 � del_cookie s zStreamResponse.del_cookiec s t � jS )N)�super�content_length)rE )� __class__r1 r2 rv s z StreamResponse.content_length)rm r7 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)rP r: r\ rp rC r r[ ro )rE rm r1 r1 r2 rv s c s t � jS )N)ru � content_type)rE )rw r1 r2 rx # s zStreamResponse.content_typec C s | j t|�| _| �� d S )N)rx rp � _content_type� _generate_content_type_header)rE rm r1 r1 r2 rx ( s c s t � jS )N)ru �charset)rE )rw r1 r2 r{ . 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 firstr{ )rx r\ � _content_dictrO ro rp �lowerrz )rE rm �ctyper1 r1 r2 r{ 3 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 rC rn r � LAST_MODIFIED)rE r1 r1 r2 � last_modifiedB 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)rC ro r r ra rP �float�time�strftime�gmtime�math�ceil�datetimeZ utctimetuplerp )rE rm r1 r1 r2 r� J s c C sZ | j �tj�}|sd S |tkr(ttd�S t�|�}|s:d S |�dd�\}}tt |�|d�S )N)rm r � )�is_weakrm ) rC rn r �ETAGr r r � fullmatch�groupr` )rE Z quoted_value�matchr� rm r1 r1 r2 �etag[ s zStreamResponse.etagc C s� |d kr| j �tjd � n�t|t�r,|tks@t|t�rN|jtkrNt| j tj< n�t|t�rvt |� d|� d�| j tj< ndt|t�r�t|jt�r�t |j� |j r�d|j� d�n d|j� d�}|| j tj< nt dt |�� d���d S )N�"zW/"zUnsupported etag type: z . etag must be str, ETag or None) rC ro r r� ra rp r r rm r r� � ValueErrorr_ )rE rm Z hdr_valuer1 r1 r2 r� k s ")� CONTENT_TYPEr7 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 )�=Nr1 )�.0�k�vr1 r1 r2 � <genexpr>� s z?StreamResponse._generate_content_type_header.<locals>.<genexpr>)r| rO ry �join�itemsrC )rE r� Zparamsr~ r1 r1 r2 rz � s z,StreamResponse._generate_content_type_header)�codingr7 c � sH |t jkrD| jd k st�|j| jtj< | j�|j� | j� tj d � d S )N) r% r- r? rO rm rC r �CONTENT_ENCODINGrb Zpopallr[ )rE r� r1 r1 r2 �_do_start_compression� s z$StreamResponse._do_start_compressionr) )�requestr7 c � s^ | j r| �| j �I d H n@|j�tjd��� }x*tD ]"}|j|kr4| �|�I d H d S q4W d S )NrN ) r< r� r6 rn r ZACCEPT_ENCODINGr} r% rm )rE r� Zaccept_encodingr� r1 r1 r2 �_start_compression� s z!StreamResponse._start_compressionc � s* | j r d S | jd k r| jS | �|�I d H S )N)r@ r? �_start)rE r� r1 r1 r2 �prepare� s zStreamResponse.preparec � sB || _ |j }| _| �� I d H |�| �I d H | �� I d H |S )N)r> r? �_prepare_headersZ _prepare_hook�_write_headers)rE r� �writerr1 r1 r2 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= n~| j�rX| j|_|jd k�r:|tk�r4| jdk�r4|�� d|t j< t j|k�r8|t j= nd}n |tk�rX| jdk�rX|t j= | jd k�rr|�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 ) NrN )�headerr z@Using chunked encoding is forbidden for HTTP/{0.major}.{0.minor}rJ �� F)�d �e �f �g r� )r� i0 zapplication/octet-streamz keep-alive�close)"r> rO r? r9 rR rk rC r= �values�output�addr Z SET_COOKIEr; r� r: r! r\ �formatZenable_chunkingZTRANSFER_ENCODINGr[ � _length_checkrv �lengthr4 � setdefaultr� ZDATEr ZSERVERr Z CONNECTIONr )rE r� r� rR rk r6 Zcookierm r1 r1 r2 r� � sZ 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> rO r? rk r� rI rL Z write_headersrC )rE r� r� rk Z status_liner1 r1 r2 r� � s z StreamResponse._write_headers)�datar7 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()) ra �bytes� bytearray� memoryviewrO r_ r@ r\ r? �write)rE r� r1 r1 r2 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()r� )� stacklevel)r@ rO r? rU rV rW �drain)rE r1 r1 r2 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) ra r� r� r� rO r_ r@ r? � write_eofr> Z output_sizerA )rE r� r1 r1 r2 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@ rG r> rO �methodrh rw r. r5 )rE �infor1 r1 r2 �__repr__ s zStreamResponse.__repr__)�keyr7 c C s | j | S )N)rB )rE r� r1 r1 r2 � __getitem__( s zStreamResponse.__getitem__)r� rm r7 c C s || j |< d S )N)rB )rE r� rm r1 r1 r2 � __setitem__+ s zStreamResponse.__setitem__c C s | j |= d S )N)rB )rE r� r1 r1 r2 � __delitem__. s zStreamResponse.__delitem__c C s t | j�S )N)�lenrB )rE r1 r1 r2 �__len__1 s zStreamResponse.__len__c C s t | j�S )N)�iterrB )rE r1 r1 r2 �__iter__4 s zStreamResponse.__iter__c C s t t| ��S )N)�hash�id)rE r1 r1 r2 �__hash__7 s zStreamResponse.__hash__)�otherr7 c C s | |kS )Nr1 )rE r� r1 r1 r2 �__eq__: s zStreamResponse.__eq__)N)N)r� )Er. r/ r0 r� rP r rp r$ rF �propertyr` rG rH r4 rJ rK r5 r r r rD rR rS rT rY r] r r% rb r6 rc rs rt rv �setterrx r{ r� r� r� r r� r r� r rz r� r� r r� r� r� r� r� r� r� r� r� r r� r� r� r� r r� r� �objectr� � __classcell__r1 r1 )rw r2 r& L 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' Nr3 ) �bodyr4 r5 �textr6 rx r{ �zlib_executor_size� zlib_executor) r� r4 r5 r� r6 rx r{ r� r� r7 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 togetherr{ 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=)r4 r5 r6 )r� r ra r r� rp � TypeErrorr_ �encoderu rF r� r� �_compressed_body�_zlib_executor_size�_zlib_executor) rE r� r4 r5 r� r6 rx r{ r� r� Z real_headers)rw r1 r2 rF ? sL zResponse.__init__)r7 c C s | j S )N)r8 )rE r1 r1 r2 r� � s z Response.body)r� r� r[ r7 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)r8 � _body_payloadra r� r� r ZPAYLOAD_REGISTRYrn � LookupErrorr� r_ rC r: �sizerp rx r6 r� r� )rE r� r� r[ r6 r� r� rm r1 r1 r2 r� � s. c C s | j d krd S | j �| jp d�S )Nzutf-8)r8 �decoder{ )rE r1 r1 r2 r� � s z Response.text)r� r7 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) ra rp rO r_ rx r{ r� r8 r� r� )rE r� r1 r1 r2 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 ) r: r r[ rC ru rv r� r� r� r8 )rE )rw r1 r2 rv � s zResponse.content_length)rm r7 c C s t d��d S )Nz#Content length is set automatically)r\ )rE rm r1 r1 r2 rv � s r� )r� r7 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� r8 rO r> r? �_methodr Z METH_HEADrI ru r� r� r r" r� r� )rE r� r� r )rw r1 r2 r� � s" zResponse.write_eofr) )r� r7 c � sX | j sFtj| jkrF| jsF| jd k r:tt| j��| jtj< n d| jtj< t� � |�I d H S )N�0) r: r r[ rC r� r8 rp r� ru r� )rE r� )rw r1 r2 r� � s zResponse._start)� zlib_moder7 c C sB |dks t �tj|d�}| j}|d k s*t �|�|�|�� | _d S )Nr )Zwbits)rO �zlib� compressobjr8 �compress�flushr� )rE r� r� �body_inr1 r1 r2 �_compress_body� s zResponse._compress_body)r� r7 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� r: ru r� r% r- r, r� Z MAX_WBITSr8 rO r� r� �asyncioZget_event_loopZrun_in_executorr� r� r� rm rC r r� rp r[ )rE r� r� r� Zbody_out)rw r1 r2 r� s z Response._do_start_compression)r� ) r. r/ r0 r rP r rp r$ r rF r� r r� r" r� r� r r� r[ r r� rv r� r r� r� r% r� r� r1 r1 )rw r2 r' > s8 4: # r' r3 zapplication/json)r� r� r4 r5 r6 rx �dumps) r� r� r� r4 r5 r6 rx r� r7 c C s6 | t k r"|s|rtd��n|| �}t||||||d�S )Nz3only one of data, text, or body should be specified)r� r� r4 r5 r6 rx )r r� r' )r� r� r� r4 r5 r6 rx r� r1 r1 r2 r( " s r( )Cr� �collections.abc� collectionsr� �enumZjsonr� r� rU r� Zconcurrent.futuresr Z http.cookiesr r �typingr r r r r r r r r r Z multidictr r rN r r �abcr Zhelpersr r r r r r r r r Zhttpr r r r! r" Ztypedefsr# r$ �__all__Z web_requestr) rp Z BaseClassZ _reserved�Enumr% r& r' r� r� rP r( r1 r1 r1 r2 �<module> sR 0 , u f(