File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/__pycache__/web_fileresponse.cpython-310.pyc
Back
o ;j@ � @ 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%m&Z& dd l'm(Z(m)Z) dd l*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0 ddl1m2Z2 dZ3er�ddl4m5Z5 eee6ged f Z7e8ej9�:d��Z;ee8 e<d< e � Z=ee e<d< edd� dD ��Z>dZ?eddddd d ��Z@G d d � d e�ZAe=jB�C� e@�D� D ] \ZEZFe=�GeEeF� q�eH� ZIeHe jJd e<d < G d!d"� d"e2�ZKdS )#� N)�suppress)�Enum�auto)� MimeTypes)�S_ISREG)�MappingProxyType) �IO� TYPE_CHECKING�Any� Awaitable�Callable�Final�Iterator�List�Optional�Set�Tuple�Union�cast� )�hdrs)�AbstractStreamWriter)�DEFAULT_CHUNK_SIZE�ETAG_ANY�ETag�must_be_empty_body)� LooseHeaders�PathLike)� HTTPForbidden� HTTPNotFound�HTTPNotModified�HTTPPartialContent�HTTPPreconditionFailed� HTTPRequestRangeNotSatisfiable)�StreamResponse)� FileResponse)� BaseRequestZAIOHTTP_NOSENDFILE� NOSENDFILE� CONTENT_TYPESc C s i | ]}|t j| �qS � )r( � encodings_map)�.0�extr) r) �L/opt/saltstack/salt/lib/python3.10/site-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 ZdZedddfdededededB dedB d df � fd d � Z d e e d eded e fdd�Z ded e e d eded ef dd�Zddd e e d eded ef � fdd� Zededeedf ded efd d ��Zddded ed edB f� fd d � Zddd edB f� fd!d"� Zddd#ed eeejdB e j edB f fd$d%�Z d#ed ee j dB e j edB f fd&d'�Z!ddd edB f� fd(d)� Z"ddd ejd*e j d+edB d edB f � fd,d-� Z#� Z$S ).r% 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? r@ )�super�__init__�pathlib�Path�_path� _chunk_size)�selfr< r= r> r? r@ �� __class__r) r- rC _ s zFileResponse.__init__�fobj�offsetc C s |� |� |�|�S �N)�seek�read)rH rK rL r= r) r) r- �_seek_and_readl s zFileResponse._seek_and_read�writer�countc � s� �| j }t�� }|�d | j||t||��I d H }|r=|�|�I d H |t|� }|dkr-n|�d |jt||��I d H }|s|� � I d H |S �Nr ) rG �asyncioZget_event_loop�run_in_executorrP �min�write�lenrO Zdrain)rH rQ rK rL rR 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 u r.td��z |�||||�I d H W n t yO | �||||�I d H Y S w t � � � I d H |S )NzConnection lost) rB �preparer' � compressionr[ Z_loop� transport�ConnectionResetError�sendfile�NotImplementedError� write_eof)rH r\ rK rL rR rQ rY r_ rI 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 rM )Zis_weak�value)r+ �etag�re rg r) r- � <genexpr>� s � �� �z+FileResponse._etag_match.<locals>.<genexpr>)rX rh r �any)re rf rg r) rj r- � _etag_match� s �zFileResponse._etag_match� last_modifiedc � s2 �| � tj� d| _|| _|| _t� �|�I d H S )NF)� set_statusr � status_codeZ _length_checkri rn rB r] )rH r\ re rn rI r) r- � _not_modified� s � zFileResponse._not_modifiedc � s& �| � tj� d| _t� �|�I d H S rS )ro r" rp �content_lengthrB r] )rH r\ rI 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)rg T�rb)� _get_file_path_stat_encodingr1 r7 � st_mtime_ns�st_sizeZif_matchrm r8 Zif_unmodified_since�st_mtime� timestampZ if_none_matchr9 Zif_modified_since�openr �OSError�os�stat�filenor6 ) rH r\ rt � file_path�st� file_encodingre ZifmatchZ unmodsinceZ ifnonematchZmodsincerK 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 rM ) rF �ENCODING_EXTENSIONS�items� with_suffix�suffixr r~ �lstatr �st_moder� )rH rt r� Zfile_extensionr� Zcompressed_pathr� r) r) r- rx � 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� ru rv ) rT Zget_running_loopr@ �getr �ACCEPT_ENCODING�lowerrU r� �PermissionErrorro r rp rB r] r~ r r1 r7 r8 rs r9 ry rz r{ rq �_prepare_open_file�closer: �addZadd_done_callback�remove) rH r\ rY rt Zresponse_resultrK r� r� re rn Z close_futurerI r) r- r] s@ � � � � zFileResponse.preparer� r� c � s> �| 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|| d � d |� �| j t j < |dk�st%|j&|��rt� �|�I d H S | �pd}| �'||||�I d H S ) Nzbytes */r )� � Fru rv �byteszbytes r �/)(Z_statusrz r{ Zif_ranger| Z http_range�start�stop� ValueError�_headersr Z CONTENT_RANGEro r# rp rB r] rV r! Z CONTENT_TYPE�sys� version_infor( Zguess_file_typeZ guess_typerF �FALLBACK_CONTENT_TYPE� content_typeZCONTENT_ENCODINGr� ZVARY� _compressionry ri rn rr Z ACCEPT_RANGESr �methodrd )rH r\ rK r� r� r> � file_sizeZ file_mtimerR r� Zifrange�rng�endZguesserZ real_startrL rI r) r- r� - sh � � � � z FileResponse._prepare_open_file)%r2 r3 r4 r5 r r �int�strr rC r r r� rP r r[ rd � staticmethod�tupler �boolrm �floatrq rs r1 �io�BufferedReaderr � stat_resultr� rD rE rx r] r� � __classcell__r) r) rI r- r% \ s� ������� ���� ������$���� ����� �8� �-�����r% )LrT r� r rD r� � contextlibr �enumr r Z mimetypesr r� r �typesr �typingr r r r r r r r r r r r r r� r �abcr Zhelpersr r r r Ztypedefsr r Zweb_exceptionsr r r r! r" r# Z web_responser$ �__all__Z web_requestr& r� Z_T_OnChunkSentr� �environr� r' �__annotations__r( r� r� ZADDITIONAL_CONTENT_TYPESr1 r* �clearr� r� � extensionZadd_type�setr: ZFuturer% r) r) r) r- �<module> sR < ���
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings