U
W[wU @ s d Z eZddlmZ ddlmZ ddlmZ ddl m
Z
ddl m Z m
Z
ddlmZ ddlmZ dd lmZ dd
lmZ dd lmZ eekrd d
Zdd Zndd
Zdd ZG dd dZ G dd dZ G dd dZ eeG dd dZ dgZ dS )zo
An implementation of
U{Python Web Server Gateway Interface v1.0.1}.
)exc_info)warn) implementer)blockingCallFromThread)reraiseSequence)Failure) IResource) NOT_DONE_YET)INTERNAL_SERVER_ERROR)Loggerc C s t | tr| S | dS dS )z
Convert C{string} to an ISO-8859-1 byte string, if it is not already.
@type string: C{str}/C{bytes} or C{unicode}
@rtype: C{str}/C{bytes}
@raise UnicodeEncodeError: If C{string} contains non-ISO-8859-1 chars.
iso-8859-1N)
isinstancestrencodestring r 2/usr/lib/python3/dist-packages/twisted/web/wsgi.py _wsgiString- s
r c C s | S )z
Return C{string} as is; a WSGI string is a byte string in Python 2.
@type string: C{str}/C{bytes}
@rtype: C{str}/C{bytes}
r r r r r _wsgiStringToBytes; s r c C s( t | tr| ddS | dS dS )as
Convert C{string} to a WSGI "bytes-as-unicode" string.
If it's a byte string, decode as ISO-8859-1. If it's a Unicode string,
round-trip it to bytes and back using ISO-8859-1 as the encoding.
@type string: C{str} or C{bytes}
@rtype: C{str}
@raise UnicodeEncodeError: If C{string} contains non-ISO-8859-1 chars.
r
N)r r r decoder r r r r E s
c C s
| dS )z
Convert C{string} from a WSGI "bytes-as-unicode" string to an
ISO-8859-1 byte string.
@type string: C{str}
@rtype: C{bytes}
@raise UnicodeEncodeError: If C{string} contains non-ISO-8859-1 chars.
r
)r r r r r r V s
c @ s. e Zd ZdZe Zdd Zdd Zdd ZdS ) _ErrorStreama
File-like object instances of which are used as the value for the
C{'wsgi.errors'} key in the C{environ} dictionary passed to the application
object.
This simply passes writes on to L{logging} system as
error events from the C{'wsgi'} system. In the future, it may be desirable
to expose more information in the events it logs, such as the application
object which generated the message.
c C s^ t |tsDttkr.td|t|jf td ntd|t|jf | jj |dd|fd dS )aG
Generate an event for the logging system with the given bytes as the
message.
This is called in a WSGI application thread, not the I/O thread.
@type data: str
@raise TypeError: On Python 3, if C{data} is not a native string. On
Python 2 a warning will be issued.
z+write() argument should be str, not %r (%s)categoryz)write() argument must be str, not %r (%s)ZwsgiT)systemZisErrormessageN)
r r bytesr type__name__UnicodeWarning TypeError_logerror)selfdatar r r writeq s&
z_ErrorStream.writec C s | d| dS )a
Join the given lines and pass them to C{write} to be handled in the
usual way.
This is called in a WSGI application thread, not the I/O thread.
@param iovec: A C{list} of C{'\n'}-terminated C{str} which will be
logged.
@raise TypeError: On Python 3, if C{iovec} contains any non-native
strings. On Python 2 a warning will be issued.
N)r& join)r$ Ziovecr r r
writelines s
z_ErrorStream.writelinesc C s dS )z
Nothing is buffered, so flushing does nothing. This method is required
to exist by PEP 333, though.
This is called in a WSGI application thread, not the I/O thread.
Nr r$ r r r flush s z_ErrorStream.flushN) r
__module__ __qualname____doc__r r" r& r) r+ r r r r r d s
r c @ s> e Zd ZdZdd Zd
ddZdddZdd d
Zd d ZdS ) _InputStreama
File-like object instances of which are used as the value for the
C{'wsgi.input'} key in the C{environ} dictionary passed to the application
object.
This only exists to make the handling of C{readline(-1)} consistent across
different possible underlying file-like object implementations. The other
supported methods pass through directly to the wrapped object.
c C s
|| _ dS )zt
Initialize the instance.
This is called in the I/O thread, not a WSGI application thread.
N)_wrapped)r$ inputr r r __init__ s z_InputStream.__init__Nc C s |dkr| j S | j |S )z
Pass through to the underlying C{read}.
This is called in a WSGI application thread, not the I/O thread.
N)r0 readr$ sizer r r r3 s
z_InputStream.readc C s& |dks|dkr| j S | j |S )z
Pass through to the underlying C{readline}, with a size of C{-1} replaced
with a size of L{None}.
This is called in a WSGI application thread, not the I/O thread.
N)r0 readliner4 r r r r7 s
z_InputStream.readlinec C s |dkr| j S | j |S )z
Pass through to the underlying C{readlines}.
This is called in a WSGI application thread, not the I/O thread.
N)r0 readlinesr4 r r r r8 s
z_InputStream.readlinesc C s
t | jS )z
Pass through to the underlying C{__iter__}.
This is called in a WSGI application thread, not the I/O thread.
)iterr0 r* r r r __iter__ s z_InputStream.__iter__)N)N)N) r r, r- r. r2 r3 r7 r8 r: r r r r r/ s
r/ c @ sT e Zd ZdZdZe Zdd Zdd Zddd Z d
d Z
d d
Z dd Z dd Z
dS )
_WSGIResponsea$
Helper for L{WSGIResource} which drives the WSGI application using a
threadpool and hooks it up to the L{http.Request}.
@ivar started: A L{bool} indicating whether or not the response status and
headers have been written to the request yet. This may only be read or
written in the WSGI application thread.
@ivar reactor: An L{IReactorThreads} provider which is used to call methods
on the request in the I/O thread.
@ivar threadpool: A L{ThreadPool} which is used to call the WSGI
application object in a non-I/O thread.
@ivar application: The WSGI application object.
@ivar request: The L{http.Request} upon which the WSGI environment is
based and to which the application's output will be sent.
@ivar environ: The WSGI environment L{dict}.
@ivar status: The HTTP response status L{str} supplied to the WSGI
I{start_response} callable by the application.
@ivar headers: A list of HTTP response headers supplied to the WSGI
I{start_response} callable by the application.
@ivar _requestFinished: A flag which indicates whether it is possible to
generate more response data or not. This is L{False} until
L{http.Request.notifyFinish} tells us the request is done,
then L{True}.
Fc C s d| _ || _|| _|| _|| _| j | j |jrHdd |j }nd}|j
rddd |j
}nd}|j dd}t
|dkrd}n|d }t|jt| jt|t|t|t|dpdt|dpdt| tt| jt|jd
| _d | j_|j D ]D\} }
d
t| d d } d
dd |
D dd| j| < q| j d| rpdprddddt t!|j"d d S )NF / ? s content-typer' s content-length)
ZREQUEST_METHODZ REMOTE_ADDRZ SCRIPT_NAMEZ PATH_INFOZ QUERY_STRINGZ CONTENT_TYPEZCONTENT_LENGTHZ SERVER_NAMEZ SERVER_PORTZSERVER_PROTOCOLZHTTP_-_,c s s | ]}t |V qd S N)r ).0vr r r C s z)_WSGIResponse.__init__..
)r? r ZhttpsZhttpT)z wsgi.versionzwsgi.url_schemez
wsgi.run_oncezwsgi.multithreadzwsgi.multiprocessz wsgi.errorsz
wsgi.input)#startedreactor
threadpool applicationrequestZ notifyFinishZaddBoth _finishedZprepathr( ZpostpathZurisplitlenr methodZgetClientAddressZhostZ getHeaderZgetRequestHostnamer ZgetHostZportZ clientprotoenvironZdefaultContentTypeZrequestHeadersZgetAllRawHeadersupperreplaceupdateZisSecurer r/ Zcontent) r$ rJ rK rL rM Z
scriptNameZpathInfopartsZ queryStringnamevaluesr r r r2 sb
z_WSGIResponse.__init__c C s
d| _ dS )zc
Record the end of the response generation for the request being
serviced.
TN)_requestFinished)r$ Zignoredr r r rN ^ s z_WSGIResponse._finishedNc C s( | j r |dk r t|d |d t|ts@td|t|jf t|trLn.wsgiWriteTN)rI r rJ )r$ r% rf r re r r& s ! z_WSGIResponse.writec C sd | j dd\}}t|}| j|t| | jD ],\}}| dkr2| jj t|t| q2dS )a,
Set the response code and response headers on the request object, but
do not flush them. The caller is responsible for doing a write in
order for anything to actually be written out in response to the
request.
This must be called in the I/O thread.
Nr? )Zserverdate)
r^ rO intrM setResponseCoder r_ lowerZresponseHeadersZ addRawHeader)r$ coder rW valuer r r rc s z"_WSGIResponse._sendResponseHeadersc C s | j | j dS )zo
Start the WSGI application in the threadpool.
This must be called in the I/O thread.
N)rK Z callInThreadrunr* r r r start s z_WSGIResponse.startc s zP j j}|D ] }|r( | jr q4qt|dd}|dk rN| W n0 fdd} jj| jft Y n X fdd} j| j d _dS )z
Call the WSGI application object, iterate it, and handle its output.
This must be called in a non-I/O thread (ie, a WSGI application
thread).
closeNc sB j jdt|||d | r( j n jt j d S )NzWSGI application error)failure)r" rp r rM ZloseConnectionri r finish)rI r rl tracebackr* r r wsgiError s
z$_WSGIResponse.run..wsgiErrorc s j s | s j d S rC )rY rc rM rq rd r* r r
wsgiFinish s z%_WSGIResponse.run..wsgiFinishT)
rL rR rb r& rY getattrrJ ZcallFromThreadrI r )r$ Z appIteratorra ro rs rt r r* r rm s
z_WSGIResponse.run)N)r r, r- r. rY r r" r2 rN rb r& rc rn rm r r r r r; s !L
A- r; c @ s4 e Zd ZdZdZdd Zdd Zdd Zd d
Zd S ) WSGIResourcea
An L{IResource} implementation which delegates responsibility for all
resources hierarchically inferior to it to a WSGI application.
@ivar _reactor: An L{IReactorThreads} provider which will be passed on to
L{_WSGIResponse} to schedule calls in the I/O thread.
@ivar _threadpool: A L{ThreadPool} which will be passed on to
L{_WSGIResponse} to run the WSGI application object.
@ivar _application: The WSGI application object.
Tc C s || _ || _|| _d S rC )_reactor _threadpool _application)r$ rJ rK rL r r r r2 , s zWSGIResource.__init__c C s t | j| j| j|}| tS )a
Turn the request into the appropriate C{environ} C{dict} suitable to be
passed to the WSGI application object and then pass it on.
The WSGI application object is given almost complete control of the
rendering process. C{NOT_DONE_YET} will always be returned in order
and response completion will be dictated by the application object, as
will the status, headers, and the response body.
)r; rw rx ry rn r
)r$ rM Zresponser r r render2 s
zWSGIResource.renderc C s t ddS )z
Reject attempts to retrieve a child resource. All path segments beyond
the one which refers to this resource are handled by the WSGI
application object.
z/Cannot get IResource children from WSGIResourceN RuntimeError)r$ rW rM r r r getChildWithDefaultB s z WSGIResource.getChildWithDefaultc C s t ddS )z
Reject attempts to add a child resource to this resource. The WSGI
application object handles all path segments beneath this resource, so
L{IResource} children can never be found.
z0Cannot put IResource children under WSGIResourceNr{ )r$ pathZchildr r r putChildK s zWSGIResource.putChildN) r r, r- r. ZisLeafr2 rz r} r r r r r rv s rv N)!r. r Z
__metaclass__sysr warningsr Zzope.interfacer Ztwisted.internet.threadsr Ztwisted.python.compatr r Ztwisted.python.failurer Ztwisted.web.resourcer Ztwisted.web.serverr
Ztwisted.web.httpr Ztwisted.loggerr r r r r r r/ r; rv __all__r r r r s0
FC .: