Edit File: web_fileresponse.cpython-37.pyc
B �k�a * � @ s U d dl Z d dlZd dlZd dlZd dlZd dlmZmZmZm Z m Z m Z m Z m Z mZmZmZ ddlmZ ddlmZ ddlmZmZ ddlmZmZ ddlm Z m Z m Z m Z dd l m!Z! d Z"er�dd l#m$Z$ e e e%ge d f Z&e'ej(�)d ��Z*ee' e+d < G dd� de!�Z,dS )� N) �IO� TYPE_CHECKING�Any� Awaitable�Callable�Iterator�List�Optional�Tuple�Union�cast� )�hdrs)�AbstractStreamWriter)�ETAG_ANY�ETag)�Final� LooseHeaders)�HTTPNotModified�HTTPPartialContent�HTTPPreconditionFailed� HTTPRequestRangeNotSatisfiable)�StreamResponse)� FileResponse)� BaseRequestZAIOHTTP_NOSENDFILE� NOSENDFILEc s� e Zd ZdZdeeejf eee e e e dd�� fdd� Z e e e eee d�d d �Zd e e eee d �� fd d� Zeeeedf ed�dd��Zd eee e d�� fdd� Zd e e d�� fdd� Zd e e d�� fdd� Z� ZS ) r z,A response object can be used to send files.� �� N)�path� chunk_size�status�reason�headers�returnc s6 t � j|||d� t|t�r&t�|�}|| _|| _d S )N)r r! r" )�super�__init__� isinstance�str�pathlib�Path�_path� _chunk_size)�selfr r r r! r" )� __class__� �K/opt/alt/python37/lib64/python3.7/site-packages/aiohttp/web_fileresponse.pyr% / s zFileResponse.__init__)�writer�fobj�offset�countr# c � s� | j }t�� }|�d |j|�I d H |�d |j|�I d H }xF|r�|�|�I d H || }|dkrbP |�d |jt||��I d H }q<W |�� I d H |S )Nr ) r+ �asyncio�get_event_loop�run_in_executor�seek�read�write�minZdrain)r, r0 r1 r2 r3 r �loop�chunkr. r. r/ �_sendfile_fallback? s z FileResponse._sendfile_fallbackr )�requestr1 r2 r3 r# c � s� t � �|�I d H }|d k s t�ts2tjdk s2| jrH| �||||�I d H S |j}|j }|d k s`t�y|� ||||�I d H W n& t k r� | �||||�I d H S X t � � � I d H |S )N)� � ) r$ �prepare�AssertionErrorr �sys� version_info� compressionr= Z_loop� transport�sendfile�NotImplementedErrorZ write_eof)r, r> r1 r2 r3 r0 r; rF )r- r. r/ � _sendfileU s zFileResponse._sendfile.)� etag_value�etagsr# c s4 t |�dkr |d jtkr dS t� fdd�|D ��S )Nr r Tc 3 s | ]}|j s|j� kV qd S )N)Zis_weak�value)�.0�etag)rJ r. r/ � <genexpr>n s z2FileResponse._strong_etag_match.<locals>.<genexpr>)�lenrL r �any)rJ rK r. )rJ r/ �_strong_etag_matchj s z FileResponse._strong_etag_match)r> rJ � last_modifiedr# c � s0 | � tj� d| _|| _|| _t� �|�I d H S )NF)� set_statusr � status_codeZ _length_checkrN rS r$ rA )r, r> rJ rS )r- r. r/ � _not_modifiedp s zFileResponse._not_modified)r> r# c � s$ | � tj� d| _t� �|�I d H S )Nr )rT r rU �content_lengthr$ rA )r, r> )r- r. r/ �_precondition_failed{ s z!FileResponse._precondition_failedc � s� | j }d}d|j�tjd�kr>|�|jd �}|�� r>|}d}t� � }|� d |j �I d H }|j d�d|j d��}|j}|j} | d k r�| �|| �s�| �|�I d H S |j} | d k r�| d kr�|j| �� kr�| �|�I d H S |j} | d k �r| �|| ��r| �|||�I d H S |j} | d k �rD| d k�rD|j| �� k�rD| �|||�I d H S tj| jk�rtt�t|��\} }| �snd} d}n|�r~dnd }d}| j}|j }|}d }|j }|d k�s�|j|�� k�r�y|j }|j }|j }W nB t k �r d |� �| jtj!< | �"t#j$� t%� �&|�I d H S X |d k �s(|d k �r�|d k �r\|d k�r\||7 }|d k �rRd }|| }n t'|d k �rl|n||�| }||k�r�d |� �| jtj!< | �"t#j$� t%� �&|�I d H S t(j$}| �"|� |�r�| | _)|�r�|| jtj*< |�r�tj| jtj+< || _,|j| _-|| _.d | jtj/< t0t1|�}|t(j$k�rHd �2||| d |�| jtj!< |d k�sl|j3tj4k�sl| j5dk�r~t%� �&|�I d H S |� d |j6d�I d H }|�r�|}nd }z| �7||||�I d H S |� d |j8�I d H X d S )NF�gzip� z.gzT�x�-zapplication/octet-streamzbytes */r �byteszbytes {}-{}/{}r )�� i0 �rb)9r* r" �getr ZACCEPT_ENCODING� with_name�name�is_filer4 r5 r6 �stat� st_mtime_ns�st_size�st_mtimeZif_matchrR rX Zif_unmodified_since� timestampZ if_none_matchrV Zif_modified_sinceZ CONTENT_TYPE� mimetypesZ guess_typer' Z_statusZif_rangeZ http_range�start�stop� ValueErrorZ CONTENT_RANGErT r rU r$ rA r: r � content_typeZCONTENT_ENCODINGZVARYrN rS rW Z ACCEPT_RANGESr �int�format�methodZ METH_HEADr �openrI �close)r, r> �filepathrY Z gzip_pathr; �strJ rS ZifmatchZ unmodsinceZ ifnonematchZmodsince�ct�encodingZ should_set_ctr � file_sizer3 rj Zifrange�rng�endZ real_startr1 r2 )r- r. r/ rA � s� $zFileResponse.prepare)r r NN)�__name__� __module__� __qualname__�__doc__r r' r( r) rn r r r% r r r r= rI � staticmethodr r �boolrR �floatrV rX rA � __classcell__r. r. )r- r/ r , s" r )-r4 ri �osr( rC �typingr r r r r r r r r r r rZ r �abcr Zhelpersr r Ztypedefsr r Zweb_exceptionsr r r r Z web_responser �__all__Z web_requestr r] Z_T_OnChunkSentr �environr` r �__annotations__r r. r. r. r/ �<module> s$ 4