h}.
)Sequence)exc_info)ListUnion)warn) implementer)blockingCallFromThread)Logger)Failure)INTERNAL_SERVER_ERROR) IResource) NOT_DONE_YETstringreturnc [ U [ 5 ( a U R S5 R S5 $ U R S5 $ )a;
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-1)
isinstancestrencodedecoder s W/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/web/wsgi.py _wsgiStringr % s: &# }}\*11,??}}\** c $ U R S5 $ )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 _wsgiStringToBytesr 7 s == &&r c V \ rS rSrSr\" 5 rS\SS4S jrS\ \ SS4S jr
S r S
r g) _ErrorStreamD a
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 [ U[ 5 ( d' [ SU< S[ U5 R < S35 eU R
R
USSU4S9 g)z
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 ()wsgiT)systemisErrormessageN)r r TypeErrortype__name___logerror)selfr s r write_ErrorStream.writeR sN $$$d,,.
VTD7Kr iovecc D U R SR U5 5 g)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: if C{iovec} contains any non-native strings.
N)r. join)r- r0 s r
writelines_ErrorStream.writelinesg s
2775>"r c g)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.
N r- s r flush_ErrorStream.flushu s r r7 )
r*
__module__ __qualname____firstlineno____doc__r
r+ r r. r r4 r9 __static_attributes__r7 r r r r D sB 8DL# L$ L* #S #d # r r c B \ rS rSrSrS rS
S jrS
S jrS
S jrS r S r
g) _InputStream~ al
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 Xl g)z\
Initialize the instance.
This is called in the I/O thread, not a WSGI application thread.
N_wrapped)r- inputs r __init___InputStream.__init__ s
r Nc r Uc U R R 5 $ U R R U5 $ )zk
Pass through to the underlying C{read}.
This is called in a WSGI application thread, not the I/O thread.
)rE readr- sizes r rJ _InputStream.read s1 <==%%' '}}!!$''r c ~ US:X d Uc U R R 5 $ U R R U5 $ )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.
)rE readlinerK s r rP _InputStream.readline s7 2: ==))+ +}}%%d++r c r Uc U R R 5 $ U R R U5 $ )zp
Pass through to the underlying C{readlines}.
This is called in a WSGI application thread, not the I/O thread.
)rE readlinesrK s r rS _InputStream.readlines s1 <==**, ,}}&&t,,r c , [ U R 5 $ )zo
Pass through to the underlying C{__iter__}.
This is called in a WSGI application thread, not the I/O thread.
)iterrE r8 s r __iter___InputStream.__iter__ s DMM""r rD N) r* r; r< r= r> rG rJ rP rS rW r? r7 r r rA rA ~ s ( , -#r rA c X \ rS rSrSrSr\" 5 rS rS r S
S jr
S r S r S
r
S rS rg)
_WSGIResponse a
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 SU l Xl X l X0l X@l U R R 5 R
U R 5 UR ( a SSR UR 5 - nOSnUR ( a SSR UR 5 - nOSnUR R SS5 n[ U5 S:X a SnOUS nUR 5 n [ UR 5 [ U R" 5 [ [% U R& 5 5 [ U5 [ U5 [ U5 [ UR) S5 =( d S5 [ UR) S5 =( d S5 [ UR+ 5 5 [ [% UR- 5 R& 5 5 [ UR. 5 S . U l S U R l UR4 R7 5 Hf u pS
[ U
5 R9 5 R; S S 5 - n
S
R S U 5 5 R; SS5 U R0 U
' Mh U R0 R= SUR? 5 =( a S=( d SSSS[A 5 [C URD 5 S.5 g )NF /r ? s content-typer2 s content-length) REQUEST_METHOD REMOTE_ADDR REMOTE_PORT SCRIPT_NAME PATH_INFO QUERY_STRING CONTENT_TYPECONTENT_LENGTH SERVER_NAME SERVER_PORTSERVER_PROTOCOLHTTP_-_,c 3 8 # U H n[ U5 v M g 7frY )r ).0vs r )_WSGIResponse.__init__.. s )I&Q+a..&s
)r` r httpshttpT)z wsgi.versionzwsgi.url_schemez
wsgi.run_oncezwsgi.multithreadzwsgi.multiprocessz wsgi.errorsz
wsgi.input)#startedreactor
threadpool applicationrequest notifyFinishaddBoth _finishedprepathr3 postpathurisplitlengetClientAddressr methodhostr port getHeadergetRequestHostnamegetHost clientprotoenvirondefaultContentTyperequestHeadersgetAllRawHeadersupperreplaceupdateisSecurer rA content) r- rz r{ r| r}
scriptNamepathInfoparts queryString
remotePeernamevaluess r rG _WSGIResponse.__init__ sG $& !!#++DNN; ?? '// ::J J dii(8(8 99HH !!$* u:? K (K --/
)'.. 9&z7&s:??';<&z2$X. ' 4 '(9(9/(J(Pb Q )'*;*;+> ?
" +/ ' # 2 2 C C ELD[ . 4 4 6 > >sC HHD "%)I&)I!I!Q!Qc"DLL F
&#*#3#3#5#A'#KV!&$(%* +~ +7?? ;+
r c SU l g)zK
Record the end of the response generation for the request being
serviced.
TN)_requestFinished)r- ignoreds r r _WSGIResponse._finished2 s
!% r Nc U R ( a Ub US R US 5 e[ U[ 5 ( d. [ SR U[
U5 R 5 5 e[ U[ 5 ( a Og[ U[ 5 ( a+ [ SU< S[
U5 R < S3[ S9 O'[ SU< S[
U5 R < S35 eU H n[ U[ 5 ( a Og[ U[ 5 ( a+ [ S U< S[
U5 R < S3[ S9 O'[ S
U< S[
U5 R < S35 e[ U5 S:w a [ S
U< 35 eU H' n[ U[ 5 ( a M [ S U< 35 e M Xl X l U R $ ) 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.
r` z!status must be str, not {!r} ({})z headers should be a list, not r" r# )categoryz 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 )ry with_tracebackr r r( formatr) r* listr r RuntimeWarningtupler statusheadersr. )r- r r excInfoheaderelems r
startResponse_WSGIResponse.startResponse9 s < U ( d TR 5 TR R T5 g rY )_sendResponseHeadersr} r. )ry r r- s r wsgiWrite&_WSGIResponse.write..wsgiWrite s$ ))+ LL t $r T)r rz ry )r- r r s `` r r. _WSGIResponse.write~ s1 B %
)$,, 4<<P DL4DLs 3 <c f U R R SS5 u p[ U5 nU R R U[ U5 5 U R HS u p4UR 5 S; d M U R R R [ U5 [ U5 5 MU g)z
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` )serverdate)
r r intr} setResponseCoder r lowerresponseHeaders addRawHeader)r- coder' r values r r "_WSGIResponse._sendResponseHeaders s ))$2
4y $$T+=g+FG < TR ( d2 U ( d TR 5 TR R 5 g g rY )r r r} finish)ry r- s r
wsgiFinish%_WSGIResponse.run..wsgiFinish s0 ,," 113LL'') -r c > TR R S[ X!U5 S9 U ( a TR R 5 g TR R [ 5 TR R 5 g )NzWSGI application error)failure)r+ r r r} loseConnectionr r r )ry r) r tracebackr- s r wsgiError$_WSGIResponse.run..wsgiError s^ !!,ge96U " LL//1LL001FGLL'')r T) r| r r r. r getattrrz callFromThreadry
BaseExceptionr )r- appIteratorr r r r s ` r r _WSGIResponse.run s B **4<<9K9KLK#JJt$((( $
K$7E
*
LL ' '
DLL A - N
*
LL ' ' 4<< M(* M Ns AB( B( (A C+*C+) r r| r r rz r} ry r r{ rY )r* r; r< r= r> r r
r+ rG r r r. r r r r? r7 r r r[ r[ s? B 8DN
`%CJ) V(/' r r[ c 4 \ rS rSrSrSrS rS rS rS r Sr
g )
WSGIResourcei a/
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 ( Xl X l X0l g rY )_reactor _threadpool _application)r- rz r{ r| s r rG WSGIResource.__init__ s
% 'r c [ U R U R U R U5 nUR 5 [
$ )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[ r r r r r )r- r} responses r renderWSGIResource.render
s9 ! MM4++T->->
r c [ S5 e)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 r} s r getChildWithDefault WSGIResource.getChildWithDefault s LMMr c [ S5 e)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 putChildWSGIResource.putChild" s MNNr )r r r N) r* r; r< r= r> isLeafrG r r r r? r7 r r r r s$ $ F(
NOr r N)!r> collections.abcr sysr typingr r warningsr zope.interfacer twisted.internet.threadsr twisted.loggerr
twisted.python.failurer twisted.web.httpr twisted.web.resourcer
twisted.web.serverr r bytesr r r rA r[ r __all__r7 r r r s
% & ; ! * 2 * + +c5j) +c +$
's
'u
'7 7 t<# <#~o o d
Y8O 8O 8Ov
r