OwlCyberSecurity - MANAGER
Edit File: asgi.cpython-39.pyc
a kH�f#/ � @ s� d dl Z d dlZd dlZd dlZd dlmZmZ d dlmZ d dl m Z d dl m Z m Z d dlmZ d dlmZmZmZmZmZmZmZ d dlmZ d d lmZ d d l m Z e � d �Z G d d � d e�Z G dd� dej!�Z"dS )� N)�ThreadSensitiveContext� sync_to_async)�settings)�signals)�RequestAborted�RequestDataTooBig)�base)� FileResponse� HttpRequest� HttpResponse�HttpResponseBadRequest�HttpResponseServerError� QueryDict� parse_cookie)�set_script_prefix)�aclosing)�cached_propertyzdjango.requestc sz e Zd ZdZdZdd� Zedd� �Z� fdd�Zd d � Z d d � Z d d� Z e e e �Z e e �Zedd� �Z� fdd�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�| _| jrX|d �| j�rX|d t| j�d � | _n |d | _| jr�d| j� d�| j� ddd�f | _ n |d | _ | j d � � | _ | j �d d�}t|t�r�|�� }| j || j| jd d d �| _| j �d ��r&| j d d | jd< | jd | jd< | j d d | jd< | j �d��rb| j d d | jd< t| j d d �| jd< nd| jd< d| jd< | j �dg �D ]z\}}|�d�}|dk�r�d}n$|dk�r�d}nd |� � � 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_STRINGZ SCRIPT_NAMEZ PATH_INFOzwsgi.multithreadzwsgi.multiprocess�clientr Z REMOTE_ADDRZ REMOTE_HOSTZ REMOTE_PORT�serverZ SERVER_NAMEZ SERVER_PORT�unknown�0�headers�latin1zcontent-lengthZCONTENT_LENGTHz content-typeZ CONTENT_TYPEzHTTP_%s�-�_�,)�scopeZ_post_parse_errorZ _read_startedZresolver_match�get� script_name� startswith�lenZ path_info�rstrip�replacer �upperr � isinstance�bytes�decode�META�strZ_set_content_type_params�_stream)�selfr' � body_filer �name�valueZcorrected_name� r9 �[/home/gouroczh/virtualenv/test/3.9/lib/python3.9/site-packages/django/core/handlers/asgi.py�__init__& s` � � zASGIRequest.__init__c C s t | jd �S )Nr )r r2 �r5 r9 r9 r: �GETi s zASGIRequest.GETc s | j �d�pt� �� S )N�scheme)r' r( �super� _get_schemer< �� __class__r9 r: r@ m s zASGIRequest._get_schemec C s t | d�s| �� | jS )N�_post)�hasattr�_load_post_and_filesrC r< r9 r9 r: � _get_postp s zASGIRequest._get_postc C s || _ d S �N)rC )r5 �postr9 r9 r: � _set_postu s zASGIRequest._set_postc C s t | d�s| �� | jS )N�_files)rD rE rJ r< r9 r9 r: � _get_filesx s zASGIRequest._get_filesc C s t | j�dd��S )NZ HTTP_COOKIEr )r r2 r( r< r9 r9 r: �COOKIES� s zASGIRequest.COOKIESc s t � �� | j�� d S rG )r? �closer4 r< rA r9 r: rM � s zASGIRequest.close)�__name__� __module__� __qualname__�__doc__Zbody_receive_timeoutr; r r= r@ rF rI rK �property�POSTZFILESrL rM � __classcell__r9 r9 rA r: r s C r c sp e Zd ZdZeZdZ� fdd�Zdd� Zdd� Z d d � Z d d � Z � fd d�Z dd� Z edd� �Zdd� Z� ZS )� ASGIHandlerzHandler for ASGI requests.i c s t � �� | jdd� d S )NT)�is_async)r? r; Zload_middlewarer< rA r9 r: r; � s zASGIHandler.__init__c � sn |d dkr t d|d ��t� 4 I dH �* | �|||�I dH W d �I dH qj1 I dH s`0 Y dS )zV Async entrypoint - parses the request and hands off to get_response. �type�httpz5Django can only handle ASGI/HTTP connections, not %s.N)� ValueErrorr �handle)r5 r' �receive�sendr9 r9 r: �__call__� s �zASGIHandler.__call__c � s� z| � |�I dH }W n ty( Y dS 0 t| �|�� ttjjdd�| j|d�I dH | � ||�\}}|du r�|� � | � ||�I dH dS | � |�I dH }| j|_ t|t�r�| j|_| � ||�I dH dS )zK Handles the ASGI request. Called via the __call__ method. NT�Zthread_sensitive)Zsenderr' )� read_bodyr r �get_script_prefixr r Zrequest_startedr\ rB �create_requestrM � send_responseZget_response_asyncZ_handler_classr/ r � chunk_size� block_size)r5 r' r[ r\ r6 �requestZerror_response�responser9 r9 r: rZ � s$ � zASGIHandler.handlec � sj t jtjdd�}|� I dH }|d dkr6|�� t� �d|v rL|�|d � |�dd�sq\q|�d � |S ) z+Reads an HTTP body from an ASGI connection.zw+b)�max_size�modeNrW zhttp.disconnect�body� more_bodyFr ) �tempfile�SpooledTemporaryFiler ZFILE_UPLOAD_MAX_MEMORY_SIZErM r �writer( �seek)r5 r[ r6 �messager9 r9 r: r_ � s � zASGIHandler.read_bodyc C sl z| � ||�dfW S tyF tjdt�� ddid� dt� f Y S tyf dtddd�f Y S 0 dS ) 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�sysrq r r r )r5 r' r6 r9 r9 r: ra � s � zASGIHandler.create_requestc sD zt � �|||�W S ty> ttjr0t�� nddd� Y S 0 dS )z#Last-chance handler for exceptions.zInternal Server Errorz text/plain)� content_typeN)r? �handle_uncaught_exception� Exceptionr r �DEBUG� traceback� format_exc)r5 re �resolverrq rA r9 r: rz � s �z%ASGIHandler.handle_uncaught_exceptionc � s� g }|� � D ]F\}}t|t�r(|�d�}t|t�r<|�d�}|�t|�t|�f� q |j�� D ]$}|�d|jdd��d�� � f� q^|d|j |d��I dH |j �r:t |� � �4 I dH �V}|2 z63 dH W }| �|�D ] \} } |d | d d ��I dH q�q�6 W d �I dH �q&1 I dH �s 0 Y |d d i�I dH n0| �|j�D ]"\} } |d | | d ��I dH �qFt|jd d �� I dH dS )z)Encode and send a response out over ASGI.�asciir# s Set-Cookier )�headerzhttp.response.start)rW rs r" Nzhttp.response.bodyT)rW ri rj rW r^ )�itemsr/ r3 �encode�appendr0 �cookies�values�output�striprp Z streamingr � __aiter__� chunk_bytes�contentr rM ) r5 rf r\ �response_headersr� r8 �cr� �part�chunkr% �lastr9 r9 r: rb � sH ��� ��> ��zASGIHandler.send_responsec c sX d}|s|dfV dS |t |�k rT|||| j � || j t |�kfV || j7 }qdS )z Chunks some data up so it can be sent in reasonable size messages. Yields (chunk, last_chunk) tuples. r TN)r+ rc )�cls�data�positionr9 r9 r: r� * s �zASGIHandler.chunk_bytesc C s t jr t jS |�dd�pdS )zU Return the script prefix to use from either the scope or a setting. r r )r ZFORCE_SCRIPT_NAMEr( )r5 r' r9 r9 r: r` ; s z ASGIHandler.get_script_prefix)rN rO rP rQ r rt rc r; r] rZ r_ ra rz rb � classmethodr� r` rT r9 r9 rA r: rU � s 8 rU )#�loggingrx rk r} Z asgiref.syncr r Z django.confr Z django.corer Zdjango.core.exceptionsr r Zdjango.core.handlersr Z django.httpr r r r r r r Z django.urlsr Zdjango.utils.asyncior Zdjango.utils.functionalr � getLoggerrv r � BaseHandlerrU r9 r9 r9 r: �<module> s $ m