+ jRFRt^RIHt^RIHt^RIt]t^RIH t ^RI H t ^RI H t Ht^RIHt^RIHtHt^R IHt^R IHt^R IHt^R IHt^R IHtHtHtH t H!t!^RI"H#t#^RI$H%t%^RI&H't'H(t(!RR] PR4t*!RR]PV4t+!RR],4t-!RR]4t.!RR4t/!RR]4t0R# ]dRtLi;i)z# Tests for L{twisted.web.distrib}. )abspath) parseStringN)skipIf) verifyObject)deferreactor)globalLogPublisher)failurefilepath)pb SIZE_LIMIT) proto_helpers)TestCase)clientdistribresourceserverstatic)Headers)_render) DummyChannel DummyRequestc]tRt^#tRtR#)MySiteN)__name__ __module__ __qualname____firstlineno____static_attributes__r?/usr/lib/python3/dist-packages/twisted/web/test/test_distrib.pyrr#sr!rc.a]tRt^'toRtRtRtRtVtR#)PBServerFactoryz A PB server factory which keeps track of the most recent protocol it created. @ivar proto: L{None} or the L{Broker} instance most recently returned from C{buildProtocol}. Ncb\PPW4VnVP#N)r r$ buildProtocolproto)selfaddrs&&r"r'PBServerFactory.buildProtocol2s$''55dA zzr!)r() rrrr__doc__r(r'r __classdictcell__ __classdict__s@r"r$r$'s Er!r$c]tRt^7tRtRtR#)ArbitraryErrorz An exception for this test. rN)rrrrr,r rr!r"r1r17sr!r1c~a]tRt^=toRtRtRtRtRtRt Rt Rt Rt Rt RtR tR tR tR tR tRtRtVtR#) DistribTestsNc a\P!4\P!4.oVPeCVPPe+VPPP V3Rl4MS^,P R4VP eVP PemVP PPP V3Rl4VP PPPP4MS^,P R4VPe*SPVPP44VPe*SPVPP44\P!S4#)zs Clean up all the event sources left behind by either directly by test methods or indirectly via some distrib API. Nc4<S^,PR4#)Ncallbackdlsr"'DistribTests.tearDown..JsRU^^D5Ir!c4<S^,PR4#)Nr7r9sr"r;r<NsAPTAUr!)rDeferredf1r(notifyOnDisconnectr8sub publisherbroker transportloseConnectionport1append stopListeningport2 gatherResults)r)r:s&@r"tearDownDistribTests.tearDownCs nn 0 1 77 477==#< GGMM , ,-I J qENN4 88 DHH$6$6$B HH   % % 8 89U V HH   % % / / > > @ qENN4 :: ! IIdjj..0 1 :: ! IIdjj..0 1""2&&r!c\P!4pVPR\P!RR44\ P !V4p\\P!V44Vn \P!^VP4Vn \P!RVPP4P 4Vn\P!4pVPRVP"4\%V4p\P!^V4Vn\(P*!\4pRVP&P4P R2pVP-R4pVP/RV4pVP1\(P24VP1VP4R4V#) stheresrootz text/plain 127.0.0.1sherezhttp://127.0.0.1:z /here/thereasciiGET)rResourceputChildrDatarSiter$rResourcePublisherr@r listenTCPrGResourceSubscriptiongetHostportrBrrJrAgentencoderequest addCallbackreadBody assertEqual)r)r1site1r2f2agenturlds& r" testDistribDistribTests.testDistribXs@     Hfkk'<@A B!'";";E"BC&&q$''2 // TZZ=O=O=Q=V=VW     GTXX& BZ&&q"-  W%!$**"4"4"6";";![Q   112""$%::499diiPP8;;x($$QKH ../##%!!r!c "VPV4wr4\P!\4pRVP RVP R2pVP R4pVP!RV3/VBpVP\P4V#)ai Set up a resource on a distrib site using L{ResourcePublisher} and then retrieve it from a L{ResourceSubscription} via an HTTP client. @param child: The resource to publish using distrib. @param **kwargs: Extra keyword arguments to pass to L{Agent.request} when requesting the resource. @return: A L{Deferred} which fires with the result of the request. http://:/childrPrQ) rwrr[rrmrZr\r]r^r_)r)rnkwargsrurvrerfrgs&&, r" _requestTestDistribTests._requestTestsy"55e< W% a f=jj! MM&# 0 0 foo&r!c VPV4wr4RVP RVP R2pVPR4p\P !\ 4P!RV3/VBpRpVPV4V#)a Set up a resource on a distrib site using L{ResourcePublisher} and then retrieve it from a L{ResourceSubscription} via an HTTP client. @param child: The resource to publish using distrib. @param **kwargs: Extra keyword arguments to pass to L{Agent.request} when requesting the resource. @return: A L{Deferred} which fires with a tuple consisting of a L{twisted.test.proto_helpers.AccumulatingProtocol} containing the body of the response and an L{IResponse} with the response itself. rzr{r|rPrQcaa\P!4oSPS4\P!4;pSnVP VV3Rl4V#)c <SS3#r&r)_protocolresponses&r"r;GDistribTests._requestAgentTest..cbCollectBody..s Xx$8r!)rAccumulatingProtocol deliverBodyrr?closedDeferredr^)rrgrsf @r" cbCollectBody5DistribTests._requestAgentTest..cbCollectBodysE$99;H   **/..*: :A' MM8 9Hr!) rwrmrZr\rr[rr]r^)r)rnr}rurvrfrgrs&&, r"_requestAgentTestDistribTests._requestAgentTestsy"55e< a f=jj! LL ! ) )&# @ @  m$r!c 4aaaaa/o\P!4o\P!S4R.o!VV3RlR\P 4pVVV3RloSP V!4\RR./4R7pVVV3RlpVPV4V#) zn The request headers are available on the request object passed to a distributed resource's C{render} method. Nc0<a]tRt^toVV3RltRtVtR#)>DistribTests.test_requestHeaders..ReportRequestHeaderscv<VS^&SP\VPP444R#)r6r!)updatedictrequestHeadersgetAllRawHeaders)r)r]reqrs&&r"renderEDistribTests.test_requestHeaders..ReportRequestHeaders.renders1 A%%d7+A+A+R+R+T&UVr!rNrrrrrr r-)r/rrs@r"ReportRequestHeadersrs  r!rc<SUu.uF qR,NK ppSPRV4SPRV4SPS^,V4\P!S4R#uupi) log_formatzconnected to publisherz3could not connect to distributed web service: {msg}N)assertInrremoveObserver)emsgs logObserverrr)s r" check_logs4DistribTests.test_requestHeaders..check_logss_-89[lOO[D9 MM2D 9 MMOQU V MM#a&$ '  - -k : :sA.foobar)headersc<SPPPS4SPSR,R.4R#)sFoosbarN)r@r(rAr`)resultrrr)s&r" cbRequested5DistribTests.test_requestHeaders..cbRequesteds0 GGMM , ,Z 8   ^F3fX >r!) rEventLoggingObserverr addObserverrrRr~rr^)r)rr]rrrrrsf @@@@r"test_requestHeaders DistribTests.test_requestHeaderss #88: &&{3f  8#4#4   ;## "GUUG4D,E$  ? K(r!c a!RR\P4pSPV!44pV3RlpVPV4V#)zi The response code can be set by the request object passed to a distributed resource's C{render} method. c&a]tRt^toRtRtVtR#)>DistribTests.test_requestResponseCode..SetResponseCodec(VP^4R#)setResponseCoder)r]s&&r"rEDistribTests.test_requestResponseCode..SetResponseCode.renders'',r!rNrr.s@r"SetResponseCoder  r!rc<SPV^,PR4SPV^,P^4SPV^,PR4R#)r6r!sOKNr`datacodephraserr)s&r"r:DistribTests.test_requestResponseCode..cbRequestedsM   VAY^^S 1   VAY^^S 1   VAY--u 5r!rrRrr^r)rr]rsf r"test_requestResponseCode%DistribTests.test_requestResponseCodesD  h//  (():; 6 K(r!c a!RR\P4pSPV!44pV3RlpVPV4V#)zu The response code and message can be set by the request object passed to a distributed resource's C{render} method. c&a]tRt^toRtRtVtR#)EDistribTests.test_requestResponseCodeMessage..SetResponseCodec*VP^R4R#)r some-messagerrrs&&r"rLDistribTests.test_requestResponseCodeMessage..SetResponseCode.renders''_=r!rNrr.s@r"rrrr!rc<SPV^,PR4SPV^,P^4SPV^,PR4R#)r6r!rNrrs&r"rADistribTests.test_requestResponseCodeMessage..cbRequestedsM   VAY^^S 1   VAY^^S 1   VAY-- ?r!rrsf r"test_requestResponseCodeMessage,DistribTests.test_requestResponseCodeMessagesE  h//  (():; @ K(r!c !RR\P4pVPV!44pVPVPR\ ,R,4V#)z If a string longer than the Banana size limit is passed to the L{distrib.Request} passed to the remote resource, it is broken into smaller strings to be transported over the PB connection. c&a]tRtRtoRtRtVtR#)0DistribTests.test_largeWrite..LargeWritei cVPR\,R,4VP4\P#xy)writer finishr NOT_DONE_YETrs&&r"r7DistribTests.test_largeWrite..LargeWrite.render s. dZ/$67 ***r!rNrr.s@r" LargeWriter s + +r!rrrrrRr~r^r`r )r)rr]s& r"test_largeWriteDistribTests.test_largeWritesM +** + ##JL1D,,dZ.?$.FGr!c !RR\P4pVPV!44pVPVPR\ ,R,4V#)z Like L{test_largeWrite}, but for the case where C{render} returns a long string rather than explicitly passing it to L{Request.write}. c&a]tRtRtoRtRtVtR#)2DistribTests.test_largeReturn..LargeReturnic*R\,R,#rr rs&&r"r9DistribTests.test_largeReturn..LargeReturn.rendersj(4//r!rNrr.s@r" LargeReturnrs 0 0r!rrrr)r)rr]s& r"test_largeReturnDistribTests.test_largeReturnsM  0(++ 0##KM2D,,dZ.?$.FGr!c \aa\\P!44;Snp\P !^V4;Snp\P!RVP4P4;Sn p\R.4o\VS4pVV3RlpVPV4V#)zb If there is an error issuing the request to the remote publisher, an error response is returned. rOr!c<SPSPR4SP\P4pSP\ V4^4.ROpSPRP V4.SP4R#)i N) r!ss: 500 - Server Connection Losts s#

