~Mc%@sWdZddlZddlZddlZddlmZmZddlmZm Z m Z ddl m Z ddl mZddlmZddlmZmZdd lmZdd lmZmZdd lmZmZdd lmZdd lmZddlm Z m!Z!ddl"m#Z#m$Z$m%Z%ddl&m'Z'ddl(m)Z)ddl(m*Z*m+Z+ddl(m,Z,m-Z-ddl(m.Z.ddl(m/Z/ddl(m0Z0ddl(m1Z1ddl(m2Z2ddl(m3Z3ddl(m4Z4ddl(m5Z5ddl(m6Z6ddl(m7Z7ddl(m8Z8ddl(m9Z9dd l(m:Z:dd!l(m;Z;dd"l(m<Z<d#Z=d$Z>d%e?fd&YZ@d'e@fd(YZAd)e?fd*YZBd+fd,YZCd-ZDee d.d/d0d1eDZDd2e?fd3YZEd4ZFee d.d/d0d1eFZFd5efd6YZGd7fd8YZHd9e*fd:YZId;e)ejJfd<YZKe7d=eKd>fd?YZLd@e jMe0fdAYZNdBe3e jMfdCYZOe7eNeOd1dDZPdEe'jQfdFYZRdGZSdHZTdIejUfdJYZVdKejWfdLYZXdMefdNYZYdOfdPYZZeeZee-dQfdRYZ[dSe*e[fdTYZ\dUe*e[fdVYZ]dWdXdYdZd[d\d]d^d_d`dadbdcdddedfdgdhdid%d'd)d2d+d5d7d9d;d@dBdjdEdkdldIdKdMg%Z^dS(ms Perspective Broker "This isn't a professional opinion, but it's probably got enough internet to kill you." --glyph Introduction ============ This is a broker for proxies for and copies of objects. It provides a translucent interface layer to those proxies. The protocol is not opaque, because it provides objects which represent the remote proxies and require no context (server references, IDs) to operate on. It is not transparent because it does I{not} attempt to make remote objects behave identically, or even similiarly, to local objects. Method calls are invoked asynchronously, and specific rules are applied when serializing arguments. To get started, begin with L{PBClientFactory} and L{PBServerFactory}. @author: Glyph Lefkowitz iN(t implementst Interface(tlogtfailuretreflect(tVersion(t deprecated(tmd5(tdefertprotocol(tPortal(t IAnonymoust ICredentials(tIUsernameHashedPasswordt Anonymous(tstyles(tregisterAdapter(t IJellyablet IUnjellyable(tjellytunjellytglobalSecurity(tbanana(t Serializable(t Referenceablet NoSuchMethod(tRoottIPBRoot(t ViewPoint(tViewable(tCopyable(t Jellyable(t Cacheable(t RemoteCopy(t RemoteCache(tRemoteCacheObserver(tcopyTags(tsetUnjellyableForClass(tsetUnjellyableFactoryForClass(tsetUnjellyableForClassTree(tsetCopierForClass(tsetFactoryForClass(tsetCopierForClassTreeiiS"t ProtocolErrorcBseZdZRS(sN This error is raised when an invalid protocol statement is received. (t__name__t __module__t__doc__(((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR+PstDeadReferenceErrorcBseZdZRS(sx This error is raised when a method is called on a dead reference (one whose broker has been disconnected). (R,R-R.(((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR/UstErrorcBseZdZRS(s  This error can be raised to generate known error conditions. When a PB callable method (perspective_, remote_, view_) raises this error, it indicates that a traceback should not be printed, but instead, the string representation of the exception should be sent. (R,R-R.(((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR0[st RemoteMethodcBs2eZdZdZdZdZdZRS(s9This is a translucent reference to a remote message. cCs||_||_dS(sKInitialize with a L{RemoteReference} and the name of this message. N(tobjtname(tselfR2R3((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt__init__hs cCst|j|jf|S(N(tcmpR2R3(R4tother((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt__cmp__nscCst|j|jfS(N(thashR2R3(R4((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt__hash__qscOs1|jjjd|jj|jj|j||S(s/Asynchronously invoke a remote method. t(R2tbrokert _sendMessaget perspectivetluidR3(R4targstkw((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt__call__ts(R,R-R.R5R8R:RB(((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR1es    cOsdS(s} Do nothing. Neque porro quisquam est qui dolorem ipsum quia dolor sit amet, consectetur, adipisci velit... N((R@RA((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt noOperation{sttwistediiitPBConnectionLostcBseZRS((R,R-(((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyREscCstjdtj|dS(s9 Print a traceback (string) to the standard log. sPerspective Broker Traceback:N(Rtmsg(ttb((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pytprintTracebacks t IPerspectivecBseZdZdZRS(s per*spec*tive, n. : The relationship of aspects of a subject to each other and to a whole: 'a perspective of history'; 'a need to view the problem in the proper perspective'. This is a Perspective Broker-specific wrapper for an avatar. That is to say, a PB-published view on to the business logic for the system's concept of a 'user'. The concept of attached/detached is no longer implemented by the framework. The realm is expected to implement such semantics if needed. cCsdS(s This method is called when a network message is received. @arg broker: The Perspective Broker. @type message: str @arg message: The name of the method called by the other end. @type args: list in jelly format @arg args: The arguments that were passed by the other end. It is recommend that you use the `unserialize' method of the broker to decode this. @type kwargs: dict in jelly format @arg kwargs: The keyword arguments that were passed by the other end. It is recommended that you use the `unserialize' method of the broker to decode this. @rtype: A jelly list. @return: It is recommended that you use the `serialize' method of the broker on whatever object you need to return to generate the return value. N((R<tmessageR@tkwargs((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pytperspectiveMessageReceiveds(R,R-R.RL(((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRIs tAvatarcBs!eZdZeedZRS(s A default IPerspective implementor. This class is intended to be subclassed, and a realm should return an instance of such a subclass when IPerspective is requested of it. A peer requesting a perspective will receive only a L{RemoteReference} to a pb.Avatar. When a method is called on that L{RemoteReference}, it will translate to a method on the remote perspective named 'perspective_methodname'. (For more information on invoking methods on other objects, see L{flavors.ViewPoint}.) cCs|j||}|j||}t|d|}y|||}Wn.tk rztjd|||fnX|j|||||S(si This method is called when a network message is received. This will call:: self.perspective_%(message)s(*broker.unserialize(args), **broker.unserialize(kw)) to handle the method; subclasses of Avatar are expected to implement methods using this naming convention. sperspective_%ss%s didn't accept %s and %s(t unserializetgetattrt TypeErrorRRFt serialize(R4R<RJR@RAtmethodtstate((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRLs  (R,R-R.RRIRL(((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRMs tAsReferenceablecBseZdZddZRS(s6 A reference directed towards another object. tremotecCst||d|_dS(NtMessageReceived(ROtremoteMessageReceived(R4tobjectt messageType((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR5s(R,R-R.R5(((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRTstRemoteReferencecBs{eZdZeedZdZdZdZdZ dZ dZ dZ d Z d Zd ZRS( s] A translucent reference to a remote object. I may be a reference to a L{flavors.ViewPoint}, a L{flavors.Referenceable}, or an L{IPerspective} implementor (e.g., pb.Avatar). From the client's perspective, it is not possible to tell which except by convention. I am a "translucent" reference because although no additional bookkeeping overhead is given to the application programmer for manipulating a reference, return values are asynchronous. See also L{twisted.internet.defer}. @ivar broker: The broker I am obtained through. @type broker: L{Broker} cCs1||_||_||_||_g|_dS(s(internal) Initialize me with a broker and a locally-unique ID. The ID is unique only to the particular Perspective Broker instance. N(R?R<t doRefCountR>tdisconnectCallbacks(R4R>R<R?R[((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR5 s     cCsQt|st|jj|t|jdkrM|jj|jndS(sRegister a callback to be called if our broker gets disconnected. This callback will be called with one argument, this instance. iN(tcallabletAssertionErrorR\tappendtlenR<tnotifyOnDisconnectt _disconnected(R4tcallback((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRascCs3|jj||js/|jj|jndS(s>Remove a callback that was registered with notifyOnDisconnect.N(R\tremoveR<tdontNotifyOnDisconnectRb(R4Rc((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRes cCs+x|jD]}||q Wd|_dS(s<Called if we are disconnected and have callbacks registered.N(R\tNone(R4Rc((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRb%scCs9|jr1|j|jks$tdd|jfSdSdS(sZIf I am being sent back to where I came from, serialize as a local backreference. s6Can't send references to brokers other than their own.tlocalt unpersistablesReferences cannot be serializedN(RhsReferences cannot be serialized(tinvokerR<R^R?(R4tjellier((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pytjellyFor+s  cCs'|j|jj|j|dd|S(Ni(R5RitunserializingPerspective(R4t unjelliert unjellyList((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt unjellyFor4s#cOs%|jjd|j|j|||S(sAsynchronously invoke a remote method. @type _name: C{string} @param _name: the name of the remote method to invoke @param args: arguments to serialize for the remote function @param kw: keyword arguments to serialize for the remote function. @rtype: L{twisted.internet.defer.Deferred} @returns: a Deferred which will be fired when the result of this remote call is received. R;(R<R=R>R?(R4t_nameR@RA((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt callRemote8scCs t||S(s,Get a L{RemoteMethod} for this key. (R1(R4tkey((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt remoteMethodJscCsGt|tr7|j|jkr7t|j|jSnt|j|S(s4Compare me [to another L{RemoteReference}]. (t isinstanceRZR<R6R?(R4R7((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR8OscCs|jS(sHash me. (R?(R4((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR:WscCs#|jr|jj|jndS(s;Do distributed reference counting on finalization. N(R[R<t sendDecRefR?(R4((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt__del__\s (R,R-R.RRR5RaReRbRkRoRqRsR8R:Rv(((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRZs        RUtLocalcBs5eZdZddZdZdZdZRS(s.(internal) A reference to a local object. cCs||_||_d|_dS(sInitialize. iN(RXR>trefcount(R4RXR>((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR5hs  cCsd|j|jfS(Ns(RXRx(R4((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt__repr__oscCs|jd|_|jS(s1Increment and return my reference count. i(Rx(R4((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pytincrefrscCs|jd|_|jS(s1Decrement and return my reference count. i(Rx(R4((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pytdecrefxsN(R,R-R.RfR5RyRzR{(((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRwds    tCopyableFailurecBseZdZdZdZRS(s} A L{flavors.RemoteCopy} and L{flavors.Copyable} version of L{twisted.python.failure.Failure} for serialization. icCs|jj}d|dtstoppedObservingR#Rt localSecuritytremoteSecurityRRR(R4treasontdtlobjt cacheableR>R((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pytconnectionLost;s8               cCs&t|st|jj|dS(s4Call the given callback when the Broker disconnects.N(R]R^RR_(R4R((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRa_scCs&t|st|jj|dS(s7Call the given callback if the Broker fails to connect.N(R]R^RR_(R4R((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt notifyOnFaildscCsWt|st|jdkrCy |WqStjqSXn|jj|dS(s1Call the given callback when the Broker connects.N(R]R^RRfRterrR_(R4R((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pytnotifyOnConnectis cCs,y|jj|Wntk r'nXdS(s4Remove a callback from list of disconnect callbacks.N(RRdt ValueError(R4R((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRets cCs)|jj|}|dkr"dS|jS(s Get a local object for a locally unique ID. @return: An object previously stored with L{registerReference} or C{None} if there is no object which corresponds to the given identifier. N(RtgetRfRX(R4R?tlob((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pytlocalObjectForID{s icCs|dk st|j}|jj|}|dkrt|jtkr|jd|_|jdkr|j j t dnt dn|j }t ||j|<||j|stcallbackKeywordsR>RRR@RAN( RtRtDeferredt addCallbacksRQRt jellyMethodt jellyArgstjellyKwRRRf(R4RXR>RRR@RA((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRQs$        cCs4||_zt||jd|SWdd|_XdS(sOUnjelly an sexp according to the local security rules for this broker. N(RlRRRf(R4RR>((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRNs cCs|jd|_|jS(sGenerate a new LUID. i(R(R4((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR scCs|jd|_|jS(s#Generate a new request ID. i(R(R4((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt newRequestIDsc Csd}d}d} |jdr5|d}|d=n|jdrX|d}|d=n|jdr| ru| s~td|d} |d=n|jrtdny:|j|d|d|} |j|d|d|} Wntjtj SX|j } | rXtj } | |j | <|s5|r^t jd | j||q^nd} |j|d | ||| | | | S( Nit pbcallbackt pberrbacktpbanswers*You can't specify a no-answer requirement.sCalling Stale BrokerR>RRs&warning! using deprecated "pbcallback"RJ(Rfthas_keyR^RR/RQRRRRRRRRRFRR(R4tprefixR>tobjectIDRJR@RAtpbctpbetanswerRequiredtnetArgstnetKwt requestIDtrval((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR=s<            #cCs&|j|j||||||dS(N(t _recvMessageR(R4RRRJRRR((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt proto_message:scCs&|j|j||||||dS(N(RR(R4RRRJRRR((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pytproto_cachemessage<sc CsQyC||}|dkr*tdn|j||||} Wntk r} |rMt| ts|jj| jr|j| |q|jt | |qMn|rt j ddt t } |j| |nt j nZX|rMt| tjr:|f} | j|j|jd| d| qM|j| |ndS(sReceived a message-send. Look up message based on object, unserialize the arguments, and invoke it with args, and send an 'answer' or 'error' response. sInvalid Object IDs)Peer will receive following PB traceback:tisErrort callbackArgst errbackArgsN(RfR0RWRtRRtisClassAllowedt __class__t _sendErrorR|RRFtTrueRRRRt _sendAnswert_sendFailureOrError( R4t findObjMethodRRRJRRRRXt netResultteRR@((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR?s,  $  cCs|jd||dS(s@(internal) Send an answer to a previously sent message. tanswerN(R(R4RR((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR iscCs1|j|}|j|=|j|j|dS(sv(internal) Got an answer to a previously sent message. Look up the appropriate callback and call it. N(RRcRN(R4RRR((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt proto_answerns  cCs<|jtdkr(|j||n|j||dS(s Call L{_sendError} or L{_sendFailure}, depending on whether C{fail} represents an L{Error} subclass or not. N(tcheckR0Rft _sendFailureR (R4RR((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR zscCs.tjdtj||j||dS(sLog error and then send it.s)Peer will receive following PB traceback:N(RRFRR (R4RR((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRs  cCst|tjrrt|jts<|jj|jjrH|j}qrt|tsrt ||j j }qrnt|tr|j j |_ n|j d||j |dS(s@(internal) Send an error for a previously sent message. terrorN(RtRRRRRRRR|RRRRRQ(R4RR((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR s cCs1|j|}|j|=|j|j|dS(s'(internal) Deal with an error. N(RRRN(R4RRR((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt proto_errors  cCs|jd|dS(s,(internal) Send a DECREF directive. R{N(R(R4R((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRuscCsi|j|j}|dkre|j|jj}|j|=|j|=|jj|dndS(s(internal) Decrement the reference count of an object. If the reference count is zero, it will free the reference to this object. icSsdS(N(Rf(((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRsN(RR{RXRRRtpop(R4RtrefsR((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt proto_decrefs    cCs|jd|dS(s-(internal) Send a DECACHE directive. tdecacheN(R(R4R((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt decCacheRefscCs|j|j}|dkr|j|}|j}|j}y |j|t|||WntjnX|j}|j |=|j|=|j d|ndS(s(internal) Decrement the reference count of a cached object. If the reference count is zero, free the reference, then send an 'uncached' directive. ituncacheN( RR{RXR>RR#RRRRR(R4RRRRR>R((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt proto_decaches        cCs$|j|}d|_|j|=dS(sF(internal) Tell the client it is now OK to uncache an object. N(RRfR<(R4RR2((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt proto_uncaches  N(6R,R-R.RRftusernameRRR5RRRRRRRRRRRRRaRRReRRRRRRRRRRRQRNRRR=RRRR RR RR RRuRRRR(((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRsd'       $          !   !   *       cCsUt}|j||j}t}|j||j||j}|S(sWRespond to a challenge. This is useful for challenge/response authentication. (Rtupdatetdigest(t challengetpasswordtmthashedPasswordtdoubleHashedPassword((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pytresponds       cCs[d}x<ttjddD]"}|ttjdd}qWt|j}|S(sI return some random data.R;iiiAiZ(trangetrandomt randrangetchrtrandintRR (tcrapR((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR!s  tPBClientFactorycBseZdZeZeZeedZdZ dZ dZ dZ ddZ dZd Zd Zd Zd Zd ZddZRS(s Client factory for PB brokers. As with all client factories, use with reactor.connectTCP/SSL/etc.. getPerspective and getRootObject can be called either before or after the connect. cCs ||_||_|jdS(sE @param unsafeTracebacks: if set, tracebacks for exceptions will be sent over the wire. @type unsafeTracebacks: C{bool} @param security: security options used by the broker, default to C{globalSecurity}. @type security: L{twisted.spread.jelly.SecurityOptions} N(RRt_reset(R4RR((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR5s  cCs(|jdtd|j}||_|S(sP Build the broker instance, passing the security options to it. RR(R R RR(R4taddrtp((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt buildProtocols cCsg|_d|_d|_dS(N(trootObjectRequestsRft_brokert_root(R4((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR.s  cCs5|j}|jx|D]}|j|qWdS(N(R2R.R(R4Rt deferredsR((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt_failAll$s   cCs|j|dS(N(R6(R4t connectorR((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pytclientConnectionFailed*sicCs,|rd|_d|_n |j|dS(s8Reconnecting subclasses should call with reconnecting=1.N(RfR3R4R6(R4R7Rt reconnecting((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pytclientConnectionLost-s  cCsR||_|jd|_|j}g|_x|D]}|j|jq4WdS(Ntroot(R3RR4R2Rc(R4R<tdsR((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR7s     cCsF|jr&|jj r&tj|jStj}|jj||S(s\Get root object of remote PB server. @return: Deferred of the root object. (R3RRtsucceedR4RR2R_(R4R((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt getRootObject?s  cCs |jr|jjjndS(sIf the factory is connected, close the connection. Note that if you set up the factory to reconnect, you will need to implement extra logic to prevent automatic reconnection after this is called. N(R3RR(R4((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt disconnectJs cCs"|jd|j|j||S(Ntlogin(Rqt addCallbackt _cbResponse(R4R;RR"tclient((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt_cbSendUsernameTscCs(|\}}|jdt|||S(NR&(RqR&(R4t.1R"RCR!t challenger((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRBXs cCs|jd|S(sb Attempt an anonymous login on the given remote root object. @type root: L{RemoteReference} @param root: The object on which to attempt the login, most likely returned by a call to L{PBClientFactory.getRootObject}. @param client: A jellyable object which will be used as the I{mind} parameter for the login attempt. @rtype: L{Deferred} @return: A L{Deferred} which will be called back with a L{RemoteReference} to an avatar when anonymous login succeeds, or which will errback if anonymous login fails. tloginAnonymous(Rq(R4R;RC((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt_cbLoginAnonymous\scCsT|j}tj|r1|j|j|n|j|j|j|j||S(s Login and get perspective from remote PB server. Currently the following credentials are supported:: L{twisted.cred.credentials.IUsernamePassword} L{twisted.cred.credentials.IAnonymous} @rtype: L{Deferred} @return: A L{Deferred} which will be called back with a L{RemoteReference} for the avatar logged in to, or which will errback if login fails. (R>R t providedByRARHRDRR"(R4t credentialsRCR((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR@os   N(R,R-R.RR tFalseRRR5R1R.R6R8R:RR>R?RDRBRHRfR@(((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR-s        tPBServerFactorycBs;eZdZeZeZeedZdZ dZ RS(s Server factory for perspective broker. Login is done using a Portal object, whose realm is expected to return avatars implementing IPerspective. The credential checkers in the portal should accept IUsernameHashedPassword or IUsernameMD5Password. Alternatively, any object providing or adaptable to L{IPBRoot} can be used instead of a portal to provide the root object of the PB server. cCs%t||_||_||_dS(s @param root: factory providing the root Referenceable used by the broker. @type root: object providing or adaptable to L{IPBRoot}. @param unsafeTracebacks: if set, tracebacks for exceptions will be sent over the wire. @type unsafeTracebacks: C{bool} @param security: security options used by the broker, default to C{globalSecurity}. @type security: L{twisted.spread.jelly.SecurityOptions} N(RR;RR(R4R;RR((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR5s  cCsD|jdtd|j}||_|jd|jj||S(sT Return a Broker attached to the factory (as the service provider). RRR;(R RKRRRR;t rootObject(R4R/tproto((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR1s cCsdS(N((R4R ((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRs( R,R-R.RKRRR RR5R1R(((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRLs   tIUsernameMD5PasswordcBs eZdZdZdZRS(sb I encapsulate a username and a hashed password. This credential is used for username/password over PB. CredentialCheckers which check this kind of credential must store the passwords in plaintext form or as a MD5 digest. @type username: C{str} or C{Deferred} @ivar username: The username associated with these credentials. cCsdS(s Validate these credentials against the correct password. @type password: C{str} @param password: The correct, plaintext password against which to check. @rtype: C{bool} or L{Deferred} @return: C{True} if the credentials represented by this object match the given password, C{False} if they do not, or a L{Deferred} which will be called back with one of these values. N((R"((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt checkPasswordscCsdS(s Validate these credentials against the correct MD5 digest of the password. @type password: C{str} @param password: The correct MD5 digest of a password against which to check. @rtype: C{bool} or L{Deferred} @return: C{True} if the credentials represented by this object match the given digest, C{False} if they do not, or a L{Deferred} which will be called back with one of these values. N((R"((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pytcheckMD5Passwords(R,R-R.RPRQ(((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyROs  t _PortalRootcBs*eZdZeedZdZRS(s%Root object, used to login to portal.cCs ||_dS(N(tportal(R4RS((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR5scCst|j|S(N(t_PortalWrapperRS(R4R<((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRMs(R,R-R.RRR5RM(((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRRs  t_JellyableAvatarMixincBseZdZdZRS(sk Helper class for code which deals with avatars which PB must be capable of sending to a peer. csr|\}}tj|s0t|d}n|j}fd}|jj|<jj|S(s Ensure that the avatar to be returned to the client is jellyable and set up disconnection notification to call the realm's logout object. R>csjjdS(N(R<Re((R4tlogout(s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pytdereferenceLogouts(RRIRTRR<RRa(R4REt interfacetavatarRVRRW((R4RVs5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt_cbLogins  (R,R-R.RZ(((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRUsRTcBs)eZdZdZdZdZRS(s= Root Referenceable object, used to login to portal. cCs||_||_dS(N(RSR<(R4RSR<((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR5s cCs(t}|t|j|j||fS(s3 Start of username/password login. (R!t_PortalAuthChallengerRSR<(R4Rtc((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyt remote_logins cCs/|jjt|t}|j|j|S(sU Attempt an anonymous login. @param mind: An object to use as the mind parameter to the portal login call (possibly None). @rtype: L{Deferred} @return: A Deferred which will be called back with an avatar when login succeeds or which will be errbacked if login fails somehow. (RSR@RRIRARZ(R4tmindR((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pytremote_loginAnonymous#s (R,R-R.R5R]R_(((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRTs  R[cBs?eZdZeeedZdZdZdZ RS(s5 Called with response to password challenge. cCs(||_||_||_||_dS(N(RSR<RR!(R4RSR<RR!((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR5:s   cCs5||_|jj||t}|j|j|S(N(tresponseRSR@RIRARZ(R4R`R^R((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pytremote_respondAs cCs|jt|jS(N(RQRR (R4R"((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRPIscCs?t}|j||j|j|j}|j|kS(N(RRR!R R`(R4t md5Passwordtmdtcorrect((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyRQNs    ( R,R-R.RR ROR5RaRPRQ(((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyR[4s     RRRRRRRRRR R!R"R#R$R%R&R'RtportnoRR&R!(_R.R(RRtzope.interfaceRRttwisted.pythonRRRttwisted.python.versionsRttwisted.python.deprecateRttwisted.python.hashlibRttwisted.internetRR ttwisted.cred.portalR ttwisted.cred.credentialsR R R Rttwisted.persistedRttwisted.python.componentsRttwisted.spread.interfacesRRttwisted.spread.jellyRRRttwisted.spreadRttwisted.spread.flavorsRRRRRRRRRR R!R"R#R$R%R&R'R(R)R*RRet ExceptionR+R/R0R1RCRERHRIRMRTt EphemeralRZRwRR|RRRRR&R!t ClientFactoryR-t ServerFactoryRLRORRRURTR[t__all__(((s5/usr/lib/python2.7/dist-packages/twisted/spread/pb.pyts     ! !*+ n    2  1* #$