+ j<Rt^RIHtRR.t^RIHt^RIHtHtH t ^RI H t H t ^RI Ht^RIHtHt^R IHt^R IHtHt^R IHt^R IHt^R IHt^RIHt^RIH t ^RI!H"t"^RI#H$t$H%t%H&t&RUu.uF pRV R2NK upt'Rt(]'Uu.uFqPSR4NK upt*](PSR4t+] !]4!RR44t,!RR4t-!RR4t.!RR]P^4t0R#uupiuupi)z2 Helpers related to HTTP requests, used by tests. ) annotations DummyChannel DummyRequest)BytesIO)DictListOptional) implementerverify)Version) IPv4Address IPv6Address)Deferred)IAddress ISSLTransport)Clock) deprecated)unittest)FOUND)Headers)Resource) NOT_DONE_YETSessionSiteFoobarzFoo barasciic]tRt^'tRtRtR#) NullAddressz' A null implementation of L{IAddress}. N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r@/usr/lib/python3/dist-packages/twisted/web/test/requesthelper.pyrr'sr&rc]tRt^.t!RR4t]!]4!RR]44t]!] !44t RRlt Rt Rt R tR tR tR tR tRtRtRtRtRtRtRtRtRtRtRtRtR#)rcR]tRt^/t^PtRtR RltRtRtRt Rt Rt R t R t R tR#) DummyChannel.TCPFNc `Vf\RRR4pWn\4Vn.VnR#)NTCPz 192.168.1.1i80)r _peerrwritten producersselfpeers&&r'__init__DummyChannel.TCP.__init__3s*|"5-?J"9DLDNr&c VP#N)r-r1s&r'getPeerDummyChannel.TCP.getPeer:s :: r&c \V\4'g\RV: 24hVPP V4R#)z)Can only write bytes to a transport, not N) isinstancebytes TypeErrorr.writer1datas&&r'r>DummyChannel.TCP.write=s4dE**"KD8 TUU LL  t $r&c :VFpVPV4K R#r6)r>)r1iovecr@s&& r' writeSequenceDummyChannel.TCP.writeSequenceBs 4 r&c 0\RRVP4#)r,z10.0.0.1)r portr7s&r'getHostDummyChannel.TCP.getHostFsuj$))< VPPW34R#r6)r/appendr1producer streamings&&&r'registerProducer!DummyChannel.TCP.registerProducerIs NN ! !8"7 8r&c R#r6rr7s&r'unregisterProducer#DummyChannel.TCP.unregisterProducerLs r&c RVnR#)TN) disconnectedr7s&r'loseConnectionDummyChannel.TCP.loseConnectionOs $D r&)r-rUr/r.r6)r r!r"r#rGrUr3r8r>rDrHrOrRrVr%rr&r'r,r*/s4    %  ! = 9  %r&r,c@]tRt^RtRtRtRtRtRtRt Rt Rt R #) DummyChannel.SSLc R#r6rr7s&r'abortConnection DummyChannel.SSL.abortConnectionT r&c R#r6rr7s&r'getTcpKeepAlive DummyChannel.SSL.getTcpKeepAliveXr]r&c R#r6rr7s&r' getTcpNoDelayDummyChannel.SSL.getTcpNoDelay\r]r&c R#r6rr7s&r'loseWriteConnection$DummyChannel.SSL.loseWriteConnection`r]r&c R#r6rr1enableds&&r'setTcpKeepAlive DummyChannel.SSL.setTcpKeepAlivedr]r&c R#r6rrhs&&r' setTcpNoDelayDummyChannel.SSL.setTcpNoDelayhr]r&c R#r6rr7s&r'getPeerCertificate#DummyChannel.SSL.getPeerCertificatelr]r&rN) r r!r"r#r[r_rbrerjrmrpr%rr&r'SSLrYRs%       r&rrNc 2VPV4VnR#r6)r, transportr0s&&r'r3DummyChannel.__init__rs$r&c R#r6r)r1requests&&r' requestDoneDummyChannel.requestDoneu r&c v\V\4'd0VP4UUUu.uFwrVVFquV3NK K ppppVR,V,R,V,R,pV.p V PRV44V P R4VP P V 4R#uupppi)  c3T"TFwrVR,V,R,xK R#5i)s: r}Nr).0namevalues& r' ,DummyChannel.writeHeaders..s%XPWdUlU2W<r?s&&r'r>DummyChannel.writes T"r&c <VPPV4R#r6)rtrD)r1rCs&&r'rDDummyChannel.writeSequences $$U+r&c :VPP4R#r6)rtrVr7s&r'rVDummyChannel.loseConnections %%'r&c R#r6rr7s&r' endRequestDummyChannel.endRequestrzr&c B\VPVP4#r6)r;rtrrr7s&r'isSecureDummyChannel.isSecures$..$((33r&c R#r6rr7s&r'r[DummyChannel.abortConnection r&c R#r6rr7s&r'r_DummyChannel.getTcpKeepAliverr&c R#r6rr7s&r'rbDummyChannel.getTcpNoDelayrr&c R#r6rr7s&r're DummyChannel.loseWriteConnectionrr&c R#r6rr7s&r'rjDummyChannel.setTcpKeepAliverr&c R#r6rr7s&r'rmDummyChannel.setTcpNoDelayrr&c R#r6rr7s&r'rpDummyChannel.getPeerCertificaterr&)rtr6)r r!r"r#r,r rrrrrsiter3rxrr8rHrOrRr>rDrVrrr[r_rbrerjrmrpr%rr&r'rr.s!%!%Fc :  D(  5((=,#,( 4       r&c0]tRt^t$RtRtRtRtR]R&R]R&R]R &R]R &R ]R &R ]R&Rt Rt R+RRllt Rt Rt RtR,RltRtRtRRltRtRtRtR,RltRtR t]!]!R!^^^4R"R#7R$4tR%tR&tR'tR-R(ltR)t R*t!R#).ra Represents a dummy or fake request. See L{twisted.web.server.Request}. @ivar _finishedDeferreds: L{None} or a C{list} of L{Deferreds} which will be called back with L{None} when C{finish} is called or which will be errbacked if C{processingFailed} is called. @type requestheaders: C{Headers} @ivar requestheaders: A Headers instance that stores values for all request headers. @type responseHeaders: C{Headers} @ivar responseHeaders: A Headers instance that stores values for all response headers. @type responseCode: C{int} @ivar responseCode: The response code which was passed to C{setResponseCode}. @type written: C{list} of C{bytes} @ivar written: The bytes which have been written to the request. s http://dummy/sGETNOptional[IAddress]clientz List[bytes]sitepathr.prepathzDict[bytes, List[bytes]]argszList[Deferred[None]]_finishedDeferredsc \^VnVP'dVP4K$R#)z Call an L{IPullProducer}'s C{resumeProducing} method in a loop until it unregisters itself. @param prod: The producer. @type prod: L{IPullProducer} @param s: Whether or not the producer is streaming. N)goresumeProducing)r1prodss&&&r'rODummyRequest.registerProducers%ggg  "r&c ^VnR#)N)rr7s&r'rRDummyRequest.unregisterProducers r&c(V^8dQhRRRRRRRR/#) postpathz list[bytes]sessionzOptional[Session]rrreturnNoner)formats"r' __annotate__DummyRequest.__annotate__s2'''#'# '  'r&c $.Vn.Vn^VnWn.VnRVnT;'g\ RR\4R7Vn/Vn \4Vn \4Vn RVn .VnRVnRVnR#)rN0)ruidreactorsdummysHTTP/1.0)rr.finishedrrrrr protoSessionrrrequestHeadersresponseHeaders responseCoder _serverName clientproto)r1rrrs&&&&r'r3DummyRequest.__init__s       #TTwDdEG'T %i&y "$#&r&c /pVPP4Fwr#VR,WP4&K V#)a0 Return dictionary mapping the names of all received headers to the last value received for each. Since this method does not return all header information, C{self.requestHeaders.getAllRawHeaders()} may be preferred. NOTE: This function is a direct copy of C{twisted.web.http.Request.getAllRawHeaders}. )rrlower)r1rrrs& r' getAllHeadersDummyRequest.getAllHeaderss;''88:DA!"2GGGI ;r&c fVPPVP4R.4^,#)a Retrieve the value of a request header. @type name: C{bytes} @param name: The name of the request header for which to retrieve the value. Header names are compared case-insensitively. @rtype: C{bytes} or L{None} @return: The value of the specified request header. N)r getRawHeadersr)r1rs&&r' getHeaderDummyRequest.getHeaders*""00vFqIIr&c <VPPW4R#)zATODO: make this assert on write() if the header is content-lengthN)r addRawHeaderr1rrs&&&r' setHeaderDummyRequest.setHeader s ))$6r&c VP'd VP#VP'dQR4hVPVnVP#)z8Session cannot be requested after data has been written.)rr.r)r1sessionInterfaces&&r' getSessionDummyRequest.getSession$sG <<<<<   F E F (( ||r&c VPV4pV\JdR#VPV4VP4R#)aP Render the given resource as a response to this request. This implementation only handles a few of the most common behaviors of resources. It can handle a render method that returns a string or C{NOT_DONE_YET}. It doesn't know anything about the semantics of request methods (eg HEAD) nor how to set any particular headers. Basically, it's largely broken, but sufficient for some tests at least. It should B{not} be expanded to do all the same stuff L{Request} does. Instead, L{DummyRequest} should be phased out and L{Request} (or some other real code factored in a different way) used. N)renderrr>finish)r1resourceresults&& r'rDummyRequest.render-s2& \ !  6 r&c ~\V\4'g \R4hVPP V4R#)zwrite() only accepts bytesN)r;r<r=r.rKr?s&&r'r>DummyRequest.write@s-$&&89 9 D!r&cV^8dQhRR/#)rrzDeferred[None]r)rs"r'rrEsnr&c P\4pVPPV4V#)z Return a L{Deferred} which is called back with L{None} when the request is finished. This will probably only work if you haven't called C{finish} yet. )rrrK)r1rs& r' notifyFinishDummyRequest.notifyFinishEs$ $,: &&x0r&c VP^,VnVPe0VPpRVnVFpVPR4K R#R#)ze Record that the request is finished and callback and L{Deferred}s waiting for notification of this. N)rrcallback)r1 observersobss& r'rDummyRequest.finishOsN  )  " " .//I&*D #  T"! /r&c VPe0VPpRVnVFpVPV4K R#R#)z; Errback and L{Deferreds} waiting for finish notification. N)rerrback)r1rrrs&& r'processingFailedDummyRequest.processingFailed[s>  " " .//I&*D #  F#! /r&c &V.VPV&R#r6)rrs&&&r'addArgDummyRequest.addArges ' $r&c VP'd0QRPRPVP444hWnW nR#)zc Set the HTTP status response code, but takes care that this is called before any data is written. z;Response code cannot be set after data hasbeen written: {}.@@@@N)r.rjoinrresponseMessage)r1rmessages&&&r'setResponseCodeDummyRequest.setResponseCodehsF   K R R KK %  !&r&c VP'd0QRPRPVP444hR#)z >;;## #r&c JVPf \4#VP#)zu Return the L{IAddress} of the client that made this request. @return: an address. @rtype: an L{IAddress} provider. )rrr7s&r'rDummyRequest.getClientAddresss  ;; = {{r&c VP#)zc Get a dummy hostname associated to the HTTP request. @rtype: C{bytes} @returns: a dummy hostname )rr7s&r'getRequestHostnameDummyRequest.getRequestHostnamesr&c \RR^P4#)zZ Get a dummy transport's host. @rtype: C{IPv4Address} @returns: a dummy transport's host r, 127.0.0.1)r r7s&r'rHDummyRequest.getHosts5+r22r&c W0nVP4'dRpM^PpW$8XdTpM RW3,pVPPRV4R#)a' Change the host and port the request thinks it's using. @type host: C{bytes} @param host: The value to which to change the host header. @type ssl: C{bool} @param ssl: A flag which, if C{True}, indicates that the request is considered secure (if C{True}, L{isSecure} will return C{True}). is%b:%dshostN) _forceSSLrrr)r1rrGssldefault hostHeaders&&&& r'setHostDummyRequest.setHostsJ ==??GG ?J!TL0J ((*=r&c TVP\4VPRV4R#)z] Utility function that does a redirect. The request should have finish() called after this. slocationN)r rr)r1urls&&r'redirectDummyRequest.redirects U# {C(r&)rr%rrrrrrrrrrrrrrr.)NNr6)r)"r r!r"r#r$urimethodr__annotations__rOrRr3rrrrrr>rrrrr rrrr rrrrHr)r-r%rr&r'rrs. C F!%F %   "",, #'* J7&"  #$" '   2q!,:LMN  3>,)r&c2]tRtRtRtRtRtRtRtRt R#) DummyRequestTestsiz Tests for L{DummyRequest}. c @\.4pVP4VPVP.R7pVP ^\ V44VwpVP VP R4\4VP VP R4R4R#)zX L{DummyRequest.getClientIP} is deprecated in favor of L{DummyRequest.getClientAddress} )offendingFunctionscategoryr z}twisted.web.test.requesthelper.DummyRequest.getClientIP was deprecated in Twisted 18.4.0; please use getClientAddress insteadN)rr flushWarningstest_getClientIPDeprecated assertEquallengetDeprecationWarning)r1rwwarningswarnings& r'r8,DummyRequestTests.test_getClientIPDeprecateds r"%% $ ? ?@&  CM*  Z02DE  KK "6 r&c \.4p\RRR4pW!nVPRVP 44R#)zi L{DummyRequest.getClientIP} supports IPv6 addresses, just like L{twisted.web.http.Request.getClientIP}. r,z::190N)rr rr9r)r1rwrs& r'test_getClientIPSupportsIPv6.DummyRequestTests.test_getClientIPSupportsIPv6s: r"UE51  3 3 56r&c r\.4pVP4p\P!\V4R#)z] L{DummyRequest.getClientAddress} returns an L{IAddress} provider no C{client} has been set. N)rrr verifyObjectr)r1rwnulls& r'"test_getClientAddressWithoutClient4DummyRequestTests.test_getClientAddressWithoutClients, r"'')Hd+r&c \.4p\RRR4pW!nVP4pVP W24R#)z9 L{DummyRequest.getClientAddress} returns the C{client}. r,r"rAN)rr rrassertIs)r1rwraddresss& r'test_getClientAddress'DummyRequestTests.test_getClientAddresss;r"UK7**, g&r&rN) r r!r"r#r$r8rBrGrLr%rr&r'r3r3s 2 7,'r&r3N)  z )1r$ __future__r__all__iortypingrrrzope.interfacer r incrementalr twisted.internet.addressr r twisted.internet.deferrtwisted.internet.interfacesrrtwisted.internet.taskrtwisted.python.deprecater twisted.trialrtwisted.web._responsesrtwisted.web.http_headersrtwisted.web.resourcertwisted.web.serverrrrtextLinearWhitespaceComponents sanitizedTextencodebytesLinearWhitespaceComponentssanitizedBytesrrrSynchronousTestCaser3)lw components00r'rhs# > *''.=+?'/"(,):::N!O:NBCt3-:N!O /M#/M)W/M#%%g. X J J ZL)L)^:'44:'Y "P#s 3C8 C=