File: //usr/local/CyberCP/lib/python3.10/site-packages/starlette/__pycache__/formparsers.cpython-310.pyc
o
�h%+ � @ s< d dl mZ d dlZd dlmZmZ d dlmZ d dlm Z d dl
m Z d dl m
Z
mZmZ ejr@d dlZd dlmZmZmZ n0z"z d dlZd d lmZ W n ey` d dlZd d lmZ Y nw W n
eyo dZdZY nw G d
d � d e�ZeG d d
� d
��Zddd�ZG dd� de �Z G dd� d�Z G dd� d�Z dS ) � )� annotationsN)� dataclass�field)�Enum)�SpooledTemporaryFile)� unquote_plus)�FormData�Headers�
UploadFile)�MultipartCallbacks�QuerystringCallbacks�parse_options_header)r
c @ s e Zd ZdZdZdZdZdZdS )� FormMessage� � � � � N)�__name__�
__module__� __qualname__� FIELD_START�
FIELD_NAME�
FIELD_DATA� FIELD_END�END� r r �H/usr/local/CyberCP/lib/python3.10/site-packages/starlette/formparsers.pyr s r c @ sV e Zd ZU dZded< dZded< eed�Zded < dZ d
ed < ee
d�Z d ed
< dS )�
MultipartPartNz bytes | None�content_disposition� �str�
field_name)�default_factory� bytearray�datazUploadFile | None�filezlist[tuple[bytes, bytes]]� item_headers) r r r r �__annotations__r" r r$ r% r& �listr' r r r r r # s
r �src�bytes | bytearray�codecr! �returnc C s. z| � |�W S ttfy | � d� Y S w )N�latin-1)�decode�UnicodeDecodeError� LookupError)r* r, r r r �_user_safe_decode, s
�r2 c @ s e Zd Zddd�ZdS ) �MultiPartException�messager! r- �Nonec C s
|| _ d S �N)r4 ��selfr4 r r r �__init__4 s
zMultiPartException.__init__N)r4 r! r- r5 )r r r r9 r r r r r3 3 s r3 c @ sR e Zd Zd dd�Zd d d
�Zd dd�Zd dd�Zd dd�Zd dd�Zd dd�Z dS ) �
FormParser�headersr �stream�"typing.AsyncGenerator[bytes, None]r- r5 c C s& t d usJ d��|| _|| _g | _d S )N�EThe `python-multipart` library must be installed to use form parsing.)� multipartr; r< �messages)r8 r; r< r r r r9 9 s
zFormParser.__init__c C � t jdf}| j�|� d S �N� )r r r@ �appendr7 r r r �on_field_start? �
zFormParser.on_field_startr% �bytes�start�int�endc C �" t j|||� f}| j�|� d S r6 )r r r@ rD �r8 r% rH rJ r4 r r r �
on_field_nameC � zFormParser.on_field_namec C rK r6 )r r r@ rD rL r r r �
on_field_dataG rN zFormParser.on_field_datac C rA rB )r r r@ rD r7 r r r � on_field_endK rF zFormParser.on_field_endc C rA rB )r r r@ rD r7 r r r �on_endO rF zFormParser.on_endr c � s� �| j | j| j| j| jd�}t�|�}d}d}g }| j2 z[3 d H W }|r*|�|� n|� � t
| j �}| j � � |D ]<\}} |t
jkrHd}d}q:|t
jkrR|| 7 }q:|t
jkr\|| 7 }q:|t
jkrvt|�d��}
t|�d��} |�|
| f� q:q 6 t|�S )N)rE rM rO rP rQ rC r. )rE rM rO rP rQ r? �QuerystringParserr< �write�finalizer) r@ �clearr r r r r r r/ rD r ) r8 � callbacks�parserr" � field_value�items�chunkr@ � message_type�
message_bytes�name�valuer r r �parseS sB ��
���zFormParser.parseN)r; r r< r= r- r5 �r- r5 �r% rG rH rI rJ rI r- r5 �r- r )
r r r r9 rE rM rO rP rQ r_ r r r r r: 8 s
r: c @ s� e Zd ZdZ dZ dddd�d)dd�Zd*dd�Zd+dd�Zd*dd�Zd+dd �Z d+d d �Z
d*d d �Z d*d!d"�Z d*d#d$�Z
d,d&d'�Zd(S )-�MultiPartParseri i� )� max_files�
max_fields�
max_part_sizer; r r< r= rd � int | floatre rf rI r- r5 c C sp t d usJ d��|| _|| _|| _|| _g | _d| _d| _d| _d| _ t
� | _ d| _ g | _
g | _g | _|| _d S )Nr> r rC r )r? r; r< rd re rY �_current_files�_current_fields� _current_partial_header_name� _current_partial_header_valuer �
_current_part�_charset�_file_parts_to_write�_file_parts_to_finish�_files_to_close_on_errorrf )r8 r; r< rd re rf r r r r9 � s
zMultiPartParser.__init__c C s t � | _d S r6 )r rl �r8 r r r �
on_part_begin� s z MultiPartParser.on_part_beginr% rG rH rJ c C st |||� }| j jd u r/t| j j�t|� | jkr&tdt| jd �� d���| j j�|� d S | j� | j |f� d S )Nz Part exceeded maximum size of i zKB.)
rl r& �lenr% rf r3 rI �extendrn rD )r8 r% rH rJ r\ r r r � on_part_data� s z MultiPartParser.on_part_datac C sZ | j jd u r| j�| j jt| j j| j�f� d S | j�| j � | j�| j j| j jf� d S r6 ) rl r& rY rD r" r2 r% rm ro rq r r r � on_part_end� s �� zMultiPartParser.on_part_endc C � | j |||� 7 _ d S r6 )rj �r8 r% rH rJ r r r �on_header_field� � z MultiPartParser.on_header_fieldc C rw r6 )rk rx r r r �on_header_value� rz z MultiPartParser.on_header_valuec C s@ | j �� }|dkr| j| j_| jj�|| jf� d| _ d| _d S )Ns content-dispositionrC )rj �lowerrk rl r r' rD )r8 r r r r �
on_header_end� s
z MultiPartParser.on_header_endc C s� t | jj�\}}z t|d | j�| j_W n ty td��w d|v r_| jd7 _| j| j kr:td| j � d���t|d | j�}t
| j d�}| j �
|� t|d|t| jjd �d
�| j_d S | jd7 _| j| jkrutd | j� d���d | j_d S ) Ns namez=The Content-Disposition header field "name" must be provided.s filenamer z+Too many files. Maximum number of files is �.)�max_sizer )�raw)r& �size�filenamer; z-Too many fields. Maximum number of fields is )r
rl r r2 rm r" �KeyErrorr3 rh rd r �spool_max_sizerp rD r
r r' r& ri re )r8 � disposition�optionsr� �tempfiler r r �on_headers_finished� s. � � z#MultiPartParser.on_headers_finishedc C s d S r6 r rq r r r rQ � s zMultiPartParser.on_endr c
� s` �t | jd �\}}|�dd�}t|t�r|�d�}|| _z|d }W n ty. td��w | j | j
| j | j | j
| j| j| jd�}t�||�}zF| j2 z?3 d H W }|�|� | jD ]\}} |jscJ �|j�| �I d H qZ| jD ]}|jswJ �|j�d�I d H qp| j�� | j�� qL6 W n ty� }
z | jD ]} | �� q�|
�d }
~
ww |� � t | j �S ) Nz Content-Types charsetzutf-8r. s boundaryz Missing boundary in multipart.)rr ru rv ry r{ r} r� rQ r ) r
r; �get�
isinstancerG r/ rm r� r3 rr ru rv ry r{ r} r� rQ r? �MultipartParserr< rS rn r& ro �seekrU rp �closerT r rY ) r8 �_�params�charset�boundaryrV rW rZ �partr% �excr& r r r r_ � sR �
��
�
��
zMultiPartParser.parseN) r; r r< r= rd rg re rg rf rI r- r5 r` ra rb )r r r r� rf r9 rr ru rv ry r{ r} r� rQ r_ r r r r rc | s$ �
rc )r* r+ r, r! r- r! ) �
__future__r �typing� dataclassesr r �enumr r� r � urllib.parser �starlette.datastructuresr r r
�
TYPE_CHECKING�python_multipartr? �python_multipart.multipartr r r
�ModuleNotFoundError�multipart.multipartr r r2 � Exceptionr3 r: rc r r r r �<module> s< �� �
D