o i%@sdZGdddeZGdddeZGdddeZGdddeZGd d d eZGd d d eZGd ddeZGdddeZ GdddeZ GdddeZ GdddeZ GdddeZ GdddeZdS)) Publication SubscriptionHandler RegistrationEndpointPublishRequestSubscribeRequestUnsubscribeRequest CallRequestInvocationRequestRegisterRequestUnregisterRequestc@s$eZdZdZdZddZddZdS)rzw Object representing a publication (feedback from publishing an event when doing an acknowledged publish). id was_encryptedcC||_||_dS)z :param publication_id: The publication ID of the published event. :type publication_id: int :param was_encrypted: Flag indicating whether the app payload was encrypted. :type was_encrypted: bool Nr )selfZpublication_idrr[C:\Users\psant\Downloads\PAF backend\school\venv\Lib\site-packages\autobahn/wamp/request.py__init__4 zPublication.__init__cCd|j|jS)Nz&Publication(id={0}, was_encrypted={1}))formatrrrrrr__str__@zPublication.__str__N)__name__ __module__ __qualname____doc__ __slots__rrrrrrr,s  rc@,eZdZdZdZddZddZddZd S) rz5 Object representing a handler subscription. rtopicactivesessionhandlercCs"||_||_d|_||_||_dS)a :param subscription_id: The subscription ID. :type subscription_id: int :param topic: The subscription URI or URI pattern. :type topic: str :param session: The ApplicationSession this subscription is living on. :type session: instance of ApplicationSession :param handler: The user event callback. :type handler: callable TNr!)rsubscription_idr"r$r%rrrrK  zSubscription.__init__cC|jr |j|Std)z0 Unsubscribe this subscription. zsubscription no longer activeN)r#r$Z _unsubscribe Exceptionrrrr unsubscribe`s zSubscription.unsubscribecCr)Nz#Subscription(id={0}, is_active={1}))rrr#rrrrrirzSubscription.__str__N)rrrrrrr*rrrrrrDs  rc@eZdZdZdZdddZdS)rzJ Object representing an event handler attached to a subscription. fnobj details_argNcC||_||_||_dS)aS :param fn: The event handler function to be called. :type fn: callable :param obj: The (optional) object upon which to call the function. :type obj: obj or None :param details_arg: The keyword argument under which event details should be provided. :type details_arg: str or None Nr,rr-r.r/rrrrt  zHandler.__init__NNrrrrrrrrrrrmrc@r ) rz- Object representing a registration. rr#r$ procedureendpointcCs"||_d|_||_||_||_dS)a] :param id: The registration ID. :type id: int :param active: Flag indicating whether this registration is active. :type active: bool :param procedure: The procedure URI or URI pattern. :type procedure: callable :param endpoint: The user callback. :type endpoint: callable TNr6)rr$registration_idr7r8rrrrr'zRegistration.__init__cCr() zregistration no longer activeN)r#r$ _unregisterr)rrrr unregisters zRegistration.unregistercCsd|j|j|jS)Nz4Registration(id={0}, is_active={1}, procedure="{2}"))rrr#r7rrrrrszRegistration.__str__N)rrrrrrr<rrrrrrs  rc@r+)rzO Object representing an procedure endpoint attached to a registration. r,NcCr0)aN :param fn: The endpoint procedure to be called. :type fn: callable :param obj: The (optional) object upon which to call the function. :type obj: obj or None :param details_arg: The keyword argument under which call details should be provided. :type details_arg: str or None Nr,r1rrrrr2zEndpoint.__init__r3r4rrrrrr5rc@eZdZdZdZddZdS)Requestz Object representing an outstanding request, such as for subscribe/unsubscribe, register/unregister or call/publish.  request_idon_replycCr)z :param request_id: The WAMP request ID. :type request_id: int :param on_reply: The Deferred/Future to be fired when the request returns. :type on_reply: Deferred/Future Nr?)rr@rArrrrrzRequest.__init__Nr4rrrrr>s r>c@r=)rzX Object representing an outstanding request to publish (acknowledged) an event. rcCt|||||_dS)aL :param request_id: The WAMP request ID. :type request_id: int :param on_reply: The Deferred/Future to be fired when the request returns. :type on_reply: Deferred/Future :param was_encrypted: Flag indicating whether the app payload was encrypted. :type was_encrypted: bool N)r>rr)rr@rArrrrrs zPublishRequest.__init__Nr4rrrrr rc@r=)rzM Object representing an outstanding request to subscribe to a topic. )r%r"cCt|||||_||_dS)a :param request_id: The WAMP request ID. :type request_id: int :param topic: The topic URI being subscribed to. :type topic: unicode :param on_reply: The Deferred/Future to be fired when the request returns. :type on_reply: Deferred/Future :param handler: WAMP call options that are in use for this call. :type handler: callable N)r>rr"r%)rr@r"rAr%rrrrs zSubscribeRequest.__init__Nr4rrrrrrCrc@r=)rzS Object representing an outstanding request to unsubscribe a subscription. )r&cCrBr:N)r>rr&)rr@rAr&rrrr zUnsubscribeRequest.__init__Nr4rrrrr rCrc@r=)r zI Object representing an outstanding request to call a procedure. )r7optionscCrD)a: :param request_id: The WAMP request ID. :type request_id: int :param on_reply: The Deferred/Future to be fired when the request returns. :type on_reply: Deferred/Future :param options: WAMP call options that are in use for this call. :type options: dict N)r>rr7rG)rr@r7rArGrrrr!s  zCallRequest.__init__Nr4rrrrr rCr c@seZdZdZdS)r zK Object representing an outstanding request to invoke an endpoint. N)rrrrrrrrr 2sr c@r=)r zM Object representing an outstanding request to register a procedure. )r7r8cCst|||||_||_dSrE)r>rr7r8)rr@rAr7r8rrrr?s zRegisterRequest.__init__Nr4rrrrr 8rCr c@r=)r zR Object representing an outstanding request to unregister a registration. )r9cCrBrE)r>rr9)rr@rAr9rrrrNrFzUnregisterRequest.__init__Nr4rrrrr GrCr N)__all__objectrrrrrr>rrrr r r r rrrrs)(