File: //usr/lib/python3/dist-packages/asgiref/__pycache__/wsgi.cpython-310.pyc
o
�6�a� � @ 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 �./usr/lib/python3/dist-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 dkr t d��|| _tdd��<} |� I d H }|d dkr%t d��|�|�d d
�� |�d �s4nq|�d � t|�| _| �|�I d H W d � d S 1 sRw Y d S )
N�type�httpz&WSGI wrapper received a non-HTTP scopei )�max_sizeTz 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 s8 |d |� dd��d��d�|d �d��d�|d �d�d |d
d |� d d
�|t� dddd� }d|v rH|d d |d< t|d d �|d< nd|d< d|d< d|v r\|d d |d< | j� dg �D ]6\}}|�d�}|dkrsd }n|d krzd }n
d |�� �d d!� }|�d�}||v r�|| d" | }|||< qc|S )#zM
Builds a scope and request body into a WSGI environ object.
�method� root_path� �utf8�latin1�path� query_string�asciizHTTP/%s� http_version)� r �schemer TF) �REQUEST_METHOD� SCRIPT_NAME� PATH_INFO� QUERY_STRING�SERVER_PROTOCOLz wsgi.versionzwsgi.url_schemez
wsgi.inputz wsgi.errorszwsgi.multithreadzwsgi.multiprocessz
wsgi.run_once�serverr � SERVER_NAMEr/ � SERVER_PORT� localhost�80�client� REMOTE_ADDR�headers�content-length�CONTENT_LENGTHz content-type� CONTENT_TYPEzHTTP_%s�-�_�,)r! �encode�decoder �strr �upper�replace)r
r r �environ�name�value�corrected_namer r r �
build_environ5 s@
�
z WsgiToAsgiInstance.build_environNc C s� | j r |d �|d ��t| d�r|du rtd��|�dd�\}}t|�}dd� |D �}d| _|D ]\}}|�� d kr@t|�| _q1d
||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- )�lowerrD )�.0rJ rK r r r �
<listcomp>r s ��z5WsgiToAsgiInstance.start_response.<locals>.<listcomp>r> zhttp.response.start)r �statusr= ) r �with_traceback�hasattrr �split�intr rQ rO ) r
rT �response_headers�exc_info� status_coderB r= rJ rK r r r �start_responseb s( ��
� �z!WsgiToAsgiInstance.start_responsec C s� | � | j|�}d}| �|| j�D ]:}| js d| _| �| j� | jdur4| j| }t|�|kr4|d|� }| �d|dd�� |t|�7 }|| jkrJ nq| jsWd| _| �| 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 ) rM r r r\ r r# rO r �len)r
r rI �
bytes_sent�output�
bytes_allowedr r r r$ � s*
�
� z WsgiToAsgiInstance.run_wsgi_appr )
r r r r r
r rM r\ r r$ r r r r r s
- r N) �ior �tempfiler � asgiref.syncr r r r r r r r �<module> s