+ jLNRt^RIHtHt^RIHt^RIHtHtH t H t H t ^RI H t ^RIHt^RIHt!RR]4t!R R 4t!R R ]4t!R R]4t!RR]4t!RR4t!RR]4tR#)z Test for L{twisted.web.proxy}. ) MemoryReactor StringTransportWithDisconnection)TestCase) ProxyClientProxyClientFactory ProxyRequestReverseProxyRequestReverseProxyResource)Resource)Site DummyRequestcHa]tRt^toRtRtRtRtRtRt Rt Rt Vt R #) ReverseProxyResourceTestsz$ Tests for L{ReverseProxyResource}. c h\4p\4p\RRRV4pVPRV4\ V4p\ 4pVP R4pVPV4VPVPR4VPRV,R,4VPwwrrp VPV R4VPV R4VPV \4VPV PV4VPV P R,R 4R#) z Check that a request pointing at C{uri} produce a new proxy connection, with the path of this request pointing at C{expectedURI}. 127.0.0.1/pathsindexNsGET s HTTP/1.1 Accept: text/html hosts127.0.0.1:1234)r rr putChildr r buildProtocolmakeConnection addCleanupconnectionLost dataReceived tcpClients assertEqualassertIsInstancerrestheaders)selfuri expectedURIrootreactorresourcesite transportchannelhostportfactory_timeout _bind_addrs&&& =/usr/lib/python3/dist-packages/twisted/web/test/test_proxy.py _testRender%ReverseProxyResourceTests._testRenders z/' T8WM h)Dz46 $$T*y) ..5Ws]-VVW8?8J8J5 4$g {+ t$ g'9: {3 13DEc &VPRR4#)z Test that L{ReverseProxyResource.render} initiates a connection to the given server with a L{ProxyClientFactory} as parameter. s/indexrr/r s&r. test_render%ReverseProxyResourceTests.test_render8s  844r1c &VPRR4#)z Test that L{ReverseProxyResource.render} will instantiate a child resource that will initiate a connection to the given server requesting the apropiate url subpath. s /index/page1s /path/page1r3r4s&r.test_render_subpage-ReverseProxyResourceTests.test_render_subpage?s @@r1c &VPRR4#)zZ Test that L{ReverseProxyResource.render} passes query parameters to the created factory. s/index?foo=bars /path?foo=barr3r4s&r.test_renderWithQuery.ReverseProxyResourceTests.test_renderWithQueryGs  13CDDr1c z\4p\RRRV4pVPRR4pVPV\4VP VP R4VP VP R4VP VPR4VPVPVP4R#)z The L{ReverseProxyResource.getChild} method should return a resource instance with the same class as the originating resource, forward port, host, and reactor values, and update the path value with the value passed. rrrfooNs /path/foo) rr getChildrrpathr*r)assertIdenticalr$)r r$r%childs& r. test_getChild'ReverseProxyResourceTests.test_getChildNs /' T8WM!!&$/ e%9: \2 T* [1 U]]H,<,<=r1c |\RRR4pVPRR4pVPVPR4R#)z] The L{ReverseProxyResource} return by C{getChild} has a path which has already been quoted. rrrs /%Ns/path/%20%2F%25)r r?rr@)r r%rBs& r.test_getChildWithSpecial2ReverseProxyResourceTests.test_getChildWithSpecial_s9 ( T8D!!&$/ %78r1N) __name__ __module__ __qualname____firstlineno____doc__r/r5r8r;rCrF__static_attributes____classdictcell__ __classdict__s@r.rrs0F:5AE>"99r1rc<a]tRt^itoRtRtRtRtRtRt Vt R#) DummyChannelz A dummy HTTP channel, that does nothing but holds a transport and saves connection lost. @ivar transport: the transport used by the client. @ivar lostReason: the reason saved at connection lost. c WnRVnR#)z$ Hold a reference to the transport. N)r' lostReason)r r's&&r.__init__DummyChannel.__init__rs#r1c WnR#)z+ Keep track of the connection lost reason. N)rU)r reasons&&r.rDummyChannel.connectionLostys !r1c 6VPP4#)z* Get peer information from the transport. )r'getPeerr4s&r.r\DummyChannel.getPeer~~%%''r1c 6VPP4#)z* Get host information from the transport. )r'getHostr4s&r.r`DummyChannel.getHostr^r1)rUr'N) rIrJrKrLrMrVrr\r`rNrOrPs@r.rSrSis#! ( ((r1rSca]tRt^toRtRtRtRRltRtRt Rt R t RR lt R t R tR tRtRtRtRtRtRtVtR#)ProxyClientTestsz Tests for L{ProxyClient}. c VPR4wr#VPR4pVP^4pV\RV44V3#)a Parse the headers out of some web content. @param content: Bytes received from a web server. @return: A tuple of (requestLine, headers, body). C{headers} is a dict of headers, C{requestLine} is the first line (e.g. "POST /foo ...") and C{body} is whatever is left. s  c3B"TFqPR4xK R#5i): N)split).0headers& r. 4ProxyClientTests._parseOutHeaders..s!LG&,,u"5"5Gs)rhpopdict)r contentrbody requestLines&& r._parseOutHeaders!ProxyClientTests._parseOutHeaderssG k2 --(kk!n T!LG!LLdSSr1c \V4#)z} Make a dummy request object for the URL path. @param path: A URL path, beginning with a slash. @return: A L{DummyRequest}. r )r r@s&&r. makeRequestProxyClientTests.makeRequestsD!!r1Nc TVfRR/pRVP,p\W%RW4V4#)al Make a L{ProxyClient} object used for testing. @param request: The request to use. @param method: The HTTP method to use, GET by default. @param headers: The HTTP headers to use expressed as a dict. If not provided, defaults to {'accept': 'text/html'}. @param requestBody: The body of the request. Defaults to the empty string. @return: A L{ProxyClient} accept text/html/HTTP/1.0)postpathr)r requestmethodr requestBodyr@s&&&&& r.makeProxyClient ProxyClientTests.makeProxyClients4 ? ,/Gg&&&6gGTTr1c H\4pWnVPV4V#)z Connect a proxy client to a L{StringTransportWithDisconnection}. @param proxyClient: A L{ProxyClient}. @return: The L{StringTransportWithDisconnection}. )rprotocolr)r proxyClientclientTransports&& r. connectProxyProxyClientTests.connectProxys&;<#. ""?3r1c VPV4VPP4pVPV4wrVpVP WR4VP Wc4V#)a( Assert that C{proxyClient} sends C{headers} when it connects. @param proxyClient: A L{ProxyClient}. @param requestLine: The request line we expect to be sent. @param headers: A dict of headers we expect to be sent. @return: If the assertion is successful, return the request body as bytes. )rr'valuerrr)r rrqrrequestContent receivedLinereceivedHeadersrps&&&& r.assertForwardsHeaders&ProxyClientTests.assertForwardsHeaderss\ +&$..446.2.C.CN.S+ t 3 2 r1cR\V4PR4,R,V,.pVF-wrgVF"pVPVR,V,4K$ K/ VPRV.4RP V4#)s HTTP/1.0 ascii rgr1re)strencodeappendextendjoin) r codemessagerrplinesrjvaluesrs &&&&& r.makeResponseBytes"ProxyClientTests.makeResponseBytesstD 0 0 99D@7JK%NF Ve^e34 &  c4[!||E""r1c VPVPV4VPVPV4\VPP 44pVP 4VR,pVP 4VPWg4VPRPVP4V4R#)a Assert that C{request} has forwarded a response from the server. @param request: A L{DummyRequest}. @param code: The expected HTTP response code. @param message: The expected HTTP message. @param headers: The expected HTTP headers. @param body: The expected response body. :NNNr1N) r responseCoderesponseMessagelistresponseHeadersgetAllRawHeaderssortrwritten)r r}rrrrprexpectedHeaderss&&&&&& r.assertForwardsResponse'ProxyClientTests.assertForwardsResponses --t4 00':w66GGIJ!!* : '//2D9r1c VPR4pVPWRR/V4p VPV VR,RRRR/4p VPW4V P VP WW444VP WW#V4V'dV PP4VPV PP4VPVP^4R#)zs Build a fake proxy connection, and send C{data} over it, checking that it's forwarded to the originating request. r>rxrys /foo HTTP/1.0 connectioncloseN) rurrrrrrr'loseConnection assertFalse connectedfinished) r rrrrpr~rrr}client receivedBodys &&&&&&&& r._testDataForward!ProxyClientTests._testDataForwards""6*%% i6  11  & & Hi > 3 D224'PQ ##G7TJ     + + - ))334 ))1-r1c 4VP^RRRR.3.R4#)z When connected to the server, L{ProxyClient} should send the saved request, with modifications of the headers, and then forward the result to the parent request. OKFoobarsbaz Some data rr4s&r. test_forwardProxyClientTests.test_forwards. $$ &66"2346F  r1c 6VP^RRR.3.RRR4#)zf Try to post content in the request, and check that the proxy client forward the body of the request. rrrrPOST Some contentrr4s&r. test_postDataProxyClientTests.test_postData's/ $$ &6(+,.>  r1c *VPRR.R4#)zz If the response contains a status with a message, it should be forwarded to the parent request with all the information. is Not Foundr1rr4s&r.test_statusWithMessage'ProxyClientTests.test_statusWithMessage0s $$S,C@@r1c  xRpVP^RR\\V44PR4.3.V4#)z If the response contains a I{Content-Length} header, the inbound request object should still only have C{finish} called on it once. foo bar bazrContent-Lengthrrrlenrr datas& r.test_contentLength#ProxyClientTests.test_contentLength7sE $$ +c#d)n.C.CG.L-MNOQU  r1c  |RpVP^RR\\V44PR4.3.VRR7#)z If the response contains a I{Content-Length} header, the outgoing connection is closed when all response body data has been received. rrrrF)rrrs& r.test_losesConnection%ProxyClientTests.test_losesConnectionAsN $$  #c$i."7"7"@!A B C  %  r1c  n\RRRRRRR/RR 4pVPVPRRR R /4R #) z The headers given at initialization should be modified: B{proxy-connection} should be removed if present, and B{connection} should be added. GET/foor{rxrysproxy-connectionr>r1Nrr)rrr)r rs& r.test_headersCleanups%ProxyClientTests.test_headersCleanupsOsL      &96 B      NNY mXN r1c RRRRRR/pVP4pRVR&VR\RRR VR R 4pVPVR V4R #) z The proxy doesn't really know what to do with keepalive things from the remote server, so we stomp over any keepalive header we get from the client. rxrys keep-alives300rrrrr{r1NsGET /foo HTTP/1.0)copyrr)r rrrs& r.test_keepaliveNotForwarded+ProxyClientTests.test_keepaliveNotForwardedas` | 6 =  ",,.)1 & M *VWk7CN ""6+?Qr1c  VPR4pVPPRR.4VPPRR.4VPPRR.4VPVRR /R 7pVP V4R R .R R.RR./pVP VP ^RVP4R44VPV^R\VP44R4R#)z L{server.Request} within the proxy sets certain response headers by default. When we get these headers back from the remote server, the defaults are overridden rather than simply appended. r>sserversold-barsdatesold-bazs content-typesold/quxrxry)rsServerrsDates 2010-01-01 Content-Typesapplication/x-bazrr1N) rur setRawHeadersrrrritemsrr)r r}rrs& r.test_defaultHeadersOverridden.ProxyClientTests.test_defaultHeadersOverriddenrs ""6*--i*F--g |D--o |L%%g <7P%Q &! x m_ 23  D223w}}PSTU ##GS%gmmo9NPSTr1rH)rNr1)rr1T)rIrJrKrLrMrrrurrrrrrrrrrrrrrrNrOrPs@r.rcrcsf T"U" "#:&*.X  A    $R"UUr1rcc0a]tRtRtoRtRtRtRtVtR#)ProxyClientFactoryTestsiz" Tests for L{ProxyClientFactory}. c \R.4p\RRRRR/RV4pVPRR4VPVPR 4VPVP R 4VP\ VPP44R R.3.4VPR PVP4R 4VPVP^4R#)zk Check that L{ProxyClientFactory.clientConnectionFailed} produces a B{501} response to the parent request. r>rrr{rxryNis Gateway errorrr1s

