U uc%@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_encryptedcCs||_||_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_idrrV/var/www/html/HOTSTAR/school/venv/lib/python3.8/site-packages/autobahn/wamp/request.py__init__4s zPublication.__init__cCsd|j|jS)Nz&Publication(id={0}, was_encrypted={1}))formatrrrrrr__str__@szPublication.__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_idrrr rrrrKs zSubscription.__init__cCs|jr|j|StddS)z0 Unsubscribe this subscription. zsubscription no longer activeN)rrZ _unsubscribe Exceptionrrrr unsubscribe`s zSubscription.unsubscribecCsd|j|jS)Nz#Subscription(id={0}, is_active={1}))rrrrrrrriszSubscription.__str__N)rrrrrrr#rrrrrrDs  rc@seZdZdZdZdddZdS)rzJ Object representing an event handler attached to a subscription. fnobj details_argNcCs||_||_||_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'rrrrts zHandler.__init__)NNrrrrrrrrrrrmsrc@s,eZdZdZdZddZddZddZd S) rz- Object representing a registration. rrr 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*)rrregistration_idr+r,rrrrs zRegistration.__init__cCs|jr|j|StddS) zregistration no longer activeN)rrZ _unregisterr"rrrr unregisters zRegistration.unregistercCsd|j|j|jS)Nz4Registration(id={0}, is_active={1}, procedure="{2}"))rrrr+rrrrrszRegistration.__str__N)rrrrrrr/rrrrrrs rc@seZdZdZdZdddZdS)rzO Object representing an procedure endpoint attached to a registration. r$NcCs||_||_||_dS)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$r(rrrrs zEndpoint.__init__)NNr)rrrrrsrc@seZdZdZdZddZdS)Requestz Object representing an outstanding request, such as for subscribe/unsubscribe, register/unregister or call/publish.  request_idon_replycCs||_||_dS)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 Nr1)rr2r3rrrrs zRequest.__init__Nr)rrrrr0sr0c@seZdZdZdZddZdS)rzX Object representing an outstanding request to publish (acknowledged) an event. rcCst|||||_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)r0rr)rr2r3rrrrrs zPublishRequest.__init__Nr)rrrrrsrc@seZdZdZdZddZdS)rzM Object representing an outstanding request to subscribe to a topic. )r rcCst|||||_||_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)r0rrr )rr2rr3r rrrrszSubscribeRequest.__init__Nr)rrrrrsrc@seZdZdZdZddZdS)rzS Object representing an outstanding request to unsubscribe a subscription. )r!cCst|||||_dSr.N)r0rr!)rr2r3r!rrrrszUnsubscribeRequest.__init__Nr)rrrrr src@seZdZdZdZddZdS)r zI Object representing an outstanding request to call a procedure. )r+optionscCst|||||_||_dS)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)r0rr+r5)rr2r+r3r5rrrr!s zCallRequest.__init__Nr)rrrrr sr c@seZdZdZdS)r zK Object representing an outstanding request to invoke an endpoint. N)rrrrrrrrr 2sr c@seZdZdZdZddZdS)r zM Object representing an outstanding request to register a procedure. )r+r,cCst|||||_||_dSr4)r0rr+r,)rr2r3r+r,rrrr?szRegisterRequest.__init__Nr)rrrrr 8sr c@seZdZdZdZddZdS)r zR Object representing an outstanding request to unregister a registration. )r-cCst|||||_dSr4)r0rr-)rr2r3r-rrrrNszUnregisterRequest.__init__Nr)rrrrr Gsr N)__all__objectrrrrrr0rrrr r r r rrrrs)(