\dU 4 d Z ddlmZ ddlmZ ddlmZ ddlmZ ddl m
Z
ddl m Z ddl
mZ dd lmZ dd
lmZ dd lmZ eeu rd Zd
Znd Zd Z G d d Z G d d Z G d d Z ee G d d Z dgZ dS )zo
An implementation of
U{Python Web Server Gateway Interface v1.0.1}.
)Sequence)exc_info)warn) implementer)blockingCallFromThread)Logger)Failure)INTERNAL_SERVER_ERROR) IResource) NOT_DONE_YETc Z t | t r| S | d S )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-1)
isinstancestrencodestrings 0lib/python3.11/site-packages/twisted/web/wsgi.py _wsgiStringr * s- fc " " /M== .. . c | 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 s r _wsgiStringToBytesr 8 s
r c t | t r(| d d S | d S )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 )r r r decoder s r r r D sH fc " " /== ..55lCC C== .. .r c , | d S )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 s r r r U s }}\***r c 8 e Zd ZdZ e Zd Zd Zd 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 : t |t sft t u r0t d|dt | j dt n(t d|dt | j d | j |dd|f d S )
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 ()categoryz"write() argument must be str, not wsgiT)systemisErrormessageN)
r r bytesr type__name__UnicodeWarning TypeError_logerror)selfdatas r writez_ErrorStream.writep s $$$ e||ttT$ZZ 0 0 02 + ittT$ZZ 0 0 02
VTD7KKKKKr c V | 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)r1 join)r/ iovecs r
writelinesz_ErrorStream.writelines s&
2775>>"""""r c 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/ s r flushz_ErrorStream.flush s r N) r*
__module__ __qualname____doc__r r- r1 r6 r9 r r r r r b s[ 688DL L L:
#
#
# r r c 6 e Zd ZdZd ZddZddZddZd 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 || _ dS )zt
Initialize the instance.
This is called in the I/O thread, not a WSGI application thread.
N)_wrapped)r/ inputs r __init__z_InputStream.__init__ s
r Nc l || 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.
)r@ readr/ sizes r rD z_InputStream.read s3 <=%%'' '}!!$'''r c x |dk s|| 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.
)r@ readlinerE s r rI z_InputStream.readline s; 2:: =))++ +}%%d+++r c l || 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.
)r@ readlinesrE s r rK z_InputStream.readlines s3 <=**,, ,}&&t,,,r c * t | j S )z
Pass through to the underlying C{__iter__}.
This is called in a WSGI application thread, not the I/O thread.
)iterr@ r8 s r __iter__z_InputStream.__iter__ s DM"""r N) r* r: r; r< rB rD rI rK rN r r r r> r> sx ( ( ( ( , , , , - - - -# # # # #r r> c V e Zd ZdZdZ e Zd Zd Zd dZ d Z
d Z d Z d
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 d| _ || _ || _ || _ || _ | j | j |j r dd |j z }nd}|j
r dd |j
z }nd}|j dd }t | dk rd}n|d }t |j t | j t | t | t | t | d pd t | d pd t | t t) | j t |j d
| _ d | j _ |j D ]x\ } }
d
t | d d z } d
d |
D dd | j | < y| j d| rdpddddtA tC |j" d d S )NF /r ? s content-typer3 s content-length)
REQUEST_METHOD REMOTE_ADDR SCRIPT_NAME PATH_INFO QUERY_STRING CONTENT_TYPECONTENT_LENGTH SERVER_NAME SERVER_PORTSERVER_PROTOCOLHTTP_-_,c 3 4 K | ]}t | V d S rO )r ).0vs r z)_WSGIResponse.__init__..9 s( )I)IQ+a..)I)I)I)I)I)Ir
)rU r httpshttpT)z wsgi.versionzwsgi.url_schemez
wsgi.run_oncezwsgi.multithreadzwsgi.multiprocessz wsgi.errorsz
wsgi.input)#startedreactor
threadpool applicationrequest notifyFinishaddBoth _finishedprepathr4 postpathurisplitlenr methodgetClientAddresshost getHeadergetRequestHostnamer getHostport clientprotoenvirondefaultContentTyperequestHeadersgetAllRawHeadersupperreplaceupdateisSecurer r> content) r/ rm rn ro rp
scriptNamepathInfoparts queryStringnamevaluess r rB z_WSGIResponse.__init__ s $& !!##++DN;;; ? '/ : ::JJ J dii(8 9 99HHH !!$** u::?? KK (K
*'. 9 9&w'?'?'A'A'FGG&z22$X.. ' 4 4 '(9(9/(J(J(Pb Q Q )'*;*; ? ?
+/ ' # 2 C C E E LD&[ . . 4 4 6 6 > >sC H HHD "%)I)I&)I)I)I!I!I!Q!Qc" "DL
&#*#3#3#5#5#A'#KV!&$(%* +~~ +7? ; ;+
r c d| _ dS )zc
Record the end of the response generation for the request being
serviced.
TN)_requestFinished)r/ ignoreds r rs z_WSGIResponse._finishedW s
!% r Nc | j r#|!|d |d t |t s5t d |t
| j t |t rnmt |t r0t d|dt
| j dt n(t d |dt
| j d |D ]}t |t rnmt |t r0t d
|dt
| j dt n(t d |dt
| j d t | dk rt d | |D ])}t |t st d | *|| _ || _ | j S )
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.
NrU z!status must be str, not {!r} ({})z headers should be a list, not r r! r" z headers must be a list, not z)header should be a (str, str) tuple, not z'header must be a (str, str) tuple, not z%header must be (str, str) tuple, not )rl with_tracebackr r r, formatr) r* listr r RuntimeWarningtuplerx statusheadersr1 )r/ r r excInfoheaderelems r
startResponsez_WSGIResponse.startResponse^ sF < 8G /!*++GAJ77 7
&#&& 3::DLL 1
gt $ $
*
*
D77DMM 2 2 24'
)77DMM 2 2 24
X XF&%((
FH--
vvtF|| 4 4 46 + i vvtF|| 4 4 46 6{{a T& T TUUU
X
X!$,, X#$VF$V$VWWWX
X zr c p fd} t j | j d _ S # d _ w xY 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 h | s j d S rO )_sendResponseHeadersrp r1 )rl r0 r/ s r wsgiWritez&_WSGIResponse.write..wsgiWrite s9
,))+++ L t $ $ $ $ $r T)r rm rl )r/ r0 r s `` r r1 z_WSGIResponse.write sW B % % % % % %
)$, 4<PP DLL4DL s , 5c j | j dd \ }}t | }| j |t | | j D ]U\ }}| dvr:| j j t | t | VdS )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.
NrU )serverdate)
r rw intrp setResponseCoder r lowerresponseHeaders addRawHeader)r/ coder' r values r r z"_WSGIResponse._sendResponseHeaders s ))$22
g4yy $$T+=g+F+FGGG < KD%zz||#555 ,99&t,,.@.G.G r c D | j | j dS )zo
Start the WSGI application in the threadpool.
This must be called in the I/O thread.
N)rn callInThreadrunr8 s r startz_WSGIResponse.start s"
$$TX.....r c j j }|D ]"}|r | j r n#t |dd }|
| fd} j | j n:# t $ r- fd} j j | j gt R Y nw xY wd _ 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 x j s1| s j d S d S rO )r r rp finish)rl r/ s r
wsgiFinishz%_WSGIResponse.run..wsgiFinish sL , *" 4 11333L'')))))* *r c j dt ||| | rj d S j t j d S )NzWSGI application error)failure)r- r r rp loseConnectionr r
r )rl r) r tracebackr/ s r wsgiErrorz$_WSGIResponse.run..wsgiError s !!,geT96U6U " *L//11111L001FGGGL'')))))r T) ro r r r1 r getattrrm callFromThreadrl
BaseExceptionr )r/ appIteratorr r r r s ` r r z_WSGIResponse.run s/ B **4<9KLLK#
%JJt$$$( EK$77E
*
*
*
*
*
L ' '
DL A A A A+ N N N
*
*
*
*
*
(DL ' 4< M(** M M M M M M N, s A"B 4CCrO )r* r: r; r< r r r- rB rs r r1 r r r r r r rQ rQ s B 688DL
L
L
\% % %D D D DL) ) ) V (/ / /' ' ' ' ' r rQ c . e Zd ZdZdZd Zd Zd Zd ZdS ) 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 0 || _ || _ || _ d S rO )_reactor _threadpool _application)r/ rm rn ro s r rB zWSGIResource.__init__( s
% 'r c z t | j | j | j | }| t
S )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.
)rQ r r r r r )r/ rp responses r renderzWSGIResource.render- s< ! M4+T->
r 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 WSGIResource RuntimeError)r/ r rp s r getChildWithDefaultz WSGIResource.getChildWithDefault= s LMMMr c t d )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 WSGIResourcer )r/ pathchilds r putChildzWSGIResource.putChildE s MNNNr N) r* r: r; r< isLeafrB r r r r r r r r si F( ( (
N N NO O O O Or r N) r< collections.abcr sysr warningsr zope.interfacer twisted.internet.threadsr twisted.loggerr twisted.python.failurer twisted.web.httpr
twisted.web.resourcer twisted.web.serverr r r( r r r r> rQ r __all__r r r r s
% $ $ $ $ $ & & & & & & ; ; ; ; ; ; ! ! ! ! ! ! * * * * * * 2 2 2 2 2 2 * * * * * * + + + + + +( %<< / / / / / /"
+
+
+@ @ @ @ @ @ @ @ F<# <# <# <# <# <# <# <#~n n n n n n n n b
Y5O 5O 5O 5O 5O 5O 5O 5Op
r