ruạṛ
a �u:j�j � @ st d dl Z d dlZd dlmZ d dlmZ d dlmZmZm Z m Z m Z m Z m Z mZmZmZmZmZ d dlZd dlmZ d dlmZmZmZ d dlmZm Z d dl m Z d d l m Z d d l!m"Z"m#Z# d d l$m%Z% d d l&m'Z'm(Z( d d l)m*Z*m+Z+ d dl,m-Z- d dl.m/Z/ d dl0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z; d dl<m=Z= d dl>m?Z?m@Z@ d dlAmBZB d dlCmDZD d dlEmFZF d dlGmHZHmIZImJZJmKZK d dlLmMZMmNZN d dlOmPZP d dlQmRZR e2e4e1e6e3e7hZSeTeUeVfZWe2eTe4eUe6eVe3eTe7eTiZXdZYdZZe9dd �d d �Z[dd �ej\e]e e e] ed �d!d"�Z^ej_e]ed#�d$d%�Z`ddd&�ej_ed'ef e]e e] e e e] ed(�d)d*�Zaee ed'ef ee]d'f f Zbd+dd,�eece e eb ed-�d.d/�Zdee e9 d0�d1d2�Zee9ecd �d3d4�Zfe9ecd �d5d6�Zged'ef ejhd7�d8d9�Ziej\e e]ef ed:�d;d<�Zjddd=d>�e]ed'ef e e] e e e] eced?�d@dA�Zkej\ee ec dB�dCdD�Zlejmdd+dE�ej\e]eejm e ejn ece9dF�dGdH�Zoe9eddI�dJdK�Zped'ef ecd7�dLdM�Zqed'ef ecd7�dNdO�Zred'ef ecd7�dPdQ�Zsed'ef ee e]ef edR�dSdT�ZtddddddU�eeNeRf ee ee e]ef eHf e eD e eP e e e e eed'ef ee] f ef ee e]ef e e- e eD ePe eed'ef ee] f ef f dV�dWdX�Zuee9 ee e]ef eJeIf ee e]ef e e- f dY�dZd[�Zve e9 e ee e]ef eHf ee e]ef e e- f d\�d]d^�Zwee]d'f e-d_�d`da�Zxee]e e9 db�dcdd�ZydS )e� N)�contextmanager)�deepcopy) �Any�Callable� Coroutine�Dict�List�Mapping�Optional�Sequence�Tuple�Type�Union�cast)�params)�AsyncExitStack�asynccontextmanager� contextmanager_in_threadpool)� Dependant�SecurityRequirement)�logger)� SecurityBase)�OAuth2�SecurityScopes)� OpenIdConnect)�create_response_field�get_path_param_names)� BaseModel� create_model)� ErrorWrapper)� MissingError) �SHAPE_FROZENSET� SHAPE_LIST�SHAPE_SEQUENCE� SHAPE_SET�SHAPE_SINGLETON� SHAPE_TUPLE�SHAPE_TUPLE_ELLIPSIS� FieldInfo� ModelField�Required� Undefined)� get_annotation_from_field_info)� ForwardRef�evaluate_forwardref)�lenient_issubclass)�BackgroundTasks)�run_in_threadpool)�FormData�Headers� QueryParams� UploadFile)�HTTPConnection�Request)�Response)� WebSocketz�Form data requires "python-multipart" to be installed. You can install "python-multipart" with: pip install python-multipart z�Form data requires "python-multipart" to be installed. It seems you installed "multipart" instead. You can remove "multipart" with: pip uninstall multipart And then install "python-multipart" with: pip install python-multipart )�field�returnc C s� | j }t|tj�r�zVddlm} |s(J �zddlm} |s>J �W n$ tyd t � t � t t ��Y n0 W n$ ty� t � t � t t ��Y n0 d S )Nr )� __version__)�parse_options_header)� field_info� isinstancer �Form� multipartr< Zmultipart.multipartr= � ImportErrorr �error�!multipart_incorrect_install_error� RuntimeError� multipart_not_installed_error)r: r> r< r= � rG �M/opt/bart/bart_venv/lib/python3.9/site-packages/fastapi/dependencies/utils.py�check_file_field\ s rI )�security_scopes)�param�pathrJ r; c C s. | j }|jr|j}n| j}t|||| j|d�S )N)�depends� dependencyrL �namerJ )�defaultrN � annotation�get_sub_dependantrO )rK rL rJ rM rN rG rG rH �get_param_sub_dependantq s �rS )rM rL r; c C s" t | j�sJ d��t| | j|d�S )Nz;A parameter-less dependency must have a callable dependency)rM rN rL )�callablerN rR )rM rL rG rG rH � get_parameterless_sub_dependant� s ��rU )rO rJ .)rM rN rL rO rJ r; c C s| d }|p g }t | tj�r(| j}|�|� t |t�rTg }t |ttf�rH|}t||d�}t ||||| j d�}|rx|j � |� |S )N)Zsecurity_scheme�scopes)rL �callrO rJ � use_cache) r? r ZSecurityrV �extendr r r r � get_dependantrX �security_requirements�append) rM rN rL rO rJ Zsecurity_requirementZdependency_scopesZ use_scopes� sub_dependantrG rG rH rR � s, �� rR F�� skip_repeats�visited)� dependantr_ r` r; c C s� |d u r g }|� | j� t| j�� | j�� | j�� | j�� | j�� | j �� | j | j d�}| j D ]v}|rr|j|v rrq^t |||d�}|j�|j� |j�|j� |j�|j� |j�|j� |j�|j� |j �|j � q^|S )N)� path_params� query_params� header_params� cookie_params� body_paramsZsecurity_schemesrX rL r^ )r\ � cache_keyr rb �copyrc rd re rf r[ rX rL � dependencies�get_flat_dependantrY )ra r_ r` �flat_dependantr] Zflat_subrG rG rH rj � s4 � �rj )ra r; c C s$ t | dd�}|j|j |j |j S )NT)r_ )rj rb rc rd re )ra rk rG rG rH �get_flat_params� s ����rl c C sl | j }| jtkrFt| jt�sFt| jttf �sFt� | j�sFt |t j �rJdS | j rhtdd� | j D ��shdS dS )NFc s s | ]}t |�V qd S �N)�is_scalar_field��.0�frG rG rH � <genexpr>� � z"is_scalar_field.<locals>.<genexpr>T)r> �shaper% r/ �type_r �sequence_types�dict� dataclasses� is_dataclassr? r �Body� sub_fields�all)r: r> rG rG rH rn � s � �� � �rn c C sR | j tv r>t| jt�s>| jd ur:| jD ]}t|�s& dS q&dS t| jt�rNdS dS )NFT)rt �sequence_shapesr/ ru r r{ rn rv )r: Z sub_fieldrG rG rH �is_scalar_sequence_field� s � r~ )rW r; c s< t �| �}t| di �� � fdd�|j�� D �}t �|�}|S )N� __globals__c s* g | ]"}t j|j|j|jt|� �d ��qS ))rO �kindrP rQ )�inspect� ParameterrO r� rP �get_typed_annotation�rp rK ��globalnsrG rH � <listcomp>� s ��z'get_typed_signature.<locals>.<listcomp>)r� � signature�getattr� parameters�values� Signature)rW r� Z typed_paramsZtyped_signaturerG r� rH �get_typed_signature� s � r� )rK r� r; c C s( | j }t|t�r$t|�}t|||�}|S rm )rQ r? �strr- r. )rK r� rQ rG rG rH r� s r� T)rO rJ rX )rL rW rO rJ rX r; c C sP t | �}t|�}|j}t||| ||d�}|�� D �]\} } t| jtj�rdt | | |d�} |j � | � q0t | |d�rrq0t | tj| d�} | |v r�t| d�s�J d��t| jtj� } t | | tjtjj| d�} t| |d� q0t| d�r�t| |d� q0t| jtjtjf��rt| ��rt| |d� q0| j}t|tj��s>J d | j� d ���|j� | � q0|S ) N)rW rO rL rJ rX )rK rL rJ �rK ra )rK �default_field_info� param_name�r: z1Path params must be of one of the supported types)rK r� r� � force_type�ignore_default)r: ra zParam: z) can only be a request body, using Body())r r� r� r �itemsr? rP r �DependsrS ri r\ �!add_non_field_param_to_dependency�get_param_fieldZQueryrn �Path� ParamTypesrL �add_param_to_fields�Headerr~ r> rz rO rf )rL rW rO rJ rX Zpath_param_namesZendpoint_signatureZsignature_paramsra r� rK r] Z param_fieldr� r> rG rG rH rZ sj �� ���� ��� �rZ )rK ra r; c C s� t | jt�r| j|_dS t | jt�r0| j|_dS t | jt�rH| j|_dS t | jt �r`| j|_ dS t | jt �rx| j|_ dS t | jt �r�| j|_dS d S )NT)r/ rQ r7 rO �request_param_namer9 �websocket_param_namer6 �http_connection_param_namer8 �response_param_namer0 �background_tasks_param_namer �security_scopes_param_namer� rG rG rH r� I s& r� )r� r� r� )rK r� r� r� r� r; c C sF t }d}| j| jks"|du r"| j}t|t�rjd}|}|j}t|tj�r^t|dd �d u r^|j|_|rt||_n ||d�}d}|t u s�|r�d}d }n |t ur�d}t } | j | jks�| j } t | ||�} |j s�t|dd �r�| j�dd�} n |j p�| j} t| j| || ||d�} |�s t| d ��s t�|j�| _|�sBt| jt��rBt�|j�| _| S ) NFT�in_�rP Zconvert_underscores�_�-)rO ru rP �alias�requiredr> r� )r+ rP �emptyr? r( r �Paramr� r� r* r rQ r, r� rO �replacer rn rz r> r/ ru r5 �File) rK r� r� r� r� � default_valueZ had_schemar> r� rQ r� r: rG rG rH r� a sT �� �r� )r: ra r; c C s� t tj| j�}|jtjjkr*|j�| � nb|jtjj krF|j �| � nF|jtjj krb|j �| � n*|jtjj ks�J d| j� ���|j�| � d S )Nz>non-body parameters must be in path, query, header or cookie: )r r r� r> r� r� rL rb r\ �queryrc �headerrd �cookierO re )r: ra r> rG rG rH r� � s � �r� c C s8 t �| �rt �| �S t �| �r"dS t| dd �} t �| �S )NF�__call__)r� � isroutine�iscoroutinefunction�isclassr� �rW rG rG rH �is_coroutine_callable� s r� c C s$ t �| �rdS t| dd �} t �| �S �NTr� )r� �isasyncgenfunctionr� r� rG rG rH �is_async_gen_callable� s r� c C s$ t �| �rdS t| dd �} t �| �S r� )r� �isgeneratorfunctionr� r� rG rG rH �is_gen_callable� s r� )rW �stack� sub_valuesr; c � sJ t | �r tt| �f i |���}nt| �r:t| �f i |��}|�|�I d H S rm )r� r r r� r �enter_async_context)rW r� r� �cmrG rG rH �solve_generator� s r� )�body�background_tasks�response� dependency_overrides_provider�dependency_cache)�requestra r� r� r� r� r� r; c � s( i }g }|d u r$t � }|jd= d |_|p*i }|jD �]�} ttdtf | j�| _tttdtf tt f | j �| _ | j} | } |r�|j r�| j} t |di �� | | �} | j} t| | | j| jd�} t| | |||||d�I d H }|\}}}}}|�|� |r�|�|� q2| j�r | j |v �r || j }n|t| ��s0t| ��rb| j� d�}t|t��sLJ �t| ||d�I d H }n6t | ��r�| f i |��I d H }nt | fi |��I d H }| jd u�r�||| j< | j |vr2||| j < q2t |j | j �\}}t |j | j �\}}t |j!| j�\}}t |j"| j#�\}} |�|� |�|� |�|� |�|� ||| | | 7 }|j$�r|t%|j$|d�I d H \} } |�| � |�| � |j&�r�| ||j&< |j'�r�t| t(��r�| ||j'< n |j)�r�t| t*��r�| ||j)< |j+�r�|d u �r�t,� }|||j+< |j-�r |||j-< |j.�rt/|jd �||j.< |||||fS ) Nzcontent-length.�dependency_overrides)rL rW rO rJ )r� ra r� r� r� r� r� Zfastapi_astack)rW r� r� )�required_params� received_body)rV )0r8 �headers� status_coderi r r r rW r r� rg r� r� �getrL rZ rO rJ �solve_dependencies�updaterY rX r� r� �scoper? r r� r� r1 �request_params_to_argsrb rc rd re �cookiesrf �request_body_to_argsr� r� r7 r� r9 r� r0 r� r� r ) r� ra r� r� r� r� r� r� �errorsr] rW Zuse_sub_dependantZ original_callZuse_pathZ solved_resultr� Z sub_errorsr� Zsub_dependency_cacheZsolvedr� Z path_valuesZ path_errorsZ query_valuesZ query_errors� header_valuesZ header_errorsZ cookie_valuesZ cookie_errorsZ body_valuesZ body_errorsrG rG rH r� � s� ������� � � ���� � � � r� )r� �received_paramsr; c C s� i }g }| D ]�}t |�r:t|ttf�r:|�|j�p6|j}n |�|j�}|j}t|t j �s`J d��|d u r�|j r�|� t t� |jj|jfd�� q t|j�||j< q |j|||jj|jfd�\}}t|t �r�|� |� q t|t�r�|�|� q |||j< q ||fS )Nz"Params must be subclasses of Param��loc)r~ r? r4 r3 �getlistr� rP r� r> r r� r� r\ r r r� �valuer rO �validate�listrY ) r� r� r� r� r: r� r> �v_�errors_rG rG rH r� H s@ � ����� r� )r� r� r; c � s� i }g }| �r�| d }|j }t|dd �}t| �dko8| }|rH|j|i}| D �]D}|r\d}n d|jf}d } |d ur�|jtv s�|jtv r�t|t �r�|� |j�} n6z|� |j�} W n$ t y� |� t|�� Y qLY n0 | d u �s t|tj�r�| dk�s t|tj��rF|jtv �rFt| �dk�rF|j�r4|� t|�� qLt|j�||j< qLt|tj��r~t|jt��r~t| t��r~| �� I d H } n�|jtv �rDt|tj��rDt|jt��rDt| t��rDg � tg tt t t f f d d�� fdd � } t � � 4 I d H �2} | D ]} | � | | j� �q�W d �I d H �q61 I d H �s,0 Y t |j � �} |j!| ||d �\} }t|t"��rp|� |� qLt|t#��r�|�$|� qL| ||j< qL||fS ) Nr �embed� )r� r� � )�fnr; c � s | � I d H }� � |� d S rm )r\ )r� �result��resultsrG rH � process_fn� s z(request_body_to_args.<locals>.process_fnr� )%r> r� �lenr� rt r} ru rv r? r2 r� r� �AttributeErrorr\ �get_missing_field_errorr r@ r� r rP rO r� r/ �bytesr5 �readr r r �anyioZcreate_task_groupZ start_soon�sequence_shape_to_typer� r r� rY )r� r� r� r� r: r> r� Zfield_alias_omittedr� r� r� �tgZ sub_valuer� r� rG r� rH r� o s� ��� � �� �� � � ��� � ���@ r� )r� r; c C s t t� | d�}|S )Nr� )r r )r� Zmissing_field_errorrG rG rH r� � s r� )ra rO r; c C sN t | �}|jsd S |jd }|j}t|dd �}dd� |jD �}t|�dkrZ|sZt|� |S |jD ]}t|jdd� q`d| }t|�} |jD ]} | | j| j < q�t dd � |jD ��} t d d �} t d d � |jD ��r�t j } nPt d d � |jD ��r�t j} n4t j} d d� |jD �}tt|��dk�r&|d | d< td| | d| f i | ��d�}t|� |S )Nr r� c S s h | ] }|j �qS rG )rO r� rG rG rH � <setcomp>� rs z!get_body_field.<locals>.<setcomp>r� TZBody_c s s | ]}|j rd V qdS )TN)r� ro rG rG rH rr � rs z!get_body_field.<locals>.<genexpr>r� c s s | ]}t |jtj�V qd S rm )r? r> r r� ro rG rG rH rr � rs c s s | ]}t |jtj�V qd S rm )r? r> r r@ ro rG rG rH rr � rs c S s& g | ] }t |jtj�rt|jd ��qS )� media_type)r? r> r rz r� ro rG rG rH r� � s �z"get_body_field.<locals>.<listcomp>r� r� )rO ru r� r� r> )rj rf r> r� r� rI �setattrr Z __fields__rO �anyrw r r� r@ rz �setr )ra rO rk Z first_paramr> r� Zbody_param_names_setrK Z model_nameZ BodyModelrq r� ZBodyFieldInfo_kwargsZ BodyFieldInfoZbody_param_media_typesZ final_fieldrG rG rH �get_body_field� sJ � �r� )zrx r� � contextlibr rh r �typingr r r r r r r r r r r r r� Zfastapir Zfastapi.concurrencyr r r Zfastapi.dependencies.modelsr r Zfastapi.loggerr Zfastapi.security.baser Zfastapi.security.oauth2r r Z$fastapi.security.open_id_connect_urlr Z fastapi.utilsr r Zpydanticr r Zpydantic.error_wrappersr Zpydantic.errorsr Zpydantic.fieldsr! r" r# r$ r% r& r' r( r) r* r+ Zpydantic.schemar, Zpydantic.typingr- r. Zpydantic.utilsr/ Zstarlette.backgroundr0 Zstarlette.concurrencyr1 Zstarlette.datastructuresr2 r3 r4 r5 Zstarlette.requestsr6 r7 Zstarlette.responsesr8 Zstarlette.websocketsr9 r} r� r� �tuplerv r� rF rD rI r� r� rS r� rU rR ZCacheKey�boolrj rl rn r~ r� r� r� rZ r� r� r� r� r� r� r� r� r� r� r� r� r� r� rG rG rG rH �<module> s 8 4 � � �� �� � � � � # � � ;� �� 7 � � " ��� � (� S
cải xoăn