Could not connect

) r rclientConnectionFailedrrrrrrrrr)r r}r+s& r.test_connectionFailed-ProxyClientFactoryTests.test_connectionFaileds x($ G[9l*CR  &&tT2 --s3 002BC  ((99; < ~ . /  '//24QR ))1-r1c `\RRRRR/RR4pVPR4pVPV\4VP VP R4VP VP R4VP VPR4VP VPRRRR /4R#) z L{ProxyClientFactory.buildProtocol} should produce a L{ProxyClient} with the same values of attributes (with updates on the headers). rrr{rxrys Some dataNrr) rrrrrcommandrrr)r r+protos& r.test_buildProtocol*ProxyClientFactoryTests.test_buildProtocols % G[9l*C\SW %%d+ e[1 / W- \2  MMI|]HM r1rHN) rIrJrKrLrMrrrNrOrPs@r.rrs.(  r1rcFa]tRtRtoRtR RltRtRtRtRt Rt Vt R #) ProxyRequestTestsiz Tests for L{ProxyRequest}. c \4p\V4p\4p\VRV4pVP \ V44VP V4VPVRV,R4VP\ VP4^4VPVP^,^,R4VPVP^,^,^P4VP^,^,p VPV \4VPV PV4VPV PR4VPV PRR/4VPV PV4VPV P V4VPV P"V4R#)zm Build a request pointing at C{uri}, and check that a proxied request is created, pointing a C{expectedURI}. Fshttp://example.comr{ example.comr example.comN)rrSrr gotLengthrhandleContentChunkrequestReceivedrrrrrversionrrrfather) r r!r"r~rr'r(r$r}r+s &&&&& r. _testProcessProxyRequestTests._testProcesssa 56 y)/ww7#d)$""4((=(C[Q W//0!4 ++A.q1=A ++A.q126$$Q'* g'9: &1 +6 7N*CD t, {3 1r1c &VPRR4#)aA L{ProxyRequest.process} should create a connection to the given server, with a L{ProxyClientFactory} as connection factory, with the correct parameters: - forward comment, version and data values - update headers with the B{host} value - remove the host from the URL - pass the request as parent request /foo/barrr4s&r. test_processProxyRequestTests.test_processs  k::r1c &VPRR4#)z If the incoming request doesn't contain a slash, L{ProxyRequest.process} should add one when instantiating L{ProxyClientFactory}. r1rzrr4s&r. test_processWithoutTrailingSlash2ProxyRequestTests.test_processWithoutTrailingSlashs   d++r1c *VPRRRR4#)zT L{ProxyRequest.process} should be able to retrieve request body and to forward it. rrrrr4s&r.test_processWithData&ProxyRequestTests.test_processWithDatas   k7OTTr1c \4p\V4p\4p\VRV4pVP ^4VP RRR4VP \VP4^4VP VP^,^,R4VP VP^,^,R4R#)z Check that L{ProxyRequest.process} correctly parse port in the incoming URL, and create an outgoing connection with this port. Frshttp://example.com:1234/foo/barr{rrN) rrSrrrrrrr)r r'r(r$r}s& r.test_processWithPort&ProxyRequestTests.test_processWithPorts 56 y)/ww7!(JKX W//0!4 ++A.q1=A ++A.q148r1rHN)rr1) rIrJrKrLrMrrrrrrNrOrPs@r.rrs)24 ;,U99r1rc*a]tRtRtoRtRtRtVtR#) DummyFactoryiz6 A simple holder for C{host} and C{port} information. cWnW nR#)Nr)r*)r r)r*s&&&r.rVDummyFactory.__init__s   r1rN)rIrJrKrLrMrVrNrOrPs@r.rrsr1rc*a]tRtRtoRtRtRtVtR#)ReverseProxyRequestTestsiz# Tests for L{ReverseProxyRequest}. c V\4p\V4p\4p\VRV4p\ RR4VnVP ^4VPRRR4VP\VP4^4VPVP^,^,R4VPVP^,^,R4VP^,^,pVPV\4VPVPRR/4R #) z L{ReverseProxyRequest.process} should create a connection to its factory host/port, using a L{ProxyClientFactory} instantiated with the correct parameters, and particularly set the B{host} header to the factory host. Frrrrr{rrN)rrSrrrr+rrrrrrrr)r r'r(r$r}r+s& r.r%ReverseProxyRequestTests.test_process s56 y)/%gug>&}d;! [A W//0!4 ++A.q1=A ++A.q148$$Q'* g'9: 7N*CDr1rHN)rIrJrKrLrMrrNrOrPs@r.r r sEEr1r N)rMtwisted.internet.testingrrtwisted.trial.unittestrtwisted.web.proxyrrrrr twisted.web.resourcer twisted.web.serverr twisted.web.test.test_webr rrSrcrrrr rHr1r.rsU+*#2P9P9f ( (FxUxxUv( h( VI9I9XExEr1