o @BiW%@sddlmZdZGdddeZGdddeZGdddeZGd d d eZGd d d eZGd ddeZ Gddde Z Gddde Z Gddde Z Gddde Z Gddde ZGddde ZGddde ZdS))absolute_import) Publication SubscriptionHandler RegistrationEndpointPublishRequestSubscribeRequestUnsubscribeRequest CallRequestInvocationRequestRegisterRequestUnregisterRequestc@$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)selfpublication_idrrU/var/www/html/Trade-python/venv/lib/python3.10/site-packages/autobahn/wamp/request.py__init__6 zPublication.__init__cCd|j|jS)Nz&Publication(id={0}, was_encrypted={1}))formatrrrrrr__str__BzPublication.__str__N)__name__ __module__ __qualname____doc__ __slots__rrrrrrr.s  rc@s,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(rrrrM  zSubscription.__init__cC|jr |j|Std)z0 Unsubscribe this subscription. zsubscription no longer active)r&r' _unsubscribe Exceptionrrrr unsubscribebs zSubscription.unsubscribecCr)Nz#Subscription(id={0}, is_active={1}))rrr&rrrrrkrzSubscription.__str__N)rr r!r"r#rr.rrrrrrFs  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 Nr0rr1r2r3rrrrv  zHandler.__init__NNrr r!r"r#rrrrrrorc@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 TNr:)rr'registration_idr;r<rrrrr*zRegistration.__init__cCr+) zregistration no longer active)r&r' _unregisterr-rrrr unregisters zRegistration.unregisterN)rr r!r"r#rr@rrrrrs  rc@r/)rzO Object representing an procedure endpoint attached to a registration. r0NcCr4)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 Nr0r5rrrrr6zEndpoint.__init__r7r8rrrrrr9rc@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 NrC)rrDrErrrrrzRequest.__init__Nr8rrrrrBs rBc@rA)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)rBrr)rrDrErrrrrs zPublishRequest.__init__Nr8rrrrr rc@rA)r zM 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)rBrr%r()rrDr%rEr(rrrrs zSubscribeRequest.__init__Nr8rrrrr rGr c@rA)r zS Object representing an outstanding request to unsubscribe a subscription. )r)cCrFr>N)rBrr))rrDrEr)rrrr zUnsubscribeRequest.__init__Nr8rrrrr rGr c@rA)r zI Object representing an outstanding request to call a procedure. )r;optionscCrH)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)rBrr;rK)rrDr;rErKrrrr s  zCallRequest.__init__Nr8rrrrr rGr c@seZdZdZdS)r zK Object representing an outstanding request to invoke an endpoint. N)rr r!r"rrrrr 1sr c@rA)r zM Object representing an outstanding request to register a procedure. )r;r<cCst|||||_||_dSrI)rBrr;r<)rrDrEr;r<rrrr>s zRegisterRequest.__init__Nr8rrrrr 7rGr c@rA)rzR Object representing an outstanding request to unregister a registration. )r=cCrFrI)rBrr=)rrDrEr=rrrrMrJzUnregisterRequest.__init__Nr8rrrrrFrGrN) __future__r__all__objectrrrrrrBrr r r r r rrrrrs )%