afRCddlZddlZddlZddlmZddlmZmZmZddl Z ddl m Z ddl m Z mZddlmZ ddlZddlZddlmZdZn #e$rd ZYnwxYwd Zejd Zejd Zejd ZejdZejdZejdZejdZejdZ ejdZ!ejdZ"ejdZ#dZ$dZ%dZ&e$e%e&gZ'gdZ(dZ)dZ*dZ+dZ,e)de*de+de,diZ-de-.DZ/dZ0dZ1dZ2dZ3dZ4d Z5d!Z6e0de1d"e2d#e3d$e4d%e5d&e6d'iZ7d(e7.DZ8d)Z9d*Z:dod,Z;d-ed.ee<fd/Z= dpd-ed1ed3e>d4e>d5e>d.eeFZGGd?d@eFZHGdAdBeFZIGdCdDeFZJGdEdFeFZKGdGdHeFZLGdIdJeFZMGdKdLeFZNGdMdNeFZOGdOdPeFZPGdQdReFZQGdSdTeFZRGdUdVeFZSGdWdXeFZTGdYdZeFZUGd[d\eFZVGd]d^eFZWGd_d`eFZXGdadbeFZYGdcddeFZZGdedfeFZ[GdgdheFZ\GdidjeFZ]GdkdleFZ^GdmdneFZ_dS)sN)pformat)AnyDictOptional)hlval) 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_realm_namecheck_or_raise_idcheck_or_raise_extrais_valid_enc_algois_valid_enc_serializeridentify_realm_name_categoryPAYLOAD_ENC_CRYPTO_BOXPAYLOAD_ENC_MQTT PAYLOAD_ENC_STANDARD_IDENTIFIERSz!^[A-Za-z][A-Za-z\d_\-@\.]{2,254}$z^0x([A-Fa-f\d]{40})$z^([a-z\d_\-@\.]{2,250})\.eth$z^eth\.([a-z\d_\-@\.]{2,250})$z!^(([\da-z_]+\.)|\.)*([\da-z_]+)?$z!^(([^\s\.#]+\.)|\.)*([^\s\.#]+)?$z^([\da-z_]+\.)*([\da-z_]+)$z^([^\s\.#]+\.)*([^\s\.#]+)$z^([\da-z_]+\.)*([\da-z_]*)$z^([^\s\.#]+\.)*([^\s\.#]*)$z^x_([a-z][\da-z_]+)?$ cryptoboxmqttxbr)jsonmsgpackcborubjson flatbuffersnullci|]\}}|| Sr<.0valuekeys G/var/www/html/env/lib/python3.11/site-packages/autobahn/wamp/message.py rBsDDDJE3S%DDDr2r3r4r5opaquer6ci|]\}}|| Sr<r<r=s rArBrBsBBB:5#CBBBrCcxt|tko"|tvpt|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 ``"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 )typestrr._CUSTOM_ATTRIBUTEmatch)enc_algos rAr)r)s5( >>S xh2R&R&wVgVmVmnvVwVwxrCcxt|tko"|tvpt|S)am 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 ``"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 )rJrK PAYLOAD_ENC_STANDARD_SERIALIZERSrLrM)enc_serializers rAr*r*sL,   3 & KN>^,^-Jbsbyby{IcJcJKrC(c0t|tkr|}nZt|tkr(tj|d}n|d}nd|}t||kr |d|dzS|S)Nascii-z{}z..)rJrKbytesbinasciib2a_hexdecodeformatlen)datamax_lenss rAb2ar_s DzzS  du    T " " ) )' 2 2   KK   1vv'{T!!rCr?returnct|tkrdSt|r:t|rdSt |rdSdSt |rdSdS)az Identify the real name category of the given value: * ``"standalone"``: A normal, standalone WAMP realm name, e.g. ``"realm1"``. * ``"eth"``: An Ethereum address, e.g. ``"0xe59C7418403CF1D973485B36660728a5f4A8fF9c"``. * ``"ens"``: An Ethereum ENS name, e.g. ``"wamp-proto.eth"``. * ``"reverse_ens"``: An Ethereum ENS name in reverse notation, e.g. ``"eth.wamp-proto"``. * ``None``: The value is not a WAMP realm name. :param value: The value for which to identify realm name category. :return: The category identified, one of ``["standalone", "eth", "ens", "reverse-ens"]`` or ``None``. Nens reverse_ens standaloneeth)rJrK_URI_PAT_REALM_NAMErM_URI_PAT_REALM_NAME_ENS_URI_PAT_REALM_NAME_ENS_REVERSE_URI_PAT_REALM_NAME_ETH)r?s rAr+r+s E{{ct  ''  " ( ( / / 5 , 2 25 9 9  =< & &u - -utrCWAMP message invalidmessagestrictallow_empty_componentsallow_last_empty allow_nonec |&|rdStd|t|tkr4||s0td|t||r|rt}n-|rt }n#t }n|rt}n|rt}nt}| |s-td|||j |||||S)a^ 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.InvalidUriError`, otherwise returns the value. :param value: The value to check. :param message: Prefix for message in exception raised when value is invalid. :param strict: If ``True``, do a strict check on the URI (the WAMP spec SHOULD behavior). :param allow_empty_components: If ``True``, allow empty URI components (for pattern based subscriptions and registrations). :param allow_last_empty: If ``True``, allow the last URI component to be empty (for prefix based subscriptions and registrations). :param allow_none: If ``True``, allow ``None`` for URIs. :returns: The URI value (if valid). :raises: instance of :class:`autobahn.wamp.exception.InvalidUriError` 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})) r rZrJrK_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_EMPTYrMpattern)r?rkrlrmrnropats rAr%r%sK( }  M F!";"B"B7"K"KLL L E{{c * !"A"H"HRVW\R]R]"^"^__ _ +  ,,CC # ,'CC+CC  ++CC # +&CC*C 99U  y@@AHJOQTQ\^df|~NPZ[[\\ \ rCcP|"td|t|tkr0td|t||rot|st |r|Std||tjt jt|r|Std||tj)a| 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.InvalidUriError`, otherwise returns the value. :param value: The value to check, e.g. ``"realm1"`` or ``"com.example.myapp"`` or ``"eth.example"``. :param message: Prefix for message in exception raised when value is invalid. :param allow_eth: If ``True``, allow Ethereum addresses as realm names, e.g. ``"0xe59C7418403CF1D973485B36660728a5f4A8fF9c"``. :returns: The URI value (if valid). :raises: instance of :class:`autobahn.wamp.exception.InvalidUriError` Nz{0}: realm name cannot be nullz${0}: invalid type {1} for realm namezO{0}: invalid value "{1}" for realm name (did not match patterns "{2}" or "{3}")zE{0}: invalid value "{1}" for realm name (did not match pattern "{2}"))r rZrJrKrfrMrirw)r?rk allow_eths rAr&r&7s# }>EEgNNOOO E{{cDKKGUYZ_U`U`aabbb>  $ $U + + K/F/L/LU/S/S KL!""(&%)<)D)@)H#J#JKK K  $ $U + + >L! 3 ;==>> >rCct|tkr0td|t||dks|dkr#td|||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. :param message: Prefix for message in exception raised when value is invalid. :returns: The ID value (if valid). :raises: instance of :class:`autobahn.wamp.exception.ProtocolError` z{0}: invalid type {1} for IDrlz{0}: invalid value {1} for ID)rJintrrZ)r?rks rAr'r'^su E{{c:AA'4PU;;WWXXX qyyE,,,;BB7ERRSSS LrCc Pt|tkr0td|t||D]H}t |t s1td|t||I|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. :param message: Prefix for message in exception raised when value is invalid. :returns: The extra dictionary (if valid). :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}')rJdictrrZkeys isinstancerK)r?rkks rAr(r(ss E{{dBII'SWX]S^S^__``` ZZ\\ss!S!! s U \ \]dfjklfmfmop q qrr r s LrCc X|t|tkr0td|t||D]H}t |t s1td|t||I|SdS)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}')r~)kwargsrkrs rA_validate_kwargsrs6 <<4   G N NwX\]cXdXd e eff f x xAa%% x#$Z$a$abikopqkrkrtu$v$vwww x rCcXeZdZdZdZ dZddZedZej dZedZ e j dZ ed Z e j d Z ed Z e j d Z d Z dZdefdZedZdZedZdZdZdZdS)r zo 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_last_router_internalch||_i|_d|_d|_d|_d|_d|_dSNr)selffrom_fbss rA__init__zMessage.__init__sE! $ $&*#$(!!%rCc|jSr)rrs rAcorrelation_idzMessage.correlation_ids ##rCcL|t|tksJ||_dSr)rJrKrrr?s rArzMessage.correlation_ids+}U s 2 2 22$rCc|jSr)rrs rAcorrelation_urizMessage.correlation_uris $$rCcL|t|tksJ||_dSr)rJrKrrs rArzMessage.correlation_uris+}U s 2 2 22 %rCc|jSr)rrs rAcorrelation_is_anchorzMessage.correlation_is_anchors **rCcL|t|tksJ||_dSr)rJboolrrs rArzMessage.correlation_is_anchors+}U t 3 3 33&+###rCc|jSr)rrs rAcorrelation_is_lastzMessage.correlation_is_lasts ((rCcL|t|tksJ||_dSr)rJrrrs rArzMessage.correlation_is_lasts+}U t 3 3 33$)!!!rCct||jsdS|jD]@}|dvr:|ds%t ||t ||ksdSAdS)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)rrrrr_T)r __class__ __slots__ startswithgetattr)rotherrs rA__eq__zMessage.__eq__s%00 5 ! !A111:;c9J9J 1 tQ''75!+<+<<< 55trCc.|| 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 rrrs rA__ne__zMessage.__ne__ s;;u%%%%rCr`c dt|jjdzddtt jt|dddS)Nz{} {}z::blueT)colorboldz F) rZrr__name__uppertextwrapindentrmarshalrs rA__str__zMessage.__str__stuT^%<%B%B%D%Dt%KSY`deee$X_WT\\^^5L5Lf%U%U]cjoppprr rrCct)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 rAparsez Message.parses"###rCctrrrs rArzMessage.marshal)!###rCctrrbufs rAcastz Message.cast,s!###rCctrr)rbuilders rAbuildz Message.build0rrCci|_dS)z1 Resets the serialization cache. N)rrs rAuncachezMessage.uncache3srCcv||jvr|jdkrjtjd}||}|||}t||j|<n/|| |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 r6i) rNAMEr6BuilderrFinishOutputrV serializer)r serializerrobjrs rArzMessage.serialize9s T- - --//%-d33jj))s###nn&&/4Szz ,,0:/C/CDLLNN/S/S , ++rCr)r __module__ __qualname____doc__ MESSAGE_TYPErrpropertyrsetterrrrrrrKr staticmethodrrrrrrr<rCrAr r s L I%%%% $$X$%%%%%X%&&&++X+!,,"!,))X)** *. & & &rrrrr $ $\ $$$$$$\$$$$ ,,,,,rCr cNeZdZdZdZ dZ ddZedZdZ dS) r zU A WAMP ``HELLO`` message. Format: ``[HELLO, Realm|uri, Details|dict]`` r7) realmroles authmethodsauthidauthrole authextra resumableresume_session resume_tokenNc |t|tsJt|tksJt |dksJ|D]:} | dvsJt|| t jjj| sJ;|r9t|tksJ|D]} t| tksJ|t|tksJ|t|tksJ|t|tksJ|t|tksJ|t|tksJ| t| tksJt |||_||_||_||_||_||_||_||_| |_dS)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)rrKrJrr[autobahnwamproler listrr|r rrrrrrrrrr) rrrrrrrrrrr authmethods rArzHello.__init__rsN} 5# 6 6}}6E{{d""""5zzA~~~~ Y YDJJJJJeDk8=+=+PQU+VWW X XW X  0 $$,,,,) 0 0 J''3.....~f!4!4!444>>S#8#8#88 DOOt$;$;$;; DOOt$;$;$;;%n)=)=)D)D)DD#tL'9'9S'@'@'@@  &   "",(rCc t|dkr|dtjksJt|dkr/tdt|t |ddd}t |dd }i}d |vrtd t |d d }t|dkrtd |D]}|dvr"td|t|}t ||d|}d|vr8t |dd||d$i|d}n |}|||<d} d|vr|d} t| tkr/tdt| | D]I} t| tkr/tdt| J| } d} d|vrQ|d} t| tkr/tdt| | } d}d|vrQ|d}t|tkr/tdt||}d}d|vrQ|d}t|tkr/tdt||}d}d|vrO|d}t|tkr/tdt|d}d|vrO|d}t|tkr/td t|d}d!|vrP|d!}t|tkr/td"t|n|rtd#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. rr9z$invalid message length {0} for HELLOr7z'realm' in HELLOT)ror8z'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<)r[r rrrZr%r(r rJrrKrrr|)rrdetailsr details_rolesrrole_cls details_role role_featuresrdetails_authmethods auth_methodrdetails_authidrdetails_authrolerdetails_authextrarrrrs rArz Hello.parses4yy1}}aE,>!>!>!>> t99>> F M McRVii X XYY Y"47,>4PPP&tAw0DEE ' ! ! WXX X,WW-=?^__ }   " " EFF F! ( (DJJJ#$Y$`$`ae$f$fggg)$/H/ d0CErEyEyz~EEAAL\))$\*%=?z@B@BCG@H@HIII ( D D< +C D D !) 'E$KK G # #")-"8 '((D00#$X$_$_`dex`y`y$z$z{{{2 @ @  $$++'(d(k(klpq|l}l}(~(~,.K w  $X.NN##s**#$S$Z$Z[_`n[o[o$p$pqqq#F  &z2 $%%,,#$U$\$\]abr]s]s$t$tuuu'H ' ! ! ' 4 %&&$..#$V$]$]^bct^u^u$v$vwww)I ' ! ! ,II$&&#$V$]$]^bcl^m^m$n$nooo w & &$%56NN##s**#$[$b$bcghvcwcw$x$xyyy W $ $">2LL!!S((#$Y$`$`aefrasas$t$tuuu) l#$jkkkE5+vxIWegstt rCcdii}|jD]}i|d|j<|jD]~}|dsg|dkrat ||Qd|d|jvrdii|d|j<t |||d|jd|<|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 rrROLENrrrrrrrr)rvaluesr__dict__rrrrrrrrrr rrrrrfeatures rArz Hello.marshal!sB-J%%'' ^ ^D*,GG TY '= ^ ^))#..^7f3D3DQUW^I_I_Ik!)9$))DDD7A26F(3GNtU\G]G]GG$TY/ ;GD  ^   '%)%5GM " ; " $ GH  = $"&-GJ  > %#'>GK > %#'>GK   *(,(;G$ %   (&*&7GN #"DJ88rC)NNNNNNN rrrrrrrrrrr<rCrAr r Zs L I" $"A)A)A)A)Fii\iV%9%9%9%9%9rCr cTeZdZdZdZ dZ ddZedZdZ dS) rzZ A WAMP ``WELCOME`` message. Format: ``[WELCOME, Session|id, Details|dict]`` r8) sessionrrrrr authproviderrresumedrrcustomNc ht|tksJt|tksJt|dksJ|D]:} | dvsJt || t jjj| sJ;|t|tksJ|t|tksJ|t|tksJ|t|tksJ|t|tksJ|t|tksJ| t| tksJ| t| tksJ| t| tksJ| t| tksJ| r!| D]}t |sJt|||_||_||_||_||_||_||_||_| |_| |_| |_| pi|_dS)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)rJr|rr[rrrrr rKrrLrMr rrrrrrrrrrrrr)rrrrrrrrrrrrrrrs rArzWelcome.__init__dsTfG}}####E{{d""""5zzA~~~~ Y YD/////eDk8=+=+PQU+VWW X XW X}U s 2 2 22~f!4!4!444>>S#8#8#88!T*%5%5%<%<%<<#tL'9'9S'@'@'@@ DOOt$;$;$;;$w--4"7"7"77 DOOt$;$;$;;#tL'9'9S'@'@'@@~f!5!5!55  3 3 3(..q112212      $(" "(l rCct|dkr|dtjksJt|dkr/tdt|t |dd}t |dd}|dd }|d d }|d d }|d d }|d d }|dd }d } d|vrO|d} t| tks/tdt| d } d|vrO|d} t| tks/tdt| d } d|vrP|d} t| tks/tdt| n| rtdi} d|vrtdt |dd} t| dkrtd| D]}|dvr"td|t|}t | |d|}d|vr>t |dd||di| |d}n |}|| |<i}|D]'}t |r ||||<(t|| ||||||| | | | }|S) rrr9z&invalid message length {0} for WELCOMEr7z'session' in WELCOMEr8z'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 WELCOMEr z5invalid 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<)r[rrrrZr'r(getrJrrKr rLrM)rrrrrrrrrrrrrrrrrrrrrs rArz Welcome.parses4yy1}}aG,@!@!@!@@ t99>> H O OPSTXPYPY Z Z[[ [#DG-CDD&tAw0FGG GT**Xt,,;;z400[[t44 {{>488 KK T22    i(G==D((#$V$]$]^bcj^k^k$l$lmmm ' ! ! ,I ??d**#$X$_$_`den`o`o$p$pqqq W $ $">2L %%,,#$[$b$bcghtcucu$v$vwww-  \ Z[[ [ ' ! ! YZZ Z,WW-=?`aa }   " " GHH H! ( (D///#$[$b$bcg$h$hiii)$/H/ d0CEtE{E{}AFBFBCCL\))$\*%=?|@D@DEI@J@JKKK ( K K=+>z+J K K !) 'E$KK ' 'A &&q)) '#AJq gueVXz 2#'>GK < .!%GI  > 2#'>GK   8&*&7GN #J%%'' ^ ^D*,GG TY '= ^ ^))#..^7f3D3DQUW^I_I_Ik!)9$))DDD7A26F(3GNtU\G]G]GG$TY/ ;GD  ^ $dlG<!>!>!>> t99>> F M McRVii X XYY Y&tAw0DEE#DG-@AA   %i0OO$$++#$T$[$[\`ap\q\q$r$rsss%GFG$$ rCcPi}|jr |j|d<tj||jgS)rrk)rkrrrrrs rArz Abort.marshals1 < .!%GI "GT[99rCrrr<rCrArr>sp LI  \@ : : : : :rCrc@eZdZdZdZ dZddZedZdZ dS) rz_ A WAMP ``CHALLENGE`` message. Format: ``[CHALLENGE, Method|string, Extra|dict]`` rD)methodextraNct|tksJ|t|tksJt|||_|pi|_dS)z :param method: The authentication method. :type method: str :param extra: Authentication method specific information. :type extra: dict or None N)rJrKrr rrr)rrrs rArzChallenge.__init__s`F||s""""}U t 3 3 33 [b rCct|dkr|dtjksJt|dkr/tdt||d}t |t kr/tdt |t|dd}t||}|S)rrr9z(invalid message length {0} for CHALLENGEr7z*invalid type {0} for 'method' in CHALLENGEr8z'extra' in CHALLENGE)r[rrrrZrJrKr()rrrrs rArzChallenge.parses4yy1}}aI,B!B!B!BB t99>> J Q QRUVZR[R[ \ \]] ]a <<3   L S STXY_T`T` a abb b$T!W.DEE&& rCc4tj|j|jgSr)rrrrrs rArzChallenge.marshals& TZ@@rCrrr<rCrArrst LI !!!! \2AAAAArCrc@eZdZdZdZ dZddZedZdZ dS) rzh A WAMP ``AUTHENTICATE`` message. Format: ``[AUTHENTICATE, Signature|string, Extra|dict]`` rE) signaturerNct|tksJ|t|tksJt|||_|pi|_dS)z :param signature: The signature for the authentication challenge. :type signature: str :param extra: Authentication method specific information. :type extra: dict or None N)rJrKrr rr!r)rr!rs rArzAuthenticate.__init__s`I#%%%%}U t 3 3 33"[b rCct|dkr|dtjksJt|dkr/tdt||d}t |t kr/tdt |t|dd}t||}|S)rrr9z+invalid message length {0} for AUTHENTICATEr7z0invalid type {0} for 'signature' in AUTHENTICATEr8z'extra' in AUTHENTICATE)r[rrrrZrJrKr()rr!rrs rArzAuthenticate.parses4yy1}}aL,E!E!E!EE t99>> M T TUXY]U^U^ _ _`` `G  ??c ! ! R Y YZ^_hZiZi j jkk k$T!W.GHH9e,, rCc4tj|j|jgSr)rrr!rrs rArzAuthenticate.marshals)4>4:FFrCrrr<rCrArrst LI !!!! \2GGGGGrCrcLeZdZdZdZ dZ dZeddfdZedZ dZ dS) rzZ A WAMP ``GOODBYE`` message. Format: ``[GOODBYE, Details|dict, Reason|uri]`` rFzwamp.close.normalrrkrNct|tksJ|t|tksJ|t|tksJt|||_||_||_dS)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)rJrKrr rrrkr)rrrkrs rArzGoodbye.__init__/sF||s""""$w--3"6"6"66 DOOt$;$;$;;  "rCct|dkr|dtjksJt|dkr/tdt|t |dd}t |dd}d}d}d |vrQ|d }t|tkr/td t||}d |vrO|d }t|tkr/td t|t||| }|S)rrr9z&invalid message length {0} for GOODBYEr7z'details' in GOODBYEr8z'reason' in GOODBYENrkz0invalid type {0} for 'message' detail in GOODBYErz2invalid type {0} for 'resumable' detail in GOODBYEr&) r[rrrrZr(r%rJrKr)rrrrkrrrs rArz Goodbye.parseDsV4yy1}}aG,@!@!@!@@ t99>> H O OPSTXPYPY Z Z[[ [&tAw0FGG#DG-BCC   %i0OO$$++#$V$]$]^bcr^s^s$t$tuuu%G ' ! ! ,II$&&#$X$_$_`den`o`o$p$pqqqV% )+++ rCcri}|jr |j|d<|jr |j|d<tj||jgS)rrkr)rkrrrrrs rArzGoodbye.marshalmsG < .!%GI  > 2#'>GK $gt{;;rC) rrrrrDEFAULT_REASONrrrrrr<rCrArrs L)NI -dd####*&&\&P<<<<#>> W_9OU\UhmunBnBC$w--3"6"6"66%)@)P)P%%P~f!4!4!44$](;(;s(B(B(BB&$*?*?3*F*F*FF"d;&7&74&?&?&??  H! H HBxx4'''' B49 +>+>#+E+E+EE2~~2h<+?48 CUCUY\C\C\C\]!R''DJ,@,@C,G,G,GG,G(   &v..  !  , *.'rCc t|dkr|dtjksJt|dvr/tdt||d}t |t kr"td||tjtjtjtjtjtjtjfvr"td|t|dd}t|d d }t!|d d }d }d }d }d }d } d } d } d } d } d }t|dkrt |dt"kr|d}|dd }|r1t'|s"td||dd } | rGt | t(kr/tdt | |dd } | r1t+| s"td| nt|dkrQ|d}|Gt |t,kr/tdt |t|dkrO|d}t |t.kr/tdt |d|vrQ|d}t |t kr/tdt ||} d|vrQ|d}t |t(kr/tdt ||} d|vrQ|d}t |t(kr/tdt ||} d|vr|d}d}t |t,kr|D]}t |t.krnmd |vst |d t krnId!|vst |d!t(krn%d"|vst |d"t(krnd#}|std$t|||||||| | | | | |% }|S)&rr)rErFz$invalid message length {0} for ERRORr7z,invalid type {0} for 'request_type' in ERRORz-invalid value {0} for 'request_type' in ERRORr8z'request' in ERRORr9z'details' in ERRORrDz'error' in ERRORNrFrErN0invalid value {0} for 'enc_algo' detail in EVENTr2.invalid type {0} for 'enc_key' detail in EVENTrQ6invalid 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 ERRORr3z4invalid type {0} for 'callee_authid' detail in ERRORr4z6invalid type {0} for 'callee_authrole' detail in ERRORr5FrrrTz?invalid type/value {0} for/within 'forward_for' option in ERROR) r0rr1rNr2rQrr3r4r5)r[rrrrZrJr|rrrrr rr"r'r(r%rVrr)rKr*rr)rr-r.rr/r0rr1rNr2rQrr3r4r5 detail_calleedetail_callee_authiddetail_callee_authrolevalidr8rs rArz Error.parses`4yy1}}aE,>!>!>!>> t99I % % F M McRVii X XYY YAw    $ $ N U UVb c cdd d  6 + 8 ' 4 ( 5 * 7 $ 1 * 7  9 9 9 O V VWc d dee e#DG-ABB&tAw0DEE"47,>??  t99>>d47mmu441gG{{:t44H i 1( ; ; i#$V$]$]^f$g$ghhhkk)T22G l4==C//#$T$[$[\`ah\i\i$j$jkkk$[[)94@@N u&=n&M&M u#$\$c$cdr$s$sttt4yy1}}Aw#T d(:(:'(N(U(UVZ[_V`V`(a(abbb4yy1}}a<<4'''(P(W(WX\]cXdXd(e(efff w  #H-MM""c))#$S$Z$Z[_`m[n[n$o$oppp"F g % %#*?#; ())S00#$Z$a$abfg{b|b|$}$}~~~0M  ' '%,->%? "*++s22#$\$c$cdhieAeA%B%BCCC4O G # #!-0KEK  D((%BBxx4'' **d2i=.A.AS.H.Hr))T"X,-?-?3-F-F!++tBzN/C/Cs/J/J0K g#$efffL!#%##1!"/$3 + - - - rCc&i}|j |j|d<|j |j|d<|j |j|d<|j |j|d<|jrT|j |j|d<|j |j|d<|j |j|d<|j|j |j ||j |jgS|j r'|j|j |j ||j |j |j gS|j r!|j|j |j ||j |j gS|j|j |j ||j gS) rNrr3r4r5rNr2rQ)rr3r4r5r1rNr2rQrr-r.r/rr0rs rArz Error.marshalsL ; " $ GH    )'+'9GO $   +)-)=G% &   '%)%5GM " < a}(&*m #|'%)\ "".,0,?()%t'8$,QUQ[]a]ij j{ a)4+`_. :type transaction_hash: str :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] Nrrrr) rJr|rKrr7rVrrr)r*r rrErFrGrrHrIrMrNrOrPrQrRrSrTrUrVrJrLrKrW)rr.topicr0rr1 acknowledge exclude_meexcludeexclude_authidexclude_authroleeligibleeligible_authideligible_authroleretaintransaction_hashrNr2rQr5r sessionidrrr8s rArzPublish.__init__s n$w--3"6"6"66}U s 2 2 22|tDzzdE3-FFFFF~f$U1C!C!C!CC$w--5"8"8"887#64>T#9#9#99  /% / / I#-----&$*?*?4*G*G*GG  ,) , ,F||s***** (D1B,C,Ct,K,K,KK  .- . .H~~,,,,,#4X#>#>> W_9OU\UhmunBnBC$w--3"6"6"66%)@)P)P%%P"d;&7&74&?&?&??  H! H HBxx4'''' B49 +>+>#+E+E+EE2~~2h<+?48 CUCUY\C\C\C\]!R''DJ,@,@C,G,G,GG,G111   '//  '& -!1! /"3 "2" -(rCct||jsdSt||sdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkrdS|j |j krdS|j |j krdS|j |j krdS|j |j krdS|j |j krdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkrdSdSNFT)rrr rr.rZr0rr1r[r\r]r^r_r`rarbrcrdrNr2rQr5rs rArzPublish.__eq__s%00 5~~dE** 5 =DL ( (5 ;$* $ $5 : " "5 <4; & &5 =DL ( (5   0 0 05  t . .5 =DL ( (5  4#6 6 65  !T%: : :5 >T] * *5  D$8 8 85  "d&< < <5 <4; & &5  !T%: : :5 >T] * *5 =DL ( (5  4#6 6 65   0 0 05trCc.|| Srrrs rArzPublish.__ne__;;u%%%%rCch|j%|jr|j|_|jSr)rErRequestrs rAr.zPublish.requests. = T^  N2244DM}rCcL|t|tksJ||_dSr)rJr|rErs rAr.zPublish.requests(}U s 2 2 22 rCc|j<|jr5|j}|r|d|_|jSNutf8rFrTopicrYrr^s rArZz Publish.topicG ; 4> $$&&A /hhv.. {rCcL|t|tksJ||_dSrrJrKrFrs rArZz Publish.topic(}U s 2 2 22 rCc|j]|jrV|jr=tjt |j|_|jSrrGr ArgsLengthcbor2loadsrV ArgsAsBytesrs rAr0z Publish.argsW : $. ~((** N"[t~/I/I/K/K)L)LMM zrCcV|t|ttfvsJ||_dSrrJrr7rGrs rAr0z Publish.args,}U e} < < << rCc|j]|jrV|jr=tjt |j|_|jSrrHr KwargsLengthrzr{rV KwargsAsBytesrs rArzPublish.kwargsW < DN ~**,, R${51M1M1O1O+P+PQQ |rCcL|t|tksJ||_dSrrJrrHrs rArzPublish.kwargs(}U t 3 3 33 rCc|j>|jr7|jr|j|_|jSrrIr PayloadLengthPayloadAsBytesrs rAr1zPublish.payloadE = T^ ~++-- @ $ = = ? ? }rCcL|t|tksJ||_dSrrJrVrIrs rAr1zPublish.payload (}U u 4 4 44 rCcp|j)|jr"|j}|r||_|jSr)rMr Acknowledge)rr[s rAr[zPublish.acknowledges>   $ $.4466K 0$/!  rCcL|t|tksJ||_dSr)rJrrMrs rAr[zPublish.acknowledges+}U t 3 3 33!rCct|j+|jr$|j}|dur||_|jS)NF)rNr ExcludeMe)rr\s rAr\zPublish.exclude_mesA   # #1133JU""#- rCcL|t|tksJ||_dSr)rJrrNrs rAr\zPublish.exclude_me%s+}U t 3 3 33 rCc|j|jrx|jr_g}t|jD]/}||j|0||_|jSr)rOr ExcludeLengthrangeappendExclude)rr]js rAr]zPublish.exclude*s = T^ ~++-- (t~;;==>>>>ANN4>#9#9!#<#<==== ' }rCc|t|tksJ|r|D]}t|tksJ||_dSr)rJrr|rOrr?xs rAr]zPublish.exclude4sT}U t 3 3 33  & & &Aww#~~~~~ rCcB|j|jr|jrrg}t|jD]B}||j|dC||_|jSrn)rPrExcludeAuthidLengthrr ExcludeAuthidrY)rr^rs rAr^zPublish.exclude_authid<s   'DN '~1133 6!#t~AACCDDZZA"))$.*F*Fq*I*I*P*PQW*X*XYYYY'5$##rCc|t|tksJ|r|D]}t|tksJ||_dSr)rJrrKrPrs rAr^zPublish.exclude_authidFsW}U t 3 3 33  & & &Aww#~~~~~$rCcB|j|jr|jrrg}t|jD]B}||j|dC||_|jSrn)rQrExcludeAuthroleLengthrrExcludeAuthrolerY)rr_rs rAr_zPublish.exclude_authroleNs  ! )dn )~3355 :#% t~CCEEFF^^A$++DN,J,J1,M,M,T,TU[,\,\]]]])9&%%rCc|t|tksJ|r|D]}t|tksJ||_dSr)rJrrKrQrs rAr_zPublish.exclude_authroleXsW}U t 3 3 33  & & &Aww#~~~~~!&rCc|j|jrx|jr_g}t|jD]/}||j|0||_|jSr)rRrEligibleLengthrrEligible)rr`rs rAr`zPublish.eligible`s > !dn !~,,.. *t~<<>>??@@AOODN$;$;A$>$>????!)~rCc|t|tksJ|r|D]}t|tksJ||_dSr)rJrr|rRrs rAr`zPublish.eligiblejsT}U t 3 3 33  & & &Aww#~~~~~rCcB|j|jr|jrrg}t|jD]B}||j|dC||_|jSrn)rSrEligibleAuthidLengthrrEligibleAuthidrY)rrars rArazPublish.eligible_authidrs  (T^ (~2244 8"$t~BBDDEE\\A#**4>+H+H+K+K+R+RSY+Z+Z[[[[(7%$$rCc|t|tksJ|r|D]}t|tksJ||_dSr)rJrrKrSrs rArazPublish.eligible_authid|sW}U t 3 3 33  & & &Aww#~~~~~ %rCcB|j|jr|jrrg}t|jD]B}||j|dC||_|jSrn)rTrEligibleAuthroleLengthrrEligibleAuthrolerY)rrbrs rArbzPublish.eligible_authroles  " *t~ *~4466 <$&!t~DDFFGG``A%,,T^-L-LQ-O-O-V-VW]-^-^____*;'&&rCc|t|tksJ|r|D]}t|tksJ||_dSr)rJrrKrTrs rArbzPublish.eligible_authrolesW}U t 3 3 33  & & &Aww#~~~~~"'rCcp|j)|jr"|j}|r||_|jSr)rUrRetain)rrcs rArczPublish.retains; < DN ^**,,F &% |rCcL|t|tksJ||_dSr)rJrrUrs rArczPublish.retainrrCc|j<|jr5|j}|r|d|_|jSrnrVrTransactionHashrYrrs rArdzPublish.transaction_hashJ  ! )dn )..00A :)*&)9)9&%%rCcL|t|tksJ||_dSrrJrKrVrs rArdzPublish.transaction_hash+}U s 2 2 22!&rCcp|j)|jr"|j}|r||_|jSrrJrEncAlgorrNs rArNzPublish.enc_algo; > !dn !~--//H *!)~rCcH||tttfvsJ||_dSrENC_ALGO_CRYPTOBOX ENC_ALGO_MQTT ENC_ALGO_XBRrJrs rArNzPublish.enc_algo*}*|jr7|jr|j|_|jSrrLr EncKeyLength EncKeyAsBytesrs rAr2zPublish.enc_keyD = T^ ~**,, ? $ < < > > }rCcL|t|tksJ||_dSrrJrVrLrs rAr2zPublish.enc_keyrrCcp|j)|jr"|j}|r||_|jSrrKr EncSerializerrrQs rArQzPublish.enc_serializer>   'DN '!^99;;N 6'5$##rCcT||ttttfvsJ||_dSr ENC_SER_JSONENC_SER_MSGPACK ENC_SER_CBORENC_SER_UBJSONrKrs rArQzPublish.enc_serializer/},We)f f f ff$rCc|jSrrWrs rAr5zPublish.forward_for   rCc||_dSrrrs rAr5zPublish.forward_for"rCc^ttj|dSNrrY)rr GetRootAsPublishrs rArz Publish.casts& 3 D DS! L LMMMMrCc|j}|r'|tj|}|j}|r'|tj|}|j}|r||}|j}|r||}|j}|r||}|j }|r||}|j }|rvtj |t|t|D]} || |t|}|j} | rg} | D]*} | || +tj |t| t| D]} || |t| } |j}| rg}|D]*}|||+tj |t|t|D]} || |t|}|j}|rvtj |t|t|D]} || |t|}|j}|rg}|D]*} ||| +tj |t|t|D]} || |t|}|j}|rg}|D]*}|||+tj |t|t|D]} || |t|}tj ||j%tj ||j|r tj |||r tj |||r tj !|||r tj "|||j#r%tj $||j#|j%r%tj &||j%|r tj '|||j(%tj )||j(|j*%tj +||j*|r tj ,||| r tj -|| |r tj .|||r tj /|||r tj 0|||r tj 1|||j2%tj 3||j2|%tj 4||jtj 5|}tj67|tj68|tj9j:tj6;||tj6<|}|Sr)=r0CreateByteVectorrzdumpsrr1rZ CreateStringrdr2r]r PublishGenPublishStartExcludeAuthidVectorr[reversed PrependUint64 EndVectorr^rPrependUOffsetTRelativer_!PublishStartExcludeAuthroleVectorr` PublishStartEligibleAuthidVectorrarb"PublishStartEligibleAuthroleVector PublishStartr.PublishAddRequestPublishAddTopicPublishAddArgsPublishAddKwargsPublishAddPayloadrNPublishAddEncAlgorQPublishAddEncSerializerPublishAddEncKeyr[PublishAddAcknowledger\PublishAddExcludeMePublishAddExcludePublishAddExcludeAuthidPublishAddExcludeAuthrolePublishAddEligiblePublishAddEligibleAuthidPublishAddEligibleAuthrolercPublishAddRetainPublishAddTransactionHash PublishEndr MessageStartMessageAddMsgType MessageTypePUBLISH MessageAddMsg MessageEnd)rrr0rr1rZrdr2r]rr^rPror_rQrr`rarSrbrTmsg union_msgs rArz Publish.buildsy  ?++EK,=,=>>D  C--ek&.A.ABBF,  8..w77G   0((//E0  F&334DEE ,  8..w77G,  6  " B B7CPWLL Y Y Y#G,, / /%%g....''G 55G,  E O( E E&&w';';F'C'CDDDD  " B B7CP_L`L` a a ao.. 3 3//2222$..s?/C/CDDN 0  I " , I I!(()=)=h)G)GHHHH  " D DWcRcNdNd e e e/00 3 3//2222&005F1G1GHH =  8  " C CGSQY]] [ [ [#H-- / /%%g....((X77H.  G! ) F F ''(<(*>x*H*HIIII  " E EgsSeOfOf g g g011 3 3//2222 ' 1 1#6H2I2I J J  ++G444 < #  " 4 4Wdl K K K  C  " 2 27E B B B  A  " 1 1'4 @ @ @  E  " 3 3GV D D D  G  " 4 4Wg F F F = M  " 4 4Wdm L L L   Y  " : :7DDW X X X  F  " 3 3GW E E E   '  " 8 8$BR S S S ? &  " 6 6w P P P  G  " 4 4Wg F F F  T  " : :7N S S S  X  " < >d47mmU|;;1gG{{:t44H k 1( ; ; k#$X$_$_`h$i$ijjjkk)T22G n4==C//#$V$]$]^bcj^k^k$l$lmmm$[[)94@@N w&=n&M&M w#$^$e$eft$u$uvvv4yy1}}Aw::dC%777'(P(W(WX\]aXbXb(c(cddd4yy1}}a<<c5'999'(R(Y(YZ^_eZfZf(g(ghhhHG!N    G # #!(!7 &''4//#$Z$a$abfgybzbz${${|||,K 7 " " ' 5 %&&$..#$Y$`$`aefwaxax$y$yzzz*J   $Y/NN##t++#$V$]$]^bcq^r^r$s$sttt, ~ ~  ##s**'(c(j(jkopzk{k{(|(|}}}+%G w & &$+,<$= !)**d22#$]$d$deijfAfA%B%BCCC0 B B==C'''(j(q(qrvw~rr)A)ABBB(3N  ( (&-.@&A #+,,44#$_$f$fgkmDhEhE%F%FGGG4 F F  ??c))'(l(s(stxzCuDuD)E)EFFF* 7   %j1OO$$,,#$W$^$^_cds_t_t$u$uvvv, ~ ~  ??c))'(d(k(klpqzl{l{(|(|}}}*'H  ' '%,->%? "*++t33#$^$e$efjlBgCgC%D%DEEE1 C C==C'''(k(r(rswxtAtA)B)BCCC(5O ' ) )'./B'C $,--55#$`$g$ghlnFiGiG%H%HIII5 G G  ??c))'(m(t(tuy{DvEvE)F)FGGG*!9  w  X&FF||t###$U$\$\]abh]i]i$j$jkkk  ( (&'9: $%%,,#$_$f$fgkl|g}g}$~$~ G # #!-0KEK  D((%BBxx4'' **d2i=.A.AS.H.Hr))T"X,-?-?3-F-F!++tBzN/C/Cs/J/J0K i#$ghhhg///4/$V/&g / #.+ / ", /&g/&4^/(8'7/ (x/'6o/):(9/$V/(8'7/ (x/ &g!/"&4^#/$#.+%/( rCci}|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 <|j |j |d <|j r3|j |j |d <|j |j |d <|j |j |d <|j |j|d<|S)Nr[r\r]r^r_r`rarbrcrdrNr2rQr5)r[r\r]r^r_r`rarbrcrdr1rNr2rQr5rrs rAmarshal_optionszPublish.marshal_optionsA sE   '%)%5GM " ? &$(OGL ! < #!%GI    *(,(;G$ %  ,*.*?G& ' = $"&-GJ    +)-)=G% &  ! -+/+AG' ( ; " $ GH   ,*.*?G& ' < @}(&*m #|'%)\ "".,0,?()   '%)%5GM "rCcT|}|jr tj|j||j|jgS|jr&tj|j||j|j|jgS|jr tj|j||j|jgStj|j||jgSr)rr1rrr.rZrr0rs rArzPublish.marshalg s&&(( < Q($,T\Z Z{ Q,dlGTZQUQZ\`\ghh Q,dlGTZQUQZ[[,dlGTZPPrC)NNNNNNNNNNNNNNNNNNNN)$rrrrrrrrrrr.rrZr0rr1r[r\r]r^r_r`rarbrcrdrNr2rQr5rrrrrrr<rCrArrsV  L9Ix!  $"&!%#'"& $!)l(l(l(l(\+++Z&&&X  ^^X \\X  [[X  ]]X  ^^!!X!"""  X !!!X ^^$$X$%%%&&X&'''X__%%X%&&&''X'(((X ]]&&X&'''X__X  ^^$$X$%%%!!X!"""NN\NNNN`JJ\JX$$$LQQQQQrCrc>eZdZdZdZ dZdZedZdZ dS)rzh A WAMP ``PUBLISHED`` message. Format: ``[PUBLISHED, PUBLISH.Request|id, Publication|id]`` )r. publicationct|tksJt|tksJt|||_||_dS)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)rJr|r rr.r#)rr.r#s rArzPublished.__init__ s]G}}####K  C'''' &rCcXt|dkr|dtjksJt|dkr/tdt|t |dd}t |dd}t||}|S)rrr9z(invalid message length {0} for PUBLISHEDr7z'request' in PUBLISHEDr8z'publication' in PUBLISHED)r[rrrrZr')rr.r#rs rArzPublished.parse s4yy1}}aI,B!B!B!BB t99>> J Q QRUVZR[R[ \ \]] ]#DG-EFF'Q1MNN -- rCc4tj|j|jgSr)rrr.r#rs rArzPublished.marshal s& d6FGGrCNrr<rCrArr{ so LI ''' \,HHHHHrCrcXeZdZdZdZ dZdZdZdZ d dZ e d Z d Z d Z dS) rzi A WAMP ``SUBSCRIBE`` message. Format: ``[SUBSCRIBE, Request|id, Options|dict, Topic|uri]`` exactprefixwildcard)r.rZrM get_retainedr5Nc t|tksJt|tksJ|t|tksJ|'|tjtjtjfvsJ|t|tusJ|t|tksJ|r|D]}t|tksJd|vrt|dtksJd|vr&|d t|dtksJd|vrt|dtksJt |||_ ||_ |p tj|_||_||_dS)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)rJr|rKr MATCH_EXACT MATCH_PREFIXMATCH_WILDCARDrrrr rr.rZrMr,r5)rr.rZrMr,r5r8s rArzSubscribe.__init__ s0G}}####E{{c!!!!}U s 2 2 22})*?AWYbYq)r r r rr#tL'9'9T'A'A'AA"d;&7&74&?&?&??  H! H HBxx4'''' B49 +>+>#+E+E+EE2~~2h<+?48 CUCUY\C\C\C\]!R''DJ,@,@C,G,G,GG,G  3i3 (&rCct|dkr|dtjksJt|dkr/tdt|t |dd}t |dd}t|dd d }tj}d }d }d |vr|d }t|tkr/tdt||tjtj tj fvr"td||}d|vrO|d}t|tkr/tdt|d|vr|d}d}t|tkr|D]} t| tkrnmd| vst| dt krnId| vst| dtkrn%d| vst| dtkrnd }|stdt|||||} | S)rrrDz(invalid message length {0} for SUBSCRIBEr7z'request' in SUBSCRIBEr8z'options' in SUBSCRIBEr9z'topic' in SUBSCRIBET)rmNrMz0invalid type {0} for 'match' option in SUBSCRIBEz1invalid value {0} for 'match' option in SUBSCRIBEr,z7invalid type {0} for 'get_retained' option in SUBSCRIBEr5FrrrzCinvalid type/value {0} for/within 'forward_for' option in SUBSCRIBE)rMr,r5)r[rrrrZr'r(r%r.rJrKr/r0rrrr|) rr.rrZrMr,r5 option_matchrAr8rs rArzSubscribe.parse s4yy1}}aI,B!B!B!BB t99>> J Q QRUVZR[R[ \ \]] ]#DG-EFF&tAw0HII"47,B[_```%  g  "7+LL!!S((#$V$]$]^bco^p^p$q$qrrrI$99;QS\Sk#lll#$W$^$^_k$l$lmmm E W $ $">2LL!!T))#$]$d$deijvewew$x$xyyy G # #!-0KEK  D((%BBxx4'' **d2i=.A.AS.H.Hr))T"X,-?-?3-F-F!++tBzN/C/Cs/J/J0K k#$ijjje,\ghhh rCci}|jr|jtjkr |j|d<|j |j|d<|j |j|d<|S)NrMr,r5)rMrr.r,r5rs rArzSubscribe.marshal_options@ s] : *$* (===#zGG    (&*&7GN #   '%)%5GM "rCcZtj|j||jgSr)rrr.rrZrs rArzSubscribe.marshalN s&& d6J6J6L6LdjYYrCNNN)rrrrrr.r/r0rrrrrrr<rCrArr s LKLNI"! *'*'*'*'X<<\<|   ZZZZZrCrc>eZdZdZdZ dZdZedZdZ dS)rzm A WAMP ``SUBSCRIBED`` message. Format: ``[SUBSCRIBED, SUBSCRIBE.Request|id, Subscription|id]`` !)r. subscriptionct|tksJt|tksJt|||_||_dS)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)rJr|r rr.r8)rr.r8s rArzSubscribed.__init__i ]G}}####L!!S(((( (rCcXt|dkr|dtjksJt|dkr/tdt|t |dd}t |dd}t||}|S)rrr9z)invalid message length {0} for SUBSCRIBEDr7z'request' in SUBSCRIBEDr8z'subscription' in SUBSCRIBED)r[rrrrZr')rr.r8rs rArzSubscribed.parsey 4yy1}}aJ,C!C!C!CC t99>> K R RSVW[S\S\ ] ]^^ ^#DG-FGG(a2PQQ ,// rCc4tj|j|jgSr)rrr.r8rs rArzSubscribed.marshal 't7HIIrCNrr<rCrArrX o LI ))) \,JJJJJrCrc@eZdZdZdZ dZddZedZdZ dS) rz A WAMP ``UNSUBSCRIBE`` message. Formats: * ``[UNSUBSCRIBE, Request|id, SUBSCRIBED.Subscription|id]`` * ``[UNSUBSCRIBE, Request|id, SUBSCRIBED.Subscription|id, Options|dict]`` ")r.r8r5Nct|tksJt|tksJ|r|D]}t|tksJd|vrt|dtksJd|vr&|d t|dtksJd|vrt|dtksJt|||_||_||_dS)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) rJr|rrKr rr.r8r5)rr.r8r5r8s rArzUnsubscribe.__init__ sG}}####L!!S((((  H! H HBxx4'''' B49 +>+>#+E+E+EE2~~2h<+?48 CUCUY\C\C\C\]!R''DJ,@,@C,G,G,GG,G (&rCc>t|dkr|dtjksJt|dvr/tdt|t |dd}t |dd}d}t|d krt |d d }d}|rd |vr|d }d }t|tkr|D]}t|tkrnmd |vst|d tkrnId|vst|dtkrn%d|vst|dtkrnd}|stdt|||}|S)rrr9rDz/invalid message length {0} for WAMP UNSUBSCRIBEr7z'request' in UNSUBSCRIBEr8z'subscription' in UNSUBSCRIBENr9z'options' in UNSUBSCRIBEr5FrrrTzEinvalid type/value {0} for/within 'forward_for' option in UNSUBSCRIBEr5) r[rrrrZr'r(rJrrr|rK)rr.r8rr5rAr8rs rArzUnsubscribe.parse s4yy1}}aK,D!D!D!DD t99F " " Q X XY\]aYbYb c cdd d#DG-GHH(a2QRR  t99q==*474NOOG  m}//!-0KEK  D((%BBxx4'' **d2i=.A.AS.H.Hr))T"X,-?-?3-F-F!++tBzN/C/Cs/J/J0K m#$klll'<[III rCc|jr#d|ji}tj|j|j|gStj|j|jgSrr5)r5rrr.r8rs rArzUnsubscribe.marshal sM   Ot/G ,dlD$,--44'(d(k(klprFmGmG)H)HIII3 7""+GH,=?YZZ7L&99 rCc|j|j8i}|j |j|d<|j |j|d<tj|j|gStj|jgS)rNrr8)rr8rrr.rs rArzUnsubscribed.marshal[ e ; "d&7&CG{&$(K! ,*.*;' -t|WE E -t|< `_. :type transaction_hash: str :param x_acknowledged_delivery: Whether this Event should be acknowledged. :type x_acknowledged_delivery: 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 forward_for: When this Event is forwarded for a client (or from an intermediary router). :type forward_for: list[dict] NrrrrY)rJr|rr7rrVrKrr)r*r rrTrUrGrrHrIrVrWrXrFrYrVrZrJrLrKrW)rr8r#r0rr1rpublisher_authidpublisher_authrolerZretainedrdx_acknowledged_deliveryrNr2rQr5rr8s rArzEvent.__init__ sdv#tL'9'9S'@'@'@@"d;&7&73&>&>&>>|tDzzdE]::::~f!5!5!55$w--5"8"8"887#64>T#9#9#99'40@+A+AS+H+H+HH&.$7N2O2OSW2W2W2WW#4X#>#>> W_9OU\UhmunBnBC$w--3"6"6"66%)@)P)P%%P"d;&7&74&?&?&??  H! H HBxx4'''' B49 +>+>#+E+E+EE2~~2h<+?48 CUCUY\C\C\C\]!R''DJ,@,@C,G,G,GG,G111)' '//  #!1#5  !!1(?%! -'rCct||jsdSt||sdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkrdS|j |j krdS|j |j krdS|j |j krdS|j |j krdS|j |j krdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkrdSdSrg)rrr rr8r#r0rr1rr\r]rZr^rdr_rNr2rQr5rs rArz Event.__eq__ s%00 5~~dE** 5  !2 2 25   0 0 05 : " "5 <4; & &5 =DL ( (5 ?dn , ,5  !T%: : :5  #t'> > >5 ;$* $ $5 >T] * *5  !T%: : :5  (D,H H H5 >T] * *5 =DL ( (5  4#6 6 65   0 0 05trCc.|| Srrrs rArz Event.__ne__> rirCch|j%|jr|j|_|jSr)rTr Subscriptionrs rAr8zEvent.subscriptionA s1   %$. %!%!!>D !!rCcL|t|tksJ||_dSr)rJr|rTrs rAr8zEvent.subscriptionG s+}U s 2 2 22"rCch|j%|jr|j|_|jSr)rUr Publicationrs rAr#zEvent.publicationL s1   $ $ $ : : < |jr7|jr|j|_|jSrrrs rAr1z Event.payloado rrCcL|t|tksJ||_dSrrrs rAr1z Event.payloadv rrCcp|j)|jr"|j}|r||_|jSr)rVr Publisher)rrs rArzEvent.publisher{ s; ? "t~ "0022I ,"+rCcL|t|tksJ||_dSr)rJr|rVrs rArzEvent.publisher s(}U s 2 2 22rCc|j<|jr5|j}|r|d|_|jSrn)rWrPublisherAuthidrYrrs rAr\zEvent.publisher_authid rrCcL|t|tksJ||_dSr)rJrKrWrs rAr\zEvent.publisher_authid rrCc|j<|jr5|j}|r|d|_|jSrn)rXrPublisherAuthrolerYrrs rAr]zEvent.publisher_authrole sJ  # + +0022A <+,88F+;+;(''rCcL|t|tksJ||_dSr)rJrKrXrs rAr]zEvent.publisher_authrole s+}U s 2 2 22#(   rCc|j<|jr5|j}|r|d|_|jSrnrprrs rArZz Event.topic rsrCcL|t|tksJ||_dSrrurs rArZz Event.topic rvrCch|j%|jr|j|_|jSr)rYrRetainedrs rAr^zEvent.retained s. > !dn !!^4466DN~rCcL|t|tksJ||_dSr)rJrrYrs rAr^zEvent.retained s(}U t 3 3 33rCc|j<|jr5|j}|r|d|_|jSrnrrrs rArdzEvent.transaction_hash rrCcL|t|tksJ||_dSrrrs rArdzEvent.transaction_hash rrCcp|j)|jr"|j}|r||_|jSr)rZrr)rr_s rAr_zEvent.x_acknowledged_delivery s@  ( 0T^ 0&*n&@&@&B&B #& H0G-,,rCcL|t|tksJ||_dSr)rJrrZrs rAr_zEvent.x_acknowledged_delivery s+}U t 3 3 33(-%%%rCcp|j)|jr"|j}|r||_|jSrrrs rArNzEvent.enc_algo rrCcH||tttfvsJ||_dSrrrs rArNzEvent.enc_algo rrCc|j>|jr7|jr|j|_|jSrrrs rAr2z Event.enc_key rrCcL|t|tksJ||_dSrrrs rAr2z Event.enc_key rrCcp|j)|jr"|j}|r||_|jSrrrs rArQzEvent.enc_serializer rrCcT||ttttfvsJ||_dSrrrs rArQzEvent.enc_serializer rrCc|jSrrrs rAr5zEvent.forward_for rrCc||_dSrrrs rAr5zEvent.forward_for rrCc^ttj|dSr)rr GetRootAsEventrs rArz Event.casts&k/>>sAFFGGGGrCcL|j}|r'|tj|}|j}|r'|tj|}|j}|r||}|j}|r||}|j}|r||}|j }|r||}|j }|r||}|j } | r|| } tj ||jr%tj ||j|jr%tj ||j|r tj |||r tj |||r tj |||jr%tj ||j|r tj |||r tj |||r tj |||j%tj ||j| tj |||j%tj ||j|j r%tj !||j | r tj "|| |j#r%tj $||j#tj %|} tj&'|tj&(|tj)j*tj&+|| tj&,|} | Sr)-r0rrzrrr1r\rr]rZrdr2r EventGen EventStartr8EventAddSubscriptionr#EventAddPublication EventAddArgsEventAddKwargsEventAddPayloadrEventAddPublisherEventAddPublisherAuthidEventAddPublisherAuthrole EventAddTopicr^EventAddRetainedEventAddTransactionHashr_EventAddAcknowledgerNEventAddEncAlgoEventAddEncKeyrQEventAddEncSerializerEventEndr rrrEVENTr r ) rrr0rr1r\r]rZrdr2r r s rArz Event.buildsy  ?++EK,=,=>>D  C--ek&.A.ABBF,  8..w77G0  F&334DEE !4  J!(!5!56H!I!I    0((//E0  F&334DEE ,  8..w77G''000   R  5 5gt?P Q Q Q   P  4 4Wd>N O O O  =  - -gt < < <  A  / / @ @ @  C  0 0' B B B > L  2 27DN K K K  T  8 8BR S S S  X  : :7DV W W W  ?  . .w > > > = $  1 1'4= I I I  '  8 8BR S S S  ' 3  4 4Wd>Z [ [ [ = I  0 0$- H H H  B  / / A A A   U  6 6w@S T T T"++G44((111--g{7N7TUUU))'3777'227;; rCc t|dkr|dtjksJt|dvr/tdt|t |dd}t |dd}t |dd }d }d }d }d }d }d } t|d krt|d tkr|d }| d d }|r1t|s"td|| dd }|rGt|tkr/tdt|| dd } | r1t| s"td| nt|d krQ|d }|Gt|tkr/tdt|t|d krO|d }t|tkr/tdt|d } d } d } d } d }d }d }d }d|vrQ|d}t|tkr/tdt||} d|vrQ|d}t|tkr/tdt||} d|vrQ|d}t|tkr/tdt||} d|vrQ|d}t|tkr/tdt||} d|vrO|d}t|t kr/tdt|d|vrQ|d}t|tkr/td t||}d!|vrO|d!}t|t kr/td"t|d#|vr|d#}d$}t|tkr|D]}t|tkrnmd%|vst|d%tkrnId&|vst|d&tkrn%d'|vst|d'tkrnd(}|std)t|||||| | | | |||||| |*}|S)+rrrz$invalid message length {0} for EVENTr7z'subscription' in EVENTr8z'publication' in EVENTr9z'details' in EVENTNrErDrNr;r2r<rQr=z$invalid type {0} for 'args' in EVENTz&invalid type {0} for 'kwargs' in EVENTrz0invalid type {0} for 'publisher' detail in EVENTr\z7invalid type {0} for 'publisher_authid' detail in EVENTr]z9invalid type {0} for 'publisher_authrole' detail in EVENTrZz,invalid type {0} for 'topic' detail in EVENTr^z/invalid type {0} for 'retained' detail in EVENTrd7invalid type {0} for 'transaction_hash' detail in EVENTr_z>invalid type {0} for 'x_acknowledged_delivery' detail in EVENTr5FrrrTz?invalid type/value {0} for/within 'forward_for' option in EVENT)r0rr1rr\r]rZr^rdr_rNr2rQr5)r[rrrrZr'r(rJrVrr)rKr*rrr|r)rr8r#rr0rr1rNr2rQrr\r]rZr^rdr5r_detail_publisherdetail_publisher_authiddetail_publisher_authrole detail_topicdetail_transaction_hashrAr8rs rArz Event.parseZs4yy1}}aE,>!>!>!>> t99I % % F M McRVii X XYY Y(a2KLL 'Q1IJJ &tAw0DEE t99>>d47mmu441gG{{:t44H i 1( ; ; i#$V$]$]^f$g$ghhhkk)T22G l4==C//#$T$[$[\`ah\i\i$j$jkkk$[[)94@@N u&=n&M&M u#$\$c$cdr$s$sttt4yy1}}Aw#T d(:(:'(N(U(UVZ[_V`V`(a(abbb4yy1}}a<<4'''(P(W(WX\]cXdXd(e(efff ! "& ' ! !&{3 $%%,,#$V$]$]^bcs^t^t$u$uvvv(I  ( (&-.@&A #+,,33#$]$d$deikBfCfC%D%DEEE6  7 * *(/0D(E %-..#55#$_$f$fgkmFhGhG%H%HIII!:  g  "7+LL!!S((#$R$Y$YZ^_kZlZl$m$mnnn E  z*HH~~%%#$U$\$\]abj]k]k$l$lmmm  ( (&-.@&A #+,,33#$]$d$deikBfCfC%D%DEEE6  $ / /&-.G&H #+,,44#$d$k$klprImJmJ%K%KLLL G # #!-0KEK  D((%BBxx4'' **d2i=.A.AS.H.Hr))T"X,-?-?3-F-F!++tBzN/C/Cs/J/J0K g#$efffL!#'%5'9%%5,C%##1 +---" rCci}|j |j|d<|j |j|d<|j |j|d<|j |j|d<|j |j|d<|j |j|d<|j |j|d<|j |j|d <|jrS|j |j |d <|j |j |d <|j |j |d <tj |j|j||jgS|jr&tj |j|j||j|jgS|jr tj |j|j||jgStj |j|j|gS) rNrr\r]rZr^rdr_r5rNr2rQ)rr\r]rZr^rdr_r5r1rNr2rQrrr8r#rr0rs rArz Event.marshals > %#'>GK  ,*.*?G& '  " .,0,CG( ) : !#zGG  = $"&-GJ   ,*.*?G& '  ' 3151MG- .   '%)%5GM " < Z}(&*m #|'%)\ "".,0,?()&(94;KWVZVbc c{ Z*D,=t?OQXZ^Zceiepqq Z*D,=t?OQXZ^Zcdd*D,=t?OQXYYrC)NNNNNNNNNNNNNNNNN) rrrrrrrrrrr8rr#r0rr1rr\r]rZr^rdr_rNr2rQr5rrrrrr<rCrArrm ss  L0Id]aW[OSOS e(e(e(e(N%%%N&&&""X" ###!!X! """X  [[X  ]]X  ^^X   &&X&'''((X()))X \\X __&&X&'''--X-#..$#.X__X  ^^$$X$%%%!!X!"""HH\HPPPdRR\Rh/Z/Z/Z/Z/ZrCrc>eZdZdZdZ dZdZedZdZ dS) EventReceivedzd A WAMP ``EVENT_RECEIVED`` message. Format: ``[EVENT_RECEIVED, EVENT.Publication|id]`` iQ)r#c|t|tksJt|||_dS)zl :param publication: The publication ID for the sent event. :type publication: int N)rJr|r rr#)rr#s rArzEventReceived.__init__2s? K  C''''&rCc*t|dkr|dtjksJt|dkr/tdt|t |dd}t|}|S)rrr8z-invalid message length {0} for EVENT_RECEIVEDr7z'publication' in EVENT_RECEIVED)r[rrrrZr')rr#rs rArzEventReceived.parse=s4yy1}}aM,F!F!F!FF t99>> O V VWZ[_W`W` a abb b'Q1RSS K(( rCc(tj|jgSr)rrr#rs rArzEventReceived.marshalSs*D,<==rCNrr<rCrArr!sjLI ' ' '\*>>>>>rCrc`eZdZdZdZ dZ d dZedZdZ dZ dS) 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. procedurer0rr1timeoutreceive_progressrdrNr2rQr caller_authidcaller_authroler5Nct|tksJt|tksJ|t|ttfvsJ|t|t ksJ|t|t ksJ||||J|t|tksJ|t|tksJ|t|tksJ| t| sJ| t| tksJ| t| sJ| | | || J| t| tksJ| t| tksJ|t|tksJ|t|tksJ|r|D]}t|t ksJd|vrt|dtksJd|vr&|d t|dtksJd|vrt|dtksJt |||_ ||_ ||_t||_||_||_||_||_| |_| |_| |_| |_| |_||_||_dS)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 transaction_hash: An application provided transaction hash for the originating call, which may be used in the router to throttle or deduplicate the calls on the procedure. See the discussion `here `_. :type transaction_hash: str :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)rJr|rKrr7rrVrr)r*r rr.rr0rrr1rrrdrNr2rQrrrr5)rr.rr0rr1rrrdrNr2rQrrrr5r8s rArz Call.__init__s.JG}}####I#%%%%|tDzzdE]::::~f!5!5!55$w--5"8"8"887#64#>>$w--3"6"6"66%)@)P)P%%P W_9OU\UhmunBnBC~f!4!4!44$](;(;s(B(B(BB&$*?*?3*F*F*FF"d;&7&74&?&?&??  H! H HBxx4'''' B49 +>+>#+E+E+EE2~~2h<+?48 CUCUY\C\C\C\]!R''DJ,@,@C,G,G,GG,G " &v..   0 0!  , *.&rCc t|dkr|dtjksJt|dvr/tdt|t |dd}t |dd}t|dd }d }d }d }d }d }d } t|d krt|d ttfvr|d }| d d }|r1t|s"td|| dd }|rGt|tkr/tdt|| dd } | r1t| s"td| nt|d krQ|d }|Gt|tkr/tdt|t|d krO|d }t|tkr/tdt|d } d } d } d } d }d }d }d|vry|d}t|t kr/tdt||dkr"td||} d|vrQ|d}t|t"kr/tdt||} d|vrQ|d}t|tkr/tdt||} d|vrQ|d}t|t kr/tdt||} d|vrQ|d}t|tkr/tdt||}d |vrQ|d }t|tkr/td!t||}d"|vr|d"}d#}t|tkr|D]}t|tkrnmd$|vst|d$t krnId%|vst|d%tkrn%d&|vst|d&tkrnd'}|std(t|||||| | | ||| | |||)}|S)*rrrz#invalid message length {0} for CALLr7z'request' in CALLr8z'options' in CALLr9z'procedure' in CALLNrErDrNz/invalid value {0} for 'enc_algo' detail in CALLr2z-invalid type {0} for 'enc_key' detail in CALLrQz5invalid 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 CALLrdz6invalid type {0} for 'transaction_hash' detail 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 CALLr5FrrrTz>invalid type/value {0} for/within 'forward_for' option in CALL) r0rr1rrrdrNr2rQrrrr5)r[rrrrZr'r(r%rJrKrVrr)r*rrr|r)rr.rrr0rr1rNr2rQrrrdrrrr5option_timeoutoption_receive_progressoption_transaction_hash option_calleroption_caller_authidoption_caller_authrolerAr8rs rArz Call.parsesA4yy1}}aD,=!=!=!== t99I % % E L LSQUYY W WXX X#DG-@AA&tAw0CDD&tAw0EFF  t99>>d47mmU|;;1gG{{:t44H h 1( ; ; h#$U$\$\]e$f$fgggkk)T22G k4==C//#$S$Z$Z[_`g[h[h$i$ijjj$[[)94@@N t&=n&M&M t#$[$b$bcq$r$rsss4yy1}}Aw#T d(:(:'(M(T(TUYZ^U_U_(`(`aaa4yy1}}a<<4'''(O(V(VW[\bWcWc(d(deee    $Y/NN##s**#$S$Z$Z[_`n[o[o$p$pqqq!!#$T$[$[\j$k$klll$G  ( (&-.@&A #+,,44#$\$c$cdhjAeBeB%C%CDDD6   ( (&-.@&A #+,,33#$\$c$cdhjAeBeB%C%CDDD6  w  #H-MM""c))#$R$Y$YZ^_lZmZm$n$nooo"F g % %#*?#; ())S00#$Y$`$`aefza{a{$|$|}}}0M  ' '%,->%? "*++s22#$[$b$bcgh~cc%A%ABBB4O G # #!-0KEK  D((%BBxx4'' **d2i=.A.AS.H.Hr))T"X,-?-?3-F-F!++tBzN/C/Cs/J/J0K f#$deee7 ""$4$4$""0 !.#2*,,,  rCcli}|j |j|d<|j |j|d<|j |j|d<|jr3|j |j|d<|j |j|d<|j |j|d<|j |j|d<|j |j|d<|j |j |d <|j |j |d <|S) NrrrdrNr2rQrrrr5) rrrdr1rNr2rQrrrr5rs rArzCall.marshal_optionss < #!%GI   ,*.*?G& '  ,*.*?G& ' < @}(&*m #|'%)\ "".,0,?() ; " $ GH    )'+'9GO $   +)-)=G% &   '%)%5GM "rCcT|}|jr tj|j||j|jgS|jr&tj|j||j|j|jgS|jr tj|j||j|jgStj|j||jgSr)rr1rrr.rrr0rs rArz Call.marshals&&(( < R%t|Wdndl[ [{ R)4<$.RVR[]a]hii R)4<$.RVR[\\)4<$.QQrC) NNNNNNNNNNNNN) rrrrrrrrrrrr<rCrArr]s  LI*"&"& $#!%!t't't't'lRR\Rh@RRRRRrCrcLeZdZdZdZ dZdZdZdZd dZ e d Z d Z dS) 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)r.moder5Ncdt|tksJ|t|tksJ|d|j|j|jfvsJ|t|t ksJ|r|D]}t|tksJd|vrt|dtksJd|vr&|d t|dtksJd|vrt|dtksJt |||_ ||_ ||_ dS)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) rJr|rKSKIP KILLNOWAITKILLrrr rr.rr5)rr.rr5r8s rArzCancel.__init__sUG}}####|tDzzS0000di$)DDDDD"d;&7&74&?&?&??  H! H HBxx4'''' B49 +>+>#+E+E+EE2~~2h<+?48 CUCUY\C\C\C\]!R''DJ,@,@C,G,G,GG,G  'rCc$t|dkr|dtjksJt|dkr/tdt|t |dd}t |dd}d}d}d |vr|d }t|tkr/td t||tj tj tj fvr"td ||}d |vr|d }d }t|tkr|D]}t|tkrnmd|vst|dtkrnId|vst|dtkrn%d|vst|dtkrnd}|stdt|||}|S)rrr9z%invalid message length {0} for CANCELr7z'request' in CANCELr8z'options' in CANCELNrz,invalid type {0} for 'mode' option in CANCELz/invalid value '{0}' for 'mode' option in CANCELr5FrrrTz@invalid type/value {0} for/within 'forward_for' option in CANCEL)rr5)r[rrrrZr'r(rJrKrrrrrr|) rr.rrr5 option_moderAr8rs rArz Cancel.parses4yy1}}aF,?!?!?!?? t99>> G N NsSWyy Y YZZ Z#DG-BCC&tAw0EFF W  !&/KK  C''#$R$Y$YZ^_jZkZk$l$lmmm6;0A6;"OOO#$U$\$\]h$i$ijjjD G # #!-0KEK  D((%BBxx4'' **d2i=.A.AS.H.Hr))T"X,-?-?3-F-F!++tBzN/C/Cs/J/J0K h#$fgggW4[AAA rCcri}|j |j|d<|j |j|d<tj|j|gS)rNrr5)rr5rrr.rs rArzCancel.marshal/sD 9 "iGFO   '%)%5GM "#T\7;;rCrQ) rrrrrrrrrrrrrr<rCrArrsL D DJI ''''>66\6p<<<<>T#9#9#99#4X#>#>>$w--3"6"6"66%)@)P)P%%P W_9OU\UhmunBnBC~f!4!4!44$](;(;s(B(B(BB&$*?*?3*F*F*FF"d;&7&74&?&?&??  H! H HBxx4'''' B49 +>+>#+E+E+EE2~~2h<+?48 CUCUY\C\C\C\]!R''DJ,@,@C,G,G,GG,G  &v..    !  , *.'rCc t|dkr|dtjksJt|dvr/tdt|t |dd}t |dd}d}d}d}d}d}d}d} d} d} d} d} t|d krt|d ttfvr|d }| d d}|r1t|s"td || d d}|rGt|tkr/tdt|| dd} | r1t| s"td| nt|d krQ|d }|Gt|tkr/tdt|t|d krO|d }t|tkr/tdt|d|vrQ|d}t|tkr/tdt||}d|vrQ|d}t|t kr/tdt||} d|vrQ|d}t|tkr/tdt||} d|vrQ|d}t|tkr/tdt||} d|vr|d} d}t| tkr| D]}t|tkrnmd|vst|dt krnId|vst|dtkrn%d|vst|dtkrnd }|std!t|||||||| | | | | " }|S)#rrr9rDrEz%invalid message length {0} for RESULTr7z'request' in RESULTr8z'details' in RESULTNrDr9rNz1invalid value {0} for 'enc_algo' detail in RESULTr2z/invalid type {0} for 'enc_key' detail in RESULTrQz7invalid 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 RESULTr3z5invalid type {0} for 'callee_authid' detail in RESULTr4z7invalid type {0} for 'callee_authrole' detail in RESULTr5FrrrTz@invalid type/value {0} for/within 'forward_for' option in RESULT r0rr1rrNr2rQrr3r4r5)r[rrrrZr'r(rJrKrVrr)r*rrrr|)rr.rr0rr1rrNr2rQrr3r4r5detail_progressr>r?r@rAr8rs rArz Result.parses4yy1}}aF,?!?!?!?? t99I % % G N NsSWyy Y YZZ Z#DG-BCC&tAw0EFF  t99>>d47mmU|;;1gG{{:t44H j 1( ; ; j#$W$^$^_g$h$hiiikk)T22G m4==C//#$U$\$\]abi]j]j$k$klll$[[)94@@N v&=n&M&M v#$]$d$des$t$tuuu4yy1}}Aw#T d(:(:'(O(V(VW[\`WaWa(b(bccc4yy1}}a<<4'''(Q(X(XY]^dYeYe(f(fggg  %j1OO$$,,#$V$]$]^bcr^s^s$t$tuuu&H w  #H-MM""c))#$T$[$[\`an\o\o$p$pqqq"F g % %#*?#; ())S00#$[$b$bcgh|c}c}$~$~0M  ' '%,->%? "*++s22#$]$d$deikAfBfB%C%CDDD4O G # #!-0KEK  D((%BBxx4'' **d2i=.A.AS.H.Hr))T"X,-?-?3-F-F!++tBzN/C/Cs/J/J0K h#$fgggW"$&&$$2"#0%4!, . . . rCci}|j |j|d<|j |j|d<|j |j|d<|j |j|d<|j |j|d<|jrM|j |j|d<|j |j|d<|j |j|d <tj |j ||jgS|j r tj |j ||j |j gS|j rtj |j ||j gStj |j |gS rNrrr3r4r5rNr2rQ)rrr3r4r5r1rNr2rQrrr.rr0rs rArzResult.marshal=s, = $"&-GJ  ; " $ GH    )'+'9GO $   +)-)=G% &   '%)%5GM " < D}(&*m #|'%)\ "".,0,?()'w M M{ D+T\7DIt{[[ D+T\7DINN+T\7CCrC NNNNNNNNNNNrr<rCrArr@s  L I" $#!%!`'`'`'`'Dxx\xt#D#D#D#D#DrCrcteZdZdZdZ dZdZdZdZdZ dZ d Z d Z d Z d Z ddZedZdZdZd S)rzk A WAMP ``REGISTER`` message. Format: ``[REGISTER, Request|id, Options|dict, Procedure|uri]`` @r)r*r+singlefirstlast roundrobinrandomall)r.rrMinvoke concurrencyforce_reregisterr5Nc&t|tksJt|tksJ|t|tksJ|'|tjtjtjfvsJ|t|tksJ|=|tjtjtj tj tj fvsJ| t|tkr|dksJ|dvsJ|t|tksJ|r|D]}t|tksJd|vrt|dtksJd|vr&|d t|dtksJd|vrt|dtksJt|||_||_|p tj|_|p tj|_||_||_||_dS)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)rJr|rKrr.r/r0 INVOKE_SINGLE INVOKE_FIRST INVOKE_LASTINVOKE_ROUNDROBIN INVOKE_RANDOMrrr rr.rrMrrrr5) rr.rrMrrrr5r8s rArzRegister.__init__s>:G}}####I#%%%%}U s 2 2 22}(*>@UW_Wn)o o o oo~f!4!4!44~H,BHDY[c[oqyrLNVNd,e"e"e"ee"tK'8'8C'?'?KRSOOOT#66666"d;&7&74&?&?&??  H! H HBxx4'''' B49 +>+>#+E+E+EE2~~2h<+?48 CUCUY\C\C\C\]!R''DJ,@,@C,G,G,GG,G "2h2 6 6 & 0&rCc &t|dkr|dtjksJt|dkr/tdt|t |dd}t |dd}tj}tj}d}d}d}d |vr|d }t|tkr/td t||tjtj tj fvr"td ||}|tjkrd } d } n9|tj krd } d } n$|tj krd } d } ntdt|dd| | } d|vr|d} t| tkr/tdt| | tjtjtjtjtjfvr"td| | }d|vry|d} t| t&kr/tdt| | dkr"td| | }|dd}|dvr/tdt|||}d|vr|d}d }t|t*kr|D]}t|t,krnmd|vst|dt&krnId|vst|dtkrn%d|vst|dtkrnd }|stdt|| ||||| }|S)!rrrDz'invalid message length {0} for REGISTERr7z'request' in REGISTERr8z'options' in REGISTERNrMz/invalid type {0} for 'match' option in REGISTERz0invalid value {0} for 'match' option in REGISTERFTz logic errorr9z'procedure' in REGISTER)rmrnrz0invalid 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 REGISTERr5rrrzBinvalid type/value {0} for/within 'forward_for' option in REGISTER)rMrrrr5)r[rrrrZr'r(r.rrJrKr/r0 Exceptionr%rrrrr|rrr)rr.rrMrrrr5r2rmrnr option_invokeoptions_concurrencyoptions_reregisterrAr8rs rArzRegister.parsesj4yy1}}aH,A!A!A!AA t99>> I P PQTUYQZQZ [ [\\ \#DG-DEE&tAw0GHH$'  g  "7+LL!!S((#$U$\$\]abn]o]o$p$pqqqH$8(:OQYQh#iii#$V$]$]^j$k$klll E H( ( (%* "$   h+ + +%* "#   h- - -%) "$  M** *&tAw0IbxL\]]] w  #H-MM""c))#$V$]$]^bcp^q^q$r$rsssX%;X=RT\ThjrkEGOG]%^^^#$W$^$^_l$m$mnnn"F G # #")-"8 '((C//#$[$b$bcgh{c|c|$}$}~~~"Q&&#$\$c$cdw$x$xyyy-K$[[);TBB %8 8 8KRR+,,   )1  G # #!-0KEK  D((%BBxx4'' **d2i=.A.AS.H.Hr))T"X,-?-?3-F-F!++tBzN/C/Cs/J/J0K j#$hiiiw vS^(8kSSS rCci}|jr|jtjkr |j|d<|jr|jtjkr |j|d<|jr |j|d<|j |j|d<|j |j|d<|S)NrMrrrr5)rMrr.rrrrr5rs rArzRegister.marshal_options&s : *$*(<<<#zGG  ; ,4;(*@@@ $ GH    6%)%5GM "  ,*.*?G& '   '%)%5GM "rCcZtj|j||jgSr)rrr.rrrs rArzRegister.marshal:s&%t|T5I5I5K5KT^\\rC)NNNNN)rrrrrr.r/r0rrrrr INVOKE_ALLrrrrrrr<rCrArrcs LKLNMLK$MJI!"&!4'4'4'4'lii\iV(]]]]]rCrc>eZdZdZdZ dZdZedZdZ dS)rzl A WAMP ``REGISTERED`` message. Format: ``[REGISTERED, REGISTER.Request|id, Registration|id]`` A)r. registrationct|tksJt|tksJt|||_||_dS)z :param request: The request ID of the original ``REGISTER`` request. :type request: int :param registration: The registration ID for the registered procedure (or procedure pattern). :type registration: int N)rJr|r rr.r)rr.rs rArzRegistered.__init__Ur:rCcXt|dkr|dtjksJt|dkr/tdt|t |dd}t |dd}t||}|S)rrr9z)invalid message length {0} for REGISTEREDr7z'request' in REGISTEREDr8z'registration' in REGISTERED)r[rrrrZr')rr.rrs rArzRegistered.parseer<rCc4tj|j|jgSr)rrr.rrs rArzRegistered.marshal|r>rCNrr<rCrArrDr?rCrc@eZdZdZdZ dZddZedZdZ dS) r z A WAMP `UNREGISTER` message. Formats: * ``[UNREGISTER, Request|id, REGISTERED.Registration|id]`` * ``[UNREGISTER, Request|id, REGISTERED.Registration|id, Options|dict]`` B)r.rr5Nct|tksJt|tksJt|||_||_||_dS)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)rJr|r rr.rr5)rr.rr5s rArzUnregister.__init__seG}}####L!!S(((( (&rCc>t|dkr|dtjksJt|dvr/tdt|t |dd}t |dd}d}t|d krt |d d }d}|rd |vr|d }d }t|tkr|D]}t|tkrnmd |vst|d tkrnId|vst|dtkrn%d|vst|dtkrnd}|stdt|||}|S)rrrDz.invalid message length {0} for WAMP UNREGISTERr7z'request' in UNREGISTERr8z'registration' in UNREGISTERNr9z'options' in UNREGISTERr5FrrrTzDinvalid type/value {0} for/within 'forward_for' option in UNREGISTERrE) r[r rrrZr'r(rJrrr|rK)rr.rrr5rAr8rs rArzUnregister.parses4yy1}}aJ,C!C!C!CC t99F " " P W WX[\`XaXa b bcc c#DG-FGG(a2PQQ  t99q==*474MNNG  l}//!-0KEK  D((%BBxx4'' **d2i=.A.AS.H.Hr))T"X,-?-?3-F-F!++tBzN/C/Cs/J/J0K l#$jkkk,KHHH rCc|jr#d|ji}tj|j|j|gStj|j|jgSrG)r5r rr.rrs rArzUnregister.marshalsM   Nt/G+T\4;LgV V+T\4;LM MrCrrr<rCrAr r suLI ''''*++\+Z N N N N NrCr c@eZdZdZdZ dZddZedZdZ dS) r!z A WAMP ``UNREGISTERED`` message. Formats: * ``[UNREGISTERED, UNREGISTER.Request|id]`` * ``[UNREGISTERED, UNREGISTER.Request|id, Details|dict]`` C)r.rrNc4t|tksJ|t|tksJ|t|tksJ|dkr||dkr|dksJt|||_||_||_dS)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)rJr|rKr rr.rr)rr.rrs rArzUnregistered.__init__sG}}#####tL'9'9S'@'@'@@~f!4!4!441 !57a<`_. :type transaction_hash: str :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 forward_for: When this Call is forwarded for a client (or from an intermediary router). :type forward_for: list[dict] Nrrr)rJr|rr7rrVrrKr)r*r rr.rr0rrr1rrrrrrrdrNr2rQr5)rr.rr0rr1rrrrrrrdrNr2rQr5r8s rArzInvocation.__init__vsPPG}}####L!!S((((|tDzzdE]::::~f!5!5!55$w--5"8"8"887#64#>>$w--3"6"6"66%)@)P)P%%P W_9OU\UhmunBnBC"d;&7&74&?&?&??  H! H HBxx4'''' B49 +>+>#+E+E+EE2~~2h<+?48 CUCUY\C\C\C\]!R''DJ,@,@C,G,G,GG,G ( &v..   0 *." 0   ,'rCc8 t|dkr|dtjksJt|dvr/tdt|t |dd}t |dd}t |dd }d }d }d }d }d }d } t|d krt|d tkr|d }| d d }|r1t|s"td|| dd }|rGt|tkr/tdt|| dd } | r1t| s"td| nt|d krQ|d }|Gt|tkr/tdt|t|d krO|d }t|tkr/tdt|d } d } d } d } d }d }d }d }d|vry|d}t|tkr/tdt||dkr"td||} d|vrQ|d}t|t kr/tdt||} d|vrQ|d}t|tkr/tdt||} d|vrQ|d}t|tkr/tdt||} d|vrQ|d}t|tkr/tdt||}d |vrQ|d }t|tkr/td!t||}d"|vrQ|d"}t|tkr/td#t||}d$|vr|d$}d%}t|tkr|D]}t|tkrnmd&|vst|d&tkrnId'|vst|d'tkrn%d(|vst|d(tkrnd)}|std*t|||||| | | | |||||| |+}|S),rrrz)invalid message length {0} for INVOCATIONr7z'request' in INVOCATIONr8z'registration' in INVOCATIONr9z'details' in INVOCATIONNrErDrNz5invalid value {0} for 'enc_algo' detail in INVOCATIONr2z3invalid type {0} for 'enc_key' detail in INVOCATIONrQz;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 INVOCATIONrz>d47mmu441gG{{:t44H n 1( ; ; n#$[$b$bck$l$lmmmkk)T22G q4==C//#$Y$`$`aefmanan$o$oppp$[[)94@@N z&=n&M&M z#$a$h$hiw$x$xyyy4yy1}}Aw#T d(:(:'(S(Z(Z[_`d[e[e(f(fggg4yy1}}a<<4'''(U(\(\]abh]i]i(j(jkkk     $Y/NN##s**#$Y$`$`aeftauau$v$vwww!!#$Z$a$abp$q$qrrr$G  ( (&-.@&A #+,,44#$b$i$ijnpGkHkH%I%IJJJ6  w  #H-MM""c))#$X$_$_`der`s`s$t$tuuu"F g % %#*?#; ())S00#$_$f$fgkmAhBhB%C%CDDD0M  ' '%,->%? "*++s22#$a$h$himoEjFjF%G%GHHH4O ' ! !&{3 $%%,,#$[$b$bcghxcycy$z$z{{{(I  ( (&-.@&A #+,,33#$]$d$deikBfCfC%D%DEEE6  G # #!-0KEK  D((%BBxx4'' **d2i=.A.AS.H.Hr))T"X,-?-?3-F-F!++tBzN/C/Cs/J/J0K l#$jkkk%" &!(!(*: &'4)8#,*:"*!((6%0222" rCci}|j |j|d<|j |j|d<|j |j|d<|j |j|d<|j |j|d<|j |j|d<|j |j|d<|j |j|d <|jrS|j |j |d <|j |j |d <|j |j |d <tj |j|j||jgS|jr&tj |j|j||j|jgS|jr tj |j|j||jgStj |j|j|gS) rNrrrrrrrdr5rNr2rQ)rrrrrrrdr5r1rNr2rQr"rr.rrr0rs rArzInvocation.marshals < #!%GI   ,*.*?G& ' ; " $ GH    )'+'9GO $   +)-)=G% & > %#'>GK  ,*.*?G& '   '%)%5GM " < [}(&*m #|'%)\ "".,0,?()+T\4;LgW[Wcd d{ ["/t?PRY[_[dfjfqrr ["/t?PRY[_[dee"/t?PRYZZrC)NNNNNNNNNNNNNNrr<rCrAr"r"Rs  LI,"&#!%"& $!!t't't't'l\\\\|/[/[/[/[/[rCr"cHeZdZdZdZ dZdZdZd dZe dZ d Z dS) r#z 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)r.rrr5Nct|tksJ|t|tksJ|||j|jfvsJ|t|tksJ|t|t ksJ|r|D]}t|t ksJd|vrt|dtksJd|vr&|d t|dtksJd|vrt|dtksJt|||_ ||_ ||_ ||_ dS)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) rJr|rKrrrrr rr.rrr5)rr.rrr5r8s rArzInterrupt.__init__su,G}}####|tDzzS0000|t 4?'CCCCC~f!4!4!44"d;&7&74&?&?&??  H! H HBxx4'''' B49 +>+>#+E+E+EE2~~2h<+?48 CUCUY\C\C\C\]!R''DJ,@,@C,G,G,GG,G   'rCcHt|dkr|dtjksJt|dkr/tdt|t |dd}t |dd}d}d}d}d |vr|d }t|tkr/td t||tj tj fvr"td ||}d |vrt|d d }d|vr|d}d}t|tkr|D]}t|tkrnmd|vst|dtkrnId|vst|dtkrn%d|vst|dtkrnd}|stdt||||} | S)rrr9z(invalid message length {0} for INTERRUPTr7z'request' in INTERRUPTr8z'options' in INTERRUPTNrz/invalid type {0} for 'mode' option in INTERRUPTz2invalid value '{0}' for 'mode' option in INTERRUPTrz"reason" in INTERRUPTr5FrrrTzCinvalid type/value {0} for/within 'forward_for' option in INTERRUPT)rrr5)r[r#rrrZr'r(rJrKrrr%rrr|) rr.rrrr5rrAr8rs rArzInterrupt.parsesA4yy1}}aI,B!B!B!BB t99>> J Q QRUVZR[R[ \ \]] ]#DG-EFF&tAw0HII W  !&/KK  C''#$U$\$\]abm]n]n$o$oppp9>93G"HHH#$X$_$_`k$l$lmmmD w  '(9;RSSF G # #!-0KEK  D((%BBxx4'' **d2i=.A.AS.H.Hr))T"X,-?-?3-F-F!++tBzN/C/Cs/J/J0K k#$ijjjd6{SSS rCci}|j |j|d<|j |j|d<|j |j|d<tj|j|gS)rNrrr5)rrr5r#rr.rs rArzInterrupt.marshal=sX 9 "iGFO ; " $ GH    '%)%5GM "& g>>rCr5) rrrrrrrrrrrrr<rCrAr#r#s}L DJI)')')')'V::\:x?????rCr#cVeZdZdZdZ dZ ddZedZdZ dS) 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|tksJ|t|ttfvsJ|t|tksJ|t|t ksJ||||J|t|t ksJ|t|sJ|||||J|t|tksJ|t|sJ| t| tksJ| t| tksJ| t| tksJ| t| tksJ| r| D]} t| tksJd| vrt| dtksJd| vr&| d t| dtksJd| vrt| dtksJt |||_ ||_ t||_||_||_||_||_||_| |_| |_| |_| |_dS)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 rArzYield.__init__rslG}}####|tDzzdE]::::~f!5!5!55$w--5"8"8"887#64>T#9#9#99#4X#>#>> W_9OU\UhmunBnBC$w--3"6"6"66%)@)P)P%%P~f!4!4!44$](;(;s(B(B(BB&$*?*?3*F*F*FF"d;&7&74&?&?&??  H! H HBxx4'''' B49 +>+>#+E+E+EE2~~2h<+?48 CUCUY\C\C\C\]!R''DJ,@,@C,G,G,GG,G  &v..       , *.'rCc t|dkr|dtjksJt|dvr/tdt|t |dd}t |dd}d}d}d}d}d}d}t|d krt|d tkr|d }| d d}|r1t|s"td || d d}|rGt|tkr/tdt|| dd}|r1t|s"td|nt|d krQ|d }|Gt|tkr/tdt|t|d krO|d }t|tkr/tdt|d} d} d} d} d} d|vrQ|d}t|tkr/tdt||} d|vrQ|d}t|t kr/tdt||} d|vrQ|d}t|tkr/tdt||} d|vrQ|d}t|tkr/tdt||} d|vr|d} d}t| tkr| D]}t|tkrnmd|vst|dt krnId|vst|dtkrn%d|vst|dtkrnd }|std!t||||| |||| | | | " }|S)#rrrz$invalid message length {0} for YIELDr7z'request' in YIELDr8z'options' in YIELDNrDr9rNz0invalid value {0} for 'enc_algo' detail in YIELDr2z.invalid type {0} for 'enc_key' detail in YIELDrQz6invalid 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 YIELDr3z4invalid type {0} for 'callee_authid' detail in YIELDr4z6invalid type {0} for 'callee_authrole' detail in YIELDr5FrrrTz?invalid type/value {0} for/within 'forward_for' option in YIELDr)r[r$rrrZr'r(rJrVrr)rKr*rrrr|)rr.rr0rr1rNr2rQrrr3r4r5option_progress option_calleeoption_callee_authidoption_callee_authrolerAr8rs rArz Yield.parses 4yy1}}aE,>!>!>!>> t99I % % F M McRVii X XYY Y#DG-ABB&tAw0DEE t99>>d47mmu441gG{{:t44H i 1( ; ; i#$V$]$]^f$g$ghhhkk)T22G l4==C//#$T$[$[\`ah\i\i$j$jkkk$[[)94@@N u&=n&M&M u#$\$c$cdr$s$sttt4yy1}}Aw#T d(:(:'(N(U(UVZ[_V`V`(a(abbb4yy1}}a<<4'''(P(W(WX\]cXdXd(e(efff   %j1OO$$,,#$U$\$\]abq]r]r$s$sttt&H w  #H-MM""c))#$S$Z$Z[_`m[n[n$o$oppp"F g % %#*?#; ())S00#$Z$a$abfg{b|b|$}$}~~~0M  ' '%,->%? "*++s22#$\$c$cdhieAeA%B%BCCC4O G # #!-0KEK  D((%BBxx4'' **d2i=.A.AS.H.Hr))T"X,-?-?3-F-F!++tBzN/C/Cs/J/J0K g#$efffG!#%%##1!"/$3 + - - - rCci}|j |j|d<|j |j|d<|j |j|d<|j |j|d<|j |j|d<|jrM|j |j|d<|j |j|d<|j |j|d <tj |j ||jgS|j r tj |j ||j |j gS|j rtj |j ||j gStj |j |gSr)rrr3r4r5r1rNr2rQr$rr.rr0rs rArz Yield.marshalMs, = $"&-GJ  ; " $ GH    )'+'9GO $   +)-)=G% &   '%)%5GM " < C}(&*m #|'%)\ "".,0,?()& gt|L L{ C*DL'49dkZZ C*DL'49MM*DL'BBrCrrr<rCrAr$r$Rs  L I" $#!%!]']']']'~yy\yv#C#C#C#C#CrCr$)rR)rjFFFF)rjT)rj)`rerWrpprintrtypingrrrr autobahn.utilrautobahn.wamp.exceptionrr autobahn.wamp.roler rzr6 autobahn.wampr _HAS_WAMP_FLATBUFFERS ImportError__all__compilerfrirgrhrrrursrvrqrtrLr,r-PAYLOAD_ENC_XBRr.rP ENC_ALGO_NONErrr ENC_ALGOSitemsENC_ALGOS_FROMSTR ENC_SER_NONErrrrENC_SER_OPAQUEENC_SER_FLATBUFFERSENC_SERSENC_SERS_FROMSTRr)r*r_rKr+rr%r&r|r'r(robjectr r rrrrrrrrrrrrrrrrrrrr r!r"r#r$r<rCrAr0s 6 &&&&&&&&&&BBBBBBBB111111!LLL))))))!"""!" " /J!bj!EFF%"*%<==%"*%EFF#-"*-M"N"N# #GHH"rz"FGG'BJ'EFF&2:&DEE(RZ(FGG'BJ'EFFBJ788 %%;$>$>$>NS3C*ctTWY\T\~(!!!!Hl,l,l,l,l,fl,l,l,^l9l9l9l9l9Gl9l9l9^r=r=r=r=r=gr=r=r=jM:M:M:M:M:GM:M:M:`BABABABABABABABAJBGBGBGBGBG7BGBGBGJc<c<c<c<c9>9>9>9>G9>9>9>x_R_R_R_R_R7_R_R_RD ~<~<~<~<~