OwlCyberSecurity - MANAGER
Edit File: wsgi.cpython-39.pyc
a ���e� � @ sH d dl mZ d dlmZ d dlmZmZ G dd� d�ZG dd� d�ZdS ) � )�BytesIO)�SpooledTemporaryFile)� AsyncToSync� sync_to_asyncc @ s e Zd ZdZdd� Zdd� ZdS )� WsgiToAsgizG Wraps a WSGI application to make it into an ASGI application. c C s || _ d S )N)�wsgi_application��selfr � r �M/home/gouroczh/virtualenv/pat/3.9/lib/python3.9/site-packages/asgiref/wsgi.py�__init__ s zWsgiToAsgi.__init__c � s t | j�|||�I dH dS )z� ASGI application instantiation point. We return a new WsgiToAsgiInstance here with the WSGI app and the scope, ready to respond when it is __call__ed. N)�WsgiToAsgiInstancer )r �scope�receive�sendr r r �__call__ s zWsgiToAsgi.__call__N)�__name__� __module__� __qualname__�__doc__r r r r r r r s r c @ s> e Zd ZdZdd� Zdd� Zdd� Zd d d �Zed d � �Z dS )r z; Per-socket instance of a wrapped WSGI application c C s || _ d| _d | _d S )NF)r �response_started�response_content_lengthr r r r r s zWsgiToAsgiInstance.__init__c � s� |d dkrt d��|| _tdd��t}|� I d H }|d dkrFt d��|�|�dd �� |�d �s&qfq&|�d � t|�| _| �|�I d H W d � n1 s�0 Y d S ) N�type�httpz&WSGI wrapper received a non-HTTP scopei )�max_sizez http.requestz0WSGI wrapper received a non-HTTP-request message�body� � more_bodyr ) � ValueErrorr r �write�get�seekr � sync_send� run_wsgi_app)r r r r r �messager r r r " s zWsgiToAsgiInstance.__call__c C s: |d |� dd��d��d�|d �d��d�|d �d�d |d d |� d d �|t� dddd� }d|v r�|d d |d< t|d d �|d< nd|d< d|d< d|v r�|d d |d< | j� dg �D ]n\}}|�d�}|dkr�d }n"|d kr�d }nd |�� �d d!� }|�d�}||v �r,|| d" | }|||< q�|S )#zM Builds a scope and request body into a WSGI environ object. �method� root_path� �utf8�latin1�pathZ query_string�asciizHTTP/%s� http_version)� r �schemer TF) �REQUEST_METHODZ SCRIPT_NAMEZ PATH_INFOZ QUERY_STRINGZSERVER_PROTOCOLz wsgi.versionzwsgi.url_schemez wsgi.inputz wsgi.errorszwsgi.multithreadzwsgi.multiprocessz wsgi.run_once�serverr Z SERVER_NAMEr- Z SERVER_PORT� localhost�80�clientZ REMOTE_ADDR�headers�content-lengthZCONTENT_LENGTHz content-typeZ CONTENT_TYPEzHTTP_%s�-�_�,)r �encode�decoder �strr �upper�replace)r r r �environ�name�valueZcorrected_namer r r � build_environ5 s@ � z WsgiToAsgiInstance.build_environNc C s� | j r|d �|d ��t| d�r2|du r2td��|�dd�\}}t|�}dd� |D �}d| _|D ] \}}|�� d krbt|�| _qbd ||d �| _dS ) z/ WSGI start_response callable. r- � �response_startNz=You cannot call start_response a second time without exc_info� c S s( g | ] \}}|� � �d �|�d �f�qS )r+ )�lowerr9 )�.0r? r@ r r r � <listcomp>r s �z5WsgiToAsgiInstance.start_response.<locals>.<listcomp>r5 zhttp.response.start)r �statusr4 ) r �with_traceback�hasattrr �split�intr rE rC ) r rH �response_headers�exc_info� status_coder7 r4 r? r@ r r r �start_responseb s& �� �z!WsgiToAsgiInstance.start_responsec C s� | � | j|�}d}| �|| j�D ]t}| js<d| _| �| j� | jdurh| j| }t|�|krh|d|� }| �d|dd�� |t|�7 }|| jkr q�q | js�d| _| �| j� | �ddi� dS )z� Called in a subthread to run the WSGI app. We encapsulate like this so that the start_response callable is called in the same thread. r TNzhttp.response.body)r r r r ) rA r r rP r r" rC r �len)r r r> Z bytes_sent�outputZ bytes_allowedr r r r# � s( � z WsgiToAsgiInstance.run_wsgi_app)N) r r r r r r rA rP r r# r r r r r s - r N) �ior �tempfiler Z asgiref.syncr r r r r r r r �<module> s