8'hJ ddlmZddlZddlZddlZddlZddlmZmZddl m Z  ddl Z ddl Z ddl mZdZdZej$d Zej$d Zej$d Zej$d Zej$d Zej$dZej$dZdZdZdZeeegZgdZdZdZ dZ!dZ"ede de!de"diZ#e#jIDcic]\}}|| c}}Z%dZ&dZ'dZ(dZ)dZ*dZ+dZ,e&de'de(de)de*de+de,d iZ-e-jIDcic]\}}|| c}}Z.d!Z/d"Z0d\d#Z1d]d$Z2d^d%Z3d^d&Z4d^d'Z5Gd(d)e6Z7Gd*d+e7Z8Gd,d-e7Z9Gd.d/e7Z:Gd0d1e7Z;Gd2d3e7Z<Gd4d5e7Z=Gd6d7e7Z>Gd8d9e7Z?Gd:d;e7Z@Gd<d=e7ZAGd>d?e7ZBGd@dAe7ZCGdBdCe7ZDGdDdEe7ZEGdFdGe7ZFGdHdIe7ZGGdJdKe7ZHGdLdMe7ZIGdNdOe7ZJGdPdQe7ZKGdRdSe7ZLGdTdUe7ZMGdVdWe7ZNGdXdYe7ZOGdZd[e7ZPy#e$rdZYJwxYwcc}}wcc}}w)_)absolute_importN) ProtocolErrorInvalidUriError)ROLE_NAME_TO_CLASS) message_fbsTF) MessageHelloWelcomeAbort Challenge AuthenticateGoodbyeErrorPublish Published Subscribe Subscribed Unsubscribe UnsubscribedEventCallCancelResultRegister Registered Unregister Unregistered Invocation InterruptYieldcheck_or_raise_uricheck_or_raise_idis_valid_enc_algois_valid_enc_serializerPAYLOAD_ENC_CRYPTO_BOXPAYLOAD_ENC_MQTT PAYLOAD_ENC_STANDARD_IDENTIFIERSz#^(([0-9a-z_]+\.)|\.)*([0-9a-z_]+)?$z!^(([^\s\.#]+\.)|\.)*([^\s\.#]+)?$z^([0-9a-z_]+\.)*([0-9a-z_]+)$z^([^\s\.#]+\.)*([^\s\.#]+)$z^([0-9a-z_]+\.)*([0-9a-z_]*)$z^([^\s\.#]+\.)*([^\s\.#]*)$z^x_([a-z][0-9a-z_]+)?$ cryptoboxmqttxbr)jsonmsgpackcborubjson flatbuffersnullr+r,r-r.opaquer/c|t|tjk(xr|tvxstj |S)a( For WAMP payload transparency mode, check if the provided ``enc_algo`` identifier in the WAMP message is a valid one. Currently defined standard identifiers are: * ``"cryptobox"`` * ``"mqtt"`` * ``"xbr"`` Users can select arbitrary identifiers too, but these MUST start with ``u"x_"``. :param enc_algo: The payload transparency algorithm identifier to check. :type enc_algo: str :returns: Returns ``True`` if and only if the payload transparency algorithm identifier is valid. :rtype: bool )typesix text_typer'_CUSTOM_ATTRIBUTEmatch)enc_algos Q/var/www/html/trade_iq/venv/lib/python3.12/site-packages/autobahn/wamp/message.pyr#r#sE( >S]] * C<\0\1B`q`w`wyAaBCc|t|tjk(xr|tvxstj |S)an For WAMP payload transparency mode, check if the provided ``enc_serializer`` identifier in the WAMP message is a valid one. Currently, the only standard defined identifier are * ``"json"`` * ``"msgpack"`` * ``"cbor"`` * ``"ubjson"`` * ``"flatbuffers"`` Users can select arbitrary identifiers too, but these MUST start with ``u"x_"``. :param enc_serializer: The payload transparency serializer identifier to check. :type enc_serializer: str :returns: Returns ``True`` if and only if the payload transparency serializer identifier is valid. :rtype: bool )r9r:r; PAYLOAD_ENC_STANDARD_SERIALIZERSr<r=)enc_serializers r?r$r$sN,  3== 0 UnHh6h7Tl}mDmDESmTUr@ct|tjk(r|}nWt|tjk(r%t j |j d}n|d}ndj|}t||kDr|d|dzS|S)Nascii-z{}z..) r9r:r; binary_typebinasciib2a_hexdecodeformatlen)datamax_lenss r?b2arPs| DzS]]"  ds &   T " ) )' 2   LL  1v'{U""r@c ||rytdj|t|tjk7r(||s$tdj|t||r|rt }n(|rt }nt}n|rt}n|rt}nt}|j|s*tdj|||j|||||S)an Check a value for being a valid WAMP URI. If the value is not a valid WAMP URI is invalid, raises :class:`autobahn.wamp.exception.ProtocolError`. Otherwise return the value. :param value: The value to check. :type value: str or None :param message: Prefix for message in exception raised when value is invalid. :type message: str :param strict: If ``True``, do a strict check on the URI (the WAMP spec SHOULD behavior). :type strict: bool :param allow_empty_components: If ``True``, allow empty URI components (for pattern based subscriptions and registrations). :type allow_empty_components: bool :param allow_none: If ``True``, allow ``None`` for URIs. :type allow_none: bool :returns: The URI value (if valid). :rtype: str :raises: instance of :class:`autobahn.wamp.exception.ProtocolError` Nz{0}: URI cannot be nullz{0}: invalid type {1} for URIz{0}: invalid value "{1}" for URI (did not match pattern "{2}" with options strict={3}, allow_empty_components={4}, allow_last_empty={5}, allow_none={6})) rrKr9r:r;_URI_PAT_STRICT_LAST_EMPTY_URI_PAT_STRICT_EMPTY_URI_PAT_STRICT_NON_EMPTY_URI_PAT_LOOSE_LAST_EMPTY_URI_PAT_LOOSE_EMPTY_URI_PAT_LOOSE_NON_EMPTYr=pattern)valuemessagestrictallow_empty_componentsallow_last_empty allow_nonepats r?r!r!s8 }  !"<"C"CG"LM M E{cmm# *!"B"I"I'SWX]S^"_` ` ,C #'C+C +C #&C*C 99U zAABIKPRUR]R]_eg}OQ[\] ] r@ct|tjvr$tdj |t||dks|dkDrtdj |||S)a Check a value for being a valid WAMP ID. If the value is not a valid WAMP ID, raises :class:`autobahn.wamp.exception.ProtocolError`. Otherwise return the value. :param value: The value to check. :type value: int :param message: Prefix for message in exception raised when value is invalid. :type message: str :returns: The ID value (if valid). :rtype: int :raises: instance of :class:`autobahn.wamp.exception.ProtocolError` z{0}: invalid type {1} for IDrlz{0}: invalid value {1} for ID)r9r: integer_typesrrK)rYrZs r?r"r"sc$ E{#+++;BB7DQVKXYY qyE,,<CCGUSTT Lr@c t|tk7r$tdj|t||j D]A}t |t jrtdj|t|||S)a Check a value for being a valid WAMP extra dictionary. If the value is not a valid WAMP extra dictionary, raises :class:`autobahn.wamp.exception.ProtocolError`. Otherwise return the value. :param value: The value to check. :type value: dict :param message: Prefix for message in exception raised when value is invalid. :type message: str :returns: The extra dictionary (if valid). :rtype: dict :raises: instance of :class:`autobahn.wamp.exception.ProtocolError` z${0}: invalid type {1} for WAMP extraz3{0}: invalid type {1} for key in WAMP extra ('{2}')r9dictrrKkeys isinstancer:r;)rYrZks r?check_or_raise_extrarh/s$ E{dCJJ7TXY^T_`aa ZZ\t!S]]+ V ] ]^egklmgnpq rs st Lr@c  |t|tk7r$tdj|t||j D]A}t |t jrtdj|t|||Sy)a* Check a value for being a valid WAMP kwargs dictionary. If the value is not a valid WAMP kwargs dictionary, raises :class:`autobahn.wamp.exception.ProtocolError`. Otherwise return the kwargs. The WAMP spec requires that the keys in kwargs are proper strings (unicode), not bytes. Note that the WAMP spec says nothing about keys in application payload. Key in the latter can be potentially of other type (if that is really wanted). :param kwargs: The keyword arguments to check. :type kwargs: dict :param message: Prefix for message in exception raised when value is invalid. :type message: str :returns: The kwargs dictionary (if valid). :rtype: dict :raises: instance of :class:`autobahn.wamp.exception.ProtocolError` Nz%{0}: invalid type {1} for WAMP kwargsz4{0}: invalid type {1} for key in WAMP kwargs ('{2}')rc)kwargsrZrgs r?_validate_kwargsrkIs6 <4  H O OPWY]^dYe fg g yAa/#$[$b$bcjlpqrlsuv$wxx y r@c6eZdZdZdZ dZddZedZejdZedZ e jdZ ed Z e jd Z ed Z e jd Z d Z dZedZdZedZdZdZdZy)rzo WAMP message base class. .. note:: This is not supposed to be instantiated, but subclassed only. N _from_fbs _serialized_correlation_id_correlation_uri_correlation_is_anchor_correlation_is_lastcX||_i|_d|_d|_d|_d|_yNrm)selffrom_fbss r?__init__zMessage.__init__s5! $ $&*#$(!r@c|jSru)rprvs r?correlation_idzMessage.correlation_ids###r@cR|t|tjk(sJ||_yru)r9r:r;rprvrYs r?r{zMessage.correlation_ids$}U s}} <=<$r@c|jSru)rqrzs r?correlation_urizMessage.correlation_uris$$$r@cR|t|tjk(sJ||_yru)r9r:r;rqr}s r?rzMessage.correlation_uris$}U s}} <=< %r@c|jSru)rrrzs r?correlation_is_anchorzMessage.correlation_is_anchors***r@c>|t|tk(sJ||_yru)r9boolrrr}s r?rzMessage.correlation_is_anchors }U t 343&+#r@c|jSru)rsrzs r?correlation_is_lastzMessage.correlation_is_lasts(((r@c>|t|tk(sJ||_yru)r9rrsr}s r?rzMessage.correlation_is_lasts }U t 343$)!r@ct||jsy|jD]4}|dvs|jdrt ||t ||k(r4yy)z Compare this message to another message for equality. :param other: The other message to compare with. :type other: obj :returns: ``True`` iff the messages are equal. :rtype: bool F)rorprqrrrs_T)rf __class__ __slots__ startswithgetattr)rvotherrgs r?__eq__zMessage.__eq__sa%0 !A11:;c9JtQ'75!+<<  !r@c&|j| S)z Compare this message to another message for inequality. :param other: The other message to compare with. :type other: obj :returns: ``True`` iff the messages are not equal. :rtype: bool rrvrs r?__ne__zMessage.__ne__s;;u%%%r@ct)a Factory method that parses a unserialized raw message (as returned byte :func:`autobahn.interfaces.ISerializer.unserialize`) into an instance of this class. :returns: An instance of this class. :rtype: obj NotImplementedError)wmsgs r?parsez Message.parses "##r@ctrurrzs r?marshalzMessage.marshal !##r@ctrurbufs r?castz Message.casts !##r@ctrur)rvbuilders r?buildz Message.buildrr@ci|_y)z1 Resets the serialization cache. N)rorzs r?uncachezMessage.uncaches r@cr||jvr|jdk(r`tjd}|j |}|j ||j }t||j|<n,|j|j|j|<|j|S)a Serialize this object into a wire level bytes representation and cache the resulting bytes. If the cache already contains an entry for the given serializer, return the cached representation directly. :param serializer: The wire level serializer to use. :type serializer: An instance that implements :class:`autobahn.interfaces.ISerializer` :returns: The serialized bytes. :rtype: bytes r/i) roNAMEr/BuilderrFinishOutputbytes serializer)rv serializerrobjrs r?rzMessage.serializes T-- -.0%--d3jj)s#nn&/4Sz  ,0:/C/CDLLN/S  , ++r@ru)__name__ __module__ __qualname____doc__ MESSAGE_TYPErrxpropertyr{setterrrrrr staticmethodrrrrrrr@r?rrms LI )$$%%%%&&++!!,",))* *. & $ $$$$$ ,r@rcLeZdZdZdZ dZ d dZedZdZ dZ y) r zU A WAMP ``HELLO`` message. Format: ``[HELLO, Realm|uri, Details|dict]`` r0) realmroles authmethodsauthidauthrole authextra resumableresume_session resume_tokenNc p|t|tjsJt|tk(sJt |dkDsJ|D]>} | dvsJt|| t jjj| r>J|r9t|tk(sJ|D] } t| tjk(r J|t|tjk(sJ|t|tjk(sJ|t|tk(sJ|t|tk(sJ|t|tk(sJ| t| tjk(sJtj|||_||_||_||_||_||_||_||_| |_y)a :param realm: The URI of the WAMP realm to join. :type realm: str :param roles: The WAMP session roles and features to announce. :type roles: dict of :class:`autobahn.wamp.role.RoleFeatures` :param authmethods: The authentication methods to announce. :type authmethods: list of str or None :param authid: The authentication ID to announce. :type authid: str or None :param authrole: The authentication role to announce. :type authrole: str or None :param authextra: Application-specific "extra data" to be forwarded to the client. :type authextra: dict or None :param resumable: Whether the client wants this to be a session that can be later resumed. :type resumable: bool or None :param resume_session: The session the client would like to resume. :type resume_session: int or None :param resume_token: The secure authorisation token to resume the session. :type resume_token: str or None Nr subscriber publishercallercallee)rfr:r;r9rdrLautobahnwamprolerlistrintrrxrrrrrrrrr) rvrrrrrrrrrr authmethods r?rxzHello.__init__+sN} 5#-- @A@E{d"#"5zA~~ YDNN ONeDk8==+=+=+P+PQU+VW XW Y  $, -,) : J'3==898 :~f!>?>4>S]]#BCB DOt$;<; DOt$;<;%n)=)DED#tL'9S]]'JKJ  &   "",(r@c  t|dkDr|dtjk(sJt|dk7r#tdj t|t |ddd}t |dd }i}d |vr td t |d d }t|dk(r td |D]}|dvrtdj |t|}t ||dj |}d|vr*t |ddj ||d$i|d}n|}|||<d} d|vr|d} t| tk7r#tdj t| | D]A} t| tjk7s tdj t| | } d} d|vrF|d} t| tjk7r#tdj t| | } d}d|vrF|d}t|tjk7r#tdj t||}d}d|vr<|d}t|tk7r#tdj t||}d}d|vr:|d}t|tk7r#tdj t|d}d|vr:|d}t|tk7r#td j t|d}d!|vrD|d!}t|tjk7r0td"j t||r td#t||| | ||||| }|S)% Verifies and parses an unserialized raw message into an actual WAMP message instance. :param wmsg: The unserialized raw message. :type wmsg: list :returns: An instance of this class. rr2z$invalid message length {0} for HELLOr0z'realm' in HELLOT)r^r1z'details' in HELLOrz5missing mandatory roles attribute in options in HELLOz'roles' in 'details' in HELLOz#empty 'roles' in 'details' in HELLOrz3invalid role '{0}' in 'roles' in 'details' in HELLOz+role '{0}' in 'roles' in 'details' in HELLOfeaturesz9'features' in role '{0}' in 'roles' in 'details' in HELLONrz2invalid type {0} for 'authmethods' detail in HELLOz:invalid type {0} for item in 'authmethods' detail in HELLOrz-invalid type {0} for 'authid' detail in HELLOrz/invalid type {0} for 'authrole' detail in HELLOrz0invalid type {0} for 'authextra' detail in HELLOrz0invalid type {0} for 'resumable' detail in HELLOresume-sessionz5invalid type {0} for 'resume-session' detail in HELLO resume-tokenz3invalid type {0} for 'resume-token' detail in HELLOzDresume-token must be provided if resume-session is provided in HELLOr)rLr rrrKr!rhrr9rr:r;rdrr)rrdetailsr details_rolesrrole_cls details_role role_featuresrdetails_authmethods auth_methodrdetails_authidrdetails_authrolerdetails_authextrarrrrs r?rz Hello.parsens4y1}aE,>,>!>?> t9> F M McRVi XY Y"47,?DQ&tAw0EF 7 " XY Y,WX->@`a }  " FG G! (DNN#$Y$`$`ae$fgg)$/H/ d0CErEyEyz~EALl*$\+%>@{ACACDHAIJ ( E< +D E !) 'E$K! ($ W $")."9 '(D0#$X$_$_`dex`y$z{{2 @  $ 5'(d(k(klpq|l}(~ @.K  $Y/NN#s}}4#$S$Z$Z[_`n[o$pqq#F ' !&{3 $%6#$U$\$\]abr]s$tuu'H 7 " ' 5 %&$.#$V$]$]^bct^u$vww)I 7 " -II$&#$V$]$]^bcl^m$noo  '$%67NN#s*#$[$b$bcghvcw$xyy g %"?3LL!S]]2#$Y$`$`aefras$tuu#$jkkE5+vxIWegst r@cFdii}|jjD]}i|d|j<|jD]}|j dr|dk7st ||(d|d|jvrdii|d|j<t |||d|jdt j|<|j|j|d<|j|j|d<|j|j|d<|j|j|d<|j|j|d <|j|j|d <|j|j|d <tj |j"|gS) Marshal this object into a raw message for subsequent serialization to bytes. :returns: The serialized raw message. :rtype: list rrROLErrrrrrrr)rvaluesr__dict__rrr:urrrrrrrr rrrvrrfeatures r?rz Hello.marshalsR.JJ%%' gD+-GH dii (== g))#.7f3DQUW^I_Ik"'(*;DII*FF8CR7H)$))4PWX\^ePfGH%dii0=ceeGnM  g g    '&*&6&6GN # ;; "!%GI  == $#'==GK >> %$(NNGL ! >> %$(NNGL !    *)-)<)} | dvsJt || t jjj| r>J|t|tjk(sJ|t|tjk(sJ|t|tjk(sJ|t|tjk(sJ|t|tjk(sJ|t|tk(sJ| t| tk(sJ| t| tk(sJ| t| tjk(sJ| t| tk(sJ| r| D]}tj|rJtj|||_||_||_||_||_||_||_||_| |_| |_| |_| xsi|_y)a0 :param session: The WAMP session ID the other peer is assigned. :type session: int :param roles: The WAMP roles to announce. :type roles: dict of :class:`autobahn.wamp.role.RoleFeatures` :param realm: The effective realm the session is joined on. :type realm: str or None :param authid: The authentication ID assigned. :type authid: str or None :param authrole: The authentication role assigned. :type authrole: str or None :param authmethod: The authentication method in use. :type authmethod: str or None :param authprovider: The authentication provided in use. :type authprovider: str or None :param authextra: Application-specific "extra data" to be forwarded to the client. :type authextra: arbitrary or None :param resumed: Whether the session is a resumed one. :type resumed: bool or None :param resumable: Whether this session can be resumed later. :type resumable: bool or None :param resume_token: The secure authorisation token to resume the session. :type resume_token: str or None :param custom: Implementation-specific "custom attributes" (`x_my_impl_attribute`) to be set. :type custom: dict or None rbrokerdealerN)r9r:rardrLrfrrrrr;rr<r=rrxrrrrrrrrrrrr)rvrrrrrrrrrrrrrrgs r?rxzWelcome.__init__#sfG} 1 1121E{d"#"5zA~~ YD11 21eDk8==+=+=+P+PQU+VW XW Y}U s}} <=<~f!>?>4>S]]#BCB!T*%5%FGF#tL'9S]]'JKJ DOt$;<;$w-4"787 DOt$;<;#tL'9S]]'JKJ~f!565  3(..q121 3       $(" "(l r@ctt|dkDr|dtjk(sJt|dk7r#tdj t|t |dd}t |dd}|jdd }|jd d }|jd d }|jd d }|jd d }|jdd }d } d|vr:|d} t| tk(s#tdj t| d } d|vr:|d} t| tk(s#tdj t| d } d|vrD|d} t| tjk(s0tdj t| | r tdi} d|vr tdt |dd} t| dk(r td| D]}|dvrtdj |t|}t | |dj |}d|vr-t |ddj ||di| |d}n|}|| |<i}|D] }tj|s||||<"t|| ||||||| | | | }|S) rrr2z&invalid message length {0} for WELCOMEr0z'session' in WELCOMEr1z'details' in WELCOMErNrrrrrrz0invalid type {0} for 'resumed' detail in WELCOMErz2invalid type {0} for 'resumable' detail in WELCOMErz5invalid type {0} for 'resume_token' detail in WELCOMEz8resume_token required when resumable is given in WELCOMErz7missing mandatory roles attribute in options in WELCOMEz'roles' in 'details' in WELCOMEz%empty 'roles' in 'details' in WELCOMErz5invalid role '{0}' in 'roles' in 'details' in WELCOMEz-role '{0}' in 'roles' in 'details' in WELCOMErz;'features' in role '{0}' in 'roles' in 'details' in WELCOMEr)rLr rrrKr"rhgetr9rr:r;rr<r=)rrrrrrrrrrrrrrrrrrrrgrs r?rz Welcome.parsexs4y1}aG,@,@!@A@ t9> H O OPSTXPY Z[ [#DG-DE&tAw0GH Hd+Y-;;{D1[[5 {{?D9 KK d3   j)G=D(#$V$]$]^bcj^k$lmm 7 " -I ?d*#$X$_$_`den`o$pqq g %"?3L %6#$[$b$bcghtcu$vww  Z[ [ 7 " Z[ [,WW-=?ab }  " HI I! (D11#$[$b$bcg$hii)$/H/ d0CEtE{E{}AFBCLl*$\+%>@}AEAEFJAKL ( L=+>{+K L !) 'E$K! ($ 'A &&q)#AJq  'gueVXz>$(NNGL ! <<"&,,GJ  >>$(NNGL !   '+'8'8GO $JJ%%' gD+-GH dii (== g))#.7f3DQUW^I_Ik"'(*;DII*FF8CR7H)$))4PWX\^ePfGH%dii0=ceeGnM  g g$$dllG<eZdZdZdZ dZd dZedZdZ dZ y) r zV A WAMP ``ABORT`` message. Format: ``[ABORT, Details|dict, Reason|uri]`` r2)reasonrZNct|tjk(sJ|t|tjk(sJtj |||_||_y)z :param reason: WAMP or application error URI for aborting reason. :type reason: str :param message: Optional human-readable closing message, e.g. for logging purposes. :type message: str or None N)r9r:r;rrxrrZ)rvrrZs r?rxzAbort.__init__sPF|s}},-,$w-3=="@A@  r@ct|dkDr|dtjk(sJt|dk7r#tdj t|t |dd}t |dd}d}d |vrF|d }t|tjk7r#td j t||}t||}|S) rrr2z$invalid message length {0} for ABORTr0z'details' in ABORTr1z'reason' in ABORTNrZz.invalid type {0} for 'message' detail in ABORT) rLr rrrKrhr!r9r:r;)rrrrZdetails_messagers r?rz Abort.parse$s4y1}aE,>,>!>?> t9> F M McRVi XY Y&tAw0EF#DG-AB  %j1OO$ 5#$T$[$[\`ap\q$rss%GFG$ r@cvi}|jr|j|d<tj||jgS)rrZ)rZr rrrvrs r?rz Abort.marshalEs5 <<"&,,GJ ""GT[[99r@cNdj|j|jS)rzAbort(message={0}, reason={1}))rKrZrrzs r?rz Abort.__str__Rs177 dkkRRr@rurrr@r?r r s? LI  @ :Sr@r c>eZdZdZdZ dZd dZedZdZ dZ y) r z_ A WAMP ``CHALLENGE`` message. Format: ``[CHALLENGE, Method|string, Extra|dict]`` r4)methodextraNct|tjk(sJ|t|tk(sJtj |||_|xsi|_y)z :param method: The authentication method. :type method: str :param extra: Authentication method specific information. :type extra: dict or None N)r9r:r;rdrrxrr)rvrrs r?rxzChallenge.__init__jsPF|s}},-,}U t 343 [b r@crt|dkDr|dtjk(sJt|dk7r#tdj t||d}t |t jk7r#tdj t |t|dd}t||}|S)rrr2z(invalid message length {0} for CHALLENGEr0z*invalid type {0} for 'method' in CHALLENGEr1z'extra' in CHALLENGE) rLr rrrKr9r:r;rh)rrrrs r?rzChallenge.parsezs4y1}aI,B,B!BCB t9> J Q QRUVZR[ \] ]a <3== ( L S STXY_T` ab b$T!W.EF& r@cPtj|j|jgSr)r rrrrzs r?rzChallenge.marshals&& TZZ@@r@cNdj|j|jS)rz Challenge(method={0}, extra={1}))rKrrrzs r?rzChallenge.__str__s399$++tzzRRr@rurrr@r?r r Ys? LI ! 2ASr@r c>eZdZdZdZ dZd dZedZdZ dZ y) r zh A WAMP ``AUTHENTICATE`` message. Format: ``[AUTHENTICATE, Signature|string, Extra|dict]`` r5) signaturerNct|tjk(sJ|t|tk(sJtj |||_|xsi|_y)z :param signature: The signature for the authentication challenge. :type signature: str :param extra: Authentication method specific information. :type extra: dict or None N)r9r:r;rdrrxrr)rvrrs r?rxzAuthenticate.__init__sPI#--/0/}U t 343"[b r@crt|dkDr|dtjk(sJt|dk7r#tdj t||d}t |t jk7r#tdj t |t|dd}t||}|S)rrr2z+invalid message length {0} for AUTHENTICATEr0z0invalid type {0} for 'signature' in AUTHENTICATEr1z'extra' in AUTHENTICATE) rLr rrrKr9r:r;rh)rrrrs r?rzAuthenticate.parses4y1}aL,E,E!EFE t9> M T TUXY]U^ _` `G  ?cmm + R Y YZ^_hZi jk k$T!W.HI9e, r@cPtj|j|jgSr)r rrrrzs r?rzAuthenticate.marshals))4>>4::FFr@cNdj|j|jS)rz&Authenticate(signature={0}, extra={1}))rKrrrzs r?rzAuthenticate.__str__s"9??PTPZPZ[[r@rurrr@r?r r s? LI ! 2G\r@r cJeZdZdZdZ dZ dZeddfdZedZ dZ d Z y) rzZ A WAMP ``GOODBYE`` message. Format: ``[GOODBYE, Details|dict, Reason|uri]`` r6zwamp.close.normalrrZrNct|tjk(sJ|t|tjk(sJ|t|tk(sJtj |||_||_||_y)a :param reason: Optional WAMP or application error URI for closing reason. :type reason: str :param message: Optional human-readable closing message, e.g. for logging purposes. :type message: str or None :param resumable: From the server: Whether the session is able to be resumed (true) or destroyed (false). From the client: Whether it should be resumable (true) or destroyed (false). :type resumable: bool or None N) r9r:r;rrrxrrZr)rvrrZrs r?rxzGoodbye.__init__snF|s}},-,$w-3=="@A@ DOt$;<;  "r@c$t|dkDr|dtjk(sJt|dk7r#tdj t|t |dd}t |dd}d}d}d |vrF|d }t|tjk7r#td j t||}d |vr:|d }t|tk7r#td j t|t||| }|S)rrr2z&invalid message length {0} for GOODBYEr0z'details' in GOODBYEr1z'reason' in GOODBYENrZz0invalid type {0} for 'message' detail in GOODBYErz2invalid type {0} for 'resumable' detail in GOODBYEr) rLrrrrKrhr!r9r:r;r)rrrrZrrrs r?rz Goodbye.parses4y1}aG,@,@!@A@ t9> H O OPSTXPY Z[ [&tAw0GH#DG-CD  %j1OO$ 5#$V$]$]^bcr^s$tuu%G 7 " -II$&#$X$_$_`den`o$pqqV% )+ r@ci}|jr|j|d<|jr|j|d<tj||jgS)rrZr)rZrrrrrs r?rzGoodbye.marshalDsJ <<"&,,GJ  >>$(NNGL !$$gt{{;;r@cddj|j|j|jS)rz,Goodbye(message={}, reason={}, resumable={}))rKrZrrrzs r?rzGoodbye.__str__Ts+?EEdllTXT_T_aeaoaoppr@) rrrrrDEFAULT_REASONrrxrrrrrr@r?rrsT L*NI -dd#*&&P< qr@rcReZdZdZdZ dZ d dZedZdZ dZ y) ra A WAMP ``ERROR`` message. Formats: * ``[ERROR, REQUEST.Type|int, REQUEST.Request|id, Details|dict, Error|uri]`` * ``[ERROR, REQUEST.Type|int, REQUEST.Request|id, Details|dict, Error|uri, Arguments|list]`` * ``[ERROR, REQUEST.Type|int, REQUEST.Request|id, Details|dict, Error|uri, Arguments|list, ArgumentsKw|dict]`` * ``[ERROR, REQUEST.Type|int, REQUEST.Request|id, Details|dict, Error|uri, Payload|binary]`` ) request_typerequesterrorargsrjpayloadr>enc_keyrCr callee_authidcallee_authrole forward_forNct|tjvsJt|tjvsJt|tjk(sJ|t|tt fvsJ|t|t k(sJ|t|tjk(sJ||||J| t|sJ||| ||J|t|tjk(sJ| t| sJ| t| tjvsJ| t| tjk(sJ| t| tjk(sJ| t| tk(sJ| r| D]}t|t k(sJd|vrt|dtjvsJd|vr$|d!t|dtjk(sJd|vr t|dtjk(rJtj|||_ ||_ ||_||_t!||_||_||_||_| |_| |_| |_| |_| |_y)a :param request_type: The WAMP message type code for the original request. :type request_type: int :param request: The WAMP request ID of the original request (`Call`, `Subscribe`, ...) this error occurred for. :type request: int :param error: The WAMP or application error URI for the error that occurred. :type error: str :param args: Positional values for application-defined exception. Must be serializable using any serializers in use. :type args: list or None :param kwargs: Keyword values for application-defined exception. Must be serializable using any serializers in use. :type kwargs: dict or None :param payload: Alternative, transparent payload. If given, ``args`` and ``kwargs`` must be left unset. :type payload: bytes or None :param enc_algo: If using payload transparency, the encoding algorithm that was used to encode the payload. :type enc_algo: str or None :param enc_key: If using payload transparency with an encryption algorithm, the payload encryption key. :type enc_key: str or None :param enc_serializer: If using payload transparency, the payload object serializer that was used encoding the payload. :type enc_serializer: str or None :param callee: The WAMP session ID of the effective callee that responded with the error. Only filled if callee is disclosed. :type callee: None or int :param callee_authid: The WAMP authid of the responding callee. Only filled if callee is disclosed. :type callee_authid: None or unicode :param callee_authrole: The WAMP authrole of the responding callee. Only filled if callee is disclosed. :type callee_authrole: None or unicode :param forward_for: When this Error is forwarded for a client/callee (or from an intermediary router). :type forward_for: list[dict] Nrrr)r9r:rar;rtuplerdrGr#r$rrxrrrrrkrjrr>rrCrrrr)rvrrrrrjrr>rrCrrrrffs r?rxzError.__init__|srL!S%6%6676G} 1 1121E{cmm+,+|tDzdE]:;:~f!565$w-3??"BCB7#64?> W_9OU\UhmunB DC$w-3=="@A@%)@)PQP~f1B1B!BCB$](;s}}(LML&$*?3==*PQP"d;&74&?@? ! RBx4''' B49 +>#BSBS+SSS2~2h<+?48 CUY\YfYfCfgg!R'DJ,@CMM,QQQ  R (   &v.  !  , *.'r@c t|dkDr|dtjk(sJt|dvr#tdj t||d}t |t jvrtdj ||tjtjtjtjtjtjtjfvrtdj |t|dd}t!|d d }t#|d d }d }d }d }d }d } d } d } d } d } d }t|dk(rt |dt j$k(r|d}|j'dd }|r%t)|stdj ||j'dd } | r?t | t j*k7r#tdj t | |j'dd } | rt-| stdj | t|dkDr<|d}|5t |t.k7r#tdj t |t|dkDr:|d}t |t0k7r#tdj t |d|vrE|d}t |t jvr#tdj t ||} d|vrF|d}t |t j*k7r#tdj t ||} d|vrF|d}t |t j*k7r#tdj t ||} d|vr|d}d}t |t.k(r|D]}t |t0k7rnpd |vst |d t jvrnLd!|vst |d!t j*k7rn'd"|vs t |d"t j*k7snd#}|s td$t|||||||| | | | | |% }|S)&rr)r5r6z$invalid message length {0} for ERRORr0z,invalid type {0} for 'request_type' in ERRORz-invalid value {0} for 'request_type' in ERRORr1z'request' in ERRORr2z'details' in ERRORr4z'error' in ERRORNr6r5r>0invalid value {0} for 'enc_algo' detail in EVENTr.invalid type {0} for 'enc_key' detail in EVENTrC6invalid value {0} for 'enc_serializer' detail in EVENTz$invalid type {0} for 'args' in ERRORz&invalid type {0} for 'kwargs' in ERRORrz-invalid type {0} for 'callee' detail in ERRORrz4invalid type {0} for 'callee_authid' detail in ERRORrz6invalid type {0} for 'callee_authrole' detail in ERRORrFrrrTz?invalid type/value {0} for/within 'forward_for' option in ERROR) rrjrr>rrCrrrr)rLrrrrKr9r:rarrrrrrrr"rhr!rGrr#r;r$rrd)rrrrrrrjrr>rrCrrrr detail_calleedetail_callee_authiddetail_callee_authrolevalidr!rs r?rz Error.parsesr4y1}aE,>,>!>?> t9I % F M McRVi XY YAw  S%6%6 6 N U UVb cd d  6 6 + 8 8 ' 4 4 ( 5 5 * 7 7 $ 1 1 * 7 7  9 9 O V VWc de e#DG-BC&tAw0EF"47,?@  t9>d47ms>1gG{{;5H 1( ;#$V$]$]^f$ghhkk*d3G4=CMM9#$T$[$[\`ah\i$jkk$[[):DAN&=n&M#$\$c$cdr$stt4y1}Aw#T d(:'(N(U(UVZ[_V`(abb4y1}a<4''(P(W(WX\]cXd(eff  #I.MM"#*;*;;#$S$Z$Z[_`m[n$opp"F w &#*+;#< ()S]]:#$Z$a$abfg{b|$}~~0M  (%,-?%@ "*+s}}<#$\$c$cdhieA%BCC4O W $!.1KEK D(%BBx4' *d2i=.AIZIZ.Zr)T"X,-?3==-P!+tBzN/Cs}}/T#$effL!#%##1!"/$3 + - r@ci}|j|j|d<|j|j|d<|j|j|d<|j|j|d<|jr|j |j |d<|j |j |d<|j|j|d<|j|j|j||j|jgS|jrE|j|j|j||j|j|jgS|jr:|j|j|j||j|jgS|j|j|j||jgS)rrrrrr>rrC)rrrrrr>rrCrrrrrjrrs r?rz Error.marshalds ;; "!%GI     )(,(:(:G$ %    +*.*>*>G& '    '&*&6&6GN # <<}}('+}} $||'&*ll #"".-1-@-@)*%%t'8'8$,,QUQ[Q[]a]i]ij j{{))4+<+rrCrPrrrrrrzs r?rz Error.__str__s?\ccdhduduw{wCwCEIEOEOQUQZQZ\`\g\gimivivx|xDxDFJFYFY[^_c_k_k[lnrnyny{{M{MOSOcOceieueuv vr@rrrr@r?rr[se LI( $#!%!e'N~~@ aDvr@rc4eZdZdZdZ dZ d2dZdZdZe dZ e jd Z e d Z e jd Z e d Z e jd Z e dZejdZe dZejdZe dZejdZe dZejdZe dZejdZe dZejdZe dZejdZe dZejdZe dZejdZe d Zejd!Ze d"Zejd#Ze d$Zejd%Ze d&Zejd'Ze d(Zejd)Ze d*Zejd+Zed,Zd-Zed.Z d/Z!d0Z"d1Z#y)3raZ A WAMP ``PUBLISH`` message. Formats: * ``[PUBLISH, Request|id, Options|dict, Topic|uri]`` * ``[PUBLISH, Request|id, Options|dict, Topic|uri, Arguments|list]`` * ``[PUBLISH, Request|id, Options|dict, Topic|uri, Arguments|list, ArgumentsKw|dict]`` * ``[PUBLISH, Request|id, Options|dict, Topic|uri, Payload|binary]`` )_request_topic_args_kwargs_payload _enc_algo_enc_serializer_enc_key _acknowledge _exclude_me_exclude_exclude_authid_exclude_authrole _eligible_eligible_authid_eligible_authrole_retain _forward_forNc(|t|tjvsJ|t|tjk(sJ|7t|tt tjtj fvsJ|2t|ttjtj fvsJ|t|tj k(sJ||||J|t|tk(sJ|t|tk(sJ|t|tk(sJ|t|tk(sJ|r$|D]}t|tjvrJ| t| tk(sJ| r%| D] }t|tjk(r J| t| tk(sJ| r%| D] }t|tjk(r J| t| tk(sJ| r$| D]}t|tjvrJ| t| tk(sJ| r%| D] }t|tjk(r J| t| tk(sJ| r%| D] }t|tjk(r J| t|sJ|||||J|t|tjk(sJ| t|sJ|t|tk(sJ|r|D]}t|tk(sJd|vrt|dtjvsJd|vr$|d!t|dtjk(sJd|vr t|dtjk(rJtj||||_ ||_||_t!||_||_||_||_||_| |_| |_| |_| |_| |_||_||_||_||_||_y)aL :param request: The WAMP request ID of this request. :type request: int :param topic: The WAMP or application URI of the PubSub topic the event should be published to. :type topic: str :param args: Positional values for application-defined event payload. Must be serializable using any serializers in use. :type args: list or tuple or None :param kwargs: Keyword values for application-defined event payload. Must be serializable using any serializers in use. :type kwargs: dict or None :param payload: Alternative, transparent payload. If given, ``args`` and ``kwargs`` must be left unset. :type payload: bytes or None :param acknowledge: If True, acknowledge the publication with a success or error response. :type acknowledge: bool or None :param exclude_me: If ``True``, exclude the publisher from receiving the event, even if he is subscribed (and eligible). :type exclude_me: bool or None :param exclude: List of WAMP session IDs to exclude from receiving this event. :type exclude: list of int or None :param exclude_authid: List of WAMP authids to exclude from receiving this event. :type exclude_authid: list of str or None :param exclude_authrole: List of WAMP authroles to exclude from receiving this event. :type exclude_authrole: list of str or None :param eligible: List of WAMP session IDs eligible to receive this event. :type eligible: list of int or None :param eligible_authid: List of WAMP authids eligible to receive this event. :type eligible_authid: list of str or None :param eligible_authrole: List of WAMP authroles eligible to receive this event. :type eligible_authrole: list of str or None :param retain: If ``True``, request the broker retain this event. :type retain: bool or None :param enc_algo: If using payload transparency, the encoding algorithm that was used to encode the payload. :type enc_algo: str or None :param enc_key: If using payload transparency with an encryption algorithm, the payload encryption key. :type enc_key: str or None :param enc_serializer: If using payload transparency, the payload object serializer that was used encoding the payload. :type enc_serializer: str or None or None :param forward_for: When this Call is forwarded for a client (or from an intermediary router). :type forward_for: list[dict] Nrrrrw) r9r:rar;rr rGrdrr#r$rrxr/r0r1rkr2r3r7r8r9r:r;r<r=r>r?r4r6r5r@)rvrtopicrrjr acknowledge exclude_meexcludeexclude_authidexclude_authroleeligibleeligible_authideligible_authroleretainr>rrCrrw sessionidrrr!s r?rxzPublish.__init__sUb$w-33D3D"DED}U s}} <=<|tDzdE3==#//-ZZ[Z~f$ s1W!WXW$w-3??"BCB7#64=$w-4"787 $ = I#*;*;;<; =%n)=)EFE ( 6F|s}}454 6 '40@+AT+IJI , 8H~676 84>T#9:9 % = I#*;*;;<; =&$*?4*GHG ) 6F|s}}454 6!(D1B,Ct,KLK - 8H~676 8#4X#>?> W_9OU\UhmunB DC$w-3=="@A@%)@)PQP"d;&74&?@? ! RBx4''' B49 +>#BSBS+SSS2~2h<+?48 CUY\YfYfCfgg!R'DJ,@CMM,QQQ  R 1   '/  '& -!1! /"3 " -(r@ct||jsytj||sy|j|jk7ry|j |j k7ry|j |j k7ry|j|jk7ry|j|jk7ry|j|jk7ry|j|jk7ry|j|jk7ry|j|jk7ry|j|jk7ry|j|jk7ry|j|jk7ry|j |j k7ry|j"|j"k7ry|j$|j$k7ry|j&|j&k7ry|j(|j(k7ry|j*|j*k7ryyNFT)rfrrrrrCrrjrrDrErFrGrHrIrJrKrLr>rrCrrs r?rzPublish.__eq__zs%0~~dE* ==DLL ( ;;$** $ :: " <<4;; & ==DLL (    0 0 0   t . ==DLL (   4#6#6 6  ! !T%:%: : >>T]] *  D$8$8 8  " "d&<&< < <<4;; & >>T]] * ==DLL (   4#6#6 6    0 0 0r@c&|j| Srurrs r?rzPublish.__ne__;;u%%%r@c|j+|jr|jj|_|jSru)r/rnRequestrzs r?rzPublish.requests0 == T^^ NN224DM}}r@cP|t|tjvsJ||_yru)r9r:rar/r}s r?rzPublish.requests%}U s/@/@ @A@ r@c|j>|jr2|jj}|r|jd|_|jSNutf8r0rnTopicrJrvrOs r?rCz Publish.topicA ;; 4>>$$&Ahhv. {{r@c>|t|tk(sJ||_yrur9strr0r}s r?rCz Publish.topic}U s 222 r@c|ja|jrU|jjr;tjt |jj |_|jSrur1rn ArgsLengthr-loadsr ArgsAsBytesrzs r?rz Publish.argsN :: $..~~((*!ZZdnn.H.H.J(KL zzr@cH|t|ttfvsJ||_yrur9rr r1r}s r?rz Publish.args#}U e} <=< r@c|ja|jrU|jjr;tjt |jj |_|jSrur2rn KwargsLengthr-rcr KwargsAsBytesrzs r?rjzPublish.kwargsN << DNN~~**,#zz%0L0L0N*OP ||r@c>|t|tk(sJ||_yrur9rdr2r}s r?rjzPublish.kwargs}U t 343 r@c|jE|jr9|jjr|jj|_|jSrur3rn PayloadLengthPayloadAsBytesrzs r?rzPublish.payload@ == T^^~~++- $ = = ? }}r@c>|t|tk(sJ||_yrur9rr3r}s r?rzPublish.payload}U u 444 r@c|j/|jr#|jj}|r||_|jSru)r7rn Acknowledge)rvrDs r?rDzPublish.acknowledges=    $..446K$/!   r@c>|t|tk(sJ||_yru)r9rr7r}s r?rDzPublish.acknowledges }U t 333!r@c|j1|jr%|jj}|dur||_|jS)NF)r8rn ExcludeMe)rvrEs r?rEzPublish.exclude_mesB    #113JU"#- r@c>|t|tk(sJ||_yru)r9rr8r}s r?rEzPublish.exclude_mes }U t 333 r@c4|j|jru|jjr[g}t|jjD],}|j |jj |.||_|jSru)r9rn ExcludeLengthrangeappendExclude)rvrFjs r?rFzPublish.excludest == T^^~~++-t~~;;=>>ANN4>>#9#9!#<=> ' }}r@cx|t|tk(sJ|r|D]}t|tk(rJ||_yru)r9rrr9rvrYxs r?rFzPublish.excludesA}U t 333  &Aw#~%~ & r@cR|j|jr|jjrjg}t|jjD];}|j |jj |j d=||_|jSrV)r:rnExcludeAuthidLengthrr ExcludeAuthidrJ)rvrGrs r?rGzPublish.exclude_authids    'DNN~~113!#t~~AACDZA"))$..*F*Fq*I*P*PQW*XYZ'5$###r@cx|t|tk(sJ|r|D]}t|tk(rJ||_yru)r9rr^r:rs r?rGzPublish.exclude_authidsB}U t 333  &Aw#~%~ &$r@cR|j|jr|jjrjg}t|jjD];}|j |jj |j d=||_|jSrV)r;rnExcludeAuthroleLengthrrExcludeAuthrolerJ)rvrHrs r?rHzPublish.exclude_authrole"s  ! ! )dnn~~335#% t~~CCEF^A$++DNN,J,J1,M,T,TU[,\]^)9&%%%r@cx|t|tk(sJ|r|D]}t|tk(rJ||_yru)r9rr^r;rs r?rHzPublish.exclude_authrole,sB}U t 333  &Aw#~%~ &!&r@c4|j|jru|jjr[g}t|jjD],}|j |jj |.||_|jSru)r<rnEligibleLengthrrEligible)rvrIrs r?rIzPublish.eligible4sv >> !dnn~~,,.t~~<<>?@AOODNN$;$;A$>?@!)~~r@cx|t|tk(sJ|r|D]}t|tk(rJ||_yru)r9rrr<rs r?rIzPublish.eligible>sA}U t 333  &Aw#~%~ &r@cR|j|jr|jjrjg}t|jjD];}|j |jj |j d=||_|jSrV)r=rnEligibleAuthidLengthrrEligibleAuthidrJ)rvrJrs r?rJzPublish.eligible_authidFs  (T^^~~224"$t~~BBDE\A#**4>>+H+H+K+R+RSY+Z[\(7%$$$r@cx|t|tk(sJ|r|D]}t|tk(rJ||_yru)r9rr^r=rs r?rJzPublish.eligible_authidPsB}U t 333  &Aw#~%~ & %r@cR|j|jr|jjrjg}t|jjD];}|j |jj |j d=||_|jSrV)r>rnEligibleAuthroleLengthrrEligibleAuthrolerJ)rvrKrs r?rKzPublish.eligible_authroleXs  " " *t~~~~446$&!t~~DDFG`A%,,T^^-L-LQ-O-V-VW]-^_`*;'&&&r@cx|t|tk(sJ|r|D]}t|tk(rJ||_yru)r9rr^r>rs r?rKzPublish.eligible_authrolebsB}U t 333  &Aw#~%~ &"'r@c|j/|jr#|jj}|r||_|jSru)r?rnRetain)rvrLs r?rLzPublish.retainjs8 << DNN^^**,F% ||r@c>|t|tk(sJ||_yru)r9rr?r}s r?rLzPublish.retainrs}U t 333 r@c|j/|jr#|jj}|r||_|jSrur4rnEncAlgorvr>s r?r>zPublish.enc_algow8 >> !dnn~~--/H!)~~r@c@||tttfvsJ||_yruENC_ALGO_CRYPTOBOX ENC_ALGO_MQTT ENC_ALGO_XBRr4r}s r?r>zPublish.enc_algo#}* }}r@c>|t|tk(sJ||_yrur9rr6r}s r?rzPublish.enc_keyrxr@c|j/|jr#|jj}|r||_|jSrur5rn EncSerializerrvrCs r?rCzPublish.enc_serializer=    'DNN!^^99;N'5$###r@cJ||ttttfvsJ||_yru ENC_SER_JSONENC_SER_MSGPACK ENC_SER_CBORENC_SER_UBJSONr5r}s r?rCzPublish.enc_serializer&},We)f fff$r@c|jSrur@rzs r?rzPublish.forward_for   r@c||_yrurr}s r?rzPublish.forward_for "r@cVttjj|dSNrrB)rrGetRootAsPublishrs r?rz Publish.casts  3 3 D DS! LMMr@cD|j}|r$|jtj|}|j}|r$|jtj|}|j }|r|j|}|j }|r|j|}|j}|r|j|}|j}|rdtjj|t|t|D]}|j||j!t|}|j"} | rg} | D]"} | j%|j| $tjj|t| t| D]} |j'| |j!t| } |j(} | rg}| D]"}|j%|j|$tjj+|t|t|D]} |j'| |j!t|} |j,}|rdtjj/|t|t|D]}|j||j!t|}|j0}|rg}|D]"} |j%|j| $tjj/|t|t|D]} |j'| |j!t|}|j2}|rg}|D]"}|j%|j|$tjj5|t|t|D]} |j'| |j!t|}tjj7||j8*tjj;||j8|r tjj=|||r tjj?|||r tjjA|||r tjjC|||jD*tjjG||jD|jH*tjjK||jH|jL*tjjO||jL|r tjjQ||| r tjjS|| | r tjjU|| |r tjjW|||r tjjY|||r tjj[|||j\r*tjj_||j\|r tjja|||jbr*tjje||jbtjjg|}tjhjk|tjhjm|tjnjptjhjs||tjhju|}|Sru);rCreateByteVectorr-dumpsrjrrC CreateStringrrFr PublishGenPublishStartExcludeAuthidVectorrLreversed PrependUint64 EndVectorrGrPrependUOffsetTRelativerH!PublishStartExcludeAuthroleVectorrI PublishStartEligibleAuthidVectorrJrK"PublishStartEligibleAuthroleVector PublishStartrPublishAddRequestPublishAddTopicPublishAddArgsPublishAddKwargsPublishAddPayloadrDPublishAddAcknowledgerLPublishAddRetainrEPublishAddExcludeMePublishAddExcludePublishAddExcludeAuthidPublishAddExcludeAuthrolePublishAddEligiblePublishAddEligibleAuthidPublishAddEligibleAuthroler>PublishAddEncAlgoPublishAddEncKeyrCPublishAddEncSerializer PublishEndr MessageStartMessageAddMsgType MessageTypePUBLISH MessageAddMsg MessageEnd)rvrrrjrrCrrFrrGr:rorHr;rrIrJr=rKr>msg union_msgs r?rz Publish.builds8yy ++DJJt,<=D --djj.@AF,, ..w7G  ((/E,, ..w7G,,   " " B B7CPWL Y#G, /%%g. /''G 5G,,  O( E&&w';';F'CD E  " " B B7CP_L` ao. 3//2 3$..s?/CDN 00  " , I!(()=)=h)GH I  " " D DWcRcNd e/0 3//2 3&005F1GH ==   " " C CGSQY] [#H- /%%g. /((X7H.. ! ) F ''(<(*>x*HI J  " " E EgsSeOf g01 3//2 3 ' 1 1#6H2I J  ++G4 << #  " " 4 4Wdll K   " " 2 27E B   " " 1 1'4 @   " " 3 3GV D   " " 4 4Wg F    '  " " 8 8$BRBR S ;; "  " " 3 3GT[[ I ?? &  " " 6 6w P   " " 4 4Wg F   " " : :7N S   " " < z2invalid value {0} for 'enc_algo' option in PUBLISHrz0invalid type {0} for 'enc_key' option in PUBLISHrCz8invalid value {0} for 'enc_serializer' option in PUBLISHz&invalid type {0} for 'args' in PUBLISHz(invalid type {0} for 'kwargs' in PUBLISHrDz4invalid type {0} for 'acknowledge' option in PUBLISHrEz3invalid type {0} for 'exclude_me' option in PUBLISHrFz0invalid type {0} for 'exclude' option in PUBLISHz9invalid type {0} for value in 'exclude' option in PUBLISHrGz7invalid type {0} for 'exclude_authid' option in PUBLISHz@invalid type {0} for value in 'exclude_authid' option in PUBLISHrHz9invalid type {0} for 'exclude_authrole' option in PUBLISHzBinvalid type {0} for value in 'exclude_authrole' option in PUBLISHrIz1invalid type {0} for 'eligible' option in PUBLISHz:invalid type {0} for value in 'eligible' option in PUBLISHrJz8invalid type {0} for 'eligible_authid' option in PUBLISHzAinvalid type {0} for value in 'eligible_authid' option in PUBLISHrKz:invalid type {0} for 'eligible_authrole' option in PUBLISHzCinvalid type {0} for value in 'eligible_authrole' option in PUBLISHrLz/invalid type {0} for 'retain' option in PUBLISHrFrrrTzAinvalid type/value {0} for/within 'forward_for' option in PUBLISHrrjr)rLrrrrKr"rhr!r9r:r;rGrr#r$rrdrra)#rroptionsrCrrjrr>rrCrDrErFrGrHrIrJrKrLroption_acknowledgeoption_exclude_meoption_exclude _sessionidoption_exclude_authid_authidoption_exclude_authrole _authroleoption_eligible sessionIdoption_eligible_authidoption_eligible_authroler*r!rs# r?rz Publish.parse4 s4y1}aG,@,@!@A@ t9I % H O OPSTXPY Z[ [#DG-DE&tAw0GH"47,AB t9>d47m s/OO1gG{{;5H 1( ;#$X$_$_`h$ijjkk*d3G4=CMM9#$V$]$]^bcj^k$lmm$[[):DAN&=n&M#$^$e$eft$uvv4y1}Aw:dCMM3??%KK'(P(W(WX\]aXb(cdd4y1}a<cmmS__'MM'(R(Y(YZ^_eZf(ghhHG!N    W $!(!8 &'4/#$Z$a$abfgybz${||,K G # ' 6 %&$.#$Y$`$`aefwax$yzz*J  $Z0NN#t+#$V$]$]^bcq^r$stt, ~  #3+<+<<'(c(j(jkopzk{(|}} ~%G  '$+,=$> !)*d2#$]$d$deijfA%BCC0 B=CMM1'(j(q(qrvw~r)ABB B3N ' )&-.A&B #+,4#$_$f$fgkmDhE%FGG4 F  ?cmm3'(l(s(stxzCuD)EFF F 7  ' !%k2OO$,#$W$^$^_cds_t$uvv, ~  ?#*;*;;'(d(k(klpqzl{(|}} ~'H  (%,-?%@ "*+t3#$^$e$efjlBgC%DEE1 C=CMM1'(k(r(rswxtA)BCC C5O 7 *'./C'D $,-5#$`$g$ghlnFiG%HII5 G  ?cmm3'(m(t(tuy{DvE)FGG G!9   Y'FF|t##$U$\$\]abh]i$jkk W $!.1KEK D(%BBx4' *d2i=.AIZIZ.Zr)T"X,-?3==-P!+tBzN/Cs}}/T#$ghhg//$/& / #. / ", /&/&4/(8/ (/'6/):/$/ (/&/ &4!/"#.#/& r@ci}|j|j|d<|j|j|d<|j|j|d<|j|j|d<|j|j|d<|j |j |d<|j |j |d<|j|j|d<|j|j|d <|jrQ|j|j|d <|j|j|d <|j|j|d <|j|j|d <|S)NrDrErFrGrHrIrJrKrLr>rrCr)rDrErFrGrHrIrJrKrLrr>rrCrrvrs r?marshal_optionszPublish.marshal_options sl    '&*&6&6GN # ?? &%)__GM " << #"&,,GJ     *)-)<)*>G& '  ! ! -,0,B,BG( ) ;; "!%GI  <<}}('+}} $||'&*ll #"".-1-@-@)*    '&*&6&6GN #r@c|j}|jr3tj|j||j |jgS|j r>tj|j||j |j|j gS|jr3tj|j||j |jgStj|j||j gSr)rrrrrrCrjrrs r?rzPublish.marshal s&&( <<(($,,T\\Z Z{{,,dllGTZZQUQZQZ\`\g\ghh,,dllGTZZQUQZQZ[[,,dllGTZZPPr@cdj|j|j|j|j|j |j |j|j|j|j|j|j|j|j|j|j t#|j$|j&S)raPublish(request={}, topic={}, args={}, kwargs={}, acknowledge={}, exclude_me={}, exclude={}, exclude_authid={}, exclude_authrole={}, eligible={}, eligible_authid={}, eligible_authrole={}, retain={}, enc_algo={}, enc_key={}, enc_serializer={}, payload={}, forward_for={}))rKrrCrrjrDrErFrGrHrIrJrKrLr>rrCrPrrrzs r?rzPublish.__str__1 sahhimiuiuw{wAwACGCLCLNRNYNY[_[k[kmqm|m|~B~J~JLPL_L_aeavavx|xExEGKG[G[]a]s]suyu@u@BFBOBOQUQ]Q]_c_r_rtwx|xD xD tE G K G W G W X X r@)NNNNNNNNNNNNNNNNNNN)$rrrrrrrxrrrrrrCrrjrrDrErFrGrHrIrJrKrLr>rrCrrrrrrrrrr@r?rrs L6Ir!  $"&!%#' $!'b(H)V&  ^^ \\  [[  ]]  ^^!!""  !! ^^$$%%&&''__%%&&''(( ]]__  ^^$$%%!!""NNGRCCJ"HQ&X r@rc<eZdZdZdZ dZdZedZdZ dZ y) rzh A WAMP ``PUBLISHED`` message. Format: ``[PUBLISHED, PUBLISH.Request|id, Publication|id]`` )r publicationct|tjvsJt|tjvsJtj |||_||_y)z :param request: The request ID of the original `PUBLISH` request. :type request: int :param publication: The publication ID for the published event. :type publication: int N)r9r:rarrxrr)rvrrs r?rxzPublished.__init__I sRG} 1 1121K C$5$5565 &r@ct|dkDr|dtjk(sJt|dk7r#tdj t|t |dd}t |dd}t||}|S)rrr2z(invalid message length {0} for PUBLISHEDr0z'request' in PUBLISHEDr1z'publication' in PUBLISHED)rLrrrrKr")rrrrs r?rzPublished.parseY s4y1}aI,B,B!BCB t9> J Q QRUVZR[ \] ]#DG-FG'Q1NO - r@cPtj|j|jgSr)rrrrrzs r?rzPublished.marshalp s!&& d6F6FGGr@cNdj|j|jS)rz'Published(request={0}, publication={1}))rKrrrzs r?rzPublished.__str__y s!:@@tO_O_``r@Nrrr@r?rr8 s? LI ' ,Har@rcVeZdZdZdZ dZdZdZdZ d dZ e d Z d Z d Z d Zy)rzi A WAMP ``SUBSCRIBE`` message. Format: ``[SUBSCRIBE, Request|id, Options|dict, Topic|uri]`` exactprefixwildcard)rrCr= get_retainedrNc.t|tjvsJt|tjk(sJ|t|tjk(sJ|3|tj tj tjfvsJ|t|tusJ|t|tk(sJ|r|D]}t|tk(sJd|vrt|dtjvsJd|vr$|d!t|dtjk(sJd|vr t|dtjk(rJtj|||_ ||_|xstj |_||_||_y)a :param request: The WAMP request ID of this request. :type request: int :param topic: The WAMP or application URI of the PubSub topic to subscribe to. :type topic: str :param match: The topic matching method to be used for the subscription. :type match: str :param get_retained: Whether the client wants the retained message we may have along with the subscription. :type get_retained: bool or None :param forward_for: When this Subscribe is forwarded over a router-to-router link, or via an intermediary router. :type forward_for: list[dict] Nrrr)r9r:rar;r MATCH_EXACT MATCH_PREFIXMATCH_WILDCARDrrrdrrxrrCr=rr)rvrrCr=rrr!s r?rxzSubscribe.__init__ s0G} 1 1121E{cmm+,+}U s}} <=<})*?*?AWAWYbYqYq)r rsr#tL'9T'ABA"d;&74&?@? ! RBx4''' B49 +>#BSBS+SSS2~2h<+?48 CUY\YfYfCfgg!R'DJ,@CMM,QQQ  R   3i33 (&r@cjt|dkDr|dtjk(sJt|dk7r#tdj t|t |dd}t |dd}t|dd d }tj}d }d }d |vr|d }t|tjk7r#tdj t||tjtjtjfvrtdj ||}d|vr:|d}t|tk7r#tdj t|d|vr|d}d}t|tk(r|D]} t| t k7rnpd| vst| dtj"vrnLd| vst| dtjk7rn'd| vs t| dtjk7snd }|s tdt|||||} | S)rrr4z(invalid message length {0} for SUBSCRIBEr0z'request' in SUBSCRIBEr1z'options' in SUBSCRIBEr2z'topic' in SUBSCRIBET)r\Nr=z0invalid type {0} for 'match' option in SUBSCRIBEz1invalid value {0} for 'match' option in SUBSCRIBErz7invalid type {0} for 'get_retained' option in SUBSCRIBErFrrrzCinvalid type/value {0} for/within 'forward_for' option in SUBSCRIBE)r=rr)rLrrrrKr"rhr!rr9r:r;rrrrrdra) rrrrCr=rr option_matchr*r!rs r?rzSubscribe.parse s&4y1}aI,B,B!BCB t9> J Q QRUVZR[ \] ]#DG-FG&tAw0IJ"47,C\`a%%  w "8,LL!S]]2#$V$]$]^bco^p$qrrI$9$99;Q;QS\SkSk#ll#$W$^$^_k$lmm E g %"?3LL!T)#$]$d$deijvew$xyy W $!.1KEK D(%BBx4' *d2i=.AIZIZ.Zr)T"X,-?3==-P!+tBzN/Cs}}/T#$ijje,\gh r@ci}|jr,|jtjk7r|j|d<|j|j|d<|j|j|d<|S)Nr=rr)r=rrrrrs r?rzSubscribe.marshal_options sj ::$** (=(== $ GH     ('+'8'8GO $    '&*&6&6GN #r@cntj|j|j|jgSr)rrrrrCrzs r?rzSubscribe.marshal s*&& d6J6J6LdjjYYr@cdj|j|j|j|j|j S)rzOSubscribe(request={0}, topic={1}, match={2}, get_retained={3}, forward_for={4}))rKrrCr=rrrzs r?rzSubscribe.__str__ ssbhhimiuiuw{xBxBDHDNDNPTPaPacgcscst tr@NNN)rrrrrrrrrrxrrrrrrr@r?rr sb LKL NI"! *'X<<| Ztr@rc<eZdZdZdZ dZdZedZdZ dZ y) rzm A WAMP ``SUBSCRIBED`` message. Format: ``[SUBSCRIBED, SUBSCRIBE.Request|id, Subscription|id]`` !)r subscriptionct|tjvsJt|tjvsJtj |||_||_y)z :param request: The request ID of the original ``SUBSCRIBE`` request. :type request: int :param subscription: The subscription ID for the subscribed topic (or topic pattern). :type subscription: int N)r9r:rarrxrr)rvrrs r?rxzSubscribed.__init__2 RG} 1 1121L!S%6%6676 (r@ct|dkDr|dtjk(sJt|dk7r#tdj t|t |dd}t |dd}t||}|S)rrr2z)invalid message length {0} for SUBSCRIBEDr0z'request' in SUBSCRIBEDr1z'subscription' in SUBSCRIBED)rLrrrrKr")rrrrs r?rzSubscribed.parseB 4y1}aJ,C,C!CDC t9> K R RSVW[S\ ]^ ^#DG-GH(a2QR ,/ r@cPtj|j|jgSr)rrrrrzs r?rzSubscribed.marshalY !''t7H7HIIr@cNdj|j|jS)rz)Subscribed(request={0}, subscription={1}))rKrrrzs r?rzSubscribed.__str__b "<BB4<eZdZdZdZ dZd dZedZdZ dZ y) rz A WAMP ``UNSUBSCRIBE`` message. Formats: * ``[UNSUBSCRIBE, Request|id, SUBSCRIBED.Subscription|id]`` * ``[UNSUBSCRIBE, Request|id, SUBSCRIBED.Subscription|id, Options|dict]`` ")rrrNct|tjvsJt|tjvsJ|r|D]}t|tk(sJd|vrt|dtjvsJd|vr$|d!t|dtjk(sJd|vr t|dtjk(rJt j |||_||_||_ y)a :param request: The WAMP request ID of this request. :type request: int :param subscription: The subscription ID for the subscription to unsubscribe from. :type subscription: int :param forward_for: When this Unsubscribe is forwarded over a router-to-router link, or via an intermediary router. :type forward_for: list[dict] rrNr) r9r:rardr;rrxrrr)rvrrrr!s r?rxzUnsubscribe.__init__~ sG} 1 1121L!S%6%6676 ! RBx4''' B49 +>#BSBS+SSS2~2h<+?48 CUY\YfYfCfgg!R'DJ,@CMM,QQQ  R  (&r@ct|dkDr|dtjk(sJt|dvr#tdj t|t |dd}t |dd}d}t|d kDrt |d d }d}|rd |vr|d }d }t|tk(r|D]}t|tk7rnpd |vst|d tjvrnLd|vst|dtjk7rn'd|vs t|dtjk7snd}|s tdt|||}|S)rrr2r4z/invalid message length {0} for WAMP UNSUBSCRIBEr0z'request' in UNSUBSCRIBEr1z'subscription' in UNSUBSCRIBENr2z'options' in UNSUBSCRIBErFrrrTzEinvalid type/value {0} for/within 'forward_for' option in UNSUBSCRIBEr) rLrrrrKr"rhr9rrdr:rar;)rrrrrr*r!rs r?rzUnsubscribe.parse sd4y1}aK,D,D!DED t9F " Q X XY\]aYb cd d#DG-HI(a2RS  t9q=*474OPG ~0!.1KEK D(%BBx4' *d2i=.AIZIZ.Zr)T"X,-?3==-P!+tBzN/Cs}}/T#$kll'<[I r@c|jr6d|ji}tj|j|j|gStj|j|jgSrr)rrrrrrs r?rzUnsubscribe.marshal s]    0 0G ,,dllDeZdZdZdZ dZd dZedZdZ dZ y) rz A WAMP ``UNSUBSCRIBED`` message. Formats: * ``[UNSUBSCRIBED, UNSUBSCRIBE.Request|id]`` * ``[UNSUBSCRIBED, UNSUBSCRIBE.Request|id, Details|dict]`` #)rrrNc6t|tjvsJ|t|tjvsJ|t|tjk(sJ|dk7r| |dk(r|dk7sJtj |||_||_||_y)a :param request: The request ID of the original ``UNSUBSCRIBE`` request or ``0`` is router triggered unsubscribe ("router revocation signaling"). :type request: int :param subscription: If unsubscribe was actively triggered by router, the ID of the subscription revoked. :type subscription: int or None :param reason: The reason (an URI) for an active (router initiated) revocation. :type reason: str or None. Nr) r9r:rar;rrxrrr)rvrrrs r?rxzUnsubscribed.__init__ sG} 1 1121#tL'9S=N=N'NON~f!>?>1 !57a@[\7L&9 r@c|j |jUi}|j|j|d<|j|j|d<tj|j|gStj|jgS)rrr)rrrrrrs r?rzUnsubscribed.marshal0 ~ ;; "d&7&7&CG{{&%)[[ "  ,+/+<+<( --t||WE E --t||< r?r@r0rArBr4r6r5r@)rvrrrrjrrpublisher_authidpublisher_authrolerCretainedx_acknowledged_deliveryr>rrCrrwr!s r?rxzEvent.__init__ sl#tL'9S=N=N'NON"d;&73;L;L&LML|tDzdE]:;:~f!565$w-3??"BCB7#64T#9:9&.$7N2OSW2WXW#4X#>?> W_9OU\UhmunB DC$w-3=="@A@%)@)PQP"d;&74&?@? ! RBx4''' B49 +>#BSBS+SSS2~2h<+?48 CUY\YfYfCfgg!R'DJ,@CMM,QQQ  R 1)' '/  #!1#5  !(?%! -'r@clt||jsytj||sy|j|jk7ry|j |j k7ry|j |j k7ry|j|jk7ry|j|jk7ry|j|jk7ry|j|jk7ry|j|jk7ry|j|jk7ry|j|jk7ry|j|jk7ry|j|jk7ry|j |j k7ry|j"|j"k7ry|j$|j$k7ryyrO)rfrrrrrrrjrrrDrErCrFrGr>rrCrrs r?rz Event.__eq__ s`%0~~dE*   !2!2 2    0 0 0 :: " <<4;; & ==DLL ( ??dnn ,  ! !T%:%: :  # #t'>'> > ;;$** $ >>T]] *  ( (D,H,H H >>T]] * ==DLL (   4#6#6 6    0 0 0r@c&|j| Srurrs r?rz Event.__ne__ rQr@c|j+|jr|jj|_|jSru)r<rn Subscriptionrzs r?rzEvent.subscription s5    %$..!%!D !!!r@cP|t|tjvsJ||_yru)r9r:rar<r}s r?rzEvent.subscription s&}U s/@/@ @A@"r@c|j+|jr|jj|_|jSru)r=rn Publicationrzs r?rzEvent.publication s5    $ $ : : |t|tk(sJ||_yruror}s r?rjz Event.kwargs9 rpr@c|jE|jr9|jjr|jj|_|jSrurrrzs r?rz Event.payload> rur@c>|t|tk(sJ||_yrurwr}s r?rz Event.payloadE rxr@c|j/|jr#|jj}|r||_|jSru)r>rn Publisher)rvrs r?rzEvent.publisherJ s8 ?? "t~~002I"+r@c>|t|tk(sJ||_yru)r9rr>r}s r?rzEvent.publisherR s}U s 222r@c|j>|jr2|jj}|r|jd|_|jSrV)r?rnPublisherAuthidrJrZs r?rDzEvent.publisher_authidW sF  ! ! )dnn..0A)*&)9&%%%r@c>|t|tk(sJ||_yru)r9r^r?r}s r?rDzEvent.publisher_authid_ s }U s 222!&r@c|j>|jr2|jj}|r|jd|_|jSrV)r@rnPublisherAuthrolerJrZs r?rEzEvent.publisher_authroled sF  # # +002A+,88F+;('''r@c>|t|tk(sJ||_yru)r9r^r@r}s r?rEzEvent.publisher_authrolel s }U s 222#( r@c|j>|jr2|jj}|r|jd|_|jSrVrXrZs r?rCz Event.topicq r[r@c>|t|tk(sJ||_yrur]r}s r?rCz Event.topicy r_r@c|j+|jr|jj|_|jSru)rArnRetainedrzs r?rFzEvent.retained~ s0 >> !dnn!^^446DN~~r@c>|t|tk(sJ||_yru)r9rrAr}s r?rFzEvent.retained s}U t 333r@c|j/|jr#|jj}|r||_|jSru)rBrnrz)rvrGs r?rGzEvent.x_acknowledged_delivery s>  ( ( 0T^^&*nn&@&@&B #&0G-,,,r@c>|t|tk(sJ||_yru)r9rrBr}s r?rGzEvent.x_acknowledged_delivery s }U t 333(-%r@c|j/|jr#|jj}|r||_|jSrurrs r?r>zEvent.enc_algo rr@c@||tttfvsJ||_yrurr}s r?r>zEvent.enc_algo rr@c|jE|jr9|jjr|jj|_|jSrurrzs r?rz Event.enc_key rr@c>|t|tk(sJ||_yrurr}s r?rz Event.enc_key rxr@c|j/|jr#|jj}|r||_|jSrurrs r?rCzEvent.enc_serializer rr@cJ||ttttfvsJ||_yrurr}s r?rCzEvent.enc_serializer rr@c|jSrurrzs r?rzEvent.forward_for rr@c||_yrurr}s r?rzEvent.forward_for rr@cVttjj|dSr)rrGetRootAsEventrs r?rz Event.cast s k//>>sAFGGr@c||j}|r$|jtj|}|j}|r$|jtj|}|j }|r|j|}|j }|r|j|}|j}|r|j|}|j}|r|j|}|j}|r|j|}tjj||jr*tjj||j|j r*tjj#||j |r tjj%|||r tjj'|||r tjj)|||j*r*tjj-||j*|r tjj/|||r tjj1|||r tjj3|||j4*tjj7||j4|j8*tjj;||j8|j<r*tjj?||j<|r tjjA|||jBr*tjjE||jBtjjG|} tjHjK|tjHjM|tjNjPtjHjS|| tjHjU|} | Sru)+rrr-rrjrrDrrErCrrEventGen EventStartrEventAddSubscriptionrEventAddPublication EventAddArgsEventAddKwargsEventAddPayloadrEventAddPublisherEventAddPublisherAuthidEventAddPublisherAuthrole EventAddTopicrFEventAddRetainedrGEventAddAcknowledger>EventAddEncAlgoEventAddEncKeyrCEventAddEncSerializerEventEndrrrrEVENTrr) rvrrrjrrDrErCrrrs r?rz Event.build s$yy ++DJJt,<=D --djj.@AF,, ..w7G00 &334DE !44 !(!5!56H!I   ((/E,, ..w7G''0     5 5gt?P?P Q     4 4Wd>N>N O   - -gt <   / / @   0 0' B >>  2 27DNN K   8 8BR S   : :7DV W   . .w > == $  1 1'4== I  ' ' 3  4 4Wd>Z>Z [ ==  0 0$-- H   / / A     6 6w@S@S T""++G4((1--g{7N7N7T7TU))'37''227; r@c6 t|dkDr|dtjk(sJt|dvr#tdj t|t |dd}t |dd}t |dd }d }d }d }d }d }d } t|d k(rt|d tjk(r|d }|jd d }|r%t|stdj ||jdd }|r?t|tjk7r#tdj t||jdd } | rt| stdj | t|d kDr<|d }|5t|tk7r#tdj t|t|d kDr:|d }t|tk7r#tdj t|d } d } d } d } d }d }d }d|vrE|d}t|tj vr#tdj t||} d|vrF|d}t|tjk7r#tdj t||} d|vrF|d}t|tjk7r#tdj t||} d|vrF|d}t|tjk7r#tdj t||} d|vr:|d}t|t"k7r#tdj t|d|vr:|d}t|t"k7r#td j t|d!|vr|d!}d"}t|tk(r|D]}t|tk7rnpd#|vst|d#tj vrnLd$|vst|d$tjk7rn'd%|vs t|d%tjk7snd&}|s td't|||||| | | | ||||| |(}|S))rrrz$invalid message length {0} for EVENTr0z'subscription' in EVENTr1z'publication' in EVENTr2z'details' in EVENTNr5r4r>r$rr%rCr&z$invalid type {0} for 'args' in EVENTz&invalid type {0} for 'kwargs' in EVENTrz0invalid type {0} for 'publisher' detail in EVENTrDz7invalid type {0} for 'publisher_authid' detail in EVENTrEz9invalid type {0} for 'publisher_authrole' detail in EVENTrCz,invalid type {0} for 'topic' detail in EVENTrFz/invalid type {0} for 'retained' detail in EVENTrGz>invalid type {0} for 'x_acknowledged_delivery' detail in EVENTrFrrrTz?invalid type/value {0} for/within 'forward_for' option in EVENT) rrjrrrDrErCrFrGr>rrCr)rLrrrrKr"rhr9r:rGrr#r;r$rrdrar)rrrrrrjrr>rrCrrDrErCrFrrGdetail_publisherdetail_publisher_authiddetail_publisher_authrole detail_topicr*r!rs r?rz Event.parses4y1}aE,>,>!>?> t9I % F M McRVi XY Y(a2LM 'Q1JK &tAw0EF t9>d47ms>1gG{{;5H 1( ;#$V$]$]^f$ghhkk*d3G4=CMM9#$T$[$[\`ah\i$jkk$[[):DAN&=n&M#$\$c$cdr$stt4y1}Aw#T d(:'(N(U(UVZ[_V`(abb4y1}a<4''(P(W(WX\]cXd(eff ! "& 7 "&|4 $%S->->>#$V$]$]^bcs^t$uvv(I ' )&-.A&B #+, =#$]$d$deikBfC%DEE6  G +(/0E(F %-.#--?#$_$f$fgkmFhG%HII!:  w "8,LL!S]]2#$R$Y$YZ^_kZl$mnn E ' !{+HH~%#$U$\$\]abj]k$lmm % 0&-.H&I #+,4#$d$k$klprImJ%KLL W $!.1KEK D(%BBx4' *d2i=.AIZIZ.Zr)T"X,-?3==-P!+tBzN/Cs}}/T#$effL!#'%5'9%,C%##1 +-  r@ci}|j|j|d<|j|j|d<|j|j|d<|j|j|d<|j|j|d<|j |j |d<|j |j |d<|jr|j|j|d<|j|j|d <|j|j|d <tj|j|j||jgS|jr>tj|j|j||j |jgS|j r3tj|j|j||j gStj|j|j|gS) rrrDrErCrFrGrr>rrC)rrDrErCrFrGrrr>rrCrrrrrjrrs r?rz Event.marshals >> %$(NNGL !  ,+/+@+@G' (  " " .-1-D-DG) * :: ! $ GH  == $#'==GK  ' ' 3262N2NG. /    '&*&6&6GN # <<}}('+}} $||'&*ll #"".-1-@-@)*&&(9(94;K;KWVZVbVbc c{{**D,=,=t?O?OQXZ^ZcZceiepepqq**D,=,=t?O?OQXZ^ZcZcdd**D,=,=t?O?OQXYYr@chdj|j|j|j|j|j |j |j|j|j|j|j|jt|j|jS)rzEvent(subscription={}, publication={}, args={}, kwargs={}, publisher={}, publisher_authid={}, publisher_authrole={}, topic={}, retained={}, enc_algo={}, enc_key={}, enc_serializer={}, payload={}, forward_for={}))rKrrrrjrrDrErCrFr>rrCrPrrrzs r?rz Event.__str__sTfmmnrnnAEAQAQSWS\S\^b^i^ikokyky{{P{PRVRiRikokukuw{wDwDFJFSFSUYUaUacgcvcvx{|@|H|HxIKOK[K[\ \r@)NNNNNNNNNNNNNNNN) rrrrrrrxrrrrrrrrjrrrDrErCrFrGr>rrCrrrrrrrrr@r?rrH s% L-I^]aW[8 O V VWZ[_W` ab b'Q1ST K( r@c:tj|jgSr)rrrrzs r?rzEventReceived.marshals**D,<,<==r@c8dj|jS)rzEventReceived(publication={}))rKrrzs r?rzEventReceived.__str__s066t7G7GHHr@Nrrr@r?rrs>LI '*>Ir@rc\eZdZdZdZ dZ d dZedZdZ dZ d Z y) ra[ A WAMP ``CALL`` message. Formats: * ``[CALL, Request|id, Options|dict, Procedure|uri]`` * ``[CALL, Request|id, Options|dict, Procedure|uri, Arguments|list]`` * ``[CALL, Request|id, Options|dict, Procedure|uri, Arguments|list, ArgumentsKw|dict]`` * ``[CALL, Request|id, Options|dict, Procedure|uri, Payload|binary]`` 0)r procedurerrjrtimeoutreceive_progressr>rrCr caller_authidcaller_authrolerNc8t|tjvsJt|tjk(sJ|t|tt fvsJ|t|t k(sJ|t|tjk(sJ||||J|t|tjvsJ|t|tk(sJ| t|sJ| t| tjk(sJ| t| sJ|| | ||J| t| tjvsJ| t| tjk(sJ| t| tjk(sJ|t|tk(sJ|r|D]}t|t k(sJd|vrt|dtjvsJd|vr$|d!t|dtjk(sJd|vr t|dtjk(rJtj|||_ ||_||_t!||_||_||_||_||_| |_| |_| |_| |_| |_||_y)a& :param request: The WAMP request ID of this request. :type request: int :param procedure: The WAMP or application URI of the procedure which should be called. :type procedure: str :param args: Positional values for application-defined call arguments. Must be serializable using any serializers in use. :type args: list or tuple or None :param kwargs: Keyword values for application-defined call arguments. Must be serializable using any serializers in use. :type kwargs: dict or None :param payload: Alternative, transparent payload. If given, ``args`` and ``kwargs`` must be left unset. :type payload: bytes or None :param timeout: If present, let the callee automatically cancel the call after this ms. :type timeout: int or None :param receive_progress: If ``True``, indicates that the caller wants to receive progressive call results. :type receive_progress: bool or None :param enc_algo: If using payload transparency, the encoding algorithm that was used to encode the payload. :type enc_algo: str or None :param enc_key: If using payload transparency with an encryption algorithm, the payload encryption key. :type enc_key: str or None :param enc_serializer: If using payload transparency, the payload object serializer that was used encoding the payload. :type enc_serializer: str or None :param caller: The WAMP session ID of the caller. Only filled if caller is disclosed. :type caller: None or int :param caller_authid: The WAMP authid of the caller. Only filled if caller is disclosed. :type caller_authid: None or unicode :param caller_authrole: The WAMP authrole of the caller. Only filled if caller is disclosed. :type caller_authrole: None or unicode :param forward_for: When this Publish is forwarded for a client (or from an intermediary router). :type forward_for: list[dict] Nrrr)r9r:rar;rr rdrGrr#r$rrxrrrrkrjrrrr>rrCrrrr)rvrrrrjrrrr>rrCrrrrr!s r?rxz Call.__init__:s~G} 1 1121I#--/0/|tDzdE]:;:~f!565$w-3??"BCB7#64?>$w-3=="@A@%)@)PQP W_9OU\UhmunB DC~f1B1B!BCB$](;s}}(LML&$*?3==*PQP"d;&74&?@? ! RBx4''' B49 +>#BSBS+SSS2~2h<+?48 CUY\YfYfCfgg!R'DJ,@CMM,QQQ  R  " &v.   0!  , *.&r@c t|dkDr|dtjk(sJt|dvr#tdj t|t |dd}t |dd}t|dd }d }d }d }d }d }d } t|d k(rt|d tjtjfvr|d }|jd d }|r%t|stdj ||jdd }|r?t|tjk7r#tdj t||jdd } | rt| stdj | t|d kDr<|d }|5t|tk7r#tdj t|t|d kDr:|d }t|t k7r#tdj t|d } d } d } d } d }d }d|vrd|d}t|tj"vr#tdj t||dkrtdj ||} d|vr<|d}t|t$k7r#tdj t||} d|vrE|d}t|tj"vr#tdj t||} d|vrF|d}t|tjk7r#tdj t||} d|vrF|d}t|tjk7r#tdj t||}d |vr|d }d!}t|tk(r|D]}t|t k7rnpd"|vst|d"tj"vrnLd#|vst|d#tjk7rn'd$|vs t|d$tjk7snd%}|s td&t|||||| | ||| | | ||'}|S)(rrrz#invalid message length {0} for CALLr0z'request' in CALLr1z'options' in CALLr2z'procedure' in CALLNr5r4r>z/invalid value {0} for 'enc_algo' detail in CALLrz-invalid type {0} for 'enc_key' detail in CALLrCz5invalid value {0} for 'enc_serializer' detail in CALLz#invalid type {0} for 'args' in CALLz%invalid type {0} for 'kwargs' in CALLrz-invalid type {0} for 'timeout' option in CALLz.invalid value {0} for 'timeout' option in CALLrz6invalid type {0} for 'receive_progress' option in CALLrz,invalid type {0} for 'caller' detail in CALLrz3invalid type {0} for 'caller_authid' detail in CALLrz5invalid type {0} for 'caller_authrole' detail in CALLrFrrrTz>invalid type/value {0} for/within 'forward_for' option in CALL) rrjrrrr>rrCrrrr)rLrrrrKr"rhr!r9r:r;rGrr#r$rrdrar)rrrrrrjrr>rrCrrrrrroption_timeoutoption_receive_progress option_calleroption_caller_authidoption_caller_authroler*r!rs r?rz Call.parses4y1}aD,=,=!=>= t9I % E L LSQUY WX X#DG-AB&tAw0DE&tAw0FG  t9>d47m s/OO1gG{{;5H 1( ;#$U$\$\]e$fggkk*d3G4=CMM9#$S$Z$Z[_`g[h$ijj$[[):DAN&=n&M#$[$b$bcq$rss4y1}Aw#T d(:'(M(T(TUYZ^U_(`aa4y1}a<4''(O(V(VW[\bWc(dee   $Z0NN#3+<+<<#$S$Z$Z[_`n[o$pqq!#$T$[$[\j$kll$G ' )&-.A&B #+,4#$\$c$cdhjAeB%CDD6   #I.MM"#*;*;;#$R$Y$YZ^_lZm$noo"F w &#*+;#< ()S]]:#$Y$`$`aefza{$|}}0M  (%,-?%@ "*+s}}<#$[$b$bcgh~c%ABB4O W $!.1KEK D(%BBx4' *d2i=.AIZIZ.Zr)T"X,-?3==-P!+tBzN/Cs}}/T#$dee7 ""$4$""0 !.#2* , r@ci}|j|j|d<|j|j|d<|jrQ|j|j|d<|j|j|d<|j |j |d<|j |j |d<|j|j|d<|j|j|d<|j|j|d <|S) Nrrr>rrCrrrr) rrrr>rrCrrrrrs r?rzCall.marshal_options3s << #"&,,GJ   ,+/+@+@G' ( <<}}('+}} $||'&*ll #"".-1-@-@)* ;; "!%GI     )(,(:(:G$ %    +*.*>*>G& '    '&*&6&6GN #r@c|j}|jr3tj|j||j |jgS|j r>tj|j||j |j|j gS|jr3tj|j||j |jgStj|j||j gSr)rrrrrrrjrrs r?rz Call.marshalPs&&( <<%%t||Wdnndll[ [{{))4<<$..RVR[R[]a]h]hii))4<<$..RVR[R[\\))4<<$..QQr@chdj|j|j|j|j|j |j |j|j|jt|j|j|j|j|jS)rzCall(request={}, procedure={}, args={}, kwargs={}, timeout={}, receive_progress={}, enc_algo={}, enc_key={}, enc_serializer={}, payload={}, caller={}, caller_authid={}, caller_authrole={}, forward_for={}))rKrrrrjrrr>rrCrPrrrrrrzs r?rz Call.__str__csT_ffgkgsgsuyuCuCEIENENPTP[P[]a]i]ikok@k@BFBOBOQUQ]Q]_c_r_rtwx|xDxDtEGKGRGRTXTfTfhlh|h|~B~N~NO Or@) NNNNNNNNNNNN) rrrrrrrxrrrrrrr@r?rrso LI("& $#!%!l'\HHT:R&Or@rcJeZdZdZdZ dZdZdZdZd dZ e d Z d Z d Z y) rz A WAMP ``CANCEL`` message. Format: ``[CANCEL, CALL.Request|id, Options|dict]`` See: https://wamp-proto.org/static/rfc/draft-oberstet-hybi-crossbar-wamp.html#rfc.section.14.3.4 1skipkill killnowait)rmoderNcnt|tjvsJ|t|tjk(sJ|d|j|j |j fvsJ|t|tk(sJ|r|D]}t|tk(sJd|vrt|dtjvsJd|vr$|d!t|dtjk(sJd|vr t|dtjk(rJtj|||_ ||_ ||_ y)a :param request: The WAMP request ID of the original `CALL` to cancel. :type request: int :param mode: Specifies how to cancel the call (``"skip"``, ``"killnowait"`` or ``"kill"``). :type mode: str or None :param forward_for: When this Cancel is forwarded for a client (or from an intermediary router). :type forward_for: list[dict] Nrrr)r9r:rar;SKIP KILLNOWAITKILLrrdrrxrrr)rvrrrr!s r?rxzCancel.__init__s1G} 1 1121|tDzS]]:;:dii$))DDED"d;&74&?@? ! RBx4''' B49 +>#BSBS+SSS2~2h<+?48 CUY\YfYfCfgg!R'DJ,@CMM,QQQ  R   'r@ct|dkDr|dtjk(sJt|dk7r#tdj t|t |dd}t |dd}d}d}d |vr|d }t|tjk7r#td j t||tjtjtjfvrtd j ||}d |vr|d }d }t|tk(r|D]}t|tk7rnpd|vst|dtjvrnLd|vst|dtjk7rn'd|vs t|dtjk7snd}|s tdt|||}|S)rrr2z%invalid message length {0} for CANCELr0z'request' in CANCELr1z'options' in CANCELNrz,invalid type {0} for 'mode' option in CANCELz/invalid value '{0}' for 'mode' option in CANCELrFrrrTz@invalid type/value {0} for/within 'forward_for' option in CANCEL)rr)rLrrrrKr"rhr9r:r;rrrrrdra) rrrrr option_moder*r!rs r?rz Cancel.parses4y1}aF,?,?!?@? t9> G N NsSWy YZ Z#DG-CD&tAw0FG g !'*KK CMM1#$R$Y$YZ^_jZk$lmm6;;0A0A6;;"OO#$U$\$\]h$ijjD W $!.1KEK D(%BBx4' *d2i=.AIZIZ.Zr)T"X,-?3==-P!+tBzN/Cs}}/T#$fggW4[A r@ci}|j|j|d<|j|j|d<tj|j|gS)rrr)rrrrrrs r?rzCancel.marshalsT 99 #yyGG     '&*&6&6GN ###T\\7;;r@cNdj|j|jS)rzCancel(request={0}, mode={1}))rKrrrzs r?rzCancel.__str__s066t||TYYOOr@r9)rrrrrrrrrrxrrrrrr@r?rrjsPL D DJI '>66p< Pr@rcTeZdZdZdZ dZ d dZedZdZ dZ y) raO A WAMP ``RESULT`` message. Formats: * ``[RESULT, CALL.Request|id, Details|dict]`` * ``[RESULT, CALL.Request|id, Details|dict, YIELD.Arguments|list]`` * ``[RESULT, CALL.Request|id, Details|dict, YIELD.Arguments|list, YIELD.ArgumentsKw|dict]`` * ``[RESULT, CALL.Request|id, Details|dict, Payload|binary]`` 2 rrrjrprogressr>rrCrrrrNc t|tjvsJ|t|ttfvsJ|t|t k(sJ|t|tj k(sJ||||J|t|tk(sJ| t|sJ|t|tjk(sJ| t|sJ|||||J| t| tjvsJ| t| tjk(sJ| t| tjk(sJ| t| tk(sJ| r| D]} t| t k(sJd| vrt| dtjvsJd| vr$| d!t| dtjk(sJd| vr t| dtjk(rJtj|||_ ||_t||_||_||_||_||_||_| |_| |_| |_| |_y)as :param request: The request ID of the original `CALL` request. :type request: int :param args: Positional values for application-defined event payload. Must be serializable using any serializers in use. :type args: list or tuple or None :param kwargs: Keyword values for application-defined event payload. Must be serializable using any serializers in use. :type kwargs: dict or None :param payload: Alternative, transparent payload. If given, ``args`` and ``kwargs`` must be left unset. :type payload: bytes or None :param progress: If ``True``, this result is a progressive call result, and subsequent results (or a final error) will follow. :type progress: bool or None :param enc_algo: If using payload transparency, the encoding algorithm that was used to encode the payload. :type enc_algo: str or None :param enc_key: If using payload transparency with an encryption algorithm, the payload encryption key. :type enc_key: str or None :param enc_serializer: If using payload transparency, the payload object serializer that was used encoding the payload. :type enc_serializer: str or None :param callee: The WAMP session ID of the effective callee that responded with the result. Only filled if callee is disclosed. :type callee: None or int :param callee_authid: The WAMP authid of the responding callee. Only filled if callee is disclosed. :type callee_authid: None or unicode :param callee_authrole: The WAMP authrole of the responding callee. Only filled if callee is disclosed. :type callee_authrole: None or unicode :param forward_for: When this Result is forwarded for a client/callee (or from an intermediary router). :type forward_for: list[dict] Nrrrr9r:rarr rdrGrr#r;r$rrxrrrkrjrrr>rrCrrrrrvrrrjrrr>rrCrrrrr!s r?rxzResult.__init__szlG} 1 1121|tDzdE]:;:~f!565$w-3??"BCB7#64T#9:9#4X#>?>$w-3=="@A@%)@)PQP W_9OU\UhmunB DC~f1B1B!BCB$](;s}}(LML&$*?3==*PQP"d;&74&?@? ! RBx4''' B49 +>#BSBS+SSS2~2h<+?48 CUY\YfYfCfgg!R'DJ,@CMM,QQQ  R   &v.    !  , *.'r@ct|dkDr|dtjk(sJt|dvr#tdj t|t |dd}t |dd}d}d}d}d}d}d}d} d} d} d} d} t|d k(rt|d tjtjfvr|d }|jd d}|r%t|std j ||jd d}|r?t|tjk7r#tdj t||jdd} | rt| stdj | t|d kDr<|d }|5t|tk7r#tdj t|t|d kDr:|d }t|tk7r#tdj t|d|vr<|d}t|t k7r#tdj t||}d|vrE|d}t|tj"vr#tdj t||} d|vrF|d}t|tjk7r#tdj t||} d|vrF|d}t|tjk7r#tdj t||} d|vr|d} d}t| tk(r| D]}t|tk7rnpd|vst|dtj"vrnLd|vst|dtjk7rn'd|vs t|dtjk7snd }|s td!t|||||||| | | | | " }|S)#rrr2r4r5z%invalid message length {0} for RESULTr0z'request' in RESULTr1z'details' in RESULTNr4r2r>z1invalid value {0} for 'enc_algo' detail in RESULTrz/invalid type {0} for 'enc_key' detail in RESULTrCz7invalid value {0} for 'enc_serializer' detail in RESULTz%invalid type {0} for 'args' in RESULTz'invalid type {0} for 'kwargs' in RESULTrz0invalid type {0} for 'progress' option in RESULTrz.invalid type {0} for 'callee' detail in RESULTrz5invalid type {0} for 'callee_authid' detail in RESULTrz7invalid type {0} for 'callee_authrole' detail in RESULTrFrrrTz@invalid type/value {0} for/within 'forward_for' option in RESULT rrjrrr>rrCrrrr)rLrrrrKr"rhr9r:r;rGrr#r$rrdrra)rrrrrjrrr>rrCrrrrdetail_progressr'r(r)r*r!rs r?rz Result.parsess4y1}aF,?,?!?@? t9I % G N NsSWy YZ Z#DG-CD&tAw0FG  t9>d47m s/OO1gG{{;5H 1( ;#$W$^$^_g$hiikk*d3G4=CMM9#$U$\$\]abi]j$kll$[[):DAN&=n&M#$]$d$des$tuu4y1}Aw#T d(:'(O(V(VW[\`Wa(bcc4y1}a<4''(Q(X(XY]^dYe(fgg ' !%k2OO$,#$V$]$]^bcr^s$tuu&H  #I.MM"#*;*;;#$T$[$[\`an\o$pqq"F w &#*+;#< ()S]]:#$[$b$bcgh|c}$~0M  (%,-?%@ "*+s}}<#$]$d$deikAfB%CDD4O W $!.1KEK D(%BBx4' *d2i=.AIZIZ.Zr)T"X,-?3==-P!+tBzN/Cs}}/T#$fggW"$&&$$2"#0%4!, . r@c>i}|j|j|d<|j|j|d<|j|j|d<|j|j|d<|j|j|d<|j ry|j |j |d<|j|j|d<|j|j|d<tj|j||j gS|jr3tj|j||j|jgS|jr(tj|j||jgStj|j|gS rrrrrrr>rrC)rrrrrrr>rrCrrrrjrrs r?rzResult.marshalse == $#'==GK ;; "!%GI     )(,(:(:G$ %    +*.*>*>G& '    '&*&6&6GN # <<}}('+}} $||'&*ll #"".-1-@-@)*''w M M{{++T\\7DIIt{{[[++T\\7DIINN++T\\7CCr@c<dj|j|j|j|j|j |j |jt|j|j|j|j|j S)rzResult(request={0}, args={1}, kwargs={2}, progress={3}, enc_algo={4}, enc_key={5}, enc_serializer={6}, payload={7}, callee={8}, callee_authid={9}, callee_authrole={10}, forward_for={11})rKrrrjrr>rrCrPrrrrrrzs r?rzResult.__str__s*MTTUYUaUacgclclnrnyny{{H{HJNJWJWY]YeYegkgzgz|@D@L@L|MOSOZOZ\`\n\nptpDpDFJFVFVW Wr@ NNNNNNNNNNNrrr@r?rrsh L I" $#!%!`'Dxxt#DJWr@rcreZdZdZdZ dZdZdZdZdZ dZ d Z d Z d Z d Z ddZedZdZdZdZy )rzk A WAMP ``REGISTER`` message. Format: ``[REGISTER, Request|id, Options|dict, Procedure|uri]`` @r r r singlefirstlast roundrobinrandomall)rrr=invoke concurrencyforce_reregisterrNc~t|tjvsJt|tjk(sJ|t|tjk(sJ|3|tj tj tjfvsJ|t|tjk(sJ|Q|tjtjtjtjtjfvsJ|"t|tjvr|dkDsJ|dvsJ|t|tk(sJ|r|D]}t|tk(sJd|vrt|dtjvsJd|vr$|d!t|dtjk(sJd|vr t|dtjk(rJtj!|||_||_|xstj |_|xstj|_||_||_||_y)a :param request: The WAMP request ID of this request. :type request: int :param procedure: The WAMP or application URI of the RPC endpoint provided. :type procedure: str :param match: The procedure matching policy to be used for the registration. :type match: str :param invoke: The procedure invocation policy to be used for the registration. :type invoke: str :param concurrency: The (maximum) concurrency to be used for the registration. :type concurrency: int :param forward_for: When this Register is forwarded over a router-to-router link, or via an intermediary router. :type forward_for: list[dict] Nr)NTFrrr)r9r:rar;rrrr INVOKE_SINGLE INVOKE_FIRST INVOKE_LASTINVOKE_ROUNDROBIN INVOKE_RANDOMrrdrrxrrr=rrrr) rvrrr=rrrrr!s r?rxzRegister.__init__;s0:G} 1 1121I#--/0/}U s}} <=<}(*>*>@U@UW_WnWn)o opo~f!>?>~H,B,BHDYDY[c[o[oqyrLrLNVNdNd,e"e fe"tK'8C#BSBS+SSS2~2h<+?48 CUY\YfYfCfgg!R'DJ,@CMM,QQQ  R  "2h22 6 6 6 & 0&r@c nt|dkDr|dtjk(sJt|dk7r#tdj t|t |dd}t |dd}tj}tj}d}d}d}d |vr|d }t|tjk7r#td j t||tjtjtjfvrtd j ||}|tjk(rd } d } n;|tjk(rd } d } n#|tjk(rd } d } n tdt|dd| | } d|vr|d} t| tjk7r#tdj t| | tjtj tj"tj$tj&fvrtdj | | }d|vrd|d} t| tj(vr#tdj t| | dkrtdj | | }|j+dd}|dvr#tdj t|||}d|vr|d}d }t|t,k(r|D]}t|t.k7rnpd|vst|dtj(vrnLd|vst|dtjk7rn'd|vs t|dtjk7snd }|s tdt|| ||||| }|S)!rrr4z'invalid message length {0} for REGISTERr0z'request' in REGISTERr1z'options' in REGISTERNr=z/invalid type {0} for 'match' option in REGISTERz0invalid value {0} for 'match' option in REGISTERFTz logic errorr2z'procedure' in REGISTER)r\r]rz0invalid type {0} for 'invoke' option in REGISTERz1invalid value {0} for 'invoke' option in REGISTERrz5invalid type {0} for 'concurrency' option in REGISTERz6invalid value {0} for 'concurrency' option in REGISTERr)TFNz9invalid type {0} for 'force_reregister option in REGISTERrrrrzBinvalid type/value {0} for/within 'forward_for' option in REGISTER)r=rrrr)rLrrrrKr"rhrrr9r:r;rr Exceptionr!rrrrrarrrd)rrrr=rrrrrr\r]r option_invokeoptions_concurrencyoptions_reregisterr*r!rs r?rzRegister.parseqs4y1}aH,A,A!ABA t9> I P PQTUYQZ [\ \#DG-EF&tAw0HI$$''  w "8,LL!S]]2#$U$\$\]abn]o$pqqH$8$8(:O:OQYQhQh#ii#$V$]$]^j$kll E H(( (%* "$  h++ +%* "#  h-- -%) "$ M* *&tAw0JcyM]^  #I.MM"cmm3#$V$]$]^bcp^q$rssX%;%;X=R=RT\ThThjrkEkEGOG]G]%^^#$W$^$^_l$mnn"F W $")."9 '(0A0AA#$[$b$bcgh{c|$}~~"Q&#$\$c$cdw$xyy-K$[[)eZdZdZdZ dZd dZedZdZ dZ y) rz A WAMP `UNREGISTER` message. Formats: * ``[UNREGISTER, Request|id, REGISTERED.Registration|id]`` * ``[UNREGISTER, Request|id, REGISTERED.Registration|id, Options|dict]`` B)rrrNct|tjvsJt|tjvsJtj |||_||_||_y)a :param request: The WAMP request ID of this request. :type request: int :param registration: The registration ID for the registration to unregister. :type registration: int :param forward_for: When this Unregister is forwarded over a router-to-router link, or via an intermediary router. :type forward_for: list[dict] N)r9r:rarrxrrr)rvrrrs r?rxzUnregister.__init__^sZG} 1 1121L!S%6%6676 (&r@ct|dkDr|dtjk(sJt|dvr#tdj t|t |dd}t |dd}d}t|d kDrt |d d }d}|rd |vr|d }d }t|tk(r|D]}t|tk7rnpd |vst|d tjvrnLd|vst|dtjk7rn'd|vs t|dtjk7snd}|s tdt|||}|S)rrr)z.invalid message length {0} for WAMP UNREGISTERr0z'request' in UNREGISTERr1z'registration' in UNREGISTERNr2z'options' in UNREGISTERrFrrrTzDinvalid type/value {0} for/within 'forward_for' option in UNREGISTERr*) rLrrrrKr"rhr9rrdr:rar;)rrrrrr*r!rs r?rzUnregister.parsessd4y1}aJ,C,C!CDC t9F " P W WX[\`Xa bc c#DG-GH(a2QR  t9q=*474NOG ~0!.1KEK D(%BBx4' *d2i=.AIZIZ.Zr)T"X,-?3==-P!+tBzN/Cs}}/T#$jkk,KH r@c|jr6d|ji}tj|j|j|gStj|j|jgSr,)rrrrrrs r?rzUnregister.marshals]    0 0G++T\\4;L;LgV V++T\\4;L;LM Mr@cNdj|j|jS)rz)Unregister(request={0}, registration={1})rrzs r?rzUnregister.__str__r#r@rurrr@r?rrIs@LI '*++Z Ndr@rc>eZdZdZdZ dZd dZedZdZ dZ y) rz A WAMP ``UNREGISTERED`` message. Formats: * ``[UNREGISTERED, UNREGISTER.Request|id]`` * ``[UNREGISTERED, UNREGISTER.Request|id, Details|dict]`` C)rrrNc6t|tjvsJ|t|tjvsJ|t|tjk(sJ|dk7r| |dk(r|dk7sJtj |||_||_||_y)ay :param request: The request ID of the original ``UNREGISTER`` request. :type request: int :param registration: If unregister was actively triggered by router, the ID of the registration revoked. :type registration: int or None :param reason: The reason (an URI) for revocation. :type reason: str or None. Nr) r9r:rar;rrxrrr)rvrrrs r?rxzUnregistered.__init__sG} 1 1121#tL'9S=N=N'NON~f!>?>1 !57a?>$w-3=="@A@%)@)PQP W_9OU\UhmunB DC"d;&74&?@? ! RBx4''' B49 +>#BSBS+SSS2~2h<+?48 CUY\YfYfCfgg!R'DJ,@CMM,QQQ  R  ( &v.   0 *."   ,'r@c t|dkDr|dtjk(sJt|dvr#tdj t|t |dd}t |dd}t |dd }d }d }d }d }d }d } t|d k(rt|d tjk(r|d }|jd d }|r%t|stdj ||jdd }|r?t|tjk7r#tdj t||jdd } | rt| stdj | t|d kDr<|d }|5t|tk7r#tdj t|t|d kDr:|d }t|tk7r#tdj t|d } d } d } d } d }d }d }d|vrd|d}t|tj vr#tdj t||dkrtdj ||} d|vr<|d}t|t"k7r#tdj t||} d|vrE|d}t|tj vr#tdj t||} d|vrF|d}t|tjk7r#tdj t||} d|vrF|d}t|tjk7r#tdj t||}d |vrF|d }t|tjk7r#td!j t||}d"|vr|d"}d#}t|tk(r|D]}t|tk7rnpd$|vst|d$tj vrnLd%|vst|d%tjk7rn'd&|vs t|d&tjk7snd'}|s td(t|||||| | | | ||||| |)}|S)*rrrz)invalid message length {0} for INVOCATIONr0z'request' in INVOCATIONr1z'registration' in INVOCATIONr2z'details' in INVOCATIONNr5r4r>z5invalid value {0} for 'enc_algo' detail in INVOCATIONrz3invalid type {0} for 'enc_key' detail in INVOCATIONrCz;invalid value {0} for 'enc_serializer' detail in INVOCATIONz)invalid type {0} for 'args' in INVOCATIONz+invalid type {0} for 'kwargs' in INVOCATIONrz3invalid type {0} for 'timeout' detail in INVOCATIONz4invalid value {0} for 'timeout' detail in INVOCATIONrzrrCr)rLrrrrKr"rhr9r:rGrr#r;r$rrdrar)rrrrrrjrr>rrCrrrrrrrdetail_timeoutdetail_receive_progress detail_callerdetail_caller_authiddetail_caller_authroledetail_procedurer*r!rs r?rzInvocation.parses 4y1}aJ,C,C!CDC t9I % K R RSVW[S\ ]^ ^#DG-GH(a2QR &tAw0JK t9>d47ms>1gG{{;5H 1( ;#$[$b$bck$lmmkk*d3G4=CMM9#$Y$`$`aefman$opp$[[):DAN&=n&M#$a$h$hiw$xyy4y1}Aw#T d(:'(S(Z(Z[_`d[e(fgg4y1}a<4''(U(\(\]abh]i(jkk    $Z0NN#3+<+<<#$Y$`$`aeftau$vww!#$Z$a$abp$qrr$G ' )&-.A&B #+,4#$b$i$ijnpGkH%IJJ6   #I.MM"#*;*;;#$X$_$_`der`s$tuu"F w &#*+;#< ()S]]:#$_$f$fgkmAhB%CDD0M  (%,-?%@ "*+s}}<#$a$h$himoEjF%GHH4O 7 "&|4 $%6#$[$b$bcghxcy$z{{(I W $!.1KEK D(%BBx4' *d2i=.AIZIZ.Zr)T"X,-?3==-P!+tBzN/Cs}}/T#$jkk%" &!(!(*: &'4)8#,"*!((6%02  r@ci}|j|j|d<|j|j|d<|j|j|d<|j|j|d<|j|j|d<|j |j |d<|j |j |d<|jr|j|j|d<|j|j|d <|j|j|d <tj|j|j||jgS|jr>tj|j|j||j |jgS|j r3tj|j|j||j gStj|j|j|gS) rrrrrrrrr>rrC)rrrrrrrrr>rrCrrrrrjrrs r?rzInvocation.marshalGs << #"&,,GJ   ,+/+@+@G' ( ;; "!%GI     )(,(:(:G$ %    +*.*>*>G& ' >> %$(NNGL !    '&*&6&6GN # <<}}('+}} $||'&*ll #"".-1-@-@)*++T\\4;L;LgW[WcWcd d{{"//t?P?PRY[_[d[dfjfqfqrr"//t?P?PRY[_[d[dee"//t?P?PRYZZr@chdj|j|j|j|j|j |j |j|j|j|j|j|j|jt|jS)rzInvocation(request={0}, registration={1}, args={2}, kwargs={3}, timeout={4}, receive_progress={5}, caller={6}, caller_authid={7}, caller_authrole={8}, procedure={9}, enc_algo={10}, enc_key={11}, enc_serializer={12}, payload={13}))rKrrrrjrrrrrrr>rrCrPrrzs r?rzInvocation.__str__usTx@D@L@LNRN_N_aeajajlplwlwy}yEyEGKG\G\^b^i^ikok}k}CSSUYUcUceierertxt@t@BFBUBUWZ[_[g[gWhi ir@) NNNNNNNNNNNNNrrr@r?rr!sn LI*"&#!% $!l'\RRh,[\ir@rcFeZdZdZdZ dZdZdZd dZe dZ d Z d Z y) rz A WAMP ``INTERRUPT`` message. Format: ``[INTERRUPT, INVOCATION.Request|id, Options|dict]`` See: https://wamp-proto.org/static/rfc/draft-oberstet-hybi-crossbar-wamp.html#rfc.section.14.3.4 Err)rrrrNct|tjvsJ|t|tjk(sJ|||j|j fvsJ|t|tjk(sJ|t|t k(sJ|r|D]}t|tk(sJd|vrt|dtjvsJd|vr$|d!t|dtjk(sJd|vr t|dtjk(rJtj|||_ ||_ ||_ ||_ y)aV :param request: The WAMP request ID of the original ``INVOCATION`` to interrupt. :type request: int :param mode: Specifies how to interrupt the invocation (``"killnowait"`` or ``"kill"``). With ``"kill"``, the router will wait for the callee to return an ERROR before proceeding (sending back an ERROR to the original caller). With ``"killnowait"`` the router will immediately proceed (on the caller side returning an ERROR) - but still expects the callee to send an ERROR to conclude the message exchange for the inflight call. :type mode: str or None :param reason: The reason (an URI) for the invocation interrupt, eg actively triggered by the caller (``"wamp.error.canceled"`` - ApplicationError.CANCELED) or passively because of timeout (``"wamp.error.timeout"`` - ApplicationError.TIMEOUT). :type reason: str or None. :param forward_for: When this Call is forwarded for a client (or from an intermediary router). :type forward_for: list[dict] Nrrr)r9r:rar;rrrrdrrxrrrr)rvrrrrr!s r?rxzInterrupt.__init__sN,G} 1 1121|tDzS]]:;:|t 4??'CCDC~f!>?>"d;&74&?@? ! RBx4''' B49 +>#BSBS+SSS2~2h<+?48 CUY\YfYfCfgg!R'DJ,@CMM,QQQ  R    'r@ct|dkDr|dtjk(sJt|dk7r#tdj t|t |dd}t |dd}d}d}d}d |vr|d }t|tjk7r#td j t||tjtjfvrtd j ||}d |vrt|d d }d|vr|d}d}t|tk(r|D]}t|tk7rnpd|vst|dtjvrnLd|vst|dtjk7rn'd|vs t|dtjk7snd}|s tdt||||} | S)rrr2z(invalid message length {0} for INTERRUPTr0z'request' in INTERRUPTr1z'options' in INTERRUPTNrz/invalid type {0} for 'mode' option in INTERRUPTz2invalid value '{0}' for 'mode' option in INTERRUPTrz"reason" in INTERRUPTrFrrrTzCinvalid type/value {0} for/within 'forward_for' option in INTERRUPT)rrr)rLrrrrKr"rhr9r:r;rrr!rrdra) rrrrrrrr*r!rs r?rzInterrupt.parses4y1}aI,B,B!BCB t9> J Q QRUVZR[ \] ]#DG-FG&tAw0IJ g !'*KK CMM1#$U$\$\]abm]n$opp9>>93G3G"HH#$X$_$_`k$lmmD  ' (:>r@cddj|j|j|jS)rz,Interrupt(request={0}, mode={1}, reason={2}))rKrrrrzs r?rzInterrupt.__str__s+?EEdllTXT]T]_c_j_jkkr@r) rrrrrrrrrxrrrrrr@r?rr|sLL DJI)'V::x?(lr@rcTeZdZdZdZ dZ d dZedZdZ dZ y) r aP A WAMP ``YIELD`` message. Formats: * ``[YIELD, INVOCATION.Request|id, Options|dict]`` * ``[YIELD, INVOCATION.Request|id, Options|dict, Arguments|list]`` * ``[YIELD, INVOCATION.Request|id, Options|dict, Arguments|list, ArgumentsKw|dict]`` * ``[YIELD, INVOCATION.Request|id, Options|dict, Payload|binary]`` FrNc t|tjvsJ|t|ttfvsJ|t|t k(sJ|t|tj k(sJ||||J|t|tk(sJ| t|sJ|||||J|t|tjk(sJ| t|sJ| t| tjvsJ| t| tjk(sJ| t| tjk(sJ| t| tk(sJ| r| D]} t| t k(sJd| vrt| dtjvsJd| vr$| d!t| dtjk(sJd| vr t| dtjk(rJtj|||_ ||_t||_||_||_||_||_||_| |_| |_| |_| |_y)aj :param request: The WAMP request ID of the original call. :type request: int :param args: Positional values for application-defined event payload. Must be serializable using any serializers in use. :type args: list or tuple or None :param kwargs: Keyword values for application-defined event payload. Must be serializable using any serializers in use. :type kwargs: dict or None :param payload: Alternative, transparent payload. If given, ``args`` and ``kwargs`` must be left unset. :type payload: bytes or None :param progress: If ``True``, this result is a progressive invocation result, and subsequent results (or a final error) will follow. :type progress: bool or None :param enc_algo: If using payload transparency, the encoding algorithm that was used to encode the payload. :type enc_algo: str or None :param enc_key: If using payload transparency with an encryption algorithm, the payload encryption key. :type enc_key: str or None :param enc_serializer: If using payload transparency, the payload object serializer that was used encoding the payload. :type enc_serializer: str or None :param callee: The WAMP session ID of the effective callee that responded with the error. Only filled if callee is disclosed. :type callee: None or int :param callee_authid: The WAMP authid of the responding callee. Only filled if callee is disclosed. :type callee_authid: None or unicode :param callee_authrole: The WAMP authrole of the responding callee. Only filled if callee is disclosed. :type callee_authrole: None or unicode :param forward_for: When this Call is forwarded for a client (or from an intermediary router). :type forward_for: list[dict] Nrrrrrs r?rxzYield.__init__7sxlG} 1 1121|tDzdE]:;:~f!565$w-3??"BCB7#64T#9:9#4X#>?> W_9OU\UhmunB DC$w-3=="@A@%)@)PQP~f1B1B!BCB$](;s}}(LML&$*?3==*PQP"d;&74&?@? ! RBx4''' B49 +>#BSBS+SSS2~2h<+?48 CUY\YfYfCfgg!R'DJ,@CMM,QQQ  R   &v.       , *.'r@ct|dkDr|dtjk(sJt|dvr#tdj t|t |dd}t |dd}d}d}d}d}d}d}t|d k(rt|d tjk(r|d }|jd d}|r%t|std j ||jd d}|r?t|tjk7r#tdj t||jdd}|rt|stdj |t|d kDr<|d }|5t|tk7r#tdj t|t|d kDr:|d }t|tk7r#tdj t|d} d} d} d} d} d|vr<|d}t|t k7r#tdj t||} d|vrE|d}t|tj"vr#tdj t||} d|vrF|d}t|tjk7r#tdj t||} d|vrF|d}t|tjk7r#tdj t||} d|vr|d} d}t| tk(r| D]}t|tk7rnpd|vst|dtj"vrnLd|vst|dtjk7rn'd|vs t|dtjk7snd }|s td!t||||| |||| | | | " }|S)#rrrz$invalid message length {0} for YIELDr0z'request' in YIELDr1z'options' in YIELDNr4r2r>z0invalid value {0} for 'enc_algo' detail in YIELDrz.invalid type {0} for 'enc_key' detail in YIELDrCz6invalid value {0} for 'enc_serializer' detail in YIELDz$invalid type {0} for 'args' in YIELDz&invalid type {0} for 'kwargs' in YIELDrz/invalid type {0} for 'progress' option in YIELDrz-invalid type {0} for 'callee' detail in YIELDrz4invalid type {0} for 'callee_authid' detail in YIELDrz6invalid type {0} for 'callee_authrole' detail in YIELDrFrrrTz?invalid type/value {0} for/within 'forward_for' option in YIELDr)rLr rrrKr"rhr9r:rGrr#r;r$rrdrra)rrrrrjrr>rrCrrrrroption_progress option_calleeoption_callee_authidoption_callee_authroler*r!rs r?rz Yield.parses 4y1}aE,>,>!>?> t9I % F M McRVi XY Y#DG-BC&tAw0EF t9>d47ms>1gG{{;5H 1( ;#$V$]$]^f$ghhkk*d3G4=CMM9#$T$[$[\`ah\i$jkk$[[):DAN&=n&M#$\$c$cdr$stt4y1}Aw#T d(:'(N(U(UVZ[_V`(abb4y1}a<4''(P(W(WX\]cXd(eff  ' !%k2OO$,#$U$\$\]abq]r$stt&H  #I.MM"#*;*;;#$S$Z$Z[_`m[n$opp"F w &#*+;#< ()S]]:#$Z$a$abfg{b|$}~~0M  (%,-?%@ "*+s}}<#$\$c$cdhieA%BCC4O W $!.1KEK D(%BBx4' *d2i=.AIZIZ.Zr)T"X,-?3==-P!+tBzN/Cs}}/T#$effG!#%%##1!"/$3 + - r@c>i}|j|j|d<|j|j|d<|j|j|d<|j|j|d<|j|j|d<|j ry|j |j |d<|j|j|d<|j|j|d<tj|j||j gS|jr3tj|j||j|jgS|jr(tj|j||jgStj|j|gSr)rrrrrrr>rrCr rrrjrrs r?rz Yield.marshalse == $#'==GK ;; "!%GI     )(,(:(:G$ %    +*.*>*>G& '    '&*&6&6GN # <<}}('+}} $||'&*ll #"".-1-@-@)*&& gt||L L{{**DLL'499dkkZZ**DLL'499MM**DLL'BBr@c<dj|j|j|j|j|j |j |jt|j|j|j|j|j S)rzYield(request={0}, args={1}, kwargs={2}, progress={3}, enc_algo={4}, enc_key={5}, enc_serializer={6}, payload={7}, callee={8}, callee_authid={9}, callee_authrole={10}, forward_for={11})rrzs r?rz Yield.__str__7s*LSSTXT`T`bfbkbkmqmxmxz~zGzGIMIVIVX\XdXdfjfyfy{~CKK{LNRNYNY[_[m[mosoCoCEIEUEUV Vr@rrrr@r?r r sh L I" $#!%!]'~yyv#CJVr@r )()WAMP message invalidFFFF)r )Q __future__rrerHr:rautobahn.wamp.exceptionrrautobahn.wamp.rolerr-r/ autobahn.wampr_HAS_WAMP_FLATBUFFERS ImportError__all__compilerSrVrTrWrRrUr<r%r&PAYLOAD_ENC_XBRr'rB ENC_ALGO_NONErrr ENC_ALGOSitemsENC_ALGOS_FROMSTR ENC_SER_NONErrrrENC_SER_OPAQUEENC_SER_FLATBUFFERSENC_SERSENC_SERS_FROMSTRr#r$rPr!r"rhrkobjectrr r r r r rrrrrrrrrrrrrrrrrrrr )rYkeys00r?r!s6'  B1!)! /F# #IJ"rzz"FG'BJJ'GH&2::&DE(RZZ(HI'BJJ'EFBJJ89 &%;