o
i}.
)Sequence)exc_info)ListUnion)warn) implementer)blockingCallFromThread)Logger)Failure)INTERNAL_SERVER_ERROR) IResource) NOT_DONE_YETstringreturnc C s$ t | tr
| ddS | dS )aW
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.
iso-8859-1N)
isinstancestrencodedecoder r VC:\Users\psant\Downloads\PAF backend\school\venv\Lib\site-packages\twisted/web/wsgi.py _wsgiString% s
r 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 N)r r r r r _wsgiStringToBytes7 s
r c @ sF e Zd ZdZe ZdeddfddZdee ddfdd Z d
d Z
dS ) _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.
datar Nc C s: t |tstd|t|jf | jj|dd|fd dS )a
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: if C{data} is not a native string.
z)write() argument must be str, not %r (%s)ZwsgiT)systemZisErrormessageN)r r TypeErrortype__name___logerror)selfr r r r writeR s
z_ErrorStream.writeiovecc C s | d| dS )aZ
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: if C{iovec} contains any non-native strings.
N)r$ join)r# r% r r r
writelinesg 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 flushu s z_ErrorStream.flush) r
__module__ __qualname____doc__r r! r r$ r r( r* r r r r r D s r c @ s> e Zd ZdZdd Zd
ddZd
ddZd
d 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__
z_InputStream.__init__Nc C |du r | 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)r/ readr# sizer r r r4
z_InputStream.readc C s& |dks|du r
| 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)r/ readliner5 r r r r9 s
z_InputStream.readlinec C r3 )z
Pass through to the underlying C{readlines}.
This is called in a WSGI application thread, not the I/O thread.
N)r/ readlinesr5 r r r r: r7 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.
N)iterr/ r) r r r __iter__ r2 z_InputStream.__iter__N) r r+ r, r- r1 r4 r9 r: 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 |jr$dd |j }nd}|j
r2dd |j
}nd}|j dd}t
|dkrDd}n|d }| } t|jt| jtt| jt|t|t|t|dpjdt|dprdt| tt| jt|jd | _d | j_|j D ]!\}
} d
t|
d d }
d
dd | D dd| j|
< q| j d| rdpddddt t!|j"d d S )NF / ? s content-typer& s content-length) REQUEST_METHODZ REMOTE_ADDRZ REMOTE_PORTZ SCRIPT_NAMEZ PATH_INFO QUERY_STRING CONTENT_TYPECONTENT_LENGTHZ SERVER_NAMEZ SERVER_PORTZSERVER_PROTOCOLZHTTP_-_,c s s | ]}t |V qd S r= )r ).0vr r r s z)_WSGIResponse.__init__..
)rB r httpshttpT)z wsgi.versionzwsgi.url_schemez
wsgi.run_oncezwsgi.multithreadzwsgi.multiprocessz wsgi.errorsz
wsgi.input)#startedreactor
threadpool applicationrequestZ notifyFinishZaddBoth _finishedZprepathr' ZpostpathurisplitlenZgetClientAddressr methodhostr portZ getHeaderZgetRequestHostnameZgetHostZ clientprotoenvironZdefaultContentTypeZrequestHeadersZgetAllRawHeadersupperreplaceupdateZisSecurer r. content) r# rR rS rT rU Z
scriptNameZpathInfopartsZ queryStringZ
remotePeernamevaluesr r r r1 sZ
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 rV 2 s
z_WSGIResponse._finishedNc C s( | j r|dur|d |d t|ts td|t|jt|tr&n t|t r9t
d|t|jf t d n td|t|jf |D ]D}t|t rNn t|t rat
d|t|jf t d n td |t|jf t
|dkrytd
||D ]}t|tstd |q{qF|| _|| _| jS ) z
The WSGI I{start_response} callable. The given values are saved until
they are needed to generate the response.
This will be called in a non-I/O thread.
NrB z!status must be str, not {!r} ({})z%headers should be a list, not %r (%s))categoryz#headers must be a list, not %r (%s)z0header should be a (str, str) tuple, not %r (%s)z.header must be a (str, str) tuple, not %r (%s)z'header must be a (str, str) tuple, not z%header must be (str, str) tuple, not )rQ with_tracebackr r r formatr r listr r RuntimeWarningtuplerY statusheadersr$ )r# rm rn ZexcInfoheaderelemr r r
startResponse9 s^
z_WSGIResponse.startResponsec s0 fdd}z t j|jW d_S d_w )a
The WSGI I{write} callable returned by the I{start_response} callable.
The given bytes will be written to the response body, possibly flushing
the status and headers first.
This will be called in a non-I/O thread.
c s | s j d S r= )_sendResponseHeadersrU r$ rQ r r# r r wsgiWrite s z&_WSGIResponse.write..wsgiWriteTN)r rR rQ )r# r ru r rt r r$ ~ s !z_WSGIResponse.writec C sd | j dd\}}t|}| j|t| | jD ]\}}| dvr/| jj t|t| qdS )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.
NrB )serverdate)
rm rX intrU setResponseCoder rn lowerZresponseHeadersZ addRawHeader)r# coder rc valuer r r rr 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)rS Z callInThreadrunr) r r r start s z_WSGIResponse.startc s z( j j}|D ]}|r | jr qq t|dd}|dur'| W n tyD fdd} jj| j gt
R Y nw 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 sD j jdt|||d | r j d S jt j d S )NzWSGI application error)failure)r! r r
rU ZloseConnectionry r finish)rQ r r| tracebackr) r r wsgiError s z$_WSGIResponse.run..wsgiErrorc s$ j s| s j d S d S r= )re rr rU r rs r) r r
wsgiFinish s
z%_WSGIResponse.run..wsgiFinishT) rT r] rq r$ re getattr
BaseExceptionrR ZcallFromThreadrQ r )r# Z appIteratorrp r r r r r) r r} s&
z_WSGIResponse.runr= )r r+ r, r- re r r! r1 rV rq r$ rr r~ r} r r r r r> s !P
E+ r> c @ s4 e Zd ZdZdZdd Zdd Zdd Zd d
Zd S ) WSGIResourceaW
An L{IResource} implementation which delegates responsibility for all
resources hierarchically inferior to it to a WSGI application.
The C{environ} argument passed to the application, includes the
C{REMOTE_PORT} key to complement the C{REMOTE_ADDR} key.
@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 r= )_reactor _threadpool _application)r# rR rS rT r r r r1 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.
N)r> r r r r~ r
)r# rU responser r r render
s
zWSGIResource.renderc C t d)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# rc rU r r r getChildWithDefault z WSGIResource.getChildWithDefaultc C r )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# pathchildr r r putChild" r zWSGIResource.putChildN) r r+ r, r- ZisLeafr1 r r r r r r r r s r N)!r- collections.abcr sysr typingr r warningsr Zzope.interfacer Ztwisted.internet.threadsr Ztwisted.loggerr Ztwisted.python.failurer
Ztwisted.web.httpr Ztwisted.web.resourcer Ztwisted.web.serverr
r bytesr r r r. r> r __all__r r r r s,
:? 4
;