o >h%@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 )selfpublication_idrru/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/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 active)r$r% _unsubscribe Exceptionrrrr unsubscribe`s zSubscription.unsubscribecCr)Nz#Subscription(id={0}, is_active={1}))rrr$rrrrrirzSubscription.__str__N)rrrrr rr,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/r0r1rrrrt  zHandler.__init__NNrrrrr rrrrrrmrc@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 TNr8)rr%registration_idr9r:rrrrr(zRegistration.__init__cCr)) zregistration no longer active)r$r% _unregisterr+rrrr unregisters zRegistration.unregistercCsd|j|j|jS)Nz4Registration(id={0}, is_active={1}, procedure="{2}"))rrr$r9rrrrrszRegistration.__str__N)rrrrr rr>rrrrrrs  rc@r-)rzO Object representing an procedure endpoint attached to a registration. r.NcCr2)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.r3rrrrr4zEndpoint.__init__r5r6rrrrrr7rc@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 NrA)rrBrCrrrrrzRequest.__init__Nr6rrrrr@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)rrBrCrrrrrs zPublishRequest.__init__Nr6rrrrr 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&)rrBr#rCr&rrrrs zSubscribeRequest.__init__Nr6rrrrrrErc@r?)rzS Object representing an outstanding request to unsubscribe a subscription. )r'cCrDr<N)r@rr')rrBrCr'rrrr zUnsubscribeRequest.__init__Nr6rrrrr rErc@r?)r zI Object representing an outstanding request to call a procedure. )r9optionscCrF)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@rr9rI)rrBr9rCrIrrrr!s  zCallRequest.__init__Nr6rrrrr rEr 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. )r9r:cCst|||||_||_dSrG)r@rr9r:)rrBrCr9r:rrrr?s zRegisterRequest.__init__Nr6rrrrr 8rEr c@r?)r zR Object representing an outstanding request to unregister a registration. )r;cCrDrG)r@rr;)rrBrCr;rrrrNrHzUnregisterRequest.__init__Nr6rrrrr GrEr N)__all__objectrrrrrr@rrrr r r r rrrrs)(