+ Dfj+"Rt^RIt^RIt^RIt^RIHt^RIHtHt^RI H t ^RI H t H t ^RIHt^RIHt^RIHtHt^R IHtHtHt^R IHt^RIt^R IHt^R IHt^R IH t H!t!^RI"H#t#^RI$H%t%H&t&H't'^RI(H)t)^RI*H+t+^RI,H-t-H.t.^RI/H0t0^RI1H2t2^RI3H4t5^RI6H7t7^RI8Ht^RI9H:t:^RI;Ht>^RI?H@t@HAtAHBtB^RICHDtDHEtEHFtFHGtG^RIHHItI!RR]0!]P4!R&R']Q44tT]L!]T4tU!R(R)]Q4tV]L!]V4tW!R*R+]]Pt4tc!R?R@]Pt4tdRAte!RBRC]Pt4tf!RDRE]:4tg!RFRG]Pt4th!RHRI]Pt][4ti!RJRK]Pt4tj!RLRM]Pt4tk!RNRO]aV3Rlp\V\S44V#)a Return a callable that proxies instances of C{clsToWrap} via L{_IDeprecatedHTTPChannelToRequestInterface}. @param clsToWrap: The class whose instances will be proxied. @type cls: L{_IDeprecatedHTTPChannelToRequestInterface} implementer. @return: A factory that returns L{_IDeprecatedHTTPChannelToRequestInterface} proxies. @rtype: L{callable} whose interface matches C{clsToWrap}'s constructor. c*<S!V/VBp\V4#N)r/)argskwargsinstance clsToWraps*, r8_makeRequestProxy3_makeRequestProxyFactory.._makeRequestProxyNsd-f-=hGGr7)r r)r?r@sf r8_makeRequestProxyFactoryrB@s!H & 9(=> r7c*a]tRt^WtoRtRtRtVtR#)DummyPullProducerHandlerz An HTTP request handler that registers a dummy pull producer to serve the body. The owner must call C{finish} to complete the response. c\V4VnVP^4VPVPR4R#)FN)r_actualProducersetResponseCoderegisterProducerselfs&r8process DummyPullProducerHandler.process_s33D9 S! d22E:r7)rGNr1r2r3r4r5rLr6__classdictcell__ __classdict__s@r8rDrDWs;;r7rDc0a]tRt^htoRtRtRtRtVtR#) DateTimeTestszTest date parsing functions.c\R4FWp\P!^R4p\P!V4p\P !V4pVP W$4KY R#)i'i5wN)rangerandomrandintr#datetimeToStringstringToDatetime assertEqual)rKitimetimestrtime2s& r8 testRoundtripDateTimeTests.testRoundtripksNuA>>!Z0D++D1G))'2E   T ) r7c .ROp\P!R4pVF)pVP\P!V4V4K+ VP\P!R4\P!R44R#)Sun, 06 Nov 1994 08:49:37 GMTs Thursday, 29-Sep-16 17:15:29 GMTN)rbs06 Nov 1994 08:49:37 GMTsSunday, 06-Nov-94 08:49:37 GMTs06-Nov-94 08:49:37 GMTs Sunday, 06-Nov-1994 08:49:37 GMTs06-Nov-1994 08:49:37 GMTsSun Nov 6 08:49:37 1994sNov 6 08:49:37 1994) i 1%rdrd) i rjirh)calendartimegmrZr#rY)rK dateStringsdateInt dateStrings& r8testStringToDatetime"DateTimeTests.testStringToDatetimersi  //"CD%J   T22:> H&   ! !"E F OO@ A r7r0N) r1r2r3r4r5r_rsr6rOrPs@r8rSrShs&*  r7rSc&a]tRt^toRtRtVtR#)DummyHTTPHandlerc\VPP^^4VPP4pVPR4pVf\ V4P 4pRV,R,V,R,pVP ^4VPRVP4VPRVP4VPRVP4VPRR \V43,4VPV4VP4R#) rhcontent-lengthNs'''  sRequestsCommandsVersionContent-Lengths%d)contentseekread getHeaderstrencoderH setHeaderurimethod clientprotolenwritefinish)rKdatalengthrequests& r8rLDummyHTTPHandler.processs !Q||  " 12 >['')FV#e+d2X= S! z488, z4;;/ z4#3#34 (%3wl@STr7c \4p\4p\P!4pVP R4p\ WA4pVP V4VPR4VPVP4VPVP4VP^<4VPVP4VPVP4VP^4VPR4VP^4VPVP4VPVP4R#)zm If a timed out transport ends up calling C{connectionLost}, it prevents the force-closure of the transport. Nr)rrr#rrrrrrrrrrrrs& r8+test_transportNotAbortedAfterConnectionLost8HTTP1_0Tests.test_transportNotAbortedAfterConnectionLostds #% ""$((.*8; *MN 001 //0  b  //0 //0  b%  a  //0 //0r7c ~\4p\4p\P!4pVP R4pRVP n\WA4pVPV4VPR4VPVP4VPVP4VP^<4VPVP4VPVP4VPR4VPVP4VPVP4R#)zP If the L{HTTPChannel} has its c{abortTimeout} set to L{None}, it never aborts. Nrl)rrr#rrr abortTimeoutrrrrrrrrrs& r8,test_transportNotAbortedWithZeroAbortTimeout9HTTP1_0Tests.test_transportNotAbortedWithZeroAbortTimeouts #% ""$((.)-&*8; *MN 001 //0  b  //0 //0  e  //0 //0r7c \4p\4p\P!4pVP R4p\ WA4pVP V4VPR4VPVP4VPVP4VP^<4VP^4VPVP4VPVP4VP\4R#)rNr)rrr#rrrrrrrrrrrrrs& r8"test_connectionLostAfterForceClose/HTTP1_0Tests.test_connectionLostAfterForceCloses #% ""$((.*8; *MN 001 //0  b b  //0  ../ /r7c `\4p\P!4p\VnVP V4\ VP4FpVPV4K VP\R44VP4pVPW@P4R#)zN Test that a L{http.Request} subclass with no queued kwarg works as expected. all doneNrrs& r8test_noPipeliningApi!HTTP1_0Tests.test_noPipeliningApis      0 dmm,D NN4 - ,-  !!%)?)?@r7c \4p\P!4p\VnVP V4\ VP4FpVPV4K VP4pVPVR4VP^\VP44VP'dUVP^\VP44VP^,PpVP4KfVP4pVPW@P4R#)zG Test that pipelined requests get buffered, not processed in parallel. r7N)rr#rDelayedHTTPHandlerProxyrrrrrrrZroriginalrrr)rKrrrrrs& r8test_noPipeliningHTTP1_0Tests.test_noPipelinings      2 dmm,D NN4 -  $ C O,jjj   QAJJ 0jjm,,G  " " $  !!%)?)?@r7c\<V^8dQh/S[S[S[S[,,S[3,;R&#)r)rrbytes)formatrQs"r8 __annotate__HTTP1_0Tests.__annotate__s'Xhuo6=> r7r0N)HTTP/1.0 200 OK Request: / Command: GETVersion: HTTP/1.0Content-Length: 13 ''' None ''' )r1r2r3r4rrrrrrrrrrr__annotate_func__r6rOrPs@r8rrsW    B A4(1 !UF1:1404A AWr7rc"]tRtRtRt.ROtRtR#) HTTP1_1TestsisGET / HTTP/1.1 Accept: text/html POST / HTTP/1.1 Content-Length: 10 0123456789POST / HTTP/1.1 Content-Length: 10 0123456789HEAD / HTTP/1.1 r0N))HTTP/1.1 200 OKr r Version: HTTP/1.1rrrr  Command: POSTrsContent-Length: 21''' 10 0123456789''' r)rr s Command: HEADrrr7r1r2r3r4rrr6r0r7r8rrs  !r7rc ]tRtRtRtR.tRtR#)HTTP1_1_close_TestsiJGET / HTTP/1.1 Accept: text/html Connection: close GET / HTTP/1.0 r0N)rsConnection: closer r rrrrr0r7r8rrs    r7rc4a]tRtRtoRtRtRtRtRtVt R#) HTTP0_9Testsi*sGET / HTTP/1.1 400 Bad Request c(VPW4R#r;)rZ)rKrexpectedResponses&&&r8r!HTTP0_9Tests.assertResponseEquals/s 4r7c.\P!R4h)zHTTP/0.9 not supported)r!SkipTestrJs&r8rHTTP0_9Tests.test_noPipelining2s 899r7r0N) r1r2r3r4rrrrr6rOrPs@r8rr*sH;5::r7rcTa]tRtRtoRtRtR R .tRtRtRt Rt Rt R t R t VtR #)PipeliningBodyTestsi6z` Pipelined requests get buffered and executed in the order received, not processed in parallel. stPOST / HTTP/1.1 Content-Length: 10 0123456789POST / HTTP/1.1 Transfer-Encoding: chunked a 0123456789 0 c \4p\P!4p\VnVP V4\ VP4FpVPV4K VPVP4R4VP^\VP44VP'dUVP^\VP44VP^,PpVP4KfVPVP4VP4R#)z Imitate a slow connection that delivers one byte at a time. The request handler (L{DelayedHTTPHandler}) is puppeted to step through the handling of each request. r7N)rr#rrrrrrrrZrrrrrexpectedResponses)rKrrrrs& r8test_stepwiseTinyTube)PipeliningBodyTests.test_stepwiseTinyTube^s      2 dmm,D NN4 - C( C O,jjj   QAJJ 0jjm,,G  " " $ !!!'')T-C-CDr7c \\4p\P!4p\VnVP V4VP VP4VPVP4R4VP^\VP44VP'dUVP^\VP44VP^,PpVP4KfVPVP4VP4R#)z Imitate a fast connection where several pipelined requests arrive in a single read. The request handler (L{DelayedHTTPHandler}) is puppeted to step through the handling of each request. r7N)rr#rrrrrrrZrrrrrr))rKrrrs& r8test_stepwiseDumpTruck*PipeliningBodyTests.test_stepwiseDumpTruckxs      2  t}}% C( C O,jjj   QAJJ 0jjm,,G  " " $ !!!'')T-C-CDr7c t\4p\P!4p\VnVP V4\ VP4F9pVPV4VP\VP4^4K; VPVP4VP4R#)z Imitate a slow connection that delivers one byte at a time. (L{DummyHTTPHandler}) immediately responds, but no more than one N)rr#rrrrrrrassertLessEqualrrrr))rKrrrs& r8test_immediateTinyTube*PipeliningBodyTests.test_immediateTinyTubes      0 dmm,D NN4  QZZ! 4- !!!'')T-C-CDr7c \4p\P!4p\VnVP V4VP VP4VPVP4VP4R#)a Imitate a fast connection where several pipelined requests arrive in a single read. The request handler (L{DummyHTTPHandler}) immediately responds. This doesn't check the at-most-one pending request invariant but exercises otherwise uncovered code paths. See GHSA-c8m8-j448-xjx7. N) rr#rrrrrrrrr))rKrrs& r8test_immediateDumpTruck+PipeliningBodyTests.test_immediateDumpTrucks^      0  t}}% !!!'')T-C-CDr7c |\4p\P!4p\VnVP V4VP \VP4,^ ,pVPVPV,4VPVP4VPV,4R#)ao Imitate a fast connection where a so many pipelined requests arrive in a single read that backpressure is indicated. The request handler (L{DummyHTTPHandler}) immediately responds. This doesn't check the at-most-one pending request invariant but exercises otherwise uncovered code paths. See GHSA-c8m8-j448-xjx7. @see: L{http.HTTPChannel._optimisticEagerReadSize} N) rr#rrrr_optimisticEagerReadSizerrrrrr))rKrroverLimitCounts& r8test_immediateABiggerTruck.PipeliningBodyTests.test_immediateABiggerTrucks      0 33s4==7IIBN t}}~56 !!!'')T-C-Cn-TUr7c  \4p\P!4p\VnVP V4VP \VP4,p\^V^,4FVpVPVP4VPVPRRPVPVR74KX VPVP4VPVPR4R#)z When pipelined requests are received, we will optimistically continue receiving data up to a specified limit, then pause the transport. @see: L{http.HTTPChannel._optimisticEagerReadSize} producingz(state was {state!r} after {x} iterations)statexpausedN)rr#rrrrr7rrrUrrZ producerStaterr)rKrr underLimitr>s& r8test_pipeliningReadLimit,PipeliningBodyTests.test_pipeliningReadLimits      2 //3t}}3EE q*q.)A NN4== )   :AA//QB * t}}% !//84r7r0Nr)rr rrsContent-Length: 23s''' None 0123456789''' )r1r2r3r4r5rr)r*r-r1r4r9rBr6rOrPs@r8r'r'6sN    &E4E4E(E(V,55r7r'cXa]tRtRtoRt!RR]P 4tRtRt Rt Vt R#) ShutdownTestsizE Tests that connections can be shut down by L{http.Request} objects. c*a]tRtRtoRtRtRtVtR#)!ShutdownTests.ShutdownHTTPHandleriz< A HTTP handler that just immediately calls loseConnection. c&VP4R#r;)loseConnectionrJs&r8rL)ShutdownTests.ShutdownHTTPHandler.processs    !r7r0NrNrPs@r8ShutdownHTTPHandlerrGs  " "r7rKs1POST / HTTP/1.1 Content-Length: 10 0123456789c J\4p\P!4p\VP4VnVP V4VPVP4VPVP4VP4pVPVR4R#)zQ Calling L{http.Request.loseConnection} causes the transport to be disconnected. r7N) rr#rrBrKrrrrrrrrZ)rKrrrs& r8test_losingConnection#ShutdownTests.test_losingConnectionsz      3D4L4LM  t||$ (  $r7r0N) r1r2r3r4r5r#RequestrKrrMr6rOrPs@r8rErEs,"dll"UG%%r7rEc6a]tRtRtoRtRtRtRtRtVt R#) SecurityTestsi zQ Tests that L{http.Request.isSecure} correctly takes the transport into account. c \P!4p\P!4pVP V4\P !V4pVP VP44R#)zj Calling L{http.Request.isSecure} when the channel is backed with a secure transport will return L{True}. N)r)SSLr#rrrOrisSecurerKrrreqs& r8 test_isSecureSecurityTests.test_isSecuresM         ll1o  'r7c \P!4p\P!4pVP V4\P !V4pVP VP44R#)zo Calling L{http.Request.isSecure} when the channel is not backed with a secure transport will return L{False}. N)r)TCPr#rrrOrrTrUs& r8test_notSecureSecurityTests.test_notSecuresO         ll1o (r7c ^\P!4p\P!4pVP V4\P !V4pVP PV4VP^4VP4VPVP44R#)z\ After a request is finished, calling L{http.Request.isSecure} will always return L{False}. N) r)rSr#rrrOrappendrHrrrTrUs& r8test_notSecureAfterFinish'SecurityTests.test_notSecureAfterFinish'sx         ll1o # C   (r7r0N) r1r2r3r4r5rWr[r_r6rOrPs@r8rQrQ s ( ) ) )r7rQcta]tRtRtoRtRtRt]!]P'*R4R4t Rt Rt R t ]!]P'*R4R 4t]!]PR 4R 4tR tRtRt]!]P'*R4R4t]!]P'*R4R4tRtVtR#)GenericHTTPChannelTestsi7zz Tests for L{http._genericHTTPChannelProtocol}, a L{HTTPChannel}-alike which can handle different HTTP protocol channels. rc \P!R4p\VnVP V4\ VP 4FpVPV4K VP\R44VP#)zc Run a request using the specific instance of a transport. Returns the negotiated protocol string. r7r) r#"_genericHTTPChannelProtocolFactoryrrrrrrrr_negotiatedProtocol)rKtrrs&& r8'_negotiatedProtocolForTransportInstance?GenericHTTPChannelTests._negotiatedProtocolForTransportInstanceFsh  3 3C 80 dmm,D NN4 - ,-$$$r7zHTTP/2 support not presentc  \4p\P!R4p\Vn^dVnVP Vn\4pRVnVPV4\P!VP4\P!\P!R\P!R4444VP4^,pVP!R4VP#VP$R4VP'VP(4\P!VP4\P!\P!R\P!R4444R#)zO When the transport is switched to H2, the HTTPChannel timeouts are cancelled. r7h2 cancelledFN)rr#rdrrrrrnegotiatedProtocolrhamcrest assert_thatgetDelayedCallscontains has_propertyequal_torrZrerrk)rKrrr h11Timeouts& r8test_h2CancelsH11Timeout0GenericHTTPChannelTests.test_h2CancelsH11TimeoutTs2   3 3C 80 oo  $    ! ! #   %%%%e,  **,Q/  s ..6  ,,-  ! ! #   %%%%e,  r7c `\4pVPV4pVPVR4R#)zr If the transport has no support for protocol negotiation (no negotiatedProtocol attribute), HTTP/1.1 is assumed. http/1.1N)rrgrZrKrrls& r8test_protocolUnspecified0GenericHTTPChannelTests.test_protocolUnspecifieds.  !II!L +[9r7c n\4pRVnVPV4pVPVR4R#)zv If the transport has no support for protocol negotiation (returns None for negotiatedProtocol), HTTP/1.1 is assumed. NrwrrlrgrZrxs& r8test_protocolNone)GenericHTTPChannelTests.test_protocolNones6  #!II!L +[9r7c n\4pRVnVPV4pVPVR4R#)zQ If the transport reports that HTTP/1.1 is negotiated, that's what's negotiated. rwNr|rxs& r8 test_http11#GenericHTTPChannelTests.test_http11s6  *!II!L +[9r7c n\4pRVnVPV4pVPVR4R#)ze If the transport reports that HTTP/2 is negotiated and HTTP/2 is present, that's what's negotiated. rjNr|rxs& r8test_http2_present*GenericHTTPChannelTests.test_http2_presents6  $!II!L +U3r7zHTTP/2 support presentc j\4pRVnVP\VPV4R#)zh If the transport reports that HTTP/2 is negotiated and HTTP/2 is not present, an error is encountered. rjN)rrl assertRaises ValueErrorrgrKrs& r8test_http2_absent)GenericHTTPChannelTests.test_http2_absents1  $    8 8  r7c j\4pRVnVP\VPV4R#)zh If the transport reports that a protocol other than HTTP/1.1 or HTTP/2 is negotiated, an error occurs. ssmtpN)rrlrAssertionErrorrgrs& r8test_unknownProtocol,GenericHTTPChannelTests.test_unknownProtocols1  &    8 8  r7c \P!R4pRVPnVP VPR4R#)z; The C{factory} attribute is taken from the inner channel. r7FooN)r#rdrrrZ)rKrs& r8 test_factory$GenericHTTPChannelTests.test_factorys4  3 3C 8#  F+r7c \4p\P!VR7pVPR4pVP VP VP 4VP VP P VP 4R#)z If C{callLater} is patched onto the L{http._GenericHTTPChannelProtocol} then we need to propagate it through to the backing channel. rN)rr#rrrZrr)rKrrrs& r8*test_GenericHTTPChannelPropagatesCallLaterBGenericHTTPChannelTests.test_GenericHTTPChannelPropagatesCallLaterse ""51((. ++U__= **44eooFr7c >\4p\P!VR7pVPR4pVP VP VP 4VP VP P VP 4\4pRVn\Vn VPV4VPR4VP VP VP 4VP VP P VP 4R#)z If C{callLater} is patched onto the L{http._GenericHTTPChannelProtocol} then we need to propagate it across onto a new backing channel after upgrade. rNrjP) rr#rrrZrrrrlrvrrrrKrrrrs& r8'test_genericHTTPChannelCallLaterUpgrade?GenericHTTPChannelTests.test_genericHTTPChannelCallLaterUpgrades""51((. ++U__= **44eooF#% ', $"2 * d# ++U__= **44eooFr7c \4pRVn\P!R4p\VnVP V4VPpVPVPV4VPR4VPVPV4VPVPVP4R#)zs The L{_GenericHTTPChannelProtocol} will unregister its proxy channel from the transport if upgrade is negotiated. rjr7rN) rrlr#rdrrrrassertIsproducerr assertIsNot)rKrgenericProtocoloriginalChannels& r8test_unregistersProducer0GenericHTTPChannelTests.test_unregistersProducers $% ', $AA#F)>&&&y1)22 i((/: $$T* ++_= i((/*B*BCr7r0N)r1r2r3r4r5rrgrr# H2_ENABLEDrtryr}rrrrrrrrr6rOrPs@r8rbrb7s    %  !=>/ ?/ b:::  !=>4?4 DOO56  7    , G  !=>G?G0  !=>D?Dr7rbcha]tRtRtoRRRRRRRR /t^t^t^t^tR t R t R t R t Rt RtRtVtR#)HTTPLoopbackTestsisrequestrscommandrsversionHTTP/1.0rxs21c\^VnVPVR4VPVR4R#)rr200N) gotStatusrZrKversionrmessages&&&&r8 _handleStatusHTTPLoopbackTests._handleStatus s) +. (r7c8^VnVPVR4R#)rrN) gotResponserZ)rKrs&&r8_handleResponse!HTTPLoopbackTests._handleResponse%s :;r7cVP^,VnVPVPVP4,V4R#rN) numHeadersrZrlower)rKkeyrs&&&r8 _handleHeaderHTTPLoopbackTests._handleHeader)s3//A- --ciik:EBr7cL^VnVPVP^4R#r) gotEndHeadersrZrrJs&r8_handleEndHeaders#HTTPLoopbackTests._handleEndHeaders-s !,r7cD\P!4p\Vn\ 4pVP VnVPVnVPVn VPVn \P!W4pVPVP 4V#r;)r#rrrrrhandleResponser handleHeaderrhandleEndHeadersr handleStatusr loopbackAsync addCallback_cbTestLoopback)rKserverclientds& r8 testLoopbackHTTPLoopbackTests.testLoopback1s!!# 5#% $ 4 4"00"&"8"8"00  " "6 2 d**+r7cVP'd%VP'dVP'g<\RP VPVPVP.44hV=V=V=V=R#)zdidn't get all callbacks {}N)rrr RuntimeErrorrr)rKignoreds&&r8r!HTTPLoopbackTests._cbTestLoopback=sn4#3#3#38J8J8J-44^^T%5%5t7I7IJ      N Or7)rrrrN)r1r2r3r4rrrrrrrrrrrr6rOrPs@r8rrsZKFK5 O JIKM) <C-   r7rc \P!\4R4pVP4F*wr#VPP \ V4V4K, V#)zJ Make a request with the given request headers for the persistence tests. F)r#rOr)itemsrequestHeaders setRawHeadersr)rr headerNamevs, r8 _prequestrJsHll<>51G  ,,]:-FJ) Nr7cBa]tRtRtoRtRtRtRtRtRt Rt Vt R #) PersistenceTestsiTz( Tests for persistent HTTP connections. cX\P!4Vn\4VnR#r;)r#rrrrrJs&r8setUpPersistenceTests.setUpYs'')  { r7c VPPVPR4pVPV4VP .\ VPP P444R#)zT After being used for an I{HTTP/0.9} request, the L{HTTPChannel} is not persistent. sHTTP/0.9NrcheckPersistencerrrZlistresponseHeadersgetAllRawHeadersrKpersists& r8 test_http09PersistenceTests.test_http09]T ,,// kJ ! T$,,">">"O"O"QRSr7c VPPVPR4pVPV4VP .\ VPP P444R#)zT After being used for an I{HTTP/1.0} request, the L{HTTPChannel} is not persistent. rNrrs& r8 test_http10PersistenceTests.test_http10frr7c VPPVPR4pVPV4VP .\ VPP P444R#)zP After being used for an I{HTTP/1.1} request, the L{HTTPChannel} is persistent. HTTP/1.1N)rrrrrZrrrrs& r8rPersistenceTests.test_http11osR ,,// kJ   T$,,">">"O"O"QRSr7c \R.R7pVPPVR4pVPV4VP RR.3.\ VP P444R#)zw After being used for an I{HTTP/1.1} request with a I{Connection: Close} header, the L{HTTPChannel} is not persistent. sclose) connectionrs ConnectionN)rrrrrZrrr)rKrrs& r8test_http11Close!PersistenceTests.test_http11Closexsf z2,,//E ! hZ ( ) ((99; < r7)rrN) r1r2r3r4r5rrrrrr6rOrPs@r8rrTs+#TTT   r7rc`a]tRtRtoRtRtRtRtRtRt Rt R t R t R t R tR tVtR#)IdentityTransferEncodingTestsiz( Tests for L{_IdentityTransferDecoder}. c .Vn.Vn^ Vn\VPVPPVPP4VnR#)zh Create an L{_IdentityTransferDecoder} with callbacks hooked up so that calls to them can be inspected. N)rr contentLengthr(r^decoderrJs&r8r#IdentityTransferEncodingTests.setUpsG   /    0 0$++2D2D  r7c VPPRVP,4VPVPRVP,.4VPVP R.4R#)a If L{_IdentityTransferDecoder.dataReceived} is called with a byte string with length equal to the content length passed to L{_IdentityTransferDecoder}'s initializer, the data callback is invoked with that string and the finish callback is invoked with a zero-length string. rr7NrrrrZrrrJs&r8test_exactAmountReceived6IdentityTransferEncodingTests.test_exactAmountReceivedsY !!$););";< TD,>,>%>$?@ se,r7c VPPR4VPVPR.4VPVP.4VPPRVP ^, ,4VPVPRRVP ^, ,.4VPVPR.4R#)a  If L{_IdentityTransferDecoder.dataReceived} is called multiple times with byte strings which, when concatenated, are as long as the content length provided, the data callback is invoked with each string and the finish callback is invoked only after the second call. ryr7N)rrrZrrrrJs&r8test_shortStrings/IdentityTransferEncodingTests.test_shortStringss !!$' TF+ b) !!$$*<*,>%>$?@ tf-r7c Vaa.oVV3Rlp\^VPPV4oSPR4VP S.4SPR4S^,P \ 4VP \S^,P4R4R#)z If data is passed to L{_IdentityTransferDecoder.dataReceived} after the finish callback has been invoked, C{RuntimeError} is raised. c<SPR4R# \dSP\44R#i;i)fooN)r BaseExceptionr^r)rrfailuress&r8rJIdentityTransferEncodingTests.test_rejectDataAfterFinished..finishs3 +$$V,  + * +s $>>rz;_IdentityTransferDecoder cannot decode data after finishingNsxxxx) r(rr^rrZtraprrr)rKrrrs& @@r8test_rejectDataAfterFinished:IdentityTransferEncodingTests.test_rejectDataAfterFinisheds  + +1dii.>.>GX& 2&T" &   !! " I r7c .p.p\RVPVP4pVPR4VPVR.4VPR4VPVRR.4VPV.4R#)z If L{_IdentityTransferDecoder} is constructed with L{None} for the content length, it passes all data delivered to it through to the data callback. Nrr)r(r^rrZ)rKrrrs& r8test_unknownContentLength7IdentityTransferEncodingTests.test_unknownContentLengthsv *4fmmLT" v&T" d|, $r7c vVPVPR4VPVPR4R#)zu Check the decoder's data and finish callbacks and make sure they are None in order to help avoid references cycles. N)assertIdentical dataCallbackfinishCallback)rKrs&&r8_verifyCallbacksUnreferenced:IdentityTransferEncodingTests._verifyCallbacksUnreferenceds0 W1148 W33T:r7c VPPRVP^, ,4VP\VPP 4VP VP4R#)z L{_IdentityTransferDecoder.noMoreData} raises L{_DataLoss} if it is called and the content length is known but not enough bytes have been delivered. rN)rrrrr' noMoreDatarrJs&r8test_earlyConnectionLose6IdentityTransferEncodingTests.test_earlyConnectionLosesR !!$$*<*r7c 0.p.p\P!VPVP4p\R4FpVP V4K VP V.RO4VP VR.4VP VP .4R#)zc L{_ChunkedTransferDecoder.dataReceived} decodes chunks broken up and delivered in multiple calls. 3 abc 5 12345 0 r7Nabc12345r#r(r^rrrZ_trailerHeadersrKr*rr+ss& r8 test_short'ChunkedTransferEncodingTests.test_shorts~   ( (8?? CABA NN1 C LM C5) **B/r7c .p.p\P!VPVP4pVPR4VPR4VPR4VP VRR.4VP VR.4R#)z` L{_ChunkedTransferDecoder.dataReceived} delivers partial chunk data as soon as it is received. s a; 12345s67890s 0; ...r&s...Nr')rKrrr+s& r8 test_long&ChunkedTransferEncodingTests.test_long-st   ( (hoo F ~& x  +, (34 F8,r7c <.p.p\P!VPVP4pVPR4\ R4F%pVPV4VPR4K' VP V.RO4VP VR.4R#)zZ L{_ChunkedTransferDecoder.dataReceived} is robust against receiving a zero-length input. r7r/Nr0)r#r(r^rrrZ)rKchunksrr+r<s& r8 test_empty'ChunkedTransferEncodingTests.test_empty;s   ( ( H sABA NN1  NN3 C !QR C5)r7c .p\P!VPR4pVPR4VP VR.4R#)zg L{_ChunkedTransferDecoder.dataReceived} doesn't treat CR LF pairs embedded in chunk bodies specially. Ns2  r'r)s& r8 test_newlines*ChunkedTransferEncodingTests.test_newlinesJs>   ( (4 8 '( WI&r7c .p\P!VPR4pVPR4VP VR.4R#)zL L{_ChunkedTransferDecoder.dataReceived} disregards chunk-extension fields. Ns3; x-foo=bar abc r%r'r)s& r8test_extensions,ChunkedTransferEncodingTests.test_extensionsTs>   ( (4 8 12 VH%r7c RpRpRpW,V,FapR\V34,R,p\P!RR4pVP\PVP V4Kc R#) z L{_ChunkedTransferDecoder.dataReceived} raises L{_MalformedChunkedDataError} when the chunk extension fields contain invalid characters. This is a potential request smuggling vector: see GHSA-c2jg-hw38-jrqq. s \s3;  abc cR#r;r0rs&r8GChunkedTransferEncodingTests.test_extensionsMalformed..o$r7cR#r;r0rRs&r8rSrTprUr7N)rr#r(r_MalformedChunkedDataErrorr)rKinvalidControlinvalidDelimiter invalidDelrrr+s& r8test_extensionsMalformed5ChunkedTransferEncodingTests.test_extensionsMalformed^sy P ! 2Z??AE1$K'.8D,,A   d==q~~t T @r7c \P!RR4pVP\PVPRR\P ,,R,4R#)a L{_ChunkedTransferDecoder.dataReceived} raises L{_MalformedChunkedDataError} when the chunk size line exceeds 4 KiB. This applies even when the data has already been received and buffered so that behavior is consistent regardless of how bytes are framed. Ns3;.rPr#r(rrWrmaxChunkSizeLineLengthrKr+s& r8test_oversizedChunkSizeLine8ChunkedTransferEncodingTests.test_oversizedChunkSizeLinetsL  ( (t 4   + + NN D4666 6 G r7c \P!RR4pVP\PVPR\P ^,,4R#)z L{_ChunkedTransferDecoder.dataReceived} raises L{_MalformedChunkedDataError} when the amount of data buffered while looking for the end of the chunk size line exceeds 4 KiB so that buffering does not continue without bound. Nr^r_ras& r8"test_oversizedChunkSizeLinePartial?ChunkedTransferEncodingTests.test_oversizedChunkSizeLinePartialsG  ( (t 4   + + NN D//!3 4 r7c \P!RR4pVP\PVPR4R#)z L{_ChunkedTransferDecoder.dataReceived} raises L{_MalformedChunkedDataError} when the chunk size can't be decoded as a base-16 integer. cR#r;r0rRs&r8rSFChunkedTransferEncodingTests.test_malformedChunkSize..dr7cR#r;r0rRs&r8rSrirjr7s bloop abc Nr#r(rrWrras& r8test_malformedChunkSize4ChunkedTransferEncodingTests.test_malformedChunkSizes<  ( (      + +Q^^=P r7c \P!RR4pVP\PVPR4R#)zo L{_ChunkedTransferDecoder.dataReceived} raises L{_MalformedChunkedDataError} when the chunk size is negative. cR#r;r0rRs&r8rSNChunkedTransferEncodingTests.test_malformedChunkSizeNegative..rjr7cR#r;r0rRs&r8rSrqrjr7s -3 abc Nrlras& r8test_malformedChunkSizeNegative.rjr7cR#r;r0rRs&r8rSrwrjr7s 0x3 abc Nrlras& r8test_malformedChunkSizeHex7ChunkedTransferEncodingTests.test_malformedChunkSizeHexs<  ( (      + +Q^^=N r7c \P!RR4pVP\PVPR4R#)z L{_ChunkedTransferDecoder.dataReceived} raises L{_MalformedChunkedDataError} when the chunk is followed by characters other than C{\r\n}. cR#r;r0rRs&r8rSEChunkedTransferEncodingTests.test_malformedChunkEnd..rjr7cR#r;r0rRs&r8rSr}rjr7s 3 abc!!!!Nrlras& r8test_malformedChunkEnd3ChunkedTransferEncodingTests.test_malformedChunkEnds;  ( (      + +Q^^_ r7c .p\P!RVP4pVPR4VP VR.4R#)z L{_ChunkedTransferDecoder.dataReceived} interprets a zero-length chunk as the end of the chunked data stream and calls the completion callback. N0 r7r'rKrr+s& r8 test_finish(ChunkedTransferEncodingTests.test_finishs=   ( (x ? |$ C5)r7c .p\P!RVP4pVPR4VP VR.4R#)z L{_ChunkedTransferDecoder.dataReceived} passes any bytes which come after the terminating zero-length chunk to the completion callback. Ns 0 hellohellor'rs& r8 test_extra'ChunkedTransferEncodingTests.test_extras>   ( (x ? () H:.r7c \P!RR4pVPR4VP\VPR4R#)zr L{_ChunkedTransferDecoder.dataReceived} raises C{RuntimeError} if it is called after it has seen the last chunk. NcR#r;r0rs&r8rSAChunkedTransferEncodingTests.test_afterFinished..sTr7rr)r#r(rrrras& r8test_afterFinished/ChunkedTransferEncodingTests.test_afterFinisheds9  ( (/A B |$ ,Ar7c \P!RR4pVPR4VP\VP 4pVP \V4R4R#)z L{_ChunkedTransferDecoder.noMoreData} raises L{_DataLoss} if it is called and the end of the last trailer has not yet been received. NcR#r;r0rs&r8rSGChunkedTransferEncodingTests.test_earlyConnectionLose..$r7s0 zYChunked decoder in 'TRAILER' state, still expecting more data to get to 'FINISHED' state.)r#r(rrr'rrZr)rKparserexcs& r8r5ChunkedTransferEncodingTests.test_earlyConnectionLosesW --d4FGJ' 6+<+<=  H * r7c x\P!RR4pVPR4VP4R#)z L{_ChunkedTransferDecoder.noMoreData} does not raise any exception if it is called after the terminal zero length chunk is received. NcR#r;r0rs&r8rSJChunkedTransferEncodingTests.test_finishedConnectionLose..rr7r)r#r(rr)rKrs& r8r8ChunkedTransferEncodingTests.test_finishedConnectionLoses1 --d4FGL)r7c aaa.o.oVVV3Rlp\P!RV4oSPR4VPS.4VPSR.4R#)zn L{_ChunkedTransferDecoder.noMoreData} can be called from the finished callback without raising an exception. c<SP4SPR4R# \dSP\44R#i;iTN)rr^rr)extraerrorsr successess&r8rOChunkedTransferEncodingTests.test_reentrantFinishedNoMoreData..finishedsC '!!#  &! ) gi( )s&$A ANrT)r#r(rrZ)rKrrrrs& @@@r8 test_reentrantFinishedNoMoreData=ChunkedTransferEncodingTests.test_reentrantFinishedNoMoreDatasX   '--dH=L) $ TF+r7c 2.p.p\P!VPVP4pVPR4VPR4VP V.RO4VP VR.4VP VP RR.4R#)z L{_ChunkedTransferDecoder.dataReceived} decodes chunked-encoded data and ignores trailer headers which come after the terminating zero-length chunk. r#s\a 0123456789 0 Server-Timing: total;dur=123.4 Expires: Wed, 21 Oct 2015 07:28:00 GMT r7Server-Timing: total;dur=123.4s&Expires: Wed, 21 Oct 2015 07:28:00 GMTNr$)r#r(r^rrZr:)rKr*rr+s& r8test_trailerHeaders0ChunkedTransferEncodingTests.test_trailerHeaderss   ( (8?? C 45  w  => C5)   19  r7c 2.p.p\P!VPVP4p\R4FpVP V4K VP V.RO4VP VR.4VP VP R.4R#)z L{_ChunkedTransferDecoder.dataReceived} decodes chunks of input with tailer header broken up and delivered in multiple calls. s73 abc 5 12345 0 Server-Timing: total;dur=123.4 r7rNr0r9r;s& r8test_shortTrailerHeader4ChunkedTransferEncodingTests.test_shortTrailerHeader*s   ( (8?? C T A NN1   LM C5) **-N,OPr7c \P!RR4p^ VnVP\PVP R4R#)zz L{_ChunkedTransferDecoder.dataReceived} raises L{_MalformedChunkedDataError} when the trailing headers data is too long. cR#r;r0rRs&r8rSHChunkedTransferEncodingTests.test_tooLongTrailerHeader..@rjr7cR#r;r0rRs&r8rSrArjr7s43 abc 0 Total-Trailer: header;greater-then=10 N)r#r(_maxTrailerHeadersSizerrWrras& r8test_tooLongTrailerHeader6ChunkedTransferEncodingTests.test_tooLongTrailerHeader:sE  ( (   $&    + + NN M r7c \P!RR4p^ VnVPR4VPR4VP \P VPR4R#)z L{_ChunkedTransferDecoder.dataReceived} raises L{_MalformedChunkedDataError} when the trailing headers data is too long and doesn't have final CRLF characters. cR#r;r0rRs&r8rSKChunkedTransferEncodingTests.test_unfinishedTrailerHeader..Qrjr7cR#r;r0rRs&r8rSrRrjr7s3 abc 0 01234567 AN)r#r(rrrrWras& r8test_unfinishedTrailerHeader9ChunkedTransferEncodingTests.test_unfinishedTrailerHeaderJs`  ( (   $&  34 u   + + NN  r7r0N)r1r2r3r4r5r,r=r@rDrHrKr[rbrermrsryrrrrrrrrrrrr6rOrPs@r8r!r! s ? 0 - *'&U,           */B  ,* .Q    r7r!cJa]tRtRto.R OtRtRtRtR RltRt Rt Vt R#) ChunkingTestsiacVPFPpRP\P!V44pVP VR3\P !V44KR VP \\P R4VP \\P R4VP \\P R4R#)r7s-5 malformed! s0xa malformed! s0XA malformed! N)stringsjoinr#toChunkrZ fromChunkrr)rKr<chunkeds& r8 testChunksChunkingTests.testChunksdsAhht||A/G   aXt~~g'> ? *dnn6MN *dnn6NO *dnn6NOr7c RPVPUu.uF(pRP\P!V44NK* up4p.pRp\ V4F5pWE,p\P !V4wrdVP V4K7 VPW0P4R#uupi \dKii;i)r7N) rrr#rrrr^rrZ)rKrfrresultbuffercrs& r8testConcatenatedChunks$ChunkingTests.testConcatenatedChunksls((t||L|!CHHT\\!_5|LM7#AZF #~~f5  d# $ .M  s.B4*)B99 CCc \4p\P!4pVPV4\P!VR4pVP ^4RVnVPPRR.4VPR4VPR4VPVP4R.4R#) zF Test that the L{HTTPChannel} correctly chunks responses when needed. FrtestlemurHelloWorld!Nr Test: lemurTransfer-Encoding: chunkeds5 Hello 6 World! ) rr#rrrOrHrrrrrr)rKtransrrVs& r8test_chunkedResponses#ChunkingTests.test_chunkedResponsesys !""$u%ll7E* C % ))'H:> ( ) !! KKM  r7Nc  \P!4pV'd\V4VnVP RR4pVP R^4wrV\ 4pVPV4VPVR,4\\V4V,^,4FlpVPP'dMOVPRP\P!WhV,V^,V,444Kn VPRP\P!R444VP\!R44V#)z Execute a web request based on plain text content, chunking the request payload. This is a stripped-down, chunking version of ParsingTests.runRequest. ryrGrr7r)r#rrBrreplacerrrrrUrrrrrrr) rK httpRequestr chunkSizerheaderrrposs &&&& r8runChunkedRequestChunkingTests.runChunkedRequests""$ %=n%MG "!))%9 "((a8 #% y)Vk12Ti/!34C  ...  d?cAg=R&STU 5 SXXdll3&789wz23r7c Da.o!V3RlR\P4pRpVPW!^R7pVPVPP 4R4VP\ S4^4VPS^,PRR./4R#) z Test that chunked uploads are actually processed into args. This is essentially a copy of ParsingTests.test_multipartFormData, just with chunking put in. c.<a]tRtRtoV3RltRtVtR#)7ChunkingTests.test_multipartFormData..MyRequesticl<SPV4VPR4VP4R#sdoneNr^rrrK processeds&r8rL?ChunkingTests.test_multipartFormData..MyRequest.process&  & 7# r7r0NrrQrs@r8 MyRequestr  r7rsPOST / HTTP/1.0 Content-Type: multipart/form-data; boundary=AaB03x Transfer-Encoding: chunked --AaB03x Content-Type: text/plain Content-Disposition: form-data; name="text" Content-Transfer-Encoding: quoted-printable abasdfg --AaB03x-- )rHTTP/1.0 200 OK donetextabasdfgN)r#rOrrZrrrr<rKrrVrrs& @r8test_multipartFormData$ChunkingTests.test_multipartFormDatas     ((1(E **0024RS Y+ 1**Wzl,CDr7r0)sabcvr7sfdfsd423s Ffasfas s 523523 fsdfs4234)Nr) r1r2r3r4rrrrrrr6rOrPs@r8rras,UGP / 8@EEr7rc<a]tRtRtoRtRtR3RltRtRtRt R t R t R t R t R tRtRtRtRtRtRtRtRtRtRtRtRtRtRtRtRtRtRt R t!R!t"R"t#R#t$R$t%R%t&R&t'R't(R(t)R)t*R*t+R+t,R,t-R-t.R.t/R/t0R0t1R1t2R2t3Vt4R#)4 ParsingTestsiz/ Tests for protocol parsing in L{HTTPChannel}. cRVnR#)FN didRequestrJs&r8rParsingTests.setUps r7Nc V'g\P!4pV'd\V4VnVP RR4p\ 4pVP V4\V4F2pVPP'dMVPV4K4 VP\R44V'dVPVP4V#VPVP4V#)a Execute a web request based on plain text content. @param httpRequest: Content for the request which is processed. Each L{" "} will be replaced with L{" "}. @type httpRequest: C{bytes} @param requestFactory: 2-argument callable returning a Request. @type requestFactory: C{callable} @param success: Value to compare against I{self.didRequest}. @type success: C{bool} @param channel: Channel instance over which the request is processed. @type channel: L{HTTPChannel} @return: Returns the channel used for processing the request. @rtype: L{HTTPChannel} ryrGr)r#rrBrrrrrrrrrrrrr)rKrrsuccessrrrs&&&&& r8 runRequestParsingTests.runRequests(&&(G %=n%MG "!))%9 #% y)k*D  ...   &+ wz23  OODOO ,   T__ -r7c NaRPV4p.o!V3RlR\P4pVPW#RR7pVP VP P 4R4VPVP P4VP S.4R#)a Execute a HTTP request and assert that it is rejected with a 400 Bad Response and disconnection. @param requestLines: Plain text lines of the request. These lines will be joined with newlines to form the HTTP request that is processed. @type requestLines: C{list} of C{bytes} ryc.<a]tRtRtoV3RltRtVtR#)5ParsingTests.assertRequestRejected..MyRequesticJ<SPV4VP4R#r;r^rrs&r8rL=ParsingTests.assertRequestRejected..MyRequest.process  & r7r0Nrrs@r8rr  r7rFrrN) rr#rOrrZrrrr)rK requestLinesrrrrs&& @r8assertRequestRejected"ParsingTests.assertRequestRejected sjj.      //+%/H     # # % /  ))778 B'r7c .a.o!V3RlR\P4pRpVPW!^4pVPVPP 4R4VP VPP4VPS.4R#)zw When client sends invalid HTTP method containing non-ascii characters HTTP 400 'Bad Request' status will be returned. c.<a]tRtRtoV3RltRtVtR#):ParsingTests.test_invalidMethodNonAscii..MyRequesti*cJ<SPV4VP4R#r;rrs&r8rLBParsingTests.test_invalidMethodNonAscii..MyRequest.process+rr7r0Nrrs@r8rr*rr7rsGE© / HTTP/1.1 rN)r#rOrrZrrrr)rKrbadRequestLinerrs& @r8test_invalidMethodNonAscii'ParsingTests.test_invalidMethodNonAscii#sy      ://.Q? **0024WX ))778 B'r7c DRFpVPVRRRR.4K R#)z The three components of the request line must not be separated by anything other than a single SP character, or a 400 status results. Content-Length: 0Host: foo.exampler7N)sGET / HTTP/1.0sGET / HTTP/1.0sGET / HTTP/1.0sGET / HTTP/1.1sGET / HTTP/1.1 s GET / HTTP/1.1r)rK requestLines& r8"test_invalidRequestLineExtraSpaces/ParsingTests.test_invalidRequestLineExtraSpaces5s.  K  & &24H#sS  r7c ,VP.RO4R#)zJ A request with an empty method field is rejected with a 400 status code. N)s /foo HTTP/1.1rrr7r7rrJs&r8test_invalidMethodEmpty$ParsingTests.test_invalidMethodEmptyG ""  r7c ,VP.RO4R#)z[ A request with a method that contains a NUL character is rejected with a 400 status code. N)sGET /foo HTTP/1.1rrr7r7rrJs&r8test_invalidMethodNUL"ParsingTests.test_invalidMethodNULVrr7c ,VP.RO4R#)zS A request with an invalid HTTP version number is rejected with a 400 status code. N)sHEAD /foo HTTP/1.2rrr7r7rrJs&r8test_invalidVersion ParsingTests.test_invalidVersionerr7c ,VP.RO4R#)R A request with an empty request-target (URI) is rejected with a 400 status code. N)sPOST HTTP/1.1rrr7r7rrJs&r8test_invalidRequestTargetEmpty+ParsingTests.test_invalidRequestTargetEmptytrr7c ,VP.RO4R#)r N)sPOST /foo HTTP/1.1rrr7r7rrJs&r8test_invalidRequestTargetNUL)ParsingTests.test_invalidRequestTargetNULrr7c ,VP.RO4R#)zd A request with a request-target (URI) that contains whitespace is rejected with a 400 status code. N)sPOST /foo /bar HTTP/1.1rrr7r7rrJs&r8#test_invalidRequestTargetWhitespace0ParsingTests.test_invalidRequestTargetWhitespacerr7c Da.o!V3RlR\P4pRFzwr#\P!RP W#344pRV,R,pVP WQ^4SP 4pVPW#3VP4K| R#)z L{HTTPChannel} provides username and password information supplied in an I{Authorization} header to the L{Request} which makes it available via its C{getUser} and C{getPassword} methods. c.<a]tRtRtoV3RltRtVtR#),ParsingTests.test_basicAuth..Requestict<VP4VP43VnSPV4R#r;getUser getPassword credentialsr^rKrs&r8rL4ParsingTests.test_basicAuth..Request.process+$(LLND4D4D4F#G %r7r0NrrQrs@r8rOr+ & &r7rO:$GET / HTTP/1.0 Authorization: Basic  N))rbar)rsthere:z) r#rObase64 b64encoderrrrZr0)rKrOur+r<frVrs& @r8test_basicAuthParsingTests.test_basicAuths  &dll & ?DA  A6!23A81.MyRequesticJ<SPV4VP4R#r;rrs&r8rL4ParsingTests.test_headers..MyRequest.processrr7r0Nrrs@r8rrCrr7rryrr:sbAzsQuuxquuxN)GET / HTTP/1.0Foo: bars baz: Quuxs baz: quuxr7r7r#rOrrrZr getRawHeadersrKrrrrs& @r8 test_headersParsingTests.test_headerss         <0)Q?  //==fExP   " " 0 0 87G:L r7c a.o!V3RlR\P4p.R OpVPRPV4V^4SwpVP VP P R4R.4VP VP P R4R.4VP VP P R4R.4VP VP P R 4R .4R #) a Line folded headers are handled by L{HTTPChannel} by replacing each fold with a single space by the time they are made available to the L{Request}. Any leading whitespace in the folded lines of the header value is replaced with a single space, per: A server that receives an obs-fold in a request message ... MUST ... replace each received obs-fold with one or more SP octets prior to interpreting the field value or forwarding the message downstream. See RFC 7230 section 3.2.4. c.<a]tRtRtoV3RltRtVtR#)5ParsingTests.test_headersMultiline..MyRequesticJ<SPV4VP4R#r;rrs&r8rL=ParsingTests.test_headersMultiline..MyRequest.processrr7r0Nrrs@r8rrPrr7rrysnospacesspaces space spacespacessspaces spaces spacesstabst a bN) rGs nospace: s nospace s space:spaces spacesspaces: spacess spacess spacesstab: ts as br7r7rIrKs& @r8test_headersMultiline"ParsingTests.test_headersMultilines       <0)Q?    " " 0 0 < L    " " 0 0 :      " " 0 0 ; $ %    " " 0 0 8 J r7c Pa.o!V3RlR\P4p.ROpVPRPV4V^4SwpVP VP P R4R.4VP VP P R4R.4VP VP P R4R .4VP VP P R 4R .4VP VP P R 4R .4R#)z Leading and trailing space and tab characters are stripped from headers. Other forms of whitespace are preserved. See RFC 7230 section 3.2.3 and 3.2.4. c.<a]tRtRtoV3RltRtVtR#):ParsingTests.test_headerStripWhitespace..MyRequesticJ<SPV4VP4R#r;rrs&r8rLBParsingTests.test_headerStripWhitespace..MyRequest.processrr7r0Nrrs@r8rrXrr7rryrSsspaces were strippedstabsstabs were strippedsspaces-and-tabssspaces and tabs were strippedsline-tabs vertical tab was preserved s form-feeds form feed was preserved N)rGs!spaces: spaces were stripped stabs: tabs were stripped s5spaces-and-tabs: spaces and tabs were stripped s*line-tab: vertical tab was preserved s(form-feed: form feed was preserved r7r7rIrKs& @r8test_headerStripWhitespace'ParsingTests.test_headerStripWhitespace s        <0)Q?    " " 0 0 ; $ %    " " 0 0 9 " #    " " 0 01C D - .    " " 0 0 = / 0    " " 0 0 > - . r7c R.p\\PP^,4F pVP \ V R244K" VP RR.4VPV4R#)zm C{HTTPChannel} enforces a limit of C{HTTPChannel.maxHeaders} on the number of headers received per request. rGz: foor7N)rUr#r maxHeadersr^rextendr)rKrr[s& r8test_tooManyHeaders ParsingTests.test_tooManyHeaders=se ** t''22Q67A    5k : ;8S#J' ""<0r7c ,VP.RO4R#)z If a I{Content-Length} header with a non-integer value is received, a 400 (Bad Request) response is sent to the client and the connection is closed. N)rGsContent-Length: xr7r7rrJs&r8test_invalidContentLengthHeader,ParsingTests.test_invalidContentLengthHeaderI ""  r7c ,VP.RO4R#)zx If a header without colon is received a 400 (Bad Request) response is sent to the client and the connection is closed. N)rGs HeaderName r7r7rrJs&r8test_invalidHeaderNoColon&ParsingTests.test_invalidHeaderNoColonXs ""  r7c ,VP.RO4R#)z C{HTTPChannel} rejects a request with an empty header name (i.e. nothing before the colon). It produces a 400 (Bad Request) response and closes the connection. N)rGs: foor7r7rrJs&r8test_invalidHeaderOnlyColon(ParsingTests.test_invalidHeaderOnlyColonfrer7c ,VP.RO4R#)z C{HTTPChannel} rejects a request containing a header with whitespace between the header name and colon as requried by RFC 7230 section 3.2.4. A 400 (Bad Request) response is generated and the connection closed. N)rGsHeaderName : foor7r7rrJs&r8'test_invalidHeaderWhitespaceBeforeColon4ParsingTests.test_invalidHeaderWhitespaceBeforeColonus ""  r7c DRFpVPRRVRR.4K R#)zc A request with a header name that contains invalid characters is rejected with a 400 status code. GET / HTTP/1.1rr7N)s foobar: bazs foobar: bazs Foo Bar: bazs Foo Bar: bazsfoo‽bar: bazrrKrs& r8test_invalidHeaderNameChars(ParsingTests.test_invalidHeaderNameCharss-  F  & &"$8&#sK  r7c DRFpVPRRVRR.4K R#)z\ A request with a header value that contains a NUL byte is rejected with a 400 status code. rprr7N)sx-foo: s x-foo: as x-foo: bazsx-foo: x0 rrqs& r8test_invalidHeaderValueNUL'ParsingTests.test_invalidHeaderValueNULs-  F  & &"$8&#sK   r7c a.o!V3RlR\P4pVP\PR^4.R OpVP RP V4V^4pSwrEVP VPR4R4VP VPR4R4VP VPP4R4R #) z C{HTTPChannel} enforces the limit of C{HTTPChannel.maxHeaders} per request so that headers received in an earlier request do not count towards the limit when processing a later request. c.<a]tRtRtoV3RltRtVtR#):ParsingTests.test_headerLimitPerRequest..MyRequesticJ<SPV4VP4R#r;rrs&r8rLBParsingTests.test_headerLimitPerRequest..MyRequest.processrr7r0Nrrs@r8rryrr7rr^ryrr:bazhHTTP/1.1 200 OK Transfer-Encoding: chunked 0 HTTP/1.1 200 OK Transfer-Encoding: chunked 0 N)rprHr7r7rpsBar: bazr7r7) r#rOpatchrrrrZr~rr)rKrrrfirstsecondrs& @r8test_headerLimitPerRequest'ParsingTests.test_headerLimitPerRequests      4##\15  //%**\":IqI# 0&9 ))&16:     # # %  r7c "a.o!V3RlR\P4p\P!4p^ VnRpVP VVVRR7pVP S.4VP VP P4R4R#)z Enforces a limit of C{HTTPChannel.totalHeadersSize} on the size of headers received per request starting from initial command line. c.<a]tRtRtoV3RltRtVtR#)@ParsingTests.test_headersTooBigInitialCommand..MyRequesticJ<SPV4VP4R#r;rrs&r8rLHParsingTests.test_headersTooBigInitialCommand..MyRequest.processrr7r0Nrrs@r8rrrr7rs"GET /path/longer/than/10 HTTP/1.1 FrrrrrNr#rOrtotalHeadersSizerrZrrrKrrrrs& @r8 test_headersTooBigInitialCommand-ParsingTests.test_headersTooBigInitialCommands      ""$#% < //#$ "  B' **0024WXr7c "a.o!V3RlR\P4p\P!4p^(VnRpVP VVVRR7pVP S.4VP VP P4R4R#)z Enforces a limit of C{HTTPChannel.totalHeadersSize} on the size of headers received per request counting first line and total headers. c.<a]tRtRtoV3RltRtVtR#)>ParsingTests.test_headersTooBigOtherHeaders..MyRequesticJ<SPV4VP4R#r;rrs&r8rLFParsingTests.test_headersTooBigOtherHeaders..MyRequest.processrr7r0Nrrs@r8rrrr7rs5GET /less/than/40 HTTP/1.1 Some-Header: less-than-40 FrrNrrs& @r8test_headersTooBigOtherHeaders+ParsingTests.test_headersTooBigOtherHeaderss      ""$#% T //#$ "  B' **0024WXr7c !RR\P4p\P!4p^.SimpleRequesti c&VP4R#r;)rrJs&r8rLHParsingTests.test_headersTooBigPerRequest..SimpleRequest.process s  r7r0NrrPs@r8 SimpleRequestr s  r7rsZGET / HTTP/1.1 Some-Header: total-less-than-60 GET / HTTP/1.1 Some-Header: less-than-60 F)rrrr}N) r#rOrrrrrZrr)rKrrrs& r8test_headersTooBigPerRequest)ParsingTests.test_headersTooBigPerRequest s{  DLL ""$#% !.  //#e"      # # %  r7c  aaRp/oVo!VV3RlR\P4pVPW4VPSRRRRRR /4R #) z# Test cookies parsing and reading. sKGET / HTTP/1.0 Cookie: rabbit="eat carrot"; ninja=secret; spam="hey 1=1!" c0<a]tRtRtoVV3RltRtVtR#)+ParsingTests.testCookies..MyRequesti9 cp<RFpVPV4SV&K RSnVP4R#)rabbitTN)rninjaspam) getCookierr)rKnamecookiestestcases& r8rL3ParsingTests.testCookies..MyRequest.process: s0:D$(NN4$8GDM;&*# r7r0Nr)rQrrs@r8rr9 s  r7rrs "eat carrot"rssecretrs "hey 1=1!"Nr#rOrrZ)rKrrrrs& @@r8 testCookiesParsingTests.testCookies- sZ       /   9g} U r7caaaRp.o.oVo!VVV3RlR\P4pVPW4VPSR.4VPSR.R.RR..4R#) sJGET /?key=value&multiple=two+words&multiple=more%20words&empty= HTTP/1.0 c2<a]tRtRtoVVV3RltRtVtR#)'ParsingTests.testGET..MyRequestiP c<SPVP4SPVPR,VPR,VPR,.4RSnVP 4R#skeysemptysmultipleTN)r^rr_r<rr)rKr<rrs&r8rL/ParsingTests.testGET..MyRequest.processQ sW dkk* YYv& ((;TYY{=ST'+# r7r0Nr)rQr<rrs@r8rrP s  r7rrvaluer7 two words more wordsNr)rKrrr<rrs& @@@r8testGETParsingTests.testGETG sp       / &*  SEL-3PQRr7c aaaaRp.o.o.oVo!VVVV3RlR\P4pVPW4VPSR.4VPSR.4VPSR.R..4R#) z While only a single '?' is allowed in an URL, several other servers allow several and pass all after the first through as part of the query arguments. Test that we emulate this behavior. s"GET /foo?bar=?&baz=quux HTTP/1.0 c4<a]tRtRtoVVVV3RltRtVtR#)6ParsingTests.test_extraQuestionMark..MyRequestij c <SPVP4SPVP4SPVPR,VPR,.4RSnVP 4R#)r:r|TN)r^rpathr_r<rr)rKr<rrrs&r8rL>ParsingTests.test_extraQuestionMark..MyRequest.processk sW dkk* DII& TYYv. &0ABC&*# r7r0Nr)rQr<rrrs@r8rrj s  r7rrs/foo?rFNr)rKrrr<rrrs& @@@@r8test_extraQuestionMark#ParsingTests.test_extraQuestionMark] s~ >       / &* y)  23r7c LaaaaRp\R\V4V3,4p.o.o.oVo!VVVV3RlR\P4pVP W#4VP SR.4VP SR.R.RR ..4VP S\V4.4R #) a- The request body of a I{POST} request with a I{Content-Type} header of I{application/x-www-form-urlencoded} is parsed according to that content type and made available in the C{args} attribute of the request object. The original bytes of the request may still be read from the C{content} attribute. z9key=value&multiple=two+words&multiple=more%20words&empty=zVPOST / HTTP/1.0 Content-Length: %d Content-Type: application/x-www-form-urlencoded %sc4<a]tRtRtoVVVV3RltRtVtR#)4ParsingTests.test_formPOSTRequest..MyRequesti cL<SPVP4SPVPR,VPR,VPR,.4SPVPP 44RSnVP4R#r)r^rr_r<r{r}rr)rKr<r{rrs&r8rL.MyRequest.process sp dkk* YYv& ((;TYY{=STt||0023&*# r7r0Nr)rQr<r{rrs@r8rr s  r7rsPOSTrr7rrN)rrr#rOrrZ)rKqueryrrr<r{rrs& @@@@r8test_formPOSTRequest!ParsingTests.test_formPOSTRequestw sL#  5z5!  "       / '+  SEL-3PQR =#7"89r7c RpVPV\PRR7pVPVPP 4R4R#)zH When the multipart processing fails the client gets a 400 Bad Request. sPOST / HTTP/1.0 Content-Type: multipart/form-data; boundary=☃ Content-Length: 103 --☃ Content-Type: text/plain Content-Length: 999999999999999999999999999999999999999999999999999999999999999 Content-Transfer-Encoding: quoted-printable abasdfg --☃-- FrrN)rr#rOrZrr)rKrVrs& r8test_multipartProcessingFailure,ParsingTests.test_multipartProcessingFailure sC //#t||U/C **0024WXr7c a.o!V3RlR\P4pRpVPW!RR7pVPVPP 4R4VPS^,P /4R#)zC When the multipart does not contain a header is should be skipped c.<a]tRtRtoV3RltRtVtR#)JParsingTests.test_multipartEmptyHeaderProcessingFailure..MyRequesti cl<SPV4VPR4VP4R#rrrs&r8rLRParsingTests.test_multipartEmptyHeaderProcessingFailure..MyRequest.process rr7r0Nrrs@r8rr rr7rsrPOST / HTTP/1.0 Content-Type: multipart/form-data; boundary=AaBb1313 Content-Length: 14 --AaBb1313 --AaBb1313-- FrrN)r#rOrrZrrr<rs& @r8*test_multipartEmptyHeaderProcessingFailure7ParsingTests.test_multipartEmptyHeaderProcessingFailure so    //#%/@ **0024RS 1**B/r7c Ra.o!V3RlR\P4pRpVPW!RR7pVPVPP 4R4VP\ S4^4VPS^,PRR./4VPV\VRR 7RR7pVPVPP 4R4VP\ S4^4VPS^,P/4R #) z If the request has a Content-Type of C{multipart/form-data}, and the form data is parseable, the form arguments will be added to the request's args. c.<a]tRtRtoV3RltRtVtR#)6ParsingTests.test_multipartFormData..MyRequesti cl<SPV4VPR4VP4R#rrrs&r8rL>ParsingTests.test_multipartFormData..MyRequest.process rr7r0Nrrs@r8rr rr7rsPOST / HTTP/1.0 Content-Type: multipart/form-data; boundary=AaB03x Content-Length: 149 --AaB03x Content-Type: text/plain Content-Disposition: form-data; name="text" Content-Transfer-Encoding: quoted-printable abasdfg --AaB03x-- FrrrrparsePOSTFormSubmissionN) r#rOrrZrrrr<rrs& @r8r#ParsingTests.test_multipartFormData s      //#%/@ **0024RS Y+ 1**Wzl,CD// EBE"  **0024RS Y+ 1**B/r7c  a.o!V3RlR\P4pRpR\\VP RR444,R,pVP VP R4V,VR R 7pVPVPP4R 4VP\S4^4VPS^,PR R R./4VP VP R4V,\VR R7R R 7pVPVPP4R 4VP\S4^4VPS^,P/4R#)z If the request has a Content-Type of C{multipart/form-data}, the C{Request} is told to parse the body, if the form data is parseable and contains files, each of the file portions will be added to the request's args in the same order. c.<a]tRtRtoV3RltRtVtR#)7ParsingTests.test_multipartFilesData..MyRequesti cl<SPV4VPR4VP4R#rrrs&r8rL?ParsingTests.test_multipartFilesData..MyRequest.process rr7r0Nrrs@r8rr rr7rss-----------------------------738837029596785559389649595 Content-Disposition: form-data; name="uploadedfiles"; filename="testC" Content-Type: application/octet-stream abasdfg -----------------------------738837029596785559389649595 Content-Disposition: form-data; name="uploadedfiles"; filename="testB" qwerty -----------------------------738837029596785559389649595-- zPOST / HTTP/1.0 Content-Type: multipart/form-data; boundary=---------------------------738837029596785559389649595 Content-Length: ryrGz asciiFrrs uploadedfilesrsqwertyrN) r#rOrrrrrrZrrr<r)rKrrrVrrs& @r8test_multipartFilesData$ParsingTests.test_multipartFilesData sU      #dll5'234  5    //#**W"5".MyRequestiE c<SPVP4SPVPP44\4VnSPVP4SPVP 4SPVP P4RSnVP4R#r) r^r{r}rrrr_transferDecoderrr)rKr{rrrrs&r8rL.MyRequest.processF s~t||,t||0023 'y  dkk* DII&t||<<=&*# r7)r{Nr)rQr{rrrrs@r8rrE s  r7rsHello, spam,eggs spam spamr/N)r#rOr addCleanupcloser-rZ)rKrrr{rrrrs& @@@@@r8test_chunkedEncoding!ParsingTests.test_chunkedEncoding. s       /  (()#D'!*5 %BC &* v& 4&)r7c 0aRp.o!V3RlR\P4pVPWRR7pVPSR4VP VP P 4R4VPVP P4R#) z If a request uses the I{chunked} transfer encoding, but provides an invalid chunk length value, the request fails with a 400 error. sGET / HTTP/1.1 Content-Type: text/plain Transfer-Encoding: chunked MALFORMED_LINE_THIS_SHOULD_BE_'6' Hello, 14 spam,eggs spam spam 0 c.<a]tRtRtoV3RltRtVtR#)=ParsingTests.test_malformedChunkedEncoding..MyRequestir c*<SPR4R#rr^)rKrs&r8rLEParsingTests.test_malformedChunkedEncoding..MyRequest.processs s!!$'r7r0Nr)rQrs@r8rrr s ( (r7rFrzRequest.process calledrN) r#rOrrrZrrrr)rKrrrrs& @r8test_malformedChunkedEncoding*ParsingTests.test_malformedChunkedEncoding^ s~    (  ( //+%/H %=> **0024WX ))778r7c ^a \P!V\4p.o !V 3RlR\P4pRpRp\ P !RPW4344pRV,R,pVP\ RR 4VPWb^4S P4pVPR VP4VP^\V44V^,pVR ,pVPVP \"4VP%\"4R #) z} A L{Request} that throws an exception processing basic authorization logs an error and uses an empty username and password. c.<a]tRtRtoV3RltRtVtR#)5ParsingTests.test_basicAuthException..Requesti ct<VP4VP43VnSPV4R#r;r-r1s&r8rL=ParsingTests.test_basicAuthException..Request.process r3r7r4Nrr5s@r8rOr r6r7rOrr:r7r8r9 b64decodec.#r;r0)r>s&r8rS6ParsingTests.test_basicAuthException.. s"r7 log_failureN)r7r7)rrrr#rOr;r<rr~rrrZr0rrassertIsInstancerAttributeErrorflushLoggedErrors) rKrrOr=r+r<r>rVrrs & @r8test_basicAuthException$ParsingTests.test_basicAuthException| s +<ParsingTests.test_duplicateContentLengthsWithPipelinedRequests  ""  r7c ,VP.RO4R#)z A request that includes both C{content-length} and C{transfer-encoding} headers fails with a 400 response without calling L{Request.process}. N)rrrrr7r7rrJs&r8%test_contentLengthAndTransferEncoding2ParsingTests.test_contentLengthAndTransferEncoding s ""  r7c ,VP.RO4R#)z Two pipelined requests, the first of which includes both C{content-length} and C{transfer-encoding} headers, triggers a 400 response without calling L{Request.process}. N) rrrrr7r7rrr7r7rrJs&r8:test_contentLengthAndTransferEncodingWithPipelinedRequestsGParsingTests.test_contentLengthAndTransferEncodingWithPipelinedRequests rr7c ,VP.RO4R#)z A request whose C{transfer-encoding} header includes a value other than C{chunked} or C{identity} fails with a 400 response without calling L{Request.process}. N)rsTransfer-Encoding: unknownrr7r7rrJs&r8test_unknownTransferEncoding)ParsingTests.test_unknownTransferEncoding s ""  r7c a.o!V3RlR\P4pRpVPW!R4pVPSR.4VPVPP 4R4R#)zj A request with a valid C{content-length} and a C{transfer-encoding} whose value is C{identity} succeeds. c2<a]tRtRtoRtV3RltRtVtR#)EParsingTests.test_transferEncodingIdentity..SuccessfulRequesti- Fc<SPVPP44VPRR4VP 4R#)rx0N)r^r{r}rr)rKrs&r8rLMParsingTests.test_transferEncodingIdentity..SuccessfulRequest.process0 s4 DLL--/00$7 r7r0N)r1r2r3r4rrLr6rO)rQrs@r8SuccessfulRequestr"- sI  r7r&sTGET / HTTP/1.1 Host: host.invalid Content-Length: 2 Transfer-Encoding: identity ok Fsoks&HTTP/1.1 200 OK Content-Length: 0 N)r#rOrrZrr)rKr&rrrs& @r8test_transferEncodingIdentity*ParsingTests.test_transferEncodingIdentity& sh    //'eD w'     # # % ; r7r)NTN)5r1r2r3r4r5rrrr rrrrr!r$r'r?rLrTr[r`rcrgrjrmrrrurrrrrrrrrrrrrrrrr r rrrrrr'r6rOrPs@r8rrs )V(2($$            6( 88 t0 d 1        ) VY6Y6& P 4S,44':RY,06&0P30j.*`9</6   $ $ * " *   r7rc,a]tRtRtoRtRtRtVtR#)QueryArgumentsTestsiE c *aRpV3Rlp\4V!4FpV!VR4V!VR4K \4V!4FpV!VR4V!VR4K V!4F)p\4V!VR4\4V!VR4K+ R#)z For a given URL, L{http.urlparse} should behave the same as L{urlparse}, except it should always return C{bytes}, never text. c 3"RFWpRFNpRFEpRF<pVfK VR,\\V44,p\WVRR34xK> KG KP KY R#5i)httpNr7r7)r-shttps) example.com)Nd)r7spath)rrr )schemehostportrs r8urls/QueryArgumentsTests.test_urlparse..urlsL s^--D +$2D#/'+d{]3t95M'M&0&c31O&P P%3!,..s A"AA"c<TpV'dVPR4p\V4p\VP\4'dVPP R4VP P R4VPP R4VPP R4VPP R4VPP R43pMDVPVP VPVPVPVP3p\P!V4wrVrxrS PWVWxW3V4S PV\4S PV\4S PV\4S PV\4S PV \4S PV \4R#)z^ Verify that C{url} is parsed into the same objects by both L{http.urlparse} and L{urlparse}. rzutf-8N)decoder isinstancer0rrnetlocrparamsrfragmentr#rZrr) urlr6urlToStandardImplementationstandardResultrr0r8rr9rr:rKs && r8assertSameParsing.assertSameParsingU s +. '.1jj.A+ &&ABN.//55#))009"))009"''..w7"))009"((//8"++227; #))"))"''"))"(("++ =AMM#r;sf r8 test_urlparse!QueryArgumentsTests.test_urlparseF s  Q) 3X  6C c4 ( c5 )  6C c5 ) c4 ( 6C M c4 ( M c5 ) r7c PVP\\PR4R#)z5 L{http.urlparse} should reject unicode input early. zhttp://example.org/pathN)r TypeErrorr#r rJs&r8test_urlparseRejectsUnicode/QueryArgumentsTests.test_urlparseRejectsUnicode s )T]]4MNr7r0N)r1r2r3r4r@rDr6rOrPs@r8r*r*E sK*ZOOr7r*c&a]tRtRtoRtRtVtR#) ClientDriveri c*WnW nW0nR#r;)rrrrs&&&&r8rClientDriver.handleStatus s   r7)rrrN)r1r2r3r4rr6rOrPs@r8rGrG sr7rGc2a]tRtRtoRtRtRtRtVtR#)ClientStatusParsingTestsi c\4pVPR4VPVPR4VPVPR4VPVP R4R#)sHTTP/1.0 201 foor201rNrG lineReceivedrZrrrrKrs& r8 testBaseline%ClientStatusParsingTests.testBaseline sR N *+ K0 6* F+r7c\4pVPR4VPVPR4VPVPR4VPVP R4R#) HTTP/1.0 201rrMr7NrNrPs& r8 testNoMessage&ClientStatusParsingTests.testNoMessage sQ N ' K0 6* C(r7c\4pVPR4VPVPR4VPVPR4VPVP R4R#)s HTTP/1.0 201 rrMr7NrNrPs& r8testNoMessage_trailingSpace4ClientStatusParsingTests.testNoMessage_trailingSpace sR N '( K0 6* C(r7r0N) r1r2r3r4rQrUrXr6rOrPs@r8rKrK s,)))r7rKca]tRtRtoRtRtRtRtRtRt Rt R t R t R t R tR tRtRtRtRtRtRtRtRtRtRtRtRtRtRtRtRtRt Rt!R t"R!t#R"t$R#t%R$t&R%t'R&t(R't)R(t*R)t+R*t,R+t-R,t.R-t/R.t0R/t1R0t2R1t3R2t4R3t5R4t6R5t7R6t8R7t9R8t:R9t;R:tR=t?R>t@R?tAV3R@lRAltBV3RBlRCltCRDtDREtERFtFRGtGRHtHRItIRJtJRKtKRLtLRMtMRNtNROtORPtPRQtQVtRRR#)S RequestTestsi z Tests for L{http.Request} c \P!\4R4p\W24P RR.4VP \W14R,R4\ W1RR/4VP \\W24P44RR.3.4\ W2\P!44VP \W14/4R#)a Verify that each of two different attributes which are associated with the same state properly reflect changes made through the other. This is used to test that the C{headers}/C{responseHeaders} and C{received_headers}/C{requestHeaders} pairs interact properly. Frrrr:rN) r#rOr)getattrrrZsetattrrrr$Headers)rKoldNamenewNamerVs&&& r8_compatHeadersTestRequestTests._compatHeadersTest sll<>51++GhZ@ .w7Bvv./  &779 :fvh=O51 ((8*= w/:r7c aa\P!\4R4oVV3RlpV!RR4V!RR4V!RR4V!RR4V!RR4V!R R 4V!R R 4V!R R 4V!RR4R#)zo L{http.Request.getRequestHostname} returns the hostname portion of the request, based on the C{Host:} header. Fc<SPPRV.4SPSP4V4R#)hostN)rrrZgetRequestHostname)r expectedHostrVrKs&&r8check3RequestTests.test_getRequestHostname..check s4    , ,Wvh ?   S335| Dr7r.sexample.com:8443s 192.168.1.1s192.168.1.1:19289s[2607:f0d0:1002:51::4]s2607:f0d0:1002:51::4s)[2607:f0d0:1002:0051:0000:0000:0000:0004]s'2607:f0d0:1002:0051:0000:0000:0000:0004s[::1]s::1s [::1]:8080s[2607:f0d0:1002:51::4]:9443N)r#rOr))rKrnrVsf @r8test_getRequestHostname$RequestTests.test_getRequestHostname s ll<>51 E nn- !>2 nn- "N3 ')@A 8 6  h mV$ ,.EFr7c \P!\4R4pVPP RRR.4VP VP R4R4R#)zo When there are multiple values for a single request header, L{http.Request.getHeader} returns the last value. FrrpandaNrerfs& r8test_getHeaderReceivedMultiples,RequestTests.test_getHeaderReceivedMultiples sJ ll<>51 ((8X2FG w/:r7c \P!\4R4pVPVP R4R4R#)zn L{http.Request.getHeader} returns L{None} when asked for the value of a request header which is not present. FrN)r#rOr)rZr~rfs& r8test_getHeaderNotFound#RequestTests.test_getHeaderNotFound s/ ll<>51 w/6r7c \P!\4R4pVPP RR.4VP VP 4RR/4R#)zq L{http.Request.getAllheaders} returns a C{dict} mapping all request header names to their corresponding values. FrrNr#rOr)rrrZ getAllHeadersrfs& r8test_getAllHeadersRequestTests.test_getAllHeaders sL ll<>51 ((8*= **,w.ABr7c \P!\4R4pVPVP 4/4R#)zY L{http.Request.getAllHeaders} returns an empty C{dict} if there are no request headers. FN)r#rOr)rZr{rfs& r8test_getAllHeadersNoHeaders(RequestTests.test_getAllHeadersNoHeaders s/ ll<>51 **,b1r7c \P!\4R4pVPP RRR.4VP VP 4RR/4R#)zx When there are multiple values for a single request header, L{http.Request.getAllHeaders} returns only the last value. FrrrsNrzrfs& r8!test_getAllHeadersMultipleHeaders.RequestTests.test_getAllHeadersMultipleHeaders sO ll<>51 ((8X2FG **,w.ABr7c \4p\P!VR4pVP^4VP R4VP VP PP4P4^,R4R#)zf L{http.Request.setResponseCode} takes a status code and causes it to be used as the response status. Fr7s (no clientproto yet) 201 CreatedN r)r#rOrHrrZrwrittengetvaluerrKrrVs& r8test_setResponseCode!RequestTests.test_setResponseCode sk .ll7E* C  #     % % . . 0 ; ; =a @ / r7c \4p\P!VR4pVP^R4VP R4VP VP PP4P4^,R4R#)zv L{http.Request.setResponseCode} takes a status code and a message and causes them to be used as the response status. Fshappily acceptedr7s)(no clientproto yet) 202 happily acceptedNrrs& r8test_setResponseCodeAndMessage+RequestTests.test_setResponseCodeAndMessage) sn .ll7E* C!45 #     % % . . 0 ; ; =a @ 8 r7c f\P!\4R4pVP^4R#)zx L{http.Request.setResponseCode} accepts C{int} for the code parameter and raises L{TypeError} if passed anything else. FN)r#rOr)rHrfs& r8#test_setResponseCodeAcceptsIntegers0RequestTests.test_setResponseCodeAcceptsIntegers7 s$ ll<>51 Ar7c :\4p\P!VR4pVP\P4VP R4VP VPPP4P4^,R4R#)z L{http.Request.setResponseCode} supports RFC 2324 section 2.3.2 418 response code and will automatically set the associated message. Fr7s%(no clientproto yet) 418 I'm a teapotN) r)r#rOrH IM_A_TEAPOTrrZrrrrrs& r8test_setResponseCode418$RequestTests.test_setResponseCode418? sq .ll7E* D,,- #     % % . . 0 ; ; =a @ 4 r7c \P!\4R4pVP^*4VP VP ^*4R#)z When no previous value was set and no 'if-modified-since' value was requested, L{http.Request.setLastModified} takes a timestamp in seconds since the epoch and sets the request's lastModified attribute. FNr#rOr)setLastModifiedrZ lastModifiedrfs& r8test_setLastModifiedNeverSet)RequestTests.test_setLastModifiedNeverSetO s: ll<>51 B ))2.r7c \P!\4R4pVP^4VP^4VP VP ^4R#)z If the supplied timestamp is later than the lastModified attribute's value, L{http.Request.setLastModified} updates the lastModifed attribute. FNrrfs& r8test_setLastModifiedUpdate'RequestTests.test_setLastModifiedUpdate[ sH ll<>51 A A ))1-r7c \P!\4R4pVP^4VP^4VP VP ^4R#)z If the supplied timestamp occurs earlier than the current lastModified attribute, L{http.Request.setLastModified} ignores it. FNrrfs& r8test_setLastModifiedIgnore'RequestTests.test_setLastModifiedIgnoreh sH ll<>51 A A ))1-r7c \P!\4R4pVPP \ R4R.4VP ^*4pVPV\P4R#)z If the resource is older than the if-modified-since date in the request header, L{http.Request.setLastModified} returns L{http.CACHED}. Fif-modified-sinces02 Jan 1970 00:00:00 GMTN r#rOr)rrrrrZCACHEDrKrVrs& r8test_setLastModifiedCached'RequestTests.test_setLastModifiedCachedt s_ ll<>51 (( - .1L0M $$R( -r7c \P!\4R4pVPP \ R4R.4VP R4pVPVR4R#)z~ If the resource is newer than the if-modified-since date in the request header, L{http.Request.setLastModified} returns None Frs01 Jan 1970 00:00:00 GMT@BNr#rOr)rrrrrZrs& r8test_setLastModifiedNotCached*RequestTests.test_setLastModifiedNotCached s[ ll<>51 (( - .1L0M $$W- &r7c \P!\4R4pVPP \ R4R.4VP R4VP ^4pVPVR4R#)z When L{http.Request.setLastModified} is called multiple times, the highest supplied value is honored. If that value is higher than the if-modified-since date in the request header, the method returns None. Frs01 Jan 1970 00:00:01 GMTrNrrs& r8"test_setLastModifiedTwiceNotCached/RequestTests.test_setLastModifiedTwiceNotCached si ll<>51 (( - .1L0M  G$$$Q' &r7c \P!\4R4pVPP \ R4R.4VP ^4VP ^4pVPV\P4R#)z When L{http.Request.setLastModified} is called multiple times, the highest supplied value is honored. If that value is lower than the if-modified-since date in the request header, the method returns L{http.CACHED}. Frs01 Jan 1999 00:00:01 GMTNrrs& r8test_setLastModifiedTwiceCached,RequestTests.test_setLastModifiedTwiceCached smll<>51 (( - .1L0M  A$$Q' -r7c \P!\4R4pVPR^P4VP VP P R4R.4R#)| L{http.Request.setHost} sets the value of the host request header. The port should not be added because it is the default. Fr.rkNr#rOr)setHostrZrrJrfs& r8 test_setHostRequestTests.test_setHost sH ll<>51 NB' ++99'B^DTUr7c \4p\P!4Vn\P!VR4pVP RR4VP VPPR4R.4R#)rFr.irkN r)rSrr#rOrrZrrJrKrrVs& r8test_setHostSSLRequestTests.test_setHostSSL s] N"&&( ll1e$ NC( ++99'B^DTUr7c \P!\4R4pVPR^Q4VP VP P R4R.4R#z| L{http.Request.setHost} sets the value of the host request header. The port should be added because it is not the default. Fr.rksexample.com:81Nrrfs& r8test_setHostNonDefaultPort'RequestTests.test_setHostNonDefaultPort sI ll<>51 NB' ++99'BEVDWXr7c \4p\P!4Vn\P!VR4pVP R^Q4VP VPPR4R.4R#rrrs& r8test_setHostSSLNonDefaultPort*RequestTests.test_setHostSSLNonDefaultPort s^ N"&&( ll1e$ NB' ++99'BEVDWXr7c \P!\4R4pVPRR4VP VP P R4R.4R#)zH L{http.Request.setHeader} sets the value of the given response header. FrrN)r#rOr)rrZrrJrfs& r8test_setHeaderRequestTests.test_setHeader sGll<>51 gx( ,,::7ChZPr7c \4p\P!VR4pVP!V/VBVP VP ^,V4VP R4VPPP4PR4pVUu.uFqwPR4'gKVNK ppVP \V4^4VP V^,RV,4R#uupi)z Call L{http.Request.addCookie} with C{*args} and C{**kwargs}, and check that the cookie value is equal to C{expectedCookieValue}. Fr7rGs Set-Cookies Set-Cookie: N) r)r#rO addCookierZrrrrrr startswithr) rKexpectedCookieValuer<r=rrV writtenLinesr>addCookieLiness &&*, r8 _checkCookieRequestTests._checkCookie s .ll7E* t&v& Q)<= #((0099;AA'J &2Q\\\-5P!!\Q ^,a0 *O>Q,QRRs D<Dc 0RpVPVRR4R#)z L{http.Request.addCookie} adds a new cookie to be sent with the response, and can be called with just a key and a value. L{unicode} arguments are encoded using UTF-8. foo=barfoobarNrrKrs& r8)test_addCookieWithMinimumArgumentsUnicode6RequestTests.test_addCookieWithMinimumArgumentsUnicode s ) -uer7c  @RpVPVRRRRRRRR R R 7 R #) zo L{http.Request.addCookie} adds a new cookie to be sent with the response. L{bytes} arguments are not decoded. rrr:sFri, 31 Dec 9999 23:59:59 GMTs .example.comrs31536000rTrNrrs& r8#test_addCookieWithAllArgumentsBytes0RequestTests.test_addCookieWithAllArgumentsBytes s?  .     4"  r7c  LRp.ROp\\\\,\ \ .444pRR.RR..pVF\wrEVP V!WU4WD4VF9wrgRPV!WU4V!Wu4.4pVP !WV3/Wd/BK; K^ R#)zY L{http.Request.addCookie} replaces linear whitespace and semicolons with single spaces. c&RPW.4#)=)r)rrs&&r8 cookieValue.cookieValue> s99c\* *r7zFoo; barsFoo barsFoo; bars; N))rsExpires)rsDomain)rsPath)rsMax-Age)rsComment)rzipr,r*rr+rr) rKr argumentsinputsAndOutputs inputValue outputValueargument parameterrs & r8test_addCookieSanitization'RequestTests.test_addCookieSanitization8 s  +  .1PP~&'   % + &  (8 #J   K5z (1# ::#K=#I; !!*9A8N(1 (8r7c VPRRRRR7VPRRRRR7VPRRRRR7R #) z L{http.Request.setCookie} supports a C{sameSite} argument. It will set the cookie with samesite=lax and samesite=strict values. sfoo=bar; SameSite=laxrr:laxsameSiteLaxsfoo=bar; SameSite=strictstrictNrrJs&r8test_addCookieSameSite#RequestTests.test_addCookieSameSited sP 2FFUS 2FFUS  '(  r7c VPRRRRRR7VPRRRRRR7VPRRRRRR7R #) a  L{http.Request.setCookie} supports the C{sameSite} argument together with secure. It will set the cookie with samesite=none and secure attributes to be sure that all values of samesite are supported. secure attribute is a necessary condition if the samesite is none sfoo=bar; Secure; SameSite=nonerr:NoneTrrnonesnoneNrrJs&r8 test_addCookieSameSiteNoneSecure-RequestTests.test_addCookieSameSiteNoneSecureo sn  -      -      -    r7c  VP\VPRRRRR7pVPRVP^,4VP\VPRRRRRR 7pVPR VP^,4VP\VPRRRRR7pVPR VP^,4R #) z Raises an exception when setting the cookie with not supported samesite value and without a necessary secure attribute for the samesite=none cookie. r7rr:z anything-elserz,Invalid value for sameSite: b'anything-else'rFrzCInvalid value for sameSite: b'none'. Missing the "secure" attributeN)rrrrZr<)rKerrors& r8test_addCookieWrongValues&RequestTests.test_addCookieWrongValues s !! ))3"  GTUW!!       "   S JJqM !! ))3"   S JJqM r7c 6\4p\P!VR4p\4pW1nVP ^4RVnVPPRR.4VPR4VPVP4R.4R#)zw For an HTTP 1.0 request, L{http.Request.write} sends an HTTP 1.0 Response-Line and whatever response headers are set. FrrrrN)r rr r)r#rOrrrHrrrrrrrKrrVrs& r8test_firstWriteRequestTests.test_firstWrite s .ll7E*!! C % ))'H:> ( !! KKMJK r7c X\4p\P!VR4p\4pW1nVP ^4RVnVPPRR.4VPR4VPR4VPVP4R.4R#) z For an HTTP 1.1 request, L{http.Request.write} sends an HTTP 1.1 Response-Line, whatever response headers are set, and uses chunked encoding for the response body. FrrrrrNrr rs& r8test_firstWriteHTTP11Chunked)RequestTests.test_firstWriteHTTP11Chunked s .ll7E*!! C % ))'H:> ( ) !! KKM  r7c D\4p\P!VR4p\4pW1nVP ^4RVn^VnVPPRR.4VPR4VPVP4R.4R#)z For an HTTP 1.0 request for a resource with a known last modified time, L{http.Request.write} sends an HTTP Response-Line, whatever response headers are set, and a last-modified header with that time. FrrrrN)r r,Last-Modified: Thu, 01 Jan 1970 00:00:00 GMTr) r)r#rOrrrHrrrrrrrrs& r8test_firstWriteLastModified(RequestTests.test_firstWriteLastModified s .ll7E*!! C % ))'H:> ( !! KKM  r7c \P!V\4p\4p\P !VR4p\ 4pWBnVP^4RVn RVn VPPRR.4VPR4VPVP4R .4VP!^\#V44V^,pVP!RVR,4R #) z If the last-modified header already exists in the L{http.Request} response headers, the lastModified attribute is ignored and a message is logged. Friʚ;s last-modifiedsThu, 01 Jan 1970 00:00:00 GMTrzPWarning: last-modified specified both in header list and lastModified attribute.rN)r rr)rrrr)r#rOrrrHrrrrrrrrr)rKrrrVrrs& r8test_lastModifiedAlreadyWritten,RequestTests.test_lastModifiedAlreadyWritten s +<51 --r2r7c \P!\4R4pVPP RR.4VP 4VP VPRRRR/4R#) zl L{http.Request.parseCookies} extracts cookies from C{requestHeaders} and adds them to C{received_cookies}. Fcookiestest="lemur"; test2="panda"r"lemur"test2"panda"Nr#rOr)rr parseCookiesrZrrfs& r8test_parseCookiesRequestTests.test_parseCookies*s^ ll<>51 ((5S4TU    7J*"M r7c \P!\4R4pVPP RRR.4VP 4VP VPRRRR/4R #) zP L{http.Request.parseCookies} can extract cookies from multiple Cookie headers. Fr s test="lemur"s test2="panda"rr!r"r#Nr$rfs& r8 test_parseCookiesMultipleHeaders-RequestTests.test_parseCookiesMultipleHeaders6s` ll<>51 ((_FV4WX    7J*"M r7c \P!\4R4pVP4VP VP /4R#)zR L{http.Request.parseCookies} can be called on a request without a cookie header. FN)r#rOr)r%rZrrfs& r8test_parseCookiesNoCookie&RequestTests.test_parseCookiesNoCookieBs8 ll<>51  --r2r7c \P!\4R4pVPP R.4VP 4VP VP/4R#)zV L{http.Request.parseCookies} can be called on a request with an empty cookie header. Fr Nr$rfs& r8test_parseCookiesEmptyCookie)RequestTests.test_parseCookiesEmptyCookieKsN ll<>51 ((B7  --r2r7c \P!\4R4pVPP RR.4VP 4VP VP/4R#)zH L{http.Request.parseCookies} ignores cookies which don't have a value. Fr sfoo; bar; baz;Nr$rfs& r8 test_parseCookiesIgnoreValueless-RequestTests.test_parseCookiesIgnoreValuelessUsR ll<>51 ((5F4GH  --r2r7c \P!\4R4pVPP RR.4VP 4VP VPRR/4R#)zB L{http.Request.parseCookies} parses cookies with an empty value. Fr sfoo=rr7Nr$rfs& r8test_parseCookiesEmptyValue(RequestTests.test_parseCookiesEmptyValue_sTll<>51 ((WI>  --}=r7c \P!\4R4pVPP RR.4VP 4VP VPRR/4R#)zN L{http.Request.parseCookies} leaves trailing whitespace in the cookie value. Fr sfoo=bar rsbar Nr$rfs& r8!test_parseCookiesRetainRightSpace.RequestTests.test_parseCookiesRetainRightSpacehsU ll<>51 (([MB  --/@Ar7c \P!\4R4pVPP RR.4VP 4VP VPRR/4R#)zK L{http.Request.parseCookies} strips leading whitespace in the cookie key. Fr s foo=barrr:Nr$rfs& r8test_parseCookiesStripLeftSpace,RequestTests.test_parseCookiesStripLeftSpacersU ll<>51 (([MB  --/?@r7c \P!\4R4pVPP RR.4VP 4VP VPRRRR/4R#) zZ L{http.Request.parseCookies} parses valid cookies set before or after malformed cookies. Fr s012345; test="lemur"; 12345; test2="panda"; 12345rr!r"r#Nr$rfs& r8-test_parseCookiesContinueAfterMalformedCookie:RequestTests.test_parseCookiesContinueAfterMalformedCookie|sc ll<>51 (( KL     7J*"M r7c T\P!\4R4pVP^ 4VPpVP R4VP \\R444VPVP4VPVPR4R#)z L{http.Request.connectionLost} closes L{Request.content} and drops the reference to the L{HTTPChannel} to assist with garbage collection. FrFinishedN) r#rOr) gotLengthr{handleContentChunkrrrrclosedrr)rKrVr{s& r8test_connectionLost RequestTests.test_connectionLosts} ll<>51 b++ x( 7>*#=>? ' S[[$/r7c \P!\4R4pVP\ 4R4VP \ VP\ 4R4R#)z^ Calling L{Request.registerProducer} when a producer is already registered raises ValueError. FTN)r#rOr)rIr rrrfs& r8test_registerProducerTwiceFails,RequestTests.test_registerProducerTwiceFailssD ll<>51 ]_d3 *c&:&:MOTRr7c \P!\4R4p\4pVP VR4VP VR3.VP P4R#)z Calling L{Request.registerProducer} with an IPushProducer when the request is not queued registers the producer as a push producer on the request's transport. FTNr#rOr)r rIrZr producersrKrVrs& r87test_registerProducerWhenNotQueuedRegistersPushProducerDRequestTests.test_registerProducerWhenNotQueuedRegistersPushProducersO ll<>51 ? Xt, 8T*+S]]-D-DEr7c \P!\4R4p\4pVP VR4VP VR3.VP P4R#)z Calling L{Request.registerProducer} with an IPullProducer when the request is not queued registers the producer as a pull producer on the request's transport. FNrKrMs& r87test_registerProducerWhenNotQueuedRegistersPullProducerDRequestTests.test_registerProducerWhenNotQueuedRegistersPullProducersO ll<>51 ? Xu- 8U+,cmm.E.EFr7c \4p\P!VR4pVP4pVP \ \ R444VPVPR4VPV\ 4#)zg L{Request.connectionLost} triggers all finish notification Deferreds and cleans up per-request state. TzConnection doneN) r)r#rO notifyFinishrrrrr assertFailure)rKrrrs& r8test_connectionLostNotification,RequestTests.test_connectionLostNotificationsi N,,q$''')w~6G'HIJ W__d3!!(N;;r7c \P!\4R4pVP4pVP ^4VP 4V#)z? L{Request.finish} triggers all finish notification Deferreds. F)r#rOr)rTrBrrKrrs& r8test_finishNotification$RequestTests.test_finishNotificationsC,,|~u5'') !r7c \P!\4R4pVP4pVP ^4VP R4VP 4VP\VP R4V#)zm Calling L{Request.write} after L{Request.finish} has been called results in a L{RuntimeError} being raised. Ffoobar) r#rOr)rTrBrrrrrYs& r8test_writeAfterFinish"RequestTests.test_writeAfterFinishse ,,|~u5'') ! i  , yAr7c \4p\P!VR4pVP\ \ R444VP \VP4R#)zv Calling L{Request.finish} after L{Request.connectionLost} has been called results in a L{RuntimeError} being raised. FThe end.N) r)r#rOrrrrrrrs& r8test_finishAfterConnectionLost+RequestTests.test_finishAfterConnectionLostsG .ll7E* 7>*#=>? , 3r7c \4p\P!VR4pVP\ \ R444VP R4VP\VP4R#)z Calling L{Request.write} after L{Request.connectionLost} has been called does not raise an exception. L{RuntimeError} will be raised when finish is called on the request. Frar]N) r)r#rOrrrrrrrrs& r8test_writeAfterConnectionLost*RequestTests.test_writeAfterConnectionLostsS .ll7E* 7>*#=>? ) , 3r7c \P!\4R4pVP\ V4R\ V43,4R#)z L{Request.__repr__} returns the class name, object address, and dummy-place holder values when used on a L{Request} which has not yet been initialized. FzZNr#rOr)rZrepridrKrs& r8test_reprUninitialized#RequestTests.test_reprUninitializeds? ,,|~u5  M 035g;. A r7c \P!\4R4pRVnRVnRVnVP \V4R\V43,4R#)z L{Request.__repr__} returns, as a L{str}, the class name, object address, and the method, uri, and client protocol of the HTTP request it represents. The string is in the form:: Frrrz>N) r#rOr)rrrrZrirjrks& r8test_reprInitialized!RequestTests.test_reprInitializedsT,,|~u5)!   M $')'{n 5 r7c !RR\P4pV!\4R4pVP\ V4R\ V43,4R#)z Subclasses of L{Request} inherit a C{__repr__} implementation which includes the subclass's name in place of the string C{"Request"}. c]tRtRtRtR#)1RequestTests.test_reprSubclass..Otherwisei r0N)r1r2r3r4r6r0r7r8 Otherwisers s r7rtFz\Nrh)rKrtrs& r8test_reprSubclassRequestTests.test_reprSubclasssK    LNE2  M 035g;. A r7c \P!\4R4p\4VnVP \ 4R4VP4VPRVPVPP34R#)z} L{Request.unregisterProducer} unregisters a non-queued non-streaming producer from the request and the request's transport. FNNN r#rOr)rrrIr unregisterProducerrZrrfs& r8,test_unregisterNonQueuedNonStreamingProducer9RequestTests.test_unregisterNonQueuedNonStreamingProducer*sa ll<>51')  ]_e4    cmm6L6L'MNr7c \P!\4R4p\4VnVP \ 4R4VP4VPRVPVPP34R#)zy L{Request.unregisterProducer} unregisters a non-queued streaming producer from the request and the request's transport. FTNrxryrfs& r8)test_unregisterNonQueuedStreamingProducer6RequestTests.test_unregisterNonQueuedStreamingProducer5sa ll<>51')  ]_d3    cmm6L6L'MNr7c<V^8dQhRR/#rreturnNr0)rrQs"r8r RequestTests.__annotate__@s))d)r7c L\P!4P4R#)zy L{http.HTTPFactory.stopFactory} is a no-op (that does not raise an exception) when the factory hasn't been started yet. N)r#r stopFactoryrJs&r8test_stopFactoryInvalidState)RequestTests.test_stopFactoryInvalidState@s &&(r7c<V^8dQhRR/#rr0)rrQs"r8r rGs3L3L3Lr7c ^\P!4pRVnRVnRVnVP \ 4;_uu_4VPRRR4VP4VPVP\4\4;q!nVPp\V\4'gQhVPVPV4W1nVPW1P4VPR4pRR.p\!4pVfQhVP#V4VFpVP%V4K VP&P(^,P+4VP-RVP/44R# +'giELO;i)zR L{http.Request.finish} will call the channel's factory to produce a log message. NsometimeTGET /path HTTP/1.1 rssometime "GET /path HTTP/1.1")r#rr _logDateTime_logDateTimeCallrrlogFile startFactoryrlegacyGlobalLogFilerr7rrrrrrrrrrr)rKrrgetBackLogFileprotovalrr>s& r8test_finishProducesLog#RequestTests.test_finishProducesLogGsV ""$)#'   ~ . . OO/ goo':;%,I-/(/.-8888 n++W5( noo6%%d+(+6!    U#A   q ! "))+ 68H8H8JKC/ . .s  F F, c \4p\P!^dVR7pVP4VP R4p\ 4p\ W14pVPVP^d4VPV4VPR4VP^c4VPVP4VP^4VPVP4R#)z L{HTTPChannel} timeouts whenever data from a request body is not delivered to it in time, even when it gets built from a L{HTTPFactory}. )timeoutrNr)rr#rrrrrrZrrrrrrrrs& r8"test_requestBodyTimeoutFromFactory/RequestTests.test_requestBodyTimeoutFromFactory|s ""3>((.#% *8; ))3/ *MN b 001 a  //0r7c n\P!4pRVnRVnRVnVP 4\ 4VnVPR4p^VPn RR.p\4pVPV4VPVPR4VFpVPV4K VPR4VPVPR4VPP ^,P#4VPVPR4R#) z L{http.Request.finish} will notify the channel that it is finished, and will put the transport back in the producing state so that the reactor can close the connection. NrTrrr<sGET r?)r#rrrrrrrrrr7rrrZr@rrr)rKrrrrr>s& r8test_finishCleansConnection(RequestTests.test_finishCleansConnections ""$)#' !)%%d+23/(+6! U# ,,k:A   q ! 7# ,,h7 "))+ ,,k:r7c x\P!\4R4p\\PV4R#)z L{http.Request} provides L{http._IDeprecatedHTTPChannelToRequestInterface}, which defines the interface used by L{http.HTTPChannel}. FN)r#rOr)r)_IDeprecatedHTTPChannelToRequestInterfacerfs& r86test_provides_IDeprecatedHTTPChannelToRequestInterfaceCRequestTests.test_provides_IDeprecatedHTTPChannelToRequestInterfaces& ll<>51TCCSIr7c f\P!\4R4pVPW4R#)z' A L{http.Request} is equal to itself. FNr#rOr)rZrfs& r8test_eqRequestTests.test_eqs$ll<>51 "r7c \P!\4R4pVPV\P!\4R44R#)z3 A L{http.Request} is not equal to another object. FN)r#rOr)assertNotEqualrfs& r8test_neRequestTests.test_nes3ll<>51 Clne!DEr7c Z\P!\4R4p\V4R#)z A L{http.Request} is hashable. FN)r#rOr)hashrfs& r8 test_hashableRequestTests.test_hashablesll<>51 S r7c a.o!V3RlR4p\P!\4R4pVPW!!44VPSV.4R#)z A L{http.Request} on the left hand side of an equality comparison to an instance that is not a L{http.Request} hands the comparison off to that object's C{__eq__} implementation. c:<a]tRtRtoV3RlV3RlltRtVtR#)8RequestTests.test_eqWithNonRequest.._NotARequestic&<V^8dQhRS[RS[/#rotherrobjectbool)rrQs"r8r ERequestTests.test_eqWithNonRequest.._NotARequest.__annotate__  F t r7c*<SPV4R#TrrKreqCallss&&r8__eq__?RequestTests.test_eqWithNonRequest.._NotARequest.__eq__u%r7r0N)r1r2r3r4rr6rOrQrs@r8 _NotARequestr   r7rFNrrKrrVrs& @r8test_eqWithNonRequest"RequestTests.test_eqWithNonRequestsL    ll<>51 ln- 3%(r7c a.o!V3RlR4p\P!\4R4pVPW!!44VP SV.4R#)z A L{http.Request} on the left hand side of an inequality comparison to an instance that is not a L{http.Request} hands the comparison off to that object's C{__ne__} implementation. c:<a]tRtRtoV3RlV3RlltRtVtR#)8RequestTests.test_neWithNonRequest.._NotARequestic&<V^8dQhRS[RS[/#rr)rrQs"r8r ERequestTests.test_neWithNonRequest.._NotARequest.__annotate__rr7c*<SPV4R#rrrs&&r8__ne__?RequestTests.test_neWithNonRequest.._NotARequest.__ne__rr7r0N)r1r2r3r4rr6rOrs@r8rrrr7rFN)r#rOr)rrZrs& @r8test_neWithNonRequest"RequestTests.test_neWithNonRequestsL    ll<>51 C0 3%(r7c \P!V\4p\P!\ 4R4pVP \4R4VP4VP^\V44V^,pVR,pVPVP\4VP\4R#)za A RuntimeError is logged if a producer is still registered when an L{http.Request} is finished. FTrN)rrrr#rOr)rIr rrrrrrr)rKrrrr>s& r8"test_finishProducerStillRegistered/RequestTests.test_finishProducerStillRegistereds +<rErHrNrQrVrZr^rbrerlrorur{r~rrrrrrrrrrrrrrrr6rOrPs@r8r[r[ s4$;G0;7C2C     / . . . '' ."V VY YQS&= 0? 0*X   : @ ( < <% N3    333>BA  0*S F G <  4 4   $ O O))3L3Lj1,;>J#F)$)$ -=76::r7r[cXa]tRtRtoRtRtRRRRRR /tR tR tR t R t Rt Rt Vt R#)MultilineHeadersTestsi*z Tests to exercise handling of multiline headers by L{HTTPClient}. RFCs 1945 (HTTP 1.0) and 2616 (HTTP 1.1) state that HTTP message header fields can span multiple lines if each extra line is preceded by at least one space or horizontal tab. c "RVnRVnR#)z^ Initialize variables used to verify that the header-processing functions are getting called. FN)handleHeaderCalledhandleEndHeadersCalledrJs&r8rMultilineHeadersTests.setUp2s #(&+#r7rzs10s X-Multilines line-0 line-1s X-Multiline2s line-2 line-3c XRVnVPW PV,4R#)z5 Dummy implementation of L{HTTPClient.handleHeader}. TN)rrZr)rKrrs&&&r8ourHandleHeader%MultilineHeadersTests.ourHandleHeaderBs%#' 22378r7c RVnR#)z9 Dummy implementation of L{HTTPClient.handleEndHeaders}. TN)rrJs&r8ourHandleEndHeaders)MultilineHeadersTests.ourHandleEndHeadersIs '+#r7c \4pVPVnVPVnVP R4VP R4VP VPR4VPVP4VPVP4VP R4VPVP4VPVP4VPVP^ 4R#)z A header isn't processed by L{HTTPClient.extractHeader} until it is confirmed in L{HTTPClient.lineReceived} that the header has been received completely. rTContent-Length: 10Nr7) rGrrrrrOrrrrrrrZrPs& r8test_extractHeader(MultilineHeadersTests.test_extractHeaderOs N--!55 ' ,- QXXt, 001 445 s //0 334 2&r7c ~\4pVPVnVPVnVP R4VP R4VP VP4VPVP4VPVPR4VPVPR4R#)z An HTTP request with no headers will not cause any calls to L{handleHeader} but will cause L{handleEndHeaders} to be called on L{HTTPClient} subclasses. rTr7rrMN) rGrrrrrOrrrrrZrrrPs& r8test_noHeaders$MultilineHeadersTests.test_noHeadersfs N--!55 ' s 001 334 K0 6*r7c \4pVPVnVPVnVP R4VP R4VP VP4VP R4VP R4VPVP4VP R4VP R4VP R4VPVP4VPVPR4VPVPR 4VPVP^ 4R #) z L{HTTPClient} parses multiline headers by buffering header lines until an empty line or a line that does not start with whitespace hits lineReceived, confirming that the header has been received completely. rTsX-Multiline: line-0s line-1sX-Multiline2: line-2s line-3rr7rrMN)rGrrrrrOrrrrrZrrrrPs& r8test_multilineHeaders+MultilineHeadersTests.test_multilineHeadersys N--!55 ' -. 001 {# ./ //0 z" ,- s 334 K0 6* 2&r7)rrN)r1r2r3r4r5rrrrrrrr6rOrPs@r8rr*sG, 5))O 9+ '.+&''r7rc0a]tRtRtoRtRtRtRtVtR#)Expect100ContinueServerTestsiaQ Test that the HTTP server handles 'Expect: 100-continue' header correctly. The tests in this class all assume a simplistic behavior where user code cannot choose to deny a request. Once ticket #288 is implemented and user code can run before the body of a POST is processed this should be extended to support overriding this behavior. c \4p\P!4p\VnVP V4VP R4VP R4VP R4VP R4VP R4VPVP4R4VP R4VPVP4R .4R#) zs HTTP/1.0 requests do not get 100-continue returned, even if 'Expect: 100-continue' is included (RFC 2616 10.1.1). sGET / HTTP/1.0 Host: www.example.com Content-Length: 3 Expect: 100-continue rGr7r%N)r r rrr  ''' 3 abc''' ) rr#rrrrrrZrr)rKrrs& r8 test_HTTP10(Expect100ContinueServerTests.test_HTTP10s $% ""$!6y)239:5689W% *C0V$ !! OO   r7c j\4p\P!4p\VnVP V4VP R4VP R4VP R4VP R4VPVP4R4VP R4VPVP4R4VP R4VP4pVPVPR44V\R4R pVPVR .4R #) z If a HTTP/1.1 client sends a 'Expect: 100-continue' header, the server responds with a 100 response code before handling the request body, if any. The normal resource rendering code will then be called, which will send an additional response code. sGET / HTTP/1.1 rrrr7rGsHTTP/1.1 100 Continue r%N)rr rrr r) rr#rrrrrrZrrrrr)rKrrrs& r8test_expect100ContinueHeader9Expect100ContinueServerTests.test_expect100ContinueHeaders $% ""$!6y)239:8956 *C0W% *,LMV$??$ ++,LMNC @ACD !!   r7r0N) r1r2r3r4r5rrr6rOrPs@r8rrs <& & r7rc<VUu/uF q"W,bK up#uupi)al Create a new dict containing only a subset of the items of an existing dict. @param keys: An iterable of the keys which will be added (with values from C{d}) to the result. @param d: The existing L{dict} from which to copy items. @return: The new L{dict} with keys given by C{keys} and values given by the corresponding values in C{d}. @rtype: L{dict} r0)keysrks&& r8subr s " "TqtGT "" "sc0a]tRtRtoRtRtRtRtVtR#) DeprecatedRequestAttributesTestsizA Tests for deprecated attributes of L{twisted.web.http.Request}. c  \P!\\P!RRR4R74pVP ^4VP RRR4VP4VPVP.R7pVP^\V44VPR \R R /\R R .V^,44R #) zO L{Request.getClientIP} is deprecated in favor of L{Request.getClientAddress}. rZri90rrrroffendingFunctionscategoryrzjtwisted.web.http.Request.getClientIP was deprecated in Twisted 18.4.0; please use getClientAddress insteadN)r#rOr)rrrBrequestReceivedr flushWarningstest_getClientIPrZrDeprecationWarningr )rKrwarningss& r8r1DeprecatedRequestAttributesTests.test_getClientIPs ,, g11%eL M  !k:%%$:O:O9P%Q CM* .M  Y'! 5 r7c 0\4p\P!V4pVP4VP VP .R7pVP ^\V44VP R\RR/\RR.V^,44R#)z[ L{Request.noLongerQueued} is deprecated, as we no longer process requests simultaneously. rrrzHtwisted.web.http.Request.noLongerQueued was deprecated in Twisted 16.3.0N) r)r#rOnoLongerQueuedrtest_noLongerQueuedrZrrr )rKrrrs& r8r4DeprecatedRequestAttributesTests.test_noLongerQueueds .,,w' %%$:R:R9S%T CM* .(  Y'! 5 r7r0N) r1r2r3r4r5rrr6rOrPs@r8rrs 4  r7rcva]tRtRtoRtRtRtRtRtRt Rt R t R t R t R tR tRtRtRtRtVtR#)ChannelProductionTestsi1z5 Tests for the way HTTPChannel manages backpressure. s#GET / HTTP/1.1 Host: localhost c xTp\P!4p\V4VnVP V4W13#)z Setup a L{HTTPChannel} and a transport and associate them. @param transport: A transport to back the L{HTTPChannel} @param requestFactory: An object that can construct L{Request} objects. @return: A tuple of the channel and the transport. )r#rrBrr)rKrrrs&&& r8buildChannelAndTransport/ChannelProductionTests.buildChannelAndTransport8s; ""$!9.!Iy)!!r7c VP\4\4wrVPVPV4VP VP 4R#)z] L{HTTPChannel} registers itself as a producer with its transport when a connection is made. N)r!rrvrZrr streamingrKrrs& r8test_HTTPChannelIsAProducer2ChannelProductionTests.test_HTTPChannelIsAProducerGsJ "::  /  ++W5  ++,r7c VP\4\4wrVP4VP VP R4VP VP R4R#)zF L{HTTPChannel} unregisters itself when it has loseConnection called. N)r!rrvrIrrr$r%s& r88test_HTTPChannelUnregistersSelfWhenCallingLoseConnectionOChannelProductionTests.test_HTTPChannelUnregistersSelfWhenCallingLoseConnectionSsV"::  /    i(($/ i))40r7c VP\4\4wrVP\ 4R4VP \ VP\ 4R4R#)zx If two producers are registered on a L{HTTPChannel} without the first being unregistered, a L{RuntimeError} is thrown. TN)r!rrvrIr rrr%s& r8(test_HTTPChannelRejectsMultipleProducers?ChannelProductionTests.test_HTTPChannelRejectsMultipleProducers_sQ "::  /    $7 ,(@(@-/SWXr7c VP\4\4wrVP4VP VP R4R#)zZ If there is no producer, the L{HTTPChannel} can still have C{unregisterProducer} called. Nr!rrvrzr_requestProducerr%s& r8+test_HTTPChannelCanUnregisterWithNoProducerBChannelProductionTests.test_HTTPChannelCanUnregisterWithNoProducerkB "::  /  ""$ g..5r7c VP\4\4wrVP4VP VP R4R#)zV If there is no request producer currently registered, C{stopProducing} does nothing. Nr/r%s& r8,test_HTTPChannelStopWithNoRequestOutstandingCChannelProductionTests.test_HTTPChannelStopWithNoRequestOutstandingwr3r7c VP\4\4wrVPVP4VP ^,P p\4pVPVR4VPVP.4VP4VPVPR.4R#)z If there is a request producer registered with L{HTTPChannel}, calling C{stopProducing} causes that producer to be stopped as well. TstopN) r!rrrrrrr rIrZevents stopProducingrKrrrrs& r8#test_HTTPChannelStopRequestProducer:ChannelProductionTests.test_HTTPChannelStopRequestProducers "::  1  T\\*""1%..!?  40 "-  6(3r7c .VP\4\4wrVPVPR4VP 4VPVPR4VP 4VPVPR4R#)z When L{HTTPChannel} has C{pauseProducing} called on it by the transport it will call C{pauseProducing} on the transport. When unpaused, the L{HTTPChannel} will call C{resumeProducing} on its transport. r<r?N)r!rrvrZr@pauseProducingresumeProducingr%s& r8;test_HTTPChannelPropagatesProducingFromTransportToTransportRChannelProductionTests.test_HTTPChannelPropagatesProducingFromTransportToTransports "::  /  00+>   00(; ! 00+>r7c ,VP\4\4wr^VnVP VP 4VP R4VP ^,Pp\4pVPVR4VPVPR4VPVP.4VP4VPVPR4VPVPR.4VP4VPVPR4VPVPRR.4VP4VP!4VPVPR4R#)z If a L{Request} object has registered itself as a producer with a L{HTTPChannel} object, and the L{HTTPChannel} object is paused, both the transport and L{Request} objects get paused. s123Tr?pauseresumer<N)r!rrr7rrrrr rIrZr@r9r?r@rzrr;s& r83test_HTTPChannelPropagatesPausedProductionToRequestJChannelProductionTests.test_HTTPChannelPropagatesPausedProductionToRequestsN "::  1 ,-( T\\*V$""1%..!?  40 00(; "-   00(; 7)4 ! 00(; 7H*=> ""$  00+>r7c VP\4\4wr^VnVP VP 4VP R4VP ^,Pp\4pVPVR4VPVPR4VPVP.4VP4VPVPR4VPVPR.4VP4VP4VPVPR4VP!4VPVPR4R#)z If a L{Request} object completes its response while the transport is paused, the L{HTTPChannel} does not resume the transport. sextraTr?rDr<N)r!rrr7rrrrr rIrZr@r9r?rzrr@r;s& r8/test_HTTPChannelStaysPausedWhenRequestCompletesFChannelProductionTests.test_HTTPChannelStaysPausedWhenRequestCompletess5 "::  1 ,-( T\\*X&""1%..!?  40 00(; "-   00(; 7)4 ""$  00(; ! 00+>r7c ~!RR\4pV!4pVP4VP\VP4VP V!4\ 4wr2VP VPR4VP4VP VPR4VPVP4VP VPR4VPVP4PR44VP4VP VPR4R#)z If the L{HTTPChannel} has paused the transport, it still tolerates receiving data, and does not attempt to pause the transport again. c*a]tRtRtoRtRtRtVtR#)gChannelProductionTests.test_HTTPChannelToleratesDataWhenTransportPaused..NoDoublePauseTransporti zX A version of L{StringTransport} that fails tests if it is paused while already paused. cjVPR8Xd \R4h\P!V4R#)r?zTransport was paused twice!N)r@rrr?rJs&r8r?vChannelProductionTests.test_HTTPChannelToleratesDataWhenTransportPaused..NoDoublePauseTransport.pauseProducings*%%1&'DEE..t4r7r0N)r1r2r3r4r5r?r6rOrPs@r8NoDoublePauseTransportrM s   5 5r7rPr<r?sHTTP/1.1 200 OK N)rr?rrr!rvrZr@rrrrrr@)rKrPrrs& r80test_HTTPChannelToleratesDataWhenTransportPausedGChannelProductionTests.test_HTTPChannelToleratesDataWhenTransportPauseds 5_ 5+,   " , (@(@A!:: " $&6  00+>   00(; T\\* 00(;  )445KLM ! 00+>r7c aaSP\4\4wpo\4o\P!4p\ VnVPS4VPSP4VP^,PpVPPpVV3RlpVPV4#)zv If the L{HTTPChannel} has a L{IPullProducer} registered with it it can adapt that producer into an L{IPushProducer}. c|<SP4PR^4^,pRpSPW4R#)rs<1 0 1 1 1 2 1 3 1 4 1 5 1 6 1 7 1 8 1 9 N)rrrZ)ign responseBodyexpectedResponseBodyrKrs& r8validateOChannelProductionTests.test_HTTPChannelToleratesPullProducers..validateDs;$??,22;B1EL  !   \ @r7)r!rrDr#rDummyPullProducerHandlerProxyrrrrrrrGrr)rKrrresponseCompleterXrsf @r8&test_HTTPChannelToleratesPullProducers=ChannelProductionTests.test_HTTPChannelToleratesPullProducers3s "::  7 $% ""$!>y)T\\*""1%.."2299 A  ++H55r7c \4p\4p\P!4p^dVnVP VnVP V4VP^c4VPVPV4VPVPR4VP^4VPVPR4VPVPR4R#)zC L{HTTPChannel} unregisters itself when it times out a connection. TN) rrr#rrrrrrrr$)rKrrrs& r8,test_HTTPChannelUnregistersSelfWhenTimingOutCChannelProductionTests.test_HTTPChannelUnregistersSelfWhenTimingOutVs#% ""$!OOy)  b i(('2 i))40  a i(($/ i))40r7r0N)r1r2r3r4r5rr!r&r)r,r1r5r<rArFrIrQr\r_r6rOrPs@r8rr1s]CG " - 1 Y 6 640?**?X(?T+?Z!6F11r7rc*a]tRtRtoRtRtRtVtR#)HTTPChannelSanitizationTestsinz0 Test that L{HTTPChannel} sanitizes its output. c  <\Fp\4p\P!4pVP V4VP RRRRV3.R7R\ ,R,pVPVP4RPRVR .44K R #) zm L{HTTPChannel.writeHeaders} removes linear whitespace from the list of header names and values it receives. rrsOKr)rcodereasonrsFoo: rGrr7N) r*rr#rr writeHeadersr+rZrr)rK componentrrsanitizedHeaderLines& r8*test_writeHeadersSanitizesLinearWhitespaceGHTTPChannelSanitizationTests.test_writeHeadersSanitizesLinearWhitespacess 9I')I&&(G  " "9 -  # ),- ! #+^";g"E    ! *+ 9r7r0N)r1r2r3r4r5rir6rOrPs@r8rbrbnsr7rbc*a]tRtRtoRtRtRtVtR#)HTTPClientDeprecationTestsiz- Test that L{http.HTTPClient} is deprecated. c  DVPRR\R^^^44R#)z> Accessing L{http.HTTPClient} produces a deprecation warning. ztwisted.web.http HTTPClientTwistedN)getDeprecatedModuleAttributerrJs&r8test_deprecated*HTTPClientDeprecationTests.test_deprecateds& ))   Ir1a ( r7r0N)r1r2r3r4r5rqr6rOrPs@r8rlrls  r7rlc*a]tRtRtoRtRtRtVtR#)HTTPClientSanitizationTestsiz4 Test that L{http.HTTPClient} sanitizes its output. c 2\Fp\4p\P!4pVP V4VP W4VP VP4P4RP\\.4.4K R#)zh L{HTTPClient.sendHeader} replaces linear whitespace in its header keys and values with a single space. s: N) r*rr#rnrrrZrrrr+)rKrgrrs& r8(test_sendHeaderSanitizesLinearWhitespaceDHTTPClientSanitizationTests.test_sendHeaderSanitizesLinearWhitespacess 9I')I__&F  ! !) ,   i 3   !,,.^^<=>  9r7r0N)r1r2r3r4r5rvr6rOrPs@r8rtrts  r7rt)xr5r;rnrV functoolsriorr itertoolsrtypingrrr!r urllib.parser r r zope.interfacer rrzope.interface.verifyrrm incrementalrtwisted.internetrtwisted.internet.errorrrtwisted.internet.taskrtwisted.internet.testingrrrtwisted.loggerrtwisted.protocolsrtwisted.python.compatrrtwisted.python.componentsrtwisted.python.failurertwisted.python.logrrtwisted.test.test_internetr twisted.trialtwisted.trial.unittestr" twisted.webr#r$r%twisted.web.httpr&r'r(twisted.web.test.requesthelperr)r*r+r,_utilr-rr/rBrOrDrZrSrvrINonQueuedRequestFactoryrDummyNewHTTPHandlerProxyrrrnrrrrrrrr'rErQrbrrrrr!rrr*rGrKr[rrr rrSynchronousTestCaserbrlrtr0r7r8rsV %"$-AA.$A' .&:7*=4"+00SS / 66. ;t|| ;!99Q R H%% <t||"11AB $ ' '(1*1)144GH ') '33EF,,,!7!7HcA8$$&7cAL0<0f,. :< :p5(++->p5f%H%%%D))H%%))XZDh//ZDz3))3l/ x((/ dD8HD8NQ 8#4#4Q h sEH%%'8sElk 8$$k \#RO(++ROj4??)x00).o:8$$&7o:d#k'H--k'\N 8#4#46GN b#"4 x'8'84 nz1X..z1z !8#?#?!H  !=!=  (">">r7