כhRFSrSSKJr SSKJr SSKr\rSSKJ r SSK J r SSK J r Jr SSKJr SS KJrJr SS KJr SS KJr SS KJr SS KJr SSKJrJrJrJ r J!r! SSK"J#r# SSK$J%r% SSK&J'r'J(r( "SS\ RR5r*"SS\RV5r+"SS\,5r-"SS\5r."SS5r/"SS\5r0g!\a SrNf=f)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\rSrSrSrg)MySite#N)__name__ __module__ __qualname____firstlineno____static_attributes__raC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/web/test/test_distrib.pyrr#sr#rc"\rSrSrSrSrSrSrg)PBServerFactory'z 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[RRX5UlUR$N)r r& buildProtocolproto)selfaddrs r$r*PBServerFactory.buildProtocol2s$''55dA zzr#)r+)rrr r!__doc__r+r*r"rr#r$r&r&'s Er#r&c\rSrSrSrSrg)ArbitraryError7z An exception for this test. rN)rrr r!r/r"rr#r$r1r17sr#r1cr\rSrSrSrSrSrSrSrSr Sr Sr Sr Sr S rS rS rS rS rSrSrSrg) DistribTests=Nch^[R"5[R"5/mURbAURRb*URRR U4Sj5 OTSR S5 UR bUR RblUR RRR U4Sj5 UR RRRR5 OTSR S5 URb)TRURR55 URb)TRURR55 [R"T5$)zs Clean up all the event sources left behind by either directly by test methods or indirectly via some distrib API. Nc,>TSRS5$Nrcallbackdlsr$'DistribTests.tearDown..JsRU^^D5Ir#rc,>TSRS5$)Nr9r;sr$r=r>NsAPTAUr#r@)rDeferredf1r+notifyOnDisconnectr:sub 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[R"5nURS[R"SS55 [ R "U5n[[R"U55Ul [R"SUR5Ul [R"SURR5R 5Ul[R"5nURSUR"5 [%U5n[R"SU5Ul[(R*"[5nSUR&R5R S3nUR-S 5nUR/S U5nUR1[(R25 UR1UR4S5 U$) Nstheresrootz text/plainr 127.0.0.1sherezhttp://127.0.0.1:z /here/thereasciiGET)rResourceputChildrDatarSiter&rResourcePublisherrBr listenTCPrIResourceSubscriptiongetHostportrDrrLrAgentencoderequest 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 "URU5up4[R"[5nSURSUR S3nUR S5nUR"SU40UD6nUR[R5 U$)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://:/childrRrS) ryrr]rror\r^r_r`ra)r,rpkwargsrwrxrgrhris r$ _requestTestDistribTests._requestTestsy"55e< W% a f=jj! MM&# 0 0 foo&r#c URU5up4SURSURS3nURS5n[R "[ 5R"SU40UD6nSnURU5 U$)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. r|r}r~rRrSc^^[R"5mTRT5 [R"5=nTlUR UU4Sj5 U$)Nc >TT4$r)r)_protocolresponses r$r=GDistribTests._requestAgentTest..cbCollectBody..s Xx$8r#)rAccumulatingProtocol deliverBodyrrAclosedDeferredr`)rrirs` @r$ cbCollectBody5DistribTests._requestAgentTest..cbCollectBodysE$99;H   **/..*: :A' MM8 9Hr#) ryror\r^rr]rr_r`)r,rprrwrxrhrirs r$_requestAgentTestDistribTests._requestAgentTestsy"55e< a f=jj! LL ! ) )&# @ @  m$r#c.^^^^^0m[R"5m[R"T5 S/m"UU4SjS[R 5nUUU4SjmTR U"5[SS/05S9nUUU4SjnURU5 U$) zn The request headers are available on the request object passed to a distributed resource's C{render} method. Nc$>\rSrSrUU4SjrSrg)>DistribTests.test_requestHeaders..ReportRequestHeadersct>UTS'TR[URR555 g)Nrr#)updatedictrequestHeadersgetAllRawHeaders)r,r_reqrs r$renderEDistribTests.test_requestHeaders..ReportRequestHeaders.renders1 A%%d7+A+A+R+R+T&UVr#rNrrr r!rr")rrsr$ReportRequestHeadersrs   r#rc>TVs/sHoSPM nnTRSU5 TRSU5 TRTSU5 [R"T5 gs snf)N log_formatzconnected to publisherz3could not connect to distributed web service: {msg}r)assertInr removeObserver)emsgs logObserverrr,s r$ check_logs4DistribTests.test_requestHeaders..check_logss]-89[lO[D9 MM2D 9 MMOQU V MM#a&$ '  - -k : :sA&foobar)headersc|>TRRRT5 TRTSS/5 g)NsFoosbar)rBr+rCrb)resultrrr,s r$ cbRequested5DistribTests.test_requestHeaders..cbRequesteds0 GGMM , ,Z 8   ^F3fX >r#) rEventLoggingObserverr addObserverrrTrrr`)r,rr_rrrrrs` @@@@r$test_requestHeaders DistribTests.test_requestHeaderss #88: &&{3f  8#4#4   ;## "GUUG4D,E$  ? K(r#c^"SS[R5nTRU"55nU4SjnURU5 U$)zi The response code can be set by the request object passed to a distributed resource's C{render} method. c\rSrSrSrSrg)>DistribTests.test_requestResponseCode..SetResponseCodec&URS5 g)NsetResponseCoder,r_s r$rEDistribTests.test_requestResponseCode..SetResponseCode.renders'',r#rNrrr#r$SetResponseCoder r#rc>TRUSRS5 TRUSRS5 TRUSRS5 g)Nrr#r@rsOKrbdatacodephraserr,s r$r:DistribTests.test_requestResponseCode..cbRequestedsM   VAY^^S 1   VAY^^S 1   VAY--u 5r#rrTrr`r,rr_rs` r$test_requestResponseCode%DistribTests.test_requestResponseCodesD  h//  (():; 6 K(r#c^"SS[R5nTRU"55nU4SjnURU5 U$)zu The response code and message can be set by the request object passed to a distributed resource's C{render} method. c\rSrSrSrSrg)EDistribTests.test_requestResponseCodeMessage..SetResponseCodec(URSS5 g)Nr some-messagerrrs r$rLDistribTests.test_requestResponseCodeMessage..SetResponseCode.renders''_=r#rNrrr#r$rrrr#rc>TRUSRS5 TRUSRS5 TRUSRS5 g)Nrr#r@rrrrs r$rADistribTests.test_requestResponseCodeMessage..cbRequestedsM   VAY^^S 1   VAY^^S 1   VAY-- ?r#rrs` r$test_requestResponseCodeMessage,DistribTests.test_requestResponseCodeMessagesE  h//  (():; @ K(r#c"SS[R5nURU"55nURURS[ -S-5 U$)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\rSrSrSrSrg)0DistribTests.test_largeWrite..LargeWritei cxURS[-S-5 UR5 [R$Nxy)writerfinishr NOT_DONE_YETrs r$r7DistribTests.test_largeWrite..LargeWrite.render s. dZ/$67 ***r#rNrrr#r$ LargeWriter s +r#rrrrrTrr`rbr)r,rr_s r$test_largeWriteDistribTests.test_largeWritesM +** + ##JL1D,,dZ.?$.FGr#c"SS[R5nURU"55nURURS[ -S-5 U$)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\rSrSrSrSrg)2DistribTests.test_largeReturn..LargeReturnicS[-S-$rr rs r$r9DistribTests.test_largeReturn..LargeReturn.rendersj(4//r#rNrrr#r$ LargeReturnrs 0r#rrrr)r,rr_s r$test_largeReturnDistribTests.test_largeReturnsM  0(++ 0##KM2D,,dZ.?$.FGr#c\^^[[R"55=Tln[R "SU5=Tln[R"SUR5R5=Tl n[S/5m[UT5nUU4SjnURU5 U$)zb If there is an error issuing the request to the remote publisher, an error response is returned. rrQr#c>TRTRS5 TR[R5nTR[ U5S5 /SQnTRSR U5/TR5 g)Nir@) 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# )rb responseCodeflushLoggedErrorsr NoSuchMethodlenjoinwritten)ignorederrorsexpectedr_r,s r$ cbRendered4DistribTests.test_connectionLost..cbRendered2sl   W113 7++BOO"> ++-22#  <u% L' * F2 j!r#cT[RRU[5n[R "[ 55n[S/5n[R"U5nURU5 URS[U55 URSUSS5 g)zA When a request fails, the string form of the failure is logged. r#r@zFailure instancerrN)rrcreateWithCleanupr r Failurer1rrIssuefailed assertEqualsrr)r,rfr_issues r$test_logFailedDistribTests.test_logFailedNs$88JJ $  OON, -u% g& Q !S-. (+a.*FGr#cz[RRU[5n[ 5n[ R "U5n[R"[55nURU5 UR[5 URS[U55 URUSSU5 g)zN When L{twisted.web.distrib.Request}'s fail is called, the failure is logged. r@r log_failureN)rrrr r1r rrRequestrfailrrrassertIs)r,rerrrrs r$test_requestFailDistribTests.test_requestFail]s $88JJ $  OOC ooln-   ~. !S-. k!n]3Q7r#)rBrIrLrD)rrr r!rIrLrDrBrNrjryrrrrrrrrrrr"rr#r$r4r4=sZ E E C B'*("6&: D**" *X H8r#r4c&\rSrSrSrSrSrSrg)_PasswordDatabaseincXlgr)_users)r,userss r$__init___PasswordDatabase.__init__os r#c,[UR5$r))iterrr,s r$getpwall_PasswordDatabase.getpwallrsDKK  r#cVURHnUSU:XdMUs $ [5er8)rKeyError)r,usernameusers r$getpwnam_PasswordDatabase.getpwnamus+KKDAw("  jr#rN)rrr r!rrr#r"rr#r$rrns!r#rc\rSrSrSrSrSrS\SS4SjrS r S r S r S r S r Sr\"\(+S5S5rSrg)UserDirectoryTestsi|z^ Tests for L{UserDirectory}, a resource for listing all user resources available on a system. c SSSSSUR5S4UlSSSS S UR5S4Ul[URUR/5Ul[ R "UR5Ulg) Nalicex{izAlice,,,z/bin/shbobi7zBob,,,)mktempr(r+rdatabaser UserDirectory directoryrs r$setUpUserDirectoryTests.setUpsisCj$++-S 3S(DKKM9M)4::txx*@A  ..t}}=r#cjUR[[RUR55 g)z; L{UserDirectory} instances provide L{resource.IResource}. N) assertTruerr IResourcer0rs r$test_interface!UserDirectoryTests.test_interfaces!  X%7%7HIr#namereturnNc# [U/5nURRX5n[X25nUIShvN UR UR S5 gN!7f)zZ Verify that requesting the C{name} child of C{self.directory} results in a 404 response. Ni)rr0getChildrrbr)r,r8r_rris r$_404TestUserDirectoryTests._404TestsS v&((7 F $ --s3 s8AA"AcB# URS5IShvN gN7f)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%%% cB# URS5IShvN gN7f)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_getUserWithoutResourcerBrCch[R"URS5nURS5nUR 5 [ S/5nUR RSU5nURU[R5 URURUR5 g)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+rpmakedirsrr0r;assertIsInstancerFilerbpath)r,homerIr_rs r$test_getPublicHTMLChild*UserDirectoryTests.test_getPublicHTMLChilds   ".jj/ w'((9 ffkk2 k&6&67r#c[R"URS5nUR5 UR S5n[ S/5nUR RSU5nURU[R5 URURS5 UR[UR5UR5 g)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. rH.twistd-web-pbr+s bob.twistdunixN)r rJr+rKrprr0r;rLrrZrbrorr\rN)r,rOwebr_rs r$test_getDistribChild'UserDirectoryTests.test_getDistribChilds   ". jj)*w'((@ fg&B&BC f- -sxx8r#c[S/5nSUlUR[RUR R U5 g)zZ L{UserDirectory.render} raises L{UnsupportedMethod} in response to a non-I{GET} request. rPOSTN)rmethod assertRaisesrUnsupportedMethodr0rrs r$test_invalidMethod%UserDirectoryTests.test_invalidMethods9 t$ &22DNN4I4I7Sr#c^^[R"TRS5RS5nUR 5 [R"TR S5nUR 5 URS5R S5 [S/5m[TRT5nUU4SjnURU5 U$)ze L{UserDirectory} renders a list of links to available user content in response to a I{GET} request. rHrIrSr#rcx>[SRTR55nURS5up#TR UR R S5 TR UR RS5S5 TR UR R RS5 TR UR R S5 TR UR RS5S5 TR UR R RS5 g) Nr#liahrefzalice/z Alice (file)z bob.twistd/z Bob (twistd)) rrrgetElementsByTagNamerb 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#) r rJr(rprKr+ setContentrrr0r`)r,rIrUrrr_s` @r$ test_renderUserDirectoryTests.test_renders '' 27==mL  -  "#..s3t$1 M :& r#zpwd module requiredcn[R"5nURUR[5 g)zl If L{UserDirectory} is instantiated with no arguments, it uses the L{pwd} module as its password database. N)rr/assertIdentical_pwdpwd)r,r0s r$test_passwordDatabase(UserDirectoryTests.test_passwordDatabases& ))+  Y^^S1r#)r(r+r.r0)rrr r!r/r1r6bytesr<r@rErPrVr]rkrrprqr"rr#r$r&r&|sc > J 45 4T 4&& 8 9T@ G*+2,2r#r&)1r/os.pathrxml.dom.minidomrrpro ImportErrorunittestrzope.interface.verifyrtwisted.internetrrtwisted.loggerr twisted.pythonr r twisted.spreadr twisted.spread.bananar twisted.testrtwisted.trial.unittestr twisted.webrrrrrtwisted.web.http_headersrtwisted.web.test._utilrtwisted.web.test.requesthelperrrrWrr& Exceptionr1r4rr&rr#r$rs' C.+-,,&+AA,*E V[[  b((  Y n88n8b  z2z2_  CsCCC