hh:SrSSKrSSKJr SSKJrJr SSKJrJ r J r J r SSK J r SSKJrJr SSKJr SS KJrJrJr SS KJrJr SS KJr SS KJr SS KJrJ r J!r!J"r"J#r#J$r$J%r%J&r&J'r'J(r(J)r)J*r*J+r+J,r,J-r-J.r.J/r/J0r0J1r1J2r2 SSK3J4r4J5r5 SSK6J7r7J8r8J9r9J:r: Sr;Sr<"SS\=5r>"SS\>5r?"SS\=5r@"SS\=5rA\"SS55rB"SS\=5rC"SS\5rD\"\D5"S S!55rE"S"S#\$5rF\"\55\"S$S%\)\R555rH\1"S&\H5 "S'S(5rI"S)S*\R\ 5rK"S+S,\'\R5rL\1"\K\L5 SAS-jrM"S.S/\R5rOS0rPS1rQ"S2S3\R5rS"S4S5\R5rU"S6S7\ 5rV\"\!5"S8S955rW\"\W\ \!5 "S:S;5rX"S<S=\$\X5rY\"\ \V5"S>S?\$\X55rZ/S@Qr[g)Ba 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 similarly, 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 N)md5) Interface implementer) Anonymous IAnonymous ICredentialsIUsernameHashedPassword)Portal)deferprotocol)styles)failurelogreflect)cmp comparable)registerAdapter)banana) CacheableCopyableIPBRoot Jellyable NoSuchMethod Referenceable RemoteCacheRemoteCacheObserver RemoteCopyRoot SerializableViewable ViewPointcopyTagssetCopierForClasssetCopierForClassTreesetFactoryForClasssetUnjellyableFactoryForClasssetUnjellyableForClasssetUnjellyableForClassTree) IJellyable IUnjellyable) _newInstanceglobalSecurityjellyunjellyiiS"c\rSrSrSrSrg) ProtocolErrorTzF This error is raised when an invalid protocol statement is received. N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r2X/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/spread/pb.pyr0r0Tsr:r0c\rSrSrSrSrg)DeadReferenceErrorZzl This error is raised when a method is called on a dead reference (one whose broker has been disconnected). r2Nr3r2r:r;r=r=Zsr:r=c\rSrSrSrSrg)Erroraa 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. r2Nr3r2r:r;r@r@asr:r@c\rSrSrSrSrSrg) RemoteErrorlaR This class is used to wrap a string-ified exception from the remote side to be able to reraise it. (Raising string exceptions is no longer possible in Python 2.6+) The value of this exception will be a str() representation of the remote value. @ivar remoteType: The full import path of the exception class which was raised on the remote end. @type remoteType: C{str} @ivar remoteTraceback: The remote traceback. @type remoteTraceback: C{str} @note: It's not possible to include the remoteTraceback if this exception is thrown into a generator. It must be accessed as an attribute. cF[RX5 XlX0lgN) Exception__init__ remoteTyperemoteTraceback)selfrIvaluerJs r;rHRemoteError.__init__s4'$.r:)rJrINr4r5r6r7r8rHr9r2r:r;rCrCls &/r:rCc0\rSrSrSrSrSrSrSrSr g) RemoteMethodz6 This is a translucent reference to a remote message. cXlX lg)zD Initialize with a L{RemoteReference} and the name of this message. N)objname)rKrSrTs r;rHRemoteMethod.__init__s r:cF[URUR4U5$rF)rrSrTrKothers r;__cmp__RemoteMethod.__cmp__sDHHdii(%00r:cD[URUR45$rF)hashrSrTrKs r;__hash__RemoteMethod.__hash__sTXXtyy)**r:cURRRSURRURRUR R S5UU5$)z( Asynchronously invoke a remote method. r:utf-8)rSbroker _sendMessage perspectiveluidrTencode)rKargskws r;__call__RemoteMethod.__call__sRxx++  HH HHMM II  W %     r:)rTrSN) r4r5r6r7r8rHrYr^rir9r2r:r;rPrPs1+  r:rPc\rSrSrSrg)PBConnectionLostr2N)r4r5r6r7r9r2r:r;rlrlsr:rlc\rSrSrSrSrSrg) IPerspectivea 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. cg)a 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. Nr2)rbmessagergkwargss r;perspectiveMessageReceived'IPerspective.perspectiveMessageReceivedr:r2Nr4r5r6r7r8rtr9r2r:r;roros   r:roc\rSrSrSrSrSrg)Avatara 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}.) cURX05nURX@5n[USU-5nU"U0UD6nUR X`XSU5$![a [R"USUSU35 ef=f)a1 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. zperspective_%sz didn't accept z and ) unserializegetattr TypeErrorrmsg serialize)rKrbrrrgrhmethodstates r;rt!Avatar.perspectiveMessageReceiveds!!$-    )/'9: D'B'EV2>>  GGvhodV5= >  s A*A8r2Nrwr2r:r;ryrys  ?r:ryc"\rSrSrSrSSjrSrg)AsReferenceablez. A reference directed towards another object. c*[XS-5Ulg)NMessageReceived)r}remoteMessageReceived)rKobject messageTypes r;rHAsReferenceable.__init__s%,VCT5T%U"r:)rN)remoterNr2r:r;rrs Vr:rcZ\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrg)RemoteReferenceia- 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} implementer (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} cBX0lX lX@lXl/Ulg)z(internal) Initialize me with a broker and a locally-unique ID. The ID is unique only to the particular Perspective Broker instance. N)rerb doRefCountrddisconnectCallbacks)rKrdrbrers r;rHRemoteReference.__init__s!   $&#% r:c[U5(deURRU5 [UR5S:Xa&URR UR 5 gg)z Register a callback to be called if our broker gets disconnected. @param callback: a callable which will be called with one argument, this instance. N)callablerappendlenrbnotifyOnDisconnect _disconnectedrKcallbacks r;r"RemoteReference.notifyOnDisconnect'sY!!!!   ''1 t'' (A - KK * *4+=+= > .r:cURRU5 UR(d&URRUR5 gg)z] Remove a callback that was registered with notifyOnDisconnect. @param callback: a callable N)rremoverbdontNotifyOnDisconnectrrs r;r&RemoteReference.dontNotifyOnDisconnect3s>   ''1'' KK . .t/A/A B(r:cHURH nU"U5 M SUlg)z> Called if we are disconnected and have callbacks registered. N)rrs r;rRemoteReference._disconnected=s#00H TN1#' r:cUR(a/URUR:XdS5eSUR4$g)zS If I am being sent back to where I came from, serialize as a local backreference. z6Can't send references to brokers other than their own.slocal)s unpersistablezReferences cannot be serialized)invokerrbre)rKjelliers r;jellyForRemoteReference.jellyForEs? ?? w. HG H.TYY& &Fr:cpURURRURUSS5 U$)Nr)rHrunserializingPerspective)rK unjellier unjellyLists r; unjellyForRemoteReference.unjellyForQs7    6 6    N   r:c[U[5(dURS5nURR SUR UR XU5$)a Asynchronously invoke a remote method. @type _name: L{str} @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. utf8r:) isinstancebytesrfrbrcrdre)rK_namergrhs r; callRemoteRemoteReference.callRemoteZsM%''LL(E {{'' !!499e2  r:c[X5$)z@ @param key: The key. @return: A L{RemoteMethod} for this key. )rP)rKkeys r; remoteMethodRemoteReference.remoteMethodps D&&r:c[U[5(a:URUR:Xa [URUR5$[URU5$)z= @param other: another L{RemoteReference} to compare me to. )rrrbrrerWs r;rYRemoteReference.__cmp__xsG e_ - -||t{{*499ejj114;;&&r:cUR$)z Hash me. )rer]s r;r^RemoteReference.__hash__syyr:crUR(a&URRUR5 gg)z4 Do distributed reference counting on finalization. N)rrb sendDecRefrer]s r;__del__RemoteReference.__del__s& ?? KK " "499 - r:)rbrrrerdN)r4r5r6r7r8rHrrrrrrrrYr^rr9r2r:r;rrs@$ & ?C( G ,'' .r:rrc<\rSrSrSrS SjrS\4SjrSrSr S r g) Localiz+ (internal) A reference to a local object. Nc*XlX lSUlg)z Initialize. rNrrdrefcount)rKrrds r;rHLocal.__init__s & r:returnc>SUR<SURS3$)Nz )rrr]s r;__repr__Local.__repr__sDKK?% a@@r:cBURS-UlUR$)zQ Increment the reference count. @return: the reference count after incrementing rrr]s r;incref Local.incref  ) }}r:cBURS- UlUR$)zQ Decrement the reference count. @return: the reference count after decrementing rrr]s r;decref Local.decrefrr:rrF) r4r5r6r7r8rHstrrrrr9r2r:r;rrs$A#Ar:rc"\rSrSrSrSrSrSrg)CopyableFailureizq A L{flavors.RemoteCopy} and L{flavors.Copyable} version of L{twisted.python.failure.Failure} for serialization. rcURnURR5nURS5US'SUS'/US'/US'[ UR 5US'[ UR[5(aURUS'O2[R"UR5RS 5US'UR(aUR5US 'U$S US 'U$) zp Collect state related to the exception which occurred, discarding state which cannot reasonably be serialized. _parentsparentsNtbframesstackrLtypera tracebackzTraceback unavailable )r__dict__copypoprrLrrrrqualrfunsafeTracebacks getTraceback)rK_rs r;getStateToCopyCopyableFailure.getStateToCopys LL ""$ 99Z0id hgTZZg dii ' ' IIE&M#LL3::7CE&M  !%!2!2!4E+  ";E+  r:r2N)r4r5r6r7r8rrr9r2r:r;rrs r:rcD^\rSrSrSrU4SjrSSjrSr\r\r Sr U=r $) CopiedFailureial A L{CopiedFailure} is a L{pb.RemoteCopy} of a L{failure.Failure} transferred via PB. @ivar type: The full import path of the exception class which was raised on the remote end. @type type: C{str} @ivar value: A str() representation of the remote value. @type value: L{CopiedFailure} or C{str} @ivar traceback: The remote traceback. @type traceback: C{str} cJ>URS5US'[TU] U5$)Nrr)rsupersetCopyableState)rKr __class__s r;rCopiedFailure.setCopyableStates&!IIi0jw'..r:cUc[RnURn[U[5(dUR S5nUR S5 UR US-UR-5 UR S5 g)NrazTraceback from remote host -- z:  )rlogfilerrrdecodewriterL)rKfileelideFrameworkCodedetail failureTypes r;printTracebackCopiedFailure.printTracebacksi <;;Dii +s++%,,W5K 34 ;% 23 4r:cvUR[URURUR55$)a Throw the original exception into the given generator, preserving traceback information if available. In the case of a L{CopiedFailure} where the exception type is a string, a L{pb.RemoteError} is thrown instead. @return: The next value yielded from the generator. @raise StopIteration: If there are no more values in the generator. @raise RemoteError: The wrapped remote exception. )throwrCrrLr)rKgs r;throwExceptionIntoGenerator)CopiedFailure.throwExceptionIntoGenerators(ww{499djj$..IJJr:r2)Nrdefault) r4r5r6r7r8rrrprintBriefTracebackprintDetailedTracebackr9 __classcell__)rs@r;rrs& / K)+r:rcN[[UR55nXlU$rF)r+r __getstate__r)failrfs r;failure2Copyabler s"_d&7&7&9:A) Hr:cH\rSrSrSrSrSrSrS\4Sjr Sr Sr S r S r S rS rS rSrSrSrSrSrSrSrSrSrSrSrSrSrSrS4SjrSr Sr!Sr"Sr#S5S jr$S6S!jr%S"r&S#r'S$r(S%r)S&r*S'r+S(r,S)r-S*r.S+r/S,r0S-r1S.r2S/r3S0r4S1r5S2r6S3r7g)7Brokeriz I am a broker for objects. Nrc [RRX5 SUl/Ul/Ul/Ul0UlX l/Ul SUl SUl SUl 0Ul 0Ul0Ul0Ul0Ul0UlgNr)rBananarH disconnected disconnectsfailuresconnects localObjectssecurity pageProducerscurrentRequestIDcurrentLocalIDrluidsremotelyCachedObjectsremotelyCachedLUIDslocallyCachedObjectswaitingForAnswers _localCleanup)rKisClientrs r;rHBroker.__init__s t.    !(,% &("#% $&!!#  r:c6[[UR5S- SS5HFnURUnUR5 UR 5(aM9URU MH UR(dUR R 5 gg)z= Called when the consumer attached to me runs out of buffer. rN)rangerr sendNextPage stillPaging transportunregisterProducer)rKpageridxpagers r;resumeProducingBroker.resumeProducing?s c$"4"4592rBH&&x0E    $$&&&&x0 C !! NN - - /"r:cgrFr2r]s r;pauseProducingBroker.pauseProducingL r:cgrFr2r]s r; stopProducingBroker.stopProducingPr.r:cURRU5 [UR5S:XaURR US5 gg)Nrr)rrrr%registerProducer)rKr(s r;registerPageProducerBroker.registerPageProducerTsB !!%( t!! "a ' NN + +D! 4 (r:c[U[5(a_USn[U[5(dURS5nSU-n[ XS5nU(a U"USS6 gUR SU5 g[ S5e)z* Evaluate an expression as it's received. rrzproto_%sNrsdidNotUnderstandzNon-list expression received.)rlistrrr}sendCallr0)rKsexpcommand methodNamers r;expressionReceivedBroker.expressionReceivedYsw dD ! !1gGgs++!..0#g-JTt4FQR! 17; ?@ @r:cXXR:wa[SURSU35eg)z Protocol message: (version version-number) Check to make sure that both ends of the protocol are speaking the same version dialect. @param vnum: The version number. zVersion Incompatibility:  N)versionr0)rKvnums r; proto_versionBroker.proto_versionms0 << ";DLL>4& QR R r:c&URU5 g)zh Utility method to send an expression to the other side of the connection. @param exp: The expression. N) sendEncoded)rKexps r;r8Broker.sendCallzs r:c6[R"SU-5 g)z Respond to stock 'C{didNotUnderstand}' message. Log the command that was not understood and continue. (Note: this will probably be changed to close the connection or raise an exception in the future.) @param command: The command to log. zDidn't understand command: %rN)rr)rKr:s r;proto_didNotUnderstandBroker.proto_didNotUnderstands /'9:r:cURSUR5 URH nU"5 M SUlUR RU5 g![a [R "5 MTf=f)z6 Initialize. Called after Banana negotiation is done. sversionN)r8r@r BaseExceptionrdeferrfactoryclientConnectionMaderKnotifiers r;connectionReadyBroker.connectionReadysc j$,,/ H  &   ))$/!   sAA>=A>cURH nU"5 M SUlg![a [R"5 M9f=frF)rrLrrMrPs r;connectionFailedBroker.connectionFaileds= H  &  !   s$AAc  SUlSUlUR(aPURR5H2nUR [ R "[U555 M4 URR5H8nURnURnURU[XU55 M: UR SSH nU"5 M SUlSUlSUlSUlSUl SUlSUlSUlg![a [R"5 GMf=f![a [R"5 Mf=f![a [R"5 Mf=f)zO The connection was lost. @param reason: message to put in L{failure.Failure} rN)rrrvalueserrbackrFailurerlrLrrMrrrdstoppedObservingrr localSecurityremoteSecurityrrr)rKreasondlobj cacheablerdrQs r;connectionLostBroker.connectionLostsU   ! !++224!IIgoo.>v.FGH5 ..557D I**K **!4Tk!R 8((+H  ,  !%!"%)"#' $(! 5%!JJLL!!   !   s5.D&EE*EEE'&E'*F  F c^[U5(deURRU5 g)zA @param notifier: callback to call when the Broker disconnects. N)rrrrPs r;rBroker.notifyOnDisconnects) !!!! )r:c^[U5(deURRU5 g)zD @param notifier: callback to call if the Broker fails to connect. N)rrrrPs r; notifyOnFailBroker.notifyOnFails' !!!! X&r:c[U5(deURc U"5 gURR U5 g![a [R"5 gf=f)z> @param notifier: callback to call when the Broker connects. N)rrrLrerrrrPs r;notifyOnConnectBroker.notifyOnConnectsW !!!! ==    MM  *!   sAA'&A'c\URRU5 g![a gf=f)zI @param notifier: callback to remove from list of disconnect callbacks. N)rr ValueErrorrPs r;rBroker.dontNotifyOnDisconnects-      # #H -   s  ++c[U[5(aURS5nURR U5nUcgUR $)z Get a local object for a locally unique ID. @return: An object previously stored with L{registerReference} or L{None} if there is no object which corresponds to the given identifier. rN)rrrfrgetr)rKrelobs r;localObjectForIDBroker.localObjectForIDsG dC ;;v&D##D) ; zzr:rcUceUR5nURRU5nUc[UR5[ :aTUR S-UlUR S:a%URR5 [S5e[S5eUR5n[U5URU'X0RU'U$URUR5 U$)z Store a persistent reference to a local object and map its id() to a generated, session-unique ID. @param object: a local object @return: the generated ID rz.Maximum PB reference count exceeded. Goodbye.z$Maximum PB reference count exceeded.) processUniqueIDrrqrrMAX_BROKER_REFSmaxBrokerRefsViolationsr%loseConnectionr@ newLocalIDrr)rKrpuidres r;registerReferenceBroker.registerReference s!!!%%'zz~~d# <4$$%7/3/K/Ka/O,//!3NN113 STTBCC??$D&+FmD  d ##JJt     d # * * , r:c[U[5(aURS5nUce[U5URU'g)z Store a special (string) ID for this object. This is how you specify a 'base' set of objects that the remote protocol can connect to. @param name: An ID. @param object: The object. rN)rrrfrr)rKrTrs r;setNameForLocalBroker.setNameForLocal$s? dC ;;v&D!!!"'-$r:ch[U[5(aURS5n[SXS5$)z Returns an object from the remote name mapping. Note that this does not check the validity of the name, only creates a translucent reference for it. @param name: The name to look up. @return: An object which maps to the name. rNr)rrrfr)rKrTs r; remoteForNameBroker.remoteForName4s. dC ;;v&DtT33r:cUR5nURRU5nUb$U(aURUR 5 U$)z @param instance: The instance to look up. @param incref: Flag to specify whether to increment the reference. @return: An ID that says what this instance is cached as remotely, or L{None} if it's not. )rwrrqrr)rKinstancerr|res r;cachedRemotelyAsBroker.cachedRemotelyAsCsL'')''++D1  6  & &t , 3 3 5 r:c4URUR$)zS @param luid: The LUID to look up. @return: An instance which is cached remotely. )rr)rKres r;remotelyCachedForLUIDBroker.remotelyCachedForLUIDSs ))$/666r:cUR5nUR5n[UR5[:aTUR S-UlUR S:a%UR R5 [S5e[S5eX0RU'[XR5URU'U$)z XXX @return: A new LUID. rrvz*Maximum PB cache count exceeded. Goodbye.z Maximum PB cache count exceeded.) rwr{rrrxryr%rzr@rrserializingPerspective)rKrr|res r; cacheRemotelyBroker.cacheRemotely[s '')  t)) *_ <+/+G+G!+KD (++a/--/KLL:; ;)-  &,1;V;V+W""4( r:c X RU'g)z<(internal) Store a non-filled-out cached instance locally. NrrKcidrs r; cacheLocallyBroker.cacheLocallyps *2!!#&r:c$URUnU$rFrrs r;cachedLocallyAsBroker.cachedLocallyAsws,,S1r:c `[U[R5(a#URURSUUUUS.S9 U$X lX0lX@lXPl[XRSU5SUlSUlSUlSUl$!SUlSUlSUlSUlf=f)z Jelly an object according to the remote security rules for this broker. @param object: The object to jelly. @param perspective: The perspective. @param method: The method. @param args: Arguments. @param kw: Keyword arguments. cU$rFr2)xs r;"Broker.serialize..s!r:)rdrrgrh)callbackKeywordsN) rr Deferred addCallbacksrr jellyMethod jellyArgsjellyKwr-r)rKrrdrrgrhs r;rBroker.serialize{s fenn - -   #.$  " M'2#!  d;*.D '#D !DNDL+/D '#D !DNDLs BB-cdX l[XRSU5SUl$!SUlf=f)z Unjelly an sexp according to the local security rules for this broker. @param sexp: The object to unjelly. @param perspective: The perspective. N)rr.r)rKr9rds r;r|Broker.unserializes0)4% 14d;,0D )DD )s& /cBURS-UlUR$)z# @return: A newly generated LUID. r)rr]s r;r{Broker.newLocalIDs# #11A5"""r:cBURS-UlUR$)z) @return: A newly generated request ID. r)rr]s r; newRequestIDBroker.newRequestIDs# !% 5 5 9$$$r:c SnSnSn SU;aUSnUS SU;aUSnUS SU;aU(dU(aS5eUSn US UR(a [S5eURXRUS9n URXbUS9n UR5n U (aY[R"5n XRU 'U(dU(a'[R"S5 U RXx5 OSn URUS -U UUU U U 5 U $![a, [R "[ R"55s$f=f) Nr pbcallback pberrbackpbanswerz*You can't specify a no-answer requirement.zCalling Stale Broker)rdrz&warning! using deprecated "pbcallback"smessage)rr=rrLr rrrZrrrrrrr8)rKprefixrdobjectIDrrrgrhpbcpbeanswerRequirednetArgsnetKw requestIDrvals r;rcBroker._sendMessagesQ 2 \"C< " [/C;  c X,X X* ^N:   $%;< < 1nnT7nSGNN2wNOE%%' >>#D04 " "9 -c@A!!#+D Z         ) 1::goo/0 0 1s# D3EEc FURURUUUUUU5 grF) _recvMessagersrKrrrrrrrs r; proto_messageBroker.proto_messages-   ! !       r:c FURURUUUUUU5 grF)rrrs r;proto_cachemessageBroker.proto_cachemessages-         r:c:[U[5(dURS5nU"U5nUc [S5eUR XXg5n U(a[[U [ R 5(a*U4n U RURURU U S9 gURX5 gg![an U(au[U [5(d*URRU R5(aURX5 Sn A gUR[U 5U5 Sn A gSn A gSn A f[ aO U(a0["R$"SSS9 [5n URX5 ["R&"5 gf=f)a Received a message-send. Look up message based on object, unserialize the arguments, and invoke it with args, and send an 'answer' or 'error' response. @param findObjMethod: A callable which takes C{objectID} as argument. @param requestID: The requiest ID. @param objectID: The object ID. @param message: The message. @param answerRequired: @param netArgs: Arguments. @param netKw: Keyword arguments. rNzInvalid Object ID) callbackArgs errbackArgs)Peer will receive following PB traceback:T)isError)rrrr@rr rr _sendAnswer_sendFailureOrErrorrrisClassAllowedr _sendErrorrrLrrrj) rK findObjMethodrrrrrrrr netResultrgers r;rBroker._recvMessagesU0'3''nnV,G% ;"8,F~/0044TGSI,i88%D>>AFFc(URSX!5 g)zz (internal) Send an answer to a previously sent message. @param netResult: The answer. @param requestID: The request ID. sanswerNr8)rKrrs r;rBroker._sendAnswerHs i6r:c|URUnURU URURU55 g)z (internal) Got an answer to a previously sent message. Look up the appropriate callback and call it. @param requestID: The request ID. @param netResult: The answer. N)rrr|)rKrrr_s r; proto_answerBroker.proto_answerQs9  " "9 -  " "9 - 4##I./r:cvUR[5cURX5 gURX5 g)z Call L{_sendError} or L{_sendFailure}, depending on whether C{fail} represents an L{Error} subclass or not. @param fail: The failure. @param requestID: The request ID. N)checkr@ _sendFailurerrKrrs r;rBroker._sendFailureOrError^s- ::e  $   d . OOD ,r:c~[R"S5 [R"U5 URX5 g)zZ Log error and then send it. @param fail: The failure. @param requestID: The request ID. rN)rrrjrrs r;rBroker._sendFailureks( ;<   (r:c [U[R5(a[UR[5(d4UR R URR5(a URnO4[U[5(d[XRR5n[U[5(aURRUl URSX RU55 g)zv (internal) Send an error for a previously sent message. @param fail: The failure. @param requestID: The request ID. serrorN)rrrZrLrrrrrrrNrr8rrs r;rBroker._sendErrorvs dGOO , ,$**i00DMM4P4P $$55zzo66'll.K.KL dO , ,$(LL$A$AD ! h >>$+?@r:c|URUnURU URURU55 g)z] (internal) Deal with an error. @param requestID: The request ID. @param fail: The failure. N)rrYr|)rKrrr_s r; proto_errorBroker.proto_errors9  " "9 -  " "9 - $""4()r:c(URSU5 g)zF (internal) Send a DECREF directive. @param objectID: The object ID. sdecrefNrrKrs r;rBroker.sendDecRefs i*r:c^[U[5(aURS5nURUR 5nUS:XadURUR R 5nURU URU URRUS5"5 gg)z (internal) Decrement the reference count of an object. If the reference count is zero, it will free the reference to this object. @param objectID: The object ID. rrcgrFr2r2r:r;r%Broker.proto_decref..sr:N) rrrfrrrrwrrr)rKrrefsr|s r; proto_decrefBroker.proto_decrefs h $ $v.H  *113 19$$X.55EEGD 4 !!(+    " "4 6 8 r:c(URSU5 g)zG (internal) Send a DECACHE directive. @param objectID: The object ID. sdecacheNrrs r; decCacheRefBroker.decCacheRefs j(+r:cURUR5nUS:XaURUnURnURnUR U[ XU55 UR5nURU URU URSU5 gg![ a [R"5 N_f=f)z (internal) Decrement the reference count of a cached object. If the reference count is zero, free the reference, then send an 'uncached' directive. @param objectID: The object ID. rsuncacheN) rrrrdr[rrLrrMrwrr8)rKrrr`rardr|s r; proto_decacheBroker.proto_decaches))(3::< 19--h7D I**K **!4Tk!R ,,.D((.**84 MM*h / !   s B&&CCcJURUnSUlURU g)z` (internal) Tell the client it is now OK to uncache an object. @param objectID: The object ID. N)rrb)rKrrSs r; proto_uncacheBroker.proto_uncaches+''1   % %h /r:)rrrrrrrrrrrr\rrryrr]rrrrrrr)NNNNrF)8r4r5r6r7r8r@usernamerNr,rHr)r,r0r4r<rBr8rIrRrUrrbrrgrkrrsryr}rrrrrrrrr|r{rrcrrrrrrrrrrrrrrr9r2r:r;r r sGHG !N$ L 0  5 A( S ; 0'!R*' +  60 4 7*2( T 1#%'R    @;D7 0 - )A( *+9$,08 0r:r c[5nURU5 UR5n[5nURU5 URU5 UR5nU$)z Respond to a challenge. This is useful for challenge/response authentication. @param challenge: A challenge. @param password: A password. @return: The password hashed twice. )rupdatedigest) challengepasswordmhashedPassworddoubleHashedPasswords r;respondrsS AHHXXXZN AHH^HHY88: r:c [S[[R"SS5555n[ U5R 5nU$)z @return: Some random data. c3P# UHn[R"SS5v M g7f)Ar>N)randomrandint).0rs r; challenge..s Q1PAB''1Ps$&)rr"r randrangerr)craps r;rrs= Qv7G7GB7O1PQ QD t9   D Kr:c~\rSrSrSr\rSrS\4Sjr Sr Sr Sr Sr SS jrS rS rS rS rSrSrSSjrSrg)PBClientFactoryiz 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. Fc<XlX lUR5 g)a  @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_reset)rKrrs r;rHPBClientFactory.__init__ s!1  r:cFURSURS9nXlU$)z@ Build the broker instance, passing the security options to it. Trr)r rrN)rKaddrps r; buildProtocolPBClientFactory.buildProtocols$ MM4$--M @ r:c./UlSUlSUlgrF)rootObjectRequests_broker_rootr]s r;r PBClientFactory._reset"s"$  r:cpURnUR5 UHnURU5 M grF)rr rY)rKr^ deferredsr_s r;_failAllPBClientFactory._failAll's,++  A IIf r:c&URU5 grF)r)rK connectorr^s r;clientConnectionFailed&PBClientFactory.clientConnectionFailed-s fr:cRU(aSUlSUlgURU5 g)z: Reconnecting subclasses should call with reconnecting=1. N)rrr)rKrr^ reconnectings r;clientConnectionLost$PBClientFactory.clientConnectionLost0s#  DLDJ MM& !r:cXlURS5UlURn/UlUHnUR UR5 M g)Nroot)rrrrr)rKrbdsr_s r;rO$PBClientFactory.clientConnectionMade<sF ))&1  $ $"$A JJtzz "r:cUR(a;URR(d [R"UR5$[R "5nUR RU5 U$)zM Get root object of remote PB server. @return: Deferred of the root object. )rrr succeedrrrr)rKr_s r; getRootObjectPBClientFactory.getRootObjectDsO << 9 9==, , NN  &&q)r:cpUR(a%URRR5 gg)z If 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)rr%rzr]s r; disconnectPBClientFactory.disconnectPs& << LL " " 1 1 3 r:cZURSU5RURX45$)Nlogin)r addCallback _cbResponse)rKr'rrclients r;_cbSendUsernamePBClientFactory._cbSendUsername[s+w1==   h  r:cBUupEURS[XB5U5$)Nr)rr)rK challengesrr5r challengers r;r4PBClientFactory._cbResponse`s$ * $$Y 0LfUUr:c&URSU5$)a  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. loginAnonymous)r)rKr'r5s r;_cbLoginAnonymous!PBClientFactory._cbLoginAnonymousds /88r:NcUR5n[R"U5(aURURU5 U$URUR UR URU5 U$)ap 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 providedByr3r>r6rr)rK credentialsr5r_s r;r2PBClientFactory.loginvso       - - MM$00& 9  MM$$k&:&:Kr2r9r2r:r;r r s[H(-    "#  4 V9$r:r c:\rSrSrSrSr\rS\4Sjr Sr Sr Sr g) PBServerFactoryia 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. Fc<[U5UlX lX0lg)a @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)rKr'rrs r;rHPBServerFactory.__init__sDM 0 r:cURSURS9nXlURSURR U55 U$)zD Return a Broker attached to the factory (as the service provider). Frr')r rrNrr' rootObject)rKrprotos r;rPBServerFactory.buildProtocolsC ut}} E  fdii&:&:5&AB r:cgrFr2)rKr s r;rO$PBServerFactory.clientConnectionMader.r:)r'rrN) r4r5r6r7r8rr r r,rHrrOr9r2r:r;rErEs* H.3n!" r:rEc$\rSrSrSrSrSrSrg)IUsernameMD5PasswordiaF 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. cg)a~ 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. Nr2rs r; checkPassword"IUsernameMD5Password.checkPasswordrvr:cg)a 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. Nr2rQs r;checkMD5Password%IUsernameMD5Password.checkMD5Passwordrvr:r2N)r4r5r6r7r8rRrUr9r2r:r;rOrOs     r:rOc$\rSrSrSrSrSrSrg) _PortalRootiz' Root object, used to login to portal. cXlgrFportal)rKr[s r;rH_PortalRoot.__init__s r:c.[URU5$rF)_PortalWrapperr[)rKrbs r;rI_PortalRoot.rootObjectsdkk622r:rZN)r4r5r6r7r8rHrIr9r2r:r;rXrXs3r:rXc\rSrSrSrSrSrg)_JellyableAvatarMixiniz_ Helper class for code which deals with avatars which PB must be capable of sending to a peer. c^Uup#m[R"U5(d [US5nUR5nT/mU4SjnXPRR U'URR U5 U$)z Ensure that the avatar to be returned to the client is jellyable and set up disconnection notification to call the realm's logout object. rdc4>T(dgTSnTS U"5 gr r2)fnlogouts r; maybeLogout3_JellyableAvatarMixin._cbLogin..maybeLogoutsBq Dr:)r)rArrwrbrr)rKresult interfaceavatarr|rfres @r;_cbLogin_JellyableAvatarMixin._cbLoginss '-#F$$V,,$V];F%%'  +6 !!$' &&{3 r:r2N)r4r5r6r7r8rkr9r2r:r;raras  r:rac*\rSrSrSrSrSrSrSrg)r^iz5 Root Referenceable object, used to login to portal. cXlX lgrF)r[rb)rKr[rbs r;rH_PortalWrapper.__init__!s   r:c\[5nU[URURX54$)zC Start of username/password login. @param username: The username. )r_PortalAuthChallengerr[rb)rKrcs r; remote_login_PortalWrapper.remote_login%s( K' T[[(NNNr:cURR[5U[5nUR UR 5 U$)a 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. )r[r2rror3rk)rKmindr_s r;remote_loginAnonymous$_PortalWrapper.remote_loginAnonymous.s3 KK  ik4 > dmm$r:)rbr[N) r4r5r6r7r8rHrsrwr9r2r:r;r^r^sO r:r^c0\rSrSrSrSrSrSrSrSr g) rqi>z- Called with response to password challenge. c4XlX lX0lX@lgrF)r[rbrr)rKr[rbrrs r;rH_PortalAuthChallenger.__init__Ds   "r:cXlURRX[5nUR UR 5 U$rF)responser[r2ror3rk)rKr}rvr_s r;remote_respond$_PortalAuthChallenger.remote_respondJs2 KK  d, 7 dmm$r:cRUR[U5R55$)zo L{IUsernameHashedPassword} @param password: The password. @return: L{_PortalAuthChallenger.checkMD5Password} )rUrr)rKrs r;rR#_PortalAuthChallenger.checkPasswordPs"$$S]%9%9%;<s#  = (r:rq)(rrrrrr!r rrrrrrr"r'r&r(r#r%r$rxportnor0r=r@rlrProryrrrrrr rrr rErOr)\r8rhashlibrzope.interfacerrtwisted.cred.credentialsrrrr twisted.cred.portalr twisted.internetr r twisted.persistedr twisted.pythonrrrtwisted.python.compatrrtwisted.python.componentsrtwisted.spreadrtwisted.spread.flavorsrrrrrrrrrrrr r!r"r#r$r%r&r'r(twisted.spread.interfacesr)r*twisted.spread.jellyr+r,r-r.rxrrGr0r=r@rCrPrlroryr EphemeralrrrZrrrrr rr ClientFactoryr  ServerFactoryrErOrXrar^rq__all__r2r:r;rsH 41 ',$1015!,?MM I I/)/4     @ y & 9& R \%?%?%?PVmV \ E.lF$4$4E. E.Px1  HgooxB,,J,,^ 6 O 0V]]O 0d (Lh,,L^- h,,- `' <' T W 3 3 3 VW-  F]$9D $&:;&(M+@&(<&(R* r: