File: //usr/local/CyberPanel/lib64/python3.10/site-packages/asgiref/__pycache__/wsgi.cpython-310.pyc
o
��ha � @ 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 �B/usr/local/CyberPanel/lib/python3.10/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 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 s` |� dd��d��d�}|d �d��d�}|�|�r#|t|�d� }|d |||d �d �d
|d d |� d
d�|t� dddd� }d|v rY|d d |d< t|d d �|d< nd|d< d|d< |� d�durp|d d |d< | j� dg �D ]6\}}|�d�}|d kr�d }n|d kr�d }n
d |�� � d!d"� }|�d�}||v r�|| d# | }|||< qw|S )$zM
Builds a scope and request body into a WSGI environ object.
� root_path� �utf8�latin1�pathN�method� 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�decode�
startswith�lenr �strr �upper�replace) r
r r � script_name� path_info�environ�name�value�corrected_namer r r �
build_environ5 sH
�
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 )�.0rN rO r r r �
<listcomp>v s ��z5WsgiToAsgiInstance.start_response.<locals>.<listcomp>r> zhttp.response.start)r �statusr= ) r �with_traceback�hasattrr �split�intr rU rS ) r
rX �response_headers�exc_info� status_coderB r= rN rO r r r �start_responsef 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 ) rQ r r r` r r# rS r rG )r
r rM �
bytes_sent�output�
bytes_allowedr r r r$ � s*
�
� z WsgiToAsgiInstance.run_wsgi_appr )
r r r r r
r rQ r` r r$ r r r r r s
1 r N) �ior �tempfiler � asgiref.syncr r r r r r r r �<module> s