Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
lib
/
python3
/
dist-packages
/
asgiref
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: 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
Save
Cancel