Server Connection Lost

s

Connection to distributed server lost:

[Failure instance: Traceback from remote host -- twisted.spread.flavors.NoSuchMethod: No such method: remote_requests]

s sr!)r` responseCodeflushLoggedErrorsr NoSuchMethodlenjoinwritten)ignorederrorsexpectedr]r)s& r" cbRendered4DistribTests.test_connectionLost..cbRendered2sl   W113 7++BOO"> ++-22#  <u% L' * F2 j!r!c f\PPV\4p\P !\ 44p\R.4p\P!V4pVPV4VP^\V44VPRV^,R,4R#)zA When a request fails, the string form of the failure is logged. r!zFailure instancerN)rrcreateWithCleanuprr Failurer1rrIssuefailed assertEqualsrr)r)rfr]issues& r"test_logFailedDistribTests.test_logFailedNs$88JJ $  OON, -u% g& Q !S-. (+a.*FGr!c \PPV\4p\ 4p\ P !V4p\P!\44pVPV4VP\4VP^\V44VPV^,R,V4R#)zN When L{twisted.web.distrib.Request}'s fail is called, the failure is logged. log_failureN)rrrrr1r rrRequestrfailrrrassertIs)r)rerrrrs& r"test_requestFailDistribTests.test_requestFail]s $88JJ $  OOC ooln-   ~. !S-. k!n]3Q7r!)r@rGrJrB)rrrrrGrJrBr@rLrhrwr~rrrrrrrrr r r-r.s@r"r3r3=sb E E C B'*("6&: D**" *X H88r!r3c2a]tRtRtoRtRtRtRtVtR#)_PasswordDatabaseincWnR#r&_users)r)userss&&r"__init___PasswordDatabase.__init__os r!c,\VP4#r&)iterrr)s&r"getpwall_PasswordDatabase.getpwallrsDKK  r!c`VPFpV^,V8XgKVu# \4h)r6)rKeyError)r)usernameusers&& r"getpwnam_PasswordDatabase.getpwnamus+KKDAw("  jr!rN) rrrrrrrr r-r.s@r"rrns!r!rca]tRtRtoRtRtRtV3RlRltRtRt R t R t R t R t ]!]'*R 4R4tRtVtR#)UserDirectoryTestsi|z^ Tests for L{UserDirectory}, a resource for listing all user resources available on a system. c RR^{RRVP4R3VnRR^RRVP4R3Vn\VPVP.4Vn\ P !VP4VnR#) alicexizAlice,,,z/bin/shbobi7zBob,,,N)mktempr#r%rdatabaser UserDirectory directoryrs&r"setUpUserDirectoryTests.setUpsisCj$++-S 3S(DKKM9M)4::txx*@A  ..t}}=r!c lVP\\PVP44R#)z; L{UserDirectory} instances provide L{resource.IResource}. N) assertTruerr IResourcer)rs&r"test_interface!UserDirectoryTests.test_interfaces!  X%7%7HIr!c$<V^8dQhRS[RR/#)namereturnN)bytes)formatr/s"r" __annotate__UserDirectoryTests.__annotate__s 4 45 4T 4r!c "\V.4pVPPW4p\W24pVGRjxL VP VP R4R#L"5i)zZ Verify that requesting the C{name} child of C{self.directory} results in a 404 response. Ni)rr)getChildrr`r)r)r3r]rrgs&& r"_404TestUserDirectoryTests._404TestsS v&((7 F $ --s3 s8AA#Ac D"VPR4GRjxL R#L5i)z L{UserDirectory.getChild} returns a resource which renders a 404 response when passed a string which does not correspond to any known user. scarolNr;rs&r"test_getInvalidUser&UserDirectoryTests.test_getInvalidUser mmH%%%   c D"VPR4GRjxL R#L5i)z L{UserDirectory.getChild} returns a resource which renders a 404 response when passed a string which corresponds to a known user who has neither a user directory nor a user distrib socket. saliceNr>rs&r"test_getUserWithoutResource.UserDirectoryTests.test_getUserWithoutResourcerArBc r\P!VPR,4pVPR4pVP 4\ R.4pVP PRV4pVPV\P4VPVPVP4R#)z L{UserDirectory.getChild} returns a L{static.File} instance when passed the name of a user with a home directory containing a I{public_html} directory. public_htmlr%sbobN) r FilePathr%rnmakedirsrr)r:assertIsInstancerFiler`path)r)homerGr]rs& r"test_getPublicHTMLChild*UserDirectoryTests.test_getPublicHTMLChilds   ".jj/ w'((9 ffkk2 k&6&67r!c \P!VPR,4pVP4VP R4p\ R.4pVP PRV4pVPV\P4VPVPR4VP\VP4VP4R#)z L{UserDirectory.getChild} returns a L{ResourceSubscription} instance when passed the name of a user suffixed with C{".twistd"} who has a home directory containing a I{.twistd-web-pb} socket. .twistd-web-pbr%s bob.twistdunixNrH)r rIr%rJrnrr)r:rKrrXr`rmrrZrM)r)rNwebr]rs& r"test_getDistribChild'UserDirectoryTests.test_getDistribChilds   ". jj)*w'((@ fg&B&BC f- -sxx8r!c \R.4pRVnVP\PVP P V4R#)zZ L{UserDirectory.render} raises L{UnsupportedMethod} in response to a non-I{GET} request. rPOSTN)rmethod assertRaisesrUnsupportedMethodr)rrs& r"test_invalidMethod%UserDirectoryTests.test_invalidMethods9 t$ &22DNN4I4I7Sr!c aa\P!SPR,4PR4pVP 4\P!SP R,4pVP 4VPR4P R4\R.4o\SPS4pVV3RlpVPV4V#)ze L{UserDirectory} renders a list of links to available user content in response to a I{GET} request. rGrRr!rcz<\RPSP44pVPR4wr#SP VP P R4SP VP PR4R4SP VP P PR4SP VP P R4SP VP PR4R4SP VP P PR4R#) r!liahrefzalice/z Alice (file)z bob.twistd/z Bob (twistd)N) rrrgetElementsByTagNamer` firstChildtagName getAttributer)rdocumentr#r%r]r)s& r"r2UserDirectoryTests.test_render..cbRendereds"388GOO#<=H$88>LU   U--55s ;   U--::6BH M   U--88==~ N   S^^33S 9   S^^88@- P   S^^66;;^ Lr!rH) r rIr#rnrJr% setContentrrr)r^)r)rGrTrrr]sf @r" test_renderUserDirectoryTests.test_renders '' 27==mL  -  "#..s3t$1 M :& r!zpwd module requiredc p\P!4pVPVP\4R#)zl If L{UserDirectory} is instantiated with no arguments, it uses the L{pwd} module as its password database. N)rr(assertIdentical_pwdpwd)r)r)s& r"test_passwordDatabase(UserDirectoryTests.test_passwordDatabases& ))+  Y^^S1r!)r#r%r'r)N)rrrrr,r*r/r;r?rDrOrUr\rjrrorpr r-r.s@r"r!r!|s] > J 4 4&& 8 9T@ G*+2,2r!r!)1r,os.pathrxml.dom.minidomrrorn ImportErrorunittestrzope.interface.verifyrtwisted.internetrrtwisted.loggerrtwisted.pythonr r twisted.spreadr twisted.spread.bananar twisted.testrtwisted.trial.unittestr twisted.webrrrrrtwisted.web.http_headersrtwisted.web.test._utilrtwisted.web.test.requesthelperrrrUrr$ Exceptionr1r3rr!rr!r"rs' C.+-,,&+AA,*E V[[  b((  Y n88n8b  z2z2_  CsC CC