[XMc@sdZddlZddlZddlZddlZddlmZddlmZm Z ddl m Z ddl m Z ddlmZmZmZmZddlmZmZmZdd lmZdd lmZmZmZdd lmZdd lm Z m!Z!dd l"m#Z#m$Z$ddl%m&Z&m'Z'm(Z(dej)fdYZ*dej+fdYZ,de-fdYZ.dfdYZ/dZ0dej1fdYZ2dej1fdYZ3dej4fdYZ5dej6fdYZ7ej8e5e7d ej4fd!YZ9d"Z:ej;e9e:d#ej1fd$YZ<d%ej=fd&YZ>d'ej1fd(YZ?d)ej=fd*YZ@d+ejAfd,YZBej8e@eBd-ejAfd.YZCej8e>eCd/ej1fd0YZDd1ej1fd2YZEd3ej1fd4YZFd5ej1fd6YZGd7ej4ej6e-fd8YZHej8eHeHd9ej4ej6e-fd:YZIej8eIeId;ej=ejAe-fd<YZJej8eJeJd=ejKfd>YZLd?ejKfd@YZMdAe jNfdBYZOdCejPfdDYZQdEe jNfdFYZRdGe jNfdHYZSdIdJZTeUaVeUaWdKZXdLej1fdMYZYdNej1fdOYZZdPe jNfdQYZ[dRej\fdSYZ]dTej^fdUYZ_dVej1fdWYZ`ej8e]e_dXe jNfdYYZadZebfd[YZcd\ej4fd]YZdd^ej1fd_YZed`ejffdaYZgdbej+fdcYZhdde-fdeYZidfej)fdgYZjdhe jNfdiYZkdjfdkYZldle jNfdmYZmdne fdoYZndpfdqYZodre jNfdsYZpdte jNfduYZqdve jNfdwYZrdS(xs Tests for Perspective Broker module. TODO: update protocol level tests to use new connection API, leaving only specific tests for old API. iN(tStringIO(t implementst Interface(tVersion(tunittest(tpbtutiltpublishtjelly(tprotocoltmaintreactor(tConnectionRefusedError(tDeferredt gatherResultstsucceed(tWrappingFactory(tfailuretlog(tUnauthorizedLogintUnhandledCredentials(tportaltcheckerst credentialstDummycBseZdZRS(cCst|trdSdSdS(Ns hello world!sgoodbye, cruel world!(t isinstancetDummyPerspective(tselftuser((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytview_doNothing s(t__name__t __module__R(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRsRcBseZdZdZRS(sE An L{IPerspective} avatar which will be used in some tests. cCstS(N(R(R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytperspective_getDummyViewPoint+s(RRt__doc__R (((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR'st DummyRealmcBseZeejdZRS(cGs:x3|D]+}|tjkr|t|dfSqWdS(NcSsdS(N(tNone(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt6s(Rt IPerspectiveR(RtavatarIdtmindt interfacestiface((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt requestAvatar3s (RRRRtIRealmR*(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR"0s tIOPumpcBs)eZdZdZdZdZRS(s Utility to pump data between clients and servers for protocol testing. Perhaps this is a utility worthy of being in protocol.py? cCs(||_||_||_||_dS(N(tclienttservertclientIOtserverIO(RR-R.R/R0((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt__init__?s   cCs=tjd}x&|jr8tj|krdSqWdS(s Pump until there is no more input or output. This does not run any timers, so don't use it with any code that calls reactor.callLater. iN(ttimetpump(Rttimeout((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytflushEscCs|jjd|jjd|jj}|jj}|jjd|jjd|jj|jj|jjj|jjjx|D]}|jj |qWx|D]}|jj |qW|s|rdSdSdS(sX Move data back and forth. Returns whether any data was moved. iiN( R/tseekR0treadttruncateR-t transportt_checkProducerR.t dataReceived(RtcDatatsDatatbyte((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR3Ps"     (RRR!R1R5R3(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR,9s  cCstj}tjdd}tjtjt|g}|jd}t }t }|j t j ||j t j |t ||||}|j|||fS(s4 Returns a 3-tuple: (client, server, pump). tguests 127.0.0.1(s 127.0.0.1(RtBrokerRt'InMemoryUsernamePasswordDatabaseDontUsetPBServerFactoryRtPortalR"t buildProtocolRtmakeConnectionR t FileWrapperR,R5(t clientBrokertcheckertfactoryt serverBrokertclientTransporttserverTransportR3((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytconnectedServerAndClientjs !   t SimpleRemotecBseZdZdZRS(cCs||_|dS(Ni(targ(RRO((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt remote_thunk~s cCs tdS(N(t Exception(RRO((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt remote_knuths(RRRPRR(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRN}s t NestedRemotecBseZdZRS(cCstS(N(RN(R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytremote_getSimples(RRRT(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRSst SimpleCopycBseZdZRS(cCs)d|_idd6|_dg|_dS(NitWorldtHellottest(txtytz(R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR1s (RRR1(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRUstSimpleLocalCopycBseZRS((RR(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR\stSimpleFactoryCopycBseZdZiZdZRS(s] @cvar allIDs: hold every created instances of this class. @type allIDs: C{dict} cCs||_|tj|((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR? sN(RRR#RDR1R?(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR@s tPagingTestCasecBsDeZdZdZdZdZdZdZdZRS(s0 Test pb objects sending data by pages. cCs<|j|_t|jd}|jt|jdS(s? Create a file used to test L{util.FilePager}. twN(tmktempRARCtwriteR=tclose(Rtfd((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR,s cCst\}}}|jdttddd|jd}g}tj|dj|jx|sx|j qeW|j dj |dt d|j t d d |j tidd6d d S( sg Test L{util.StringPager}, passing a callback to fire when all pages are sent. RqthelloRii tgetPagestis'Pages received not equal to pages sent!sCompleted callback not invokedN(RK(RMRR;R:RRt getAllPagesRRR3RtjoinR=R6R7(RRoRR3RYR((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_pagingWithCallback6s  cCst\}}}|jdtd|jd}g}tj|dj|jx|so|j q\W|j dj |dt ddS(s> Test L{util.StringPager} without a callback. RqRLRMis'Pages received not equal to pages sent!N( RMRR;R#RRRNRRR3RROR=(RRoRR3RYR((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_pagingWithoutCallbackJs c Cs|j}t|d}|jt\}}}t|d }|jd||jd}g}tj |dj |j d} x+| r| dkr|j | d8} qW| s|j dn|jdj|ddd d S( s@ Test L{util.FilePager}, sending an empty file. RFRRLi iisgetAllPages timed outRMs'Pages received not equal to pages sent!N(RGRCRIRMR@R#RRRRNRRR3RRRO( Rt filenameEmptyRJRoRR3t pagerizerRYRtttl((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_emptyFilePagingYs"   cCst\}}}t|jtddd}|jd||jd}g}tj|dj|j x|s|j qqW|j dj |dt d|j td d |j tidd6d |j |jjgd S( s Test L{util.FilePager}, passing a callback to fire when all pages are sent, and verify that the pager doesn't keep chunks in memory. tfrodoRii RRLRMis'Pages received not equal to pages sent!sCompleted callback not invokedN(RV(RMR@RAR:RRRRNRRR3RROR=R6R7RDtchunks(RRoRR3RSRYR((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_filePagingWithCallbackps    cCst\}}}t|jd}|jd||jd}g}tj|dj|j x|s{|j qhW|j dj |dt d|j |jjgdS(s< Test L{util.FilePager} without a callback. RRLRMis'Pages received not equal to pages sent!N(RMR@RAR#RRRRNRRR3RROR=RDRW(RRoRR3RSRYR((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_filePagingWithoutCallbacks ( RRR!RRPRQRURXRY(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRE's    tDumbPublishablecBseZdZRS(cCs idd6S(NiR,((R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytgetStateToPublishs(RRR[(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRZstDumbPubcBseZdZRS(cCs d|_dS(Ni(R*(R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt activateds(RRR](((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR\sR(cBseZdZdZRS(cCstd|_dS(NtTESTING(RZtpub(R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR1scCs|jS(N(R_(R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt remote_getPubs(RRR1R`(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR(s tDisconnectionTestCasecBs;eZdZdZdZdZdZdZRS(s' Test disconnection callbacks. cGstd|fdS(Ns I shouldn't have been called: %s(Ra(RR8((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRscCs d|_dS(s. Called on broker disconnect. iN(t gotCallback(R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytgotDisconnectedscCs |j||jd|_dS(s7 Called on RemoteReference disconnect. iN(Rt remoteObjecttobjectCallback(Rto((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytobjectDisconnectedscCst\}}}|j|jdt|jd}g}|jdtj|j|j |j t |ddS(NRft setBadCopyi( RMR3Rt BadCopySetRRst BadCopyableRRR5RR(RRoRR3tgR((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_badSerializations  cCst\}}}|j|jdt|jd}|j|j|j|j|j|j|j|j|j |j|j |j|j|j|j|j|j |j|j|j|j |j |j|j |j |j|j |j|j |j|j |j|j||_|jtjtj|j|j|j|jdS(NRf(RMR3RRNRtnotifyOnDisconnectRR t disconnectstdontNotifyOnDisconnectRt _disconnectedtdisconnectCallbacksRcRgRdtconnectionLostRtFailureR tCONNECTION_DONERRbRe(RRoRR3tr((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_disconnections.     (RRR!RRcRgRlRv(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRas     tFreakOutcBseZRS((RR(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRwsRjcBseZdZRS(cCs tdS(N(Rw(Rtp((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytgetStateToCopyFors(RRRy(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRjsRicBseZdZRS(cCsdS(N(R#(Rtbc((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytremote_setBadCopys(RRR{(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRistLocalRemoteTestcBs/eZdZdZdddZdZRS(icCs|dS(Ni((RRY((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt sync_add1sicCs||S(N((RRYRZ((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt async_addscCs tdS(N(Ra(R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt async_fails(RRtreportAllTracebacksR}R~R(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR|s t MyPerspectivecBsReZdZeejeZZdZ dZ dZ dZ dZ RS(s @ivar loggedIn: set to C{True} when the avatar is logged in. @type loggedIn: C{bool} @ivar loggedOut: set to C{True} when the avatar is logged out. @type loggedOut: C{bool} cCs ||_dS(N(R&(RR&((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR1scCs|jS(sT Return the avatar identifier which was used to access this avatar. (R&(R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytperspective_getAvatarIdscCstS(N(tMyView(R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytperspective_getViewPoint$scCs||S(s Add the given objects and return the result. This is a method unavailable on L{Echoer}, so it can only be invoked by authenticated users who received their avatar from L{TestRealm}. ((RRR((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytperspective_add(scCs t|_dS(N(tTruet loggedOut(R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytlogout1s(RRR!RRR%tFalsetloggedInRR1RRRR(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR s      t TestRealmcBs#eZdZeZdZdZRS(s A realm which repeatedly gives out a single instance of L{MyPerspective} for non-anonymous logins and which gives out a new instance of L{Echoer} for each anonymous login. @ivar lastPerspective: The L{MyPerspective} most recently created and returned from C{requestAvatar}. @ivar perspectiveFactory: A one-argument callable which will be used to create avatars to be returned from C{requestAvatar}. cCs|tjkst|dks't|tjkrLtjtdfS|j||_t|j_ tj|j|jj fSdS(s Verify that the mind and interface supplied have the expected values (this should really be done somewhere else, like inside a test method) and return an avatar appropriate for the given identifier. sBRAINS!cSsdS(N(R#(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR$OsN( RR%RRt ANONYMOUSRtperspectiveFactorytlastPerspectiveRRR(RR&R't interface((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR*Fs  N(RRR!RRR#RR*(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR6s RcBseZdZRS(cCs t|tS(N(RR(RR((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt view_check[s(RRR(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRYstNewCredTestCasecBseZdZdZdZejdZdZdZ dZ dZ dZ d Z d Zd Zd Zd ZdZdZdZdZdZRS(s= Tests related to the L{twisted.cred} support in PB. cCsjt|_tj|j|_t|j|_tjd|jdd|_|jj j|_ dS(s Create a portal with no checkers and wrap it around a simple test realm. Set up a PB server on a TCP port which serves perspectives using that portal. iRs 127.0.0.1N( RtrealmRRCRRIR RRRtportno(R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRds  cCs |jjS(s= Shut down the TCP port created by L{setUp}. (RR(R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRqscCsG|}|j}tjd|j|}|j|j||fS(sG Create a connection to the test server. @param clientFactory: the factory class used to create the connection. @return: a tuple (C{factory}, C{deferred}), where factory is an instance of C{clientFactory} and C{deferred} the L{Deferred} firing with the PB root object. s 127.0.0.1(RR RRt addCleanupt disconnect(RRRItrootObjDeferredt connector((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytgetFactoryAndRootObjectxs  cs1j\}fd}|j|S(sw Assert only that L{PBClientFactory.getRootObject}'s Deferred fires with a L{RemoteReference}. cs:j|tjt}|j|jj|S(N(tassertIsInstanceRtRemoteReferenceR RmRR(trootObjtdisconnectedDeferred(RRI(s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt gotRootObjects   (RR(RRR((RRIs8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_getRootObjectscs1j\}fd}|j|S(s Test that when a connection is lost, calling a method on a RemoteReference obtained from it raises DeadReferenceError. csFt}j|jfd}|j|j|S(NcsjtjjddS(Ntmethod(t assertRaisesRtDeadReferenceErrorRs(tign(RR(s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytlostConnections(R RmRRR(RRR(RRI(Rs8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRs    (RR(RRR((RRIs8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_deadReferenceErrors csMdtjfdY}j|\}fd}|j|S(s Test that if the L{reconnecting} flag is passed with a True value then a remote call made from a disconnection notification callback gets a result successfully. t ReconnectOncecBseZeZdZRS(cSs?|j }t|_|r&|jntjj||||S(N(treconnectedAlreadyRtconnectRRtclientConnectionLost(RRtreasont reconnecting((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRs     (RRRRR(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRscsUj|tjt}|j|jjfd}|j|S(Ncs+j}fd}|j|S(Ncs:j|tjt}|j|jj|S(N(RRRR RmRR(tanotherRootObjR(RRI(s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytgotAnotherRootObjects   (RR(RRR(RRI(s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt disconnecteds (RRRR RmRRR(RRR(RRI(s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRs    (RRRR(RRRR((RRIs8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_clientConnectionLosts cCsH|jjd}|jtjt|jtjt j dS(s Test that if a Broker loses its connection without receiving any bytes, it doesn't raise any exceptions or log any errors. s 127.0.0.1i90N(s 127.0.0.1i90( RIRDRER RFRRrRRsR Rt(Rt serverProto((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_immediateClosescCsVtj}|jtjdd}|jdtjt d|j |t S(s L{PBClientFactory.login} returns a L{Deferred} which is errbacked with the L{ConnectionRefusedError} if the underlying connection is refused. RqRs!Test simulated refused connectionN( RRtloginRtUsernamePasswordtclientConnectionFailedR#RRsR t assertFailure(RRt loginDeferred((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_loginConnectionRefuseds cs3t|jjjfd|jS(s Helper method disconnecting the given client factory and returning a C{Deferred} that will fire when the server connection has noticed the disconnection. cs jdS(N(RR#((R(s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR$s(R RIRRmR(RtignoreRI((Rs8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt _disconnects    csjjtjddtjtjdd}d}j||}fd}|j |fd}|j |t j dj }j |j|S(s Test that login can be performed with IUsernamePassword credentials and that when the connection is dropped the avatar is logged out. RtpasssBRAINS!cs9jjjjj|tjjdS(N( RRRRRRRRR#(Ru(RRI(s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytcbLoginscsjjjjdS(N(RRRR(tignored(R(s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytcbLogoutss 127.0.0.1(RtregisterCheckerRRARRRRRRR RRRR(RtcredsR'RRRR((RRIs8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_loginLogouts    cstdtjffdY}|j_jjtjddtj }|j t j ddd}fd}|j |fd}|j ||j j|tjdj|}j|j|S( s If a L{RemoteReference} to an L{IPerspective} avatar is decrefed and there remain no other references to the avatar on the server, the avatar is garbage collected and the logout method called. tEventPerspectivecs&eZdZdZfdZRS(sQ An avatar which fires a Deferred when it is logged out. cSsdS(N((RR&((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR1-scsjddS(N(RR#(R(R(s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR0s(RRR!R1R((R(s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR)s RqRsBRAINS!csS(N((tavatar(R(s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt cbLoggedIn:scsjjjjidS(N(t assertEqualRIRt _localCleanup(R(R(s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt cbLoggedOut?ss 127.0.0.1(R RtAvatarRRRRRRARRRRRRR RRRR(RRRIRRRR((RRs8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_logoutAfterDecref!s       csjjtjddddtj}|jtjddd}|jtjddd}t ||g}d}|j |fd}|j ||j j |t j dj|}j|j|S( s Two different correct login attempts can be made on the same root object at the same time and produce two different resulting avatars. RqRtbaztquuxsBRAINS!cSs.|\}}t|jd|jdgS(Nt getAvatarId(RRs(t.0tfirsttsecond((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRYs  cs0|\}}j|dj|ddS(NRqR(R(RRR(R(s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt cbAvatarIds^s s 127.0.0.1(RRRRARRRRRRRRR RRRR(RRIt firstLogint secondLoginRRRR((Rs8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_concurrentLoginJs"      csjjtjddtjjtjdd}jtjdd}j |t j |t t ||g}fd}|j |t jdj}j|j|S(sz Test that a login attempt with an invalid user or invalid password fails in the appropriate way. RRt nosuchusert wrongpasscs5jt}jt|djdS(Ni(tflushLoggedErrorsRRRRR#(Rterrors(RRI(s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytcleanup{ss 127.0.0.1(RRRRARRRRRRRRRR RRRR(RRRRRR((RRIs8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_badUsernamePasswordLoginis   cCs|jjtjtj}|jtjd}d}|j ||j |j d|j |j |t j d|j|}|j|j|S(s Verify that a PB server using a portal configured with an checker which allows IAnonymous credentials can be logged into using IAnonymous credentials. sBRAINS!cSs|jddS(NRi{(Rs(Ru((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRsi{s 127.0.0.1(RRRtAllowAnonymousAccessRRRRt AnonymousRRRR RRRR(RRIRRR((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_anonymousLogins   csjjtjddtjjtjd}j |t fd}|j |t j dj}j|j|S(sg Verify that without an anonymous checker set up, anonymous login is rejected. RRsBRAINS!cs5jt}jt|djdS(Ni(RRRRRR#(RR(RRI(s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRss 127.0.0.1(RRRRARRRRRRRRR RRRR(RRRR((RRIs8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_anonymousLoginNotPermitteds   cCs|jjtj|jjtjddtj}|jtj d}d}|j ||j |j d|j |j |t jd|j|}|j|j|S(s Like L{test_anonymousLogin} but against a portal with a checker for both IAnonymous and IUsernamePassword. RRsBRAINS!cSs|jddS(NRi{(Rs(Ru((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRsi{s 127.0.0.1(RRRRRARRRRRRRRR RRRR(RRIRRR((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt'test_anonymousLoginWithMultipleCheckerss    cCs|jjtj|jjtjddtj}|jtj ddd}d}|j ||j |j d|j |j |t jd|j|}|j|j|S(s Like L{test_anonymousLoginWithMultipleCheckers} but check that username/password authentication works. RRsBRAINS!cSs|jdddS(Ntaddidi(Rs(Ru((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRsi{s 127.0.0.1(RRRRRARRRRRRRRR RRRR(RRIRRR((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt+test_authenticatedLoginWithMultipleCheckerss    cCs|jjtjddtj}|jtjddd}d}|j |d}|j ||j |j |j |j |t j d|j|}|j|j|S(sb Verify that a viewpoint can be retrieved after authenticating with cred. RRsBRAINS!cSs |jdS(Nt getViewPoint(Rs(Ru((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRscSs |jdS(NR(Rs(t viewpoint((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytcbViewss 127.0.0.1(RRRRARRRRRRRRR RRRR(RRIRRRR((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt test_views      (RRR!RRRRRRRRRRRRRRRRRRRR(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR`s&    (  ! )      tNonSubclassingPerspectivecBs0eZeejdZdZdZRS(cCsdS(N((RR&((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR1scCs:|j||}|j||}|j|||fS(N(t unserializet serialize(RRtmessageR8tkwargs((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytperspectiveMessageReceivedscCs t|_dS(N(RR(R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRs(RRRRR%R1RR(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRs   t NSPTestCasecBs eZdZdZdZRS(s Tests for authentication against a realm where the L{IPerspective} implementation is not a subclass of L{Avatar}. cCst|_t|j_tj|j|_tj|_|jj dd|jj |jt t j |j|_tjd|jdd|_|j|jj|jjj|_dS(NRRiRs 127.0.0.1(RRRRRRCRRARHtaddUserRRRRBRIR RRRRRR(R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRs  cstjjtjddd}tjdj|jd|jj dd idd 6ffd }|j||S( s An L{IPerspective} implementation which does not subclass L{Avatar} can expose remote methods for the client to call. RRsBRAINS!s 127.0.0.1cSs|jddddS(NtANYTHINGthereRR(Rs(Rx((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR$.sRRRRcs2jx!jjD]}|jjqWdS(N(RRIRR9R(RRx(RRI(s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR1s (shere( RRRRRR RRRR(RRR((RRIs8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_NSP%s    (RRR!RR(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRs t IForwardedcBs eZdZdZdZRS(sA Interface used for testing L{util.LocalAsyncForwarder}. cCsdS(s, Simple synchronous method. N((((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt forwardMe?scCsdS(s- Simple asynchronous method. N((((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytforwardDeferredDs(RRR!RR(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR:s t ForwardedcBs?eZdZeeeZeZdZdZ dZ RS(s Test implementation of L{IForwarded}. @ivar forwarded: set if C{forwardMe} is called. @type forwarded: C{bool} @ivar unforwarded: set if C{dontForwardMe} is called. @type unforwarded: C{bool} cCs t|_dS(s6 Set a local flag to test afterwards. N(Rt forwarded(R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRWscCs t|_dS(sv Set a local flag to test afterwards. This should not be called as it's not in the interface. N(Rt unforwarded(R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt dontForwardMe]scCs ttS(s0 Asynchronously return C{True}. (RR(R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRds( RRR!RRRRRRRR(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRJs   tSpreadUtilTestCasecBs;eZdZdZdZdZdZdZRS(s+ Tests for L{twisted.spread.util}. cCs)t}|j|jddddS(sk Call a synchronous method of a L{util.LocalAsRemote} object and check the result. tadd1iiN(R|RRs(RRf((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt test_syncps cCsQt}t}|jdddd}|j|t|j|jd|S(sm Call an asynchronous method of a L{util.LocalAsRemote} object and check the result. RiRZii(R|RsRR RR(RRfR((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt test_asyncxs   csDt}|jd}fd}|jfd||S(sF Test a asynchronous failure on a remote method call. Rcs*jt|tj|jtdS(N(RRRRsttrapRa(tf(R(s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pytebscs jdS(Nssupposed to fail(R(R(R(s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR$s(R|RsR(RRfRR((Rs8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_asyncFails  cCs2t}|jd}|j|dddS(sM Test the C{remoteMethod} facility of L{util.LocalAsRemote}. RiiN(R|RR(RRftm((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_remoteMethods cCst}tj|t}|jd|j|j|jd|j|j|jd}g}|j |j |j |dddS(se Test a call to L{util.LocalAsyncForwarder} using L{Forwarded} local object. RRRiiN( RRtLocalAsyncForwarderRRsRRR RRRR(RRtlftrrR((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_localAsyncForwarders   (RRR!RRRRR(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRks   tPBWithSecurityOptionsTestcBs2eZdZdZdZdZdZRS(s& Test security customization. cCs5tj}|jd}|j|jtjdS(sl By default, client broker should use C{jelly.globalSecurity} as security settings. N(RRRDR#RtsecurityRtglobalSecurity(RRIR((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt!test_clientDefaultSecurityOptionss cCs;tjt}|jd}|j|jtjdS(sl By default, server broker should use C{jelly.globalSecurity} as security settings. N( RRBRRDR#RRRR(RRIR((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt!test_serverDefaultSecurityOptionsscCsDtj}tjd|}|jd}|j|j|dS(ss Check that the security settings are passed from the client factory to the broker object. RN(RtSecurityOptionsRRRDR#RR(RRRIR((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt test_clientSecurityCustomizations cCsJtj}tjtd|}|jd}|j|j|dS(ss Check that the security settings are passed from the server factory to the broker object. RN( RRRRBRRDR#RR(RRRIR((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt test_serverSecurityCustomizations (RRR!RRR R (((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyRs  tDeprecationTestscBs eZdZdZdZRS(sS Tests for certain deprecations of free-functions in L{twisted.spread.pb}. c Cs8|jtddddtjdddddd d S( s2 L{pb.noOperation} is deprecated. ttwistediiiiRYiRZiN(tcallDeprecatedRRt noOperation(R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_noOperationDeprecatedscCs)|jtddddtjddS(s5 L{pb.printTraceback} is deprecated. R iiis/printTraceback deprecation fake traceback valueN(R RRtprintTraceback(R((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyttest_printTracebacks(RRR!RR(((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyR s (sR!RRR2Rt cStringIORtzope.interfaceRRttwisted.python.versionsRt twisted.trialRttwisted.spreadRRRRttwisted.internetR R R ttwisted.internet.errorR ttwisted.internet.deferR RRttwisted.protocols.policiesRttwisted.pythonRRttwisted.cred.errorRRt twisted.credRRRtViewableRRRRR"R,RMRRNRStCopyableRUt RemoteCopyR\tsetUnjellyableForClassR]RftsetUnjellyableFactoryForClassRgt CacheableRkRmRnt RemoteCacheRzR~RRRRRRRtRootRRtTestCaseRRBRRRR=R#R6R7R:R;R@REt PublishableRZtRemotePublishedR\R(RaRQRwRjRit LocalAsRemoteR|RRRRRRRRRRR (((s8/usr/lib/python2.7/dist-packages/twisted/test/test_pb.pyt s0"  1       """@!+   rD)#'!?0