File: //usr/lib/python3/dist-packages/django/core/handlers/__pycache__/asgi.cpython-310.pyc
o
3�a�+ � @ s� d dl Z d dlZd dlZd dlZd dlmZ d dlmZ d dlm Z d dl
m Z m Z d dl
mZ d dlmZmZmZmZmZmZmZ d dlmZ d d lmZ e �d
�Z G d d � d e�Z G d
d� dej �Z dS )� N)�
sync_to_async)�settings)�signals)�RequestAborted�RequestDataTooBig)�base)� FileResponse� HttpRequest� HttpResponse�HttpResponseBadRequest�HttpResponseServerError� QueryDict� parse_cookie)�set_script_prefix)�cached_propertyzdjango.requestc sn e Zd ZdZdZdd� Zedd� �Z� fdd�Zd d
� Z d d � Z
d
d� Z e e e
�Z
e e �Zedd� �Z� ZS )� ASGIRequestzv
Custom request subclass that decodes from an ASGI-standard request dict
and wraps request body handling.
�< c C s || _ d| _d| _d | _| j �dd�| _| jr,|d �| j�r,|d t| j�d � | _n|d | _| jrFd| j� d�| j�
ddd�f | _ n|d | _ | j d � � | _
| j �d d�}t|t�rc|�� }| j
|| j| jd
d
d �| _| j �d �r�| j d d
| jd< | jd | jd< | j d d | jd< | j �d�r�| j d d
| jd< t| j d d �| jd< n
d| jd< d| jd< | j �dg �D ]9\}}|�d�}|dkr�d}n|dkr�d}n
d |� � �
d d � }|�d�}|| jv r�| j| d | }|| j|< q�| �| j� || _d | _d S ) NF� root_path� �pathz%s/%s�/� �method� query_stringT)�REQUEST_METHOD� QUERY_STRING� SCRIPT_NAME� PATH_INFOzwsgi.multithreadzwsgi.multiprocess�clientr � REMOTE_ADDR� REMOTE_HOST� REMOTE_PORT�server� SERVER_NAME� SERVER_PORT�unknown�0�headers�latin1zcontent-length�CONTENT_LENGTHz content-type� CONTENT_TYPEzHTTP_%s�-�_�,)�scope�_post_parse_error�
_read_started�resolver_match�get� script_name�
startswith�len� path_info�rstrip�replacer �upperr �
isinstance�bytes�decode�META�str�_set_content_type_params�_stream)�selfr. � body_filer �name�value�corrected_name� rF �;/usr/lib/python3/dist-packages/django/core/handlers/asgi.py�__init__ s`
�
�
zASGIRequest.__init__c C s t | jd �S )Nr )r
r= �rA rF rF rG �GETb s zASGIRequest.GETc s | j �d�p
t� �� S )N�scheme)r. r2 �super� _get_schemerI �� __class__rF rG rM f s zASGIRequest._get_schemec C � t | d�s | �� | jS )N�_post)�hasattr�_load_post_and_filesrQ rI rF rF rG � _get_posti �
zASGIRequest._get_postc C s
|| _ d S )N)rQ )rA �postrF rF rG � _set_postn s
zASGIRequest._set_postc C rP )N�_files)rR rS rX rI rF rF rG �
_get_filesq rU zASGIRequest._get_filesc C s t | j�dd��S )N� HTTP_COOKIEr )r r= r2 rI rF rF rG �COOKIESy s zASGIRequest.COOKIES)�__name__�
__module__� __qualname__�__doc__�body_receive_timeoutrH r rJ rM rT rW rY �property�POST�FILESr[ �
__classcell__rF rF rN rG r s C
r c sh e Zd ZdZeZdZ� fdd�Zdd� Zdd� Z d d
� Z
� fd d �Z d
d� Z e
dd� �Zdd� Z� ZS )� ASGIHandlerzHandler for ASGI requests.i c s t � �� | jdd� d S )NT)�is_async)rL rH �load_middlewarerI rN rF rG rH � s
zASGIHandler.__init__c � s� �|d dkrt d|d ��z
| �|�I dH }W n
ty# Y dS w t| �|�� ttjjdd�| j |d�I dH | �
||�\}}|du rR| � ||�I dH dS | � |�I dH }| j |_
t|t�rg| j|_| � ||�I dH dS )zV
Async entrypoint - parses the request and hands off to get_response.
�type�httpz5Django can only handle ASGI/HTTP connections, not %s.NT��thread_sensitive)�senderr. )�
ValueError� read_bodyr r �get_script_prefixr r �request_started�sendrO �create_request�
send_response�get_response_async�_handler_classr: r �
chunk_size�
block_size)rA r. �receiverq rB �request�error_response�responserF rF rG �__call__� s. � �� �
zASGIHandler.__call__c � sf �t jtjdd�} |� I dH }|d dkrt� �d|v r$|�|d � |�dd �s+nq
|�d
� |S ) z*Reads a HTTP body from an ASGI connection.zw+b)�max_size�modeTNrh zhttp.disconnect�body� more_bodyFr )�tempfile�SpooledTemporaryFiler �FILE_UPLOAD_MAX_MEMORY_SIZEr �writer2 �seek)rA rx rB �messagerF rF rG rn � s � �
zASGIHandler.read_bodyc C sh z | � ||�dfW S ty# tjdt�� ddid� dt� f Y S ty3 dtddd�f Y S w ) z�
Create the Request object and returns either (request, None) or
(None, response) if there is an error response.
Nz Bad Request (UnicodeDecodeError)� status_codei� )�exc_info�extraz413 Payload too largei� )�status) �
request_class�UnicodeDecodeError�logger�warning�sysr� r r r
)rA r. rB rF rF rG rr � s � �zASGIHandler.create_requestc s@ z t � �|||�W S ty ttjrt�� nddd� Y S w )z#Last-chance handler for exceptions.zInternal Server Errorz
text/plain)� content_type)rL �handle_uncaught_exception� Exceptionr r �DEBUG� traceback�
format_exc)rA ry �resolverr� rN rF rG r� � s
��z%ASGIHandler.handle_uncaught_exceptionc � s4 �g }|� � D ]#\}}t|t�r|�d�}t|t�r |�d�}|�t|�t|�f� q|j�� D ]}|�d|jdd��d�� � f� q0|d|j
|d��I dH |j rv|D ]}| � |�D ]\}} |d |d
d ��I dH q[qT|d d i�I dH n| � |j
�D ]\}}
|d ||
d ��I dH q|t|jd
d
�� I dH dS )z)Encode and send a response out over ASGI.�asciir( s
Set-Cookier )�headerzhttp.response.start)rh r� r' Nzhttp.response.bodyT)rh r r� rh rj )�itemsr: r> �encode�appendr; �cookies�values�output�stripr� � streaming� chunk_bytes�contentr �close) rA r{ rq �response_headersr� rD �c�part�chunkr, �lastrF rF rG rs � sD �
���� �zASGIHandler.send_responsec c sh � d}|s |dfV dS |t |�k r2|||| j � || j t |�kfV || j7 }|t |�k sdS dS )z
Chunks some data up so it can be sent in reasonable size messages.
Yields (chunk, last_chunk) tuples.
r TN)r5 rv )�cls�data�positionrF rF rG r� s �
�
�zASGIHandler.chunk_bytesc C s t jrt jS |�dd�p
dS )zU
Return the script prefix to use from either the scope or a setting.
r r )r �FORCE_SCRIPT_NAMEr2 )rA r. rF rF rG ro s z ASGIHandler.get_script_prefix)r\ r] r^ r_ r r� rv rH r| rn rr r� rs � classmethodr� ro rd rF rF rN rG re ~ s " /
re ) �loggingr� r� r� � asgiref.syncr � django.confr � django.corer �django.core.exceptionsr r �django.core.handlersr � django.httpr r r
r r r
r � django.urlsr �django.utils.functionalr � getLoggerr� r � BaseHandlerre rF rF rF rG �<module> s $
h