File: //usr/local/lib/python3.10/dist-packages/aiohttp/__pycache__/web_fileresponse.cpython-310.pyc
o
���gx@ � @ s� U d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZm Z d dl
m Z d dl m
Z
d dlmZ d dlmZmZmZmZmZmZmZmZmZmZmZm Z m Z dd l m Z dd
l m!Z! dd l"m#Z#m$Z$m%Z% dd l&m'Z'm(Z( dd
l)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/ ddl0m1Z1 dZ2er�ddl3m4Z4 eee5ged f Z6e7ej8�9d��Z:ee7 e;d< e � Z<ee e;d< edd� dD ��Z=dZ>eddddd d ��Z?G d d � d e�Z@e<jA�B� e?�C� D ]
\ZDZEe<�FeDeE� q�eG� ZHee jId e;d < G d!d"� d"e1�ZJdS )#� N)�suppress)�Enum�auto)� MimeTypes)�S_ISREG)�MappingProxyType)
�IO�
TYPE_CHECKING�Any� Awaitable�Callable�Final�Iterator�List�Optional�Set�Tuple�Union�cast� )�hdrs)�AbstractStreamWriter)�ETAG_ANY�ETag�must_be_empty_body)� LooseHeaders�PathLike)�
HTTPForbidden� HTTPNotFound�HTTPNotModified�HTTPPartialContent�HTTPPreconditionFailed� HTTPRequestRangeNotSatisfiable)�StreamResponse)� FileResponse)� BaseRequest�AIOHTTP_NOSENDFILE�
NOSENDFILE�
CONTENT_TYPESc C s i | ]}|t j| �qS � )r( �
encodings_map)�.0�extr) r) �C/usr/local/lib/python3.10/dist-packages/aiohttp/web_fileresponse.py�
<dictcomp>8 s r. )�.br�.gzzapplication/octet-streamr0 r/ z.bz2z.Zz.xz)zapplication/gzipzapplication/x-brotlizapplication/x-bzip2zapplication/x-compresszapplication/x-xzc @ s( e Zd ZdZe� Ze� Ze� Ze� ZdS )�_FileResponseResultz The result of the file response.N) �__name__�
__module__� __qualname__�__doc__r � SEND_FILE�NOT_ACCEPTABLE�PRE_CONDITION_FAILED� NOT_MODIFIEDr) r) r) r- r1 J s
r1 �_CLOSE_FUTURESc
s� e Zd ZdZ d/dedededee d ee d
df � fd d �
Z d
e
e deded
e fdd�Z
ded
e
e deded
ef
dd�Zddd
e
e deded
ef
� fdd� Zededeedf d ed
efd d ��Zddded ed
ee f� fd d!� Zddd
ee f� fd"d#� Zddd$ed
eeeej e j ee f fd%d&�Z d$ed
eee j e j ee f fd'd(�Z!ddd
ee f� fd)d*� Z"ddd
ejd+e j d,ee d
ee f
� fd-d.� Z#� Z$S )0r$ z,A response object can be used to send files.� �� N�path�
chunk_size�status�reason�headers�returnc s( t � j|||d� t�|�| _|| _d S )N)r? r@ rA )�super�__init__�pathlib�Path�_path� _chunk_size)�selfr= r> r? r@ rA �� __class__r) r- rD _ s
zFileResponse.__init__�fobj�offsetc C s |� |� |�|�S �N)�seek�read)rI rL rM r> r) r) r- �_seek_and_readl s
zFileResponse._seek_and_read�writer�countc � s� �| j }t�� }|�d | j|||�I d H }|r8|�|�I d H || }|dkr(n|�d |jt||��I d H }|s|�� I d H |S �Nr ) rH �asyncio�get_event_loop�run_in_executorrQ �writerP �min�drain)rI rR rL rM rS r> �loop�chunkr) r) r- �_sendfile_fallbackp s �
� �z FileResponse._sendfile_fallback�requestr% c � s� �t � �|�I d H }|d usJ �ts| jr | �||||�I d H S |j}|j}|d us,J �z
|�||||�I d H W n tyM | �||||�I d H Y S w t � � � I d H |S rN )
rC �preparer' � compressionr] �_loop� transport�sendfile�NotImplementedError� write_eof)rI r^ rL rM rS rR r[ rb rJ r) r- � _sendfile� s �
�zFileResponse._sendfile�
etag_value�etags.�weakc s6 t |�dkr|d jtkrdS t� �fdd�|D ��S )Nr r Tc 3 s$ � | ]
}�s |j s|j� kV qd S rN )�is_weak�value)r+ �etag�rg ri r) r- � <genexpr>� s � ��
�z+FileResponse._etag_match.<locals>.<genexpr>)�lenrk r �any)rg rh ri r) rm r- � _etag_match� s
�zFileResponse._etag_match�
last_modifiedc � s2 �| � tj� d| _|| _|| _t� �|�I d H S )NF)�
set_statusr � status_code�
_length_checkrl rr rC r_ )rI r^ rg rr rJ r) r- �
_not_modified� s � zFileResponse._not_modifiedc � s& �| � tj� d| _t� �|�I d H S rT )rs r! rt �content_lengthrC r_ )rI r^ rJ r) r- �_precondition_failed� s � z!FileResponse._precondition_failed�accept_encodingc C sB | � |�\}}}|stjd|dfS |jd�d|jd��}|j }dur2| j||dd�s2tjd||fS |j }durK|du rK|j |�
� krKtjd||fS |j } dura| j|| dd�ratj d||fS |j
}
durz| du rz|j |
�
� krztj d||fS |�d�} tt�� t�| �� �}W d � n1 s�w Y tj| ||fS )a Return the response result, io object, stat result, and encoding.
If an uncompressed file is returned, the encoding is set to
:py:data:`None`.
This method should be called from a thread executor
since it calls os.stat which may block.
N�x�-F)ri T�rb)� _get_file_path_stat_encodingr1 r7 � st_mtime_ns�st_size�if_matchrq r8 �if_unmodified_since�st_mtime� timestamp�
if_none_matchr9 �if_modified_since�openr �OSError�os�stat�filenor6 ) rI r^ ry � file_path�st�
file_encodingrg �ifmatch�
unmodsince� ifnonematch�modsincerL r) r) r- �_make_response� s6
���
�zFileResponse._make_responsec C s� | j }t�� D ]<\}}||vrq|�|j| �}tt�� |�� }t|j �r4|||fW d � S W d � n1 s>w Y q|�
� }t|j �rR||d fS d |d fS rN ) rG �ENCODING_EXTENSIONS�items� with_suffix�suffixr r� �lstatr �st_moder� )rI ry r� �file_extensionr� �compressed_pathr� r) r) r- r} � s
� �� z)FileResponse._get_file_path_stat_encodingc
� s� �t �� }|j�tjd��� }z|�d | j||�I d H \}}}}W n/ t y9 | �
t j � t
� �|�I d H Y S tyP | �
tj � t
� �|�I d H Y S w |tju re| �
t j � t
� �|�I d H S |tju rr| �|�I d H S |tju r�|jd�d|jd��}|j} | �||| �I d H S |d us�J �z | �||||�I d H W |�d |j�}
t � |
� |
� t j � S |�d |j�}
t � |
� |
� t j � w )N� rz r{ ) rU �get_running_looprA �getr �ACCEPT_ENCODING�lowerrW r� �PermissionErrorrs r rt rC r_ r� r r1 r7 r8 rx r9 r~ r r� rv �_prepare_open_file�closer: �add�add_done_callback�remove) rI r^ r[ ry �response_resultrL r� r� rg rr � close_futurerJ r) r- r_ � s@ �
� �
�
zFileResponse.preparer� r� c � s6 �| j }|j}|j}|}d } |j }
d u s||
�� kr�z |j} | j} | j} W n! tyG d|� �| j t
j < | � t
j� t� �|�I d H Y S w | d ur�| dk rc| d u rc| |7 } | dk r^d} || }n
t| d urj| n||�| }| |kr�d|� �| j t
j < | � t
j� t� �|�I d H S tj}| � |� t
j| j vr�tjdkr�tj}
ntj}
|
| j�d p�t| _|r�|| j t
j < t
j | j t
j < d| _ |j d�d|jd��| _!|| _"|| _#d| j t
j$< |tjkr�| }|d us�J �d�%||| d |�| j t
j < |dk�st&|j'|��r t� �|�I d H S | �pd}| �(||||�I d H S )
Nzbytes */r )� �
Frz r{ �byteszbytes {}-{}/{}r ))�_statusr r� �if_ranger� �
http_range�start�stop�
ValueError�_headersr �
CONTENT_RANGErs r" rt rC r_ rY r � CONTENT_TYPE�sys� version_infor( �guess_file_type�
guess_typerG �FALLBACK_CONTENT_TYPE� content_type�CONTENT_ENCODINGr� �VARY� _compressionr~ rl rr rw �
ACCEPT_RANGES�formatr �methodrf )rI r^ rL r� r� r? � file_size�
file_mtimerS r� �ifrange�rng�end�guesser�
real_startrM rJ r) r- r� , sj �
�
�
�
z FileResponse._prepare_open_file)r; r< NN)%r2 r3 r4 r5 r �intr �strr rD r r
r� rQ r r] rf � staticmethodr r �boolrq �floatrv rx r1 �io�BufferedReaderr� � stat_resultr� rE rF r} r_ r� �
__classcell__r) r) rJ r- r$ \ s� �������
����
������$���� �����
�8�
�-�����r$ )KrU r� r� rE r� �
contextlibr �enumr r � mimetypesr r� r �typesr �typingr r r
r r r
r r r r r r r r� r �abcr �helpersr r r �typedefsr r �web_exceptionsr r r r r! r" � web_responser# �__all__� web_requestr% r� �_T_OnChunkSentr� �environr� r' �__annotations__r( r� r� �ADDITIONAL_CONTENT_TYPESr1 r* �clearr� r� � extension�add_type�setr: �Futurer$ r) r) r) r- �<module> sR
< ���