כh<SrSSKJr SS/rSSKJr SSKJrJrJ r SSK J r J r SSK Jr SS KJrJr SS KJr SS KJrJr SS KJr SS KJr SSKJr SSKJr SSKJ r SSK!J"r" SSK#J$r$J%r%J&r& SVs/sH nSUS3PM snr'Sr(\'Vs/sHoRSS5PM snr*\(RSS5r+\ "\5"SS55r,"SS5r-"SS5r."SS\R^5r0gs snfs snf)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_YETSessionSite)  z FoobarzFoo barasciic\rSrSrSrSrg) NullAddress'z' A null implementation of L{IAddress}. N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r#bC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/web/test/requesthelper.pyr!r!'sr*r!c\rSrSr"SS5r\"\5"SS\55r\"\ "55r SSjr Sr S r S rS rS rS rSrSrSrSrSrSrSrSrSrSrSrSrSrg)r.cP\rSrSrSrSrSSjrSrSrSr S r S r S r S r S rg)DummyChannel.TCP/PFNc\Uc [SSS5nXl[5Ul/Ulg)NTCPz 192.168.1.1i80)r _peerrwritten producersselfpeers r+__init__DummyChannel.TCP.__init__3s*|"5-?J"9DLDNr*cUR$N)r4r8s r+getPeerDummyChannel.TCP.getPeer:s :: r*c[U[5(d[SU<35eURR U5 g)Nz)Can only write bytes to a transport, not ) isinstancebytes TypeErrorr5writer8datas r+rEDummyChannel.TCP.write=s4dE**"KD8 TUU LL  t $r*c8UHnURU5 M gr=)rE)r8iovecrGs r+ writeSequenceDummyChannel.TCP.writeSequenceBs 4 r*c0[SSUR5$)Nr3z10.0.0.1)r portr>s r+getHostDummyChannel.TCP.getHostFsuj$))< s r+unregisterProducer#DummyChannel.TCP.unregisterProducerLs r*cSUlg)NT) disconnectedr>s r+loseConnectionDummyChannel.TCP.loseConnectionOs $D r*)r4r\r6r5r=)r$r%r&r'rNr\r:r?rErKrOrVrYr]r)r#r*r+r3r//s4    %  ! = 9  %r*r3c>\rSrSrSrSrSrSrSrSr Sr S r g ) DummyChannel.SSLRcgr=r#r>s r+abortConnection DummyChannel.SSL.abortConnectionT r*cgr=r#r>s r+getTcpKeepAlive DummyChannel.SSL.getTcpKeepAliveXrer*cgr=r#r>s r+ getTcpNoDelayDummyChannel.SSL.getTcpNoDelay\rer*cgr=r#r>s r+loseWriteConnection$DummyChannel.SSL.loseWriteConnection`rer*cgr=r#r8enableds r+setTcpKeepAlive DummyChannel.SSL.setTcpKeepAlivedrer*cgr=r#rps r+ setTcpNoDelayDummyChannel.SSL.setTcpNoDelayhrer*cgr=r#r>s r+getPeerCertificate#DummyChannel.SSL.getPeerCertificatelrer*r#N) r$r%r&r'rcrgrjrmrrrurxr)r#r*r+SSLr`Rs%       r*rzNc0URU5Ulgr=)r3 transportr7s r+r:DummyChannel.__init__rs$r*cgr=r#)r8requests r+ requestDoneDummyChannel.requestDoneu r*cN[U[5(a1UR5VVVs/sHupVUHouU4PM M nnnnUS-U-S-U-S-nU/n U RSU55 U R S5 UR R U 5 gs snnnf)N  c3<# UHupUS-U-S-v M g7f)s: rNr#).0namevalues r+ ,DummyChannel.writeHeaders..s"XPWdUlU2Ws r+r?DummyChannel.getPeer~~%%''r*c6URR5$r=)r|rOr>s r+rODummyChannel.getHostrr*c:URRX5 gr=)r|rVrSs r+rVDummyChannel.registerProducers ''s r+rYDummyChannel.unregisterProducers ))+r*c:URRU5 gr=)r|rErFs r+rEDummyChannel.writes T"r*c:URRU5 gr=)r|rK)r8rJs r+rKDummyChannel.writeSequences $$U+r*c8URR5 gr=)r|r]r>s r+r]DummyChannel.loseConnections %%'r*cgr=r#r>s r+ endRequestDummyChannel.endRequestrr*cB[URUR5$r=)rBr|rzr>s r+isSecureDummyChannel.isSecures$..$((33r*cgr=r#r>s r+rcDummyChannel.abortConnection r*cgr=r#r>s r+rgDummyChannel.getTcpKeepAliverr*cgr=r#r>s r+rjDummyChannel.getTcpNoDelayrr*cgr=r#r>s r+rm DummyChannel.loseWriteConnectionrr*cgr=r#r>s r+rrDummyChannel.setTcpKeepAliverr*cgr=r#r>s r+ruDummyChannel.setTcpNoDelayrr*cgr=r#r>s r+rxDummyChannel.getPeerCertificaterr*)r|r=)r$r%r&r'r3r rrzrrsiter:rrr?rOrVrYrErKr]rrrcrgrjrmrrrurxr)r#r*r+rr.s!%!%Fc :  D(  5((=,#,( 4       r*c6\rSrSr%SrSrSrSrS\S'S\S 'S\S 'S\S 'S \S 'S\S'Sr Sr S-S.Sjjr Sr Sr SrS/SjrSrSrS0SjrSrSrSrS/SjrSrSr\"\"S S!S"S#5S$S%9S&5rS'rS(rS)rS1S*jrS+r S,r!g)2ra 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]sitepathr5prepathzDict[bytes, List[bytes]]argszList[Deferred[None]]_finishedDeferredsc|SUlUR(a$UR5 UR(aM#gg)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)r8prodss r+rVDummyRequest.registerProducers)gg  "gggr*cSUlg)Nr)rr>s r+rYDummyRequest.unregisterProducers r*c/Ul/UlSUlXl/UlSUlU=(d [ SS[5S9Ul0Ul [5Ul [5Ul SUl /UlSUlSUlg)Nr0)ruidreactorsdummysHTTP/1.0)rr5finishedpostpathrsessionrr protoSessionrrrequestHeadersresponseHeaders responseCoder _serverName clientproto)r8rrrs r+r:DummyRequest.__init__s       #TwDdEG'T %i&y "$#&r*cz0nURR5Hup#USXR5'M U$)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)r8rrrs r+ getAllHeadersDummyRequest.getAllHeaderss;''88:DA!"2GGGI ;r*c^URRUR5S/5S$)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. Nr)r getRawHeadersr)r8rs r+ getHeaderDummyRequest.getHeaders*""00vFqIIr*c:URRX5 g)zATODO: make this assert on write() if the header is content-lengthN)r addRawHeaderr8rrs r+ setHeaderDummyRequest.setHeader s ))$6r*cUR(a UR$UR(aS5eURUlUR$)Nz8Session cannot be requested after data has been written.)rr5r)r8sessionInterfaces r+ getSessionDummyRequest.getSession$sC <<<<   F E F (( ||r*c|URU5nU[LagURU5 UR5 g)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)renderrrEfinish)r8resourceresults r+rDummyRequest.render-s2& \ !  6 r*cz[U[5(d [S5eURR U5 g)Nzwrite() only accepts bytes)rBrCrDr5rRrFs r+rEDummyRequest.write@s-$&&89 9 D!r*cP[5nURRU5 U$)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. )rrrR)r8rs r+ notifyFinishDummyRequest.notifyFinishEs$ $,: &&x0r*cURS-UlURb.URnSUlUHnURS5 M gg)ze Record that the request is finished and callback and L{Deferred}s waiting for notification of this. rN)rrcallback)r8 observersobss r+rDummyRequest.finishOsN  )  " " .//I&*D #  T"! /r*czURb.URnSUlUHnURU5 M gg)z; Errback and L{Deferreds} waiting for finish notification. N)rerrback)r8rrrs r+processingFailedDummyRequest.processingFailed[s>  " " .//I&*D #  F#! /r*c$U/URU'gr=)rrs r+addArgDummyRequest.addArges ' $r*cUR(a/SRSRUR555eXlX lg)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)r5formatjoinrresponseMessage)r8rmessages r+setResponseCodeDummyRequest.setResponseCodehsD   K R R KK %  !&r*cUR(a/SRSRUR555eg)Nzs r+ getClientIPDummyRequest.getClientIPs- dkkK#= > >;;## #r*cHURc [5$UR$)zu Return the L{IAddress} of the client that made this request. @return: an address. @rtype: an L{IAddress} provider. )rr!r>s r+rDummyRequest.getClientAddresss  ;; = {{r*cUR$)zc Get a dummy hostname associated to the HTTP request. @rtype: C{bytes} @returns: a dummy hostname )rr>s r+getRequestHostnameDummyRequest.getRequestHostnamesr*c[SSS5$)zZ Get a dummy transport's host. @rtype: C{IPv4Address} @returns: a dummy transport's host r3 127.0.0.1r1)r r>s r+rODummyRequest.getHosts5+r22r*cX0lUR5(aSnOSnX$:XaUnOSX4-nURRSU5 g)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}). ir1s%b:%dshostN) _forceSSLrrr)r8rrNssldefault hostHeaders r+setHostDummyRequest.setHostsJ ==??GG ?J!TL0J ((*=r*cRUR[5 URSU5 g)z] Utility function that does a redirect. The request should have finish() called after this. slocationN)r rr)r8urls r+redirectDummyRequest.redirects U# {C(r*)rr)rrrrrrrrrrrr rrr5)NN)rz list[bytes]rzOptional[Session]rrreturnNoner=)r3zDeferred[None])r)"r$r%r&r'r(urimethodr__annotations__rVrYr:rrrrrrErrrrr rrrr rrr#rOr-r1r)r#r*r+rrs. C F!%F %   "",, # &*%) ''#'# '  '* J7&"  #$" '   2q!,:LMN  3>,)r*c0\rSrSrSrSrSrSrSrSr g) DummyRequestTestsiz Tests for L{DummyRequest}. c8[/5nUR5 URUR/S9nUR S[ U55 UunUR UR S5[5 UR UR S5S5 g)zX L{DummyRequest.getClientIP} is deprecated in favor of L{DummyRequest.getClientAddress} )offendingFunctionsrcategoryr z}twisted.web.test.requesthelper.DummyRequest.getClientIP was deprecated in Twisted 18.4.0; please use getClientAddress insteadN)rr flushWarningstest_getClientIPDeprecated assertEquallengetDeprecationWarning)r8rwarningswarnings r+r>,DummyRequestTests.test_getClientIPDeprecateds r"%% $ ? ?@&  CM*  Z02DE  KK "6 r*c[/5n[SSS5nX!lURSUR 55 g)zi L{DummyRequest.getClientIP} supports IPv6 addresses, just like L{twisted.web.http.Request.getClientIP}. r3z::190N)rrrr?r)r8rrs r+test_getClientIPSupportsIPv6.DummyRequestTests.test_getClientIPSupportsIPv6s: r"UE51  3 3 56r*cp[/5nUR5n[R"[U5 g)z] L{DummyRequest.getClientAddress} returns an L{IAddress} provider no C{client} has been set. N)rrr verifyObjectr)r8rnulls r+"test_getClientAddressWithoutClient4DummyRequestTests.test_getClientAddressWithoutClients, r"'')Hd+r*c[/5n[SSS5nX!lUR5nUR X25 g)z9 L{DummyRequest.getClientAddress} returns the C{client}. r3r&rGN)rr rrassertIs)r8rraddresss r+test_getClientAddress'DummyRequestTests.test_getClientAddresss;r"UK7**, g&r*r#N) r$r%r&r'r(r>rHrMrRr)r#r*r+r9r9s 2 7,'r*r9N)1r( __future__r__all__iortypingrrr zope.interfacer r incrementalr twisted.internet.addressr rtwisted.internet.deferrtwisted.internet.interfacesrrtwisted.internet.taskrtwisted.python.deprecater twisted.trialrtwisted.web._responsesrtwisted.web.http_headersrtwisted.web.resourcertwisted.web.serverrrrtextLinearWhitespaceComponents sanitizedTextencodebytesLinearWhitespaceComponentssanitizedBytesr!rrSynchronousTestCaser9)lw components00r+rls# > *''.=+?'/"(,):::N!O:NBCt3-:N!O /M#/M)W/M#%%g. X J J ZL)L)^:'44:'Y "P#s 3C9 C>