| Server IP : 192.158.238.246 / Your IP : 3.141.38.5 Web Server : LiteSpeed System : Linux uniform.iwebfusion.net 4.18.0-553.27.1.lve.1.el8.x86_64 #1 SMP Wed Nov 20 15:58:00 UTC 2024 x86_64 User : jenniferflocom ( 1321) PHP Version : 8.1.32 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
�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