hRCRSSKrSSKrSSKrSSKJr SSKJrJrJr SSK r SSK J r SSK J r Jr SSKJr SSKrSSKrSSKJr SrS r\R0"S 5r\R0"S 5r\R0"S 5r\R0"S5r\R0"S5r\R0"S5r\R0"S5r\R0"S5r \R0"S5r!\R0"S5r"\R0"S5r#Sr$Sr%Sr&\$\%\&/r'/SQr(Sr)Sr*Sr+Sr,\)S\*S\+S\,S0r-\-R]5VVs0sHupX_M snnr/Sr0Sr1Sr2Sr3Sr4Sr5S r6\0S\1S!\2S"\3S#\4S$\5S%\6S&0r7\7R]5VVs0sHupX_M snnr8S'r9S(r:SkS)jr;S*\S+\\<4S,jr=SlS*\S-\S/\>S0\>S1\>S+\<4S2jjr?SmS3jr@SnS*\S-\\F5rI"S?S@\F5rJ"SASB\F5rK"SCSD\F5rL"SESF\F5rM"SGSH\F5rN"SISJ\F5rO"SKSL\F5rP"SMSN\F5rQ"SOSP\F5rR"SQSR\F5rS"SSST\F5rT"SUSV\F5rU"SWSX\F5rV"SYSZ\F5rW"S[S\\F5rX"S]S^\F5rY"S_S`\F5rZ"SaSb\F5r["ScSd\F5r\"SeSf\F5r]"SgSh\F5r^"SiSj\F5r_g!\a S rGNf=fs snnfs snnf)oN)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 flatbuffersnullr2r3r4r5opaquer6c~[U5[:H=(a% U[;=(d [R U5$)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 YC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\autobahn/wamp/message.pyr)r)s0( >S xh2R&R&wVgVmVmnvVwxc~[U5[:H=(a% U[;=(d [R U5$)a1 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 )r@rA PAYLOAD_ENC_STANDARD_SERIALIZERSrBrC)enc_serializers rEr*r*sB,  3 & KN>^,^-Jbsbyby{IcJKrFc[U5[:XaUnOP[U5[:Xa&[R"U5R S5nOUcSnOSR U5n[U5U:aUSUS-$U$)Nascii-z{}z..)r@rAbytesbinasciib2a_hexdecodeformatlen)datamax_lenss rEb2arVst DzS  du    T " ) )' 2   KK  1v'{T!!rFvaluereturnc[U5[:wag[RU5(a7[RU5(ag[ RU5(agg[ RU5(agg)aR 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)r@rA_URI_PAT_REALM_NAMErC_URI_PAT_REALM_NAME_ENS_URI_PAT_REALM_NAME_ENS_REVERSE_URI_PAT_REALM_NAME_ETH)rWs rEr+r+sf E{c  '' " ( ( / / , 2 25 9 9  & &u - -rFmessagestrictallow_empty_componentsallow_last_empty allow_nonec Uc"U(ag[SRU55e[U5[:wa.UcU(d$[SRU[U555eU(a#U(a[nO7U(a[ nO)[ nO"U(a[nOU(a[nO[nURU5(d'[SRXURX#XE55eU$)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 rQr@rA_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_EMPTYrCpattern)rWrbrcrdrerfpats rEr%r%s( }  !";"B"B7"KL L E{c *!"A"H"HRVW\R]"^_ _ ,C #'C+C +C #&C*C 99U  y@@AHQTQ\Q\^d~N[\ \ rFcUc[SRU55e[U5[:wa$[SRU[U555eU(an[R U5(d[ R U5(aU$[SRX[R[ R55e[R U5(aU$[SRX[R55e)aT 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` z{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 rQr@rAr^rCrarn)rWrb allow_eths rEr&r&7s }>EEgNOO E{cDKKGUYZ_U`abb  $ $U + +/F/L/LU/S/SL!""(&)<)D)D)@)H)H#JK K  $ $U + +L! 3 ; ;=> >rFc[U5[:wa$[SRU[U555eUS:dUS:a[SRX55eU$)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)r@intrrQ)rWrbs rEr'r'^s[ E{c:AA'4PU;WXX qyE,,;BB7RSS LrFc [U5[:wa$[SRU[U555eUR 5H=n[ U[ 5(aM[SRU[U5U55e U$)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}')r@dictrrQkeys isinstancerA)rWrbks rEr(r(ssx E{dBII'SWX]S^_`` ZZ\!S!! U \ \]dfjklfmop qr r LrFc Ub[U5[:wa$[SRU[U555eUR 5H=n[ U[ 5(aM[SRU[U5U55e U$g)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}')ru)kwargsrbrys rE_validate_kwargsr|s6 <4  G N NwX\]cXd ef fAa%%#$Z$a$abikopqkrtu$vww rFcN\rSrSrSrSrSrSSjr\S5r \ RS5r \S5r \ RS 5r \S 5r \ RS 5r \S 5r \ RS 5r SrSrS\4Sjr\S5rSr\S5rSrSrSrSrg)r izc 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_internalcdXl0UlSUlSUlSUlSUlSUlgNr~)selffrom_fbss rE__init__Message.__init__s=! $ $&*#$(!!%rFcUR$r)rrs rEcorrelation_idMessage.correlation_ids###rFc@Ub[U5[:XdeXlgr)r@rArrrWs rErrs}U s 232$rFcUR$r)rrs rEcorrelation_uriMessage.correlation_uris$$$rFc@Ub[U5[:XdeXlgr)r@rArrs rErrs}U s 232 %rFcUR$r)rrs rEcorrelation_is_anchorMessage.correlation_is_anchors***rFc@Ub[U5[:XdeXlgr)r@boolrrs rErrs}U t 343&+#rFcUR$r)rrs rEcorrelation_is_lastMessage.correlation_is_lasts(((rFc@Ub[U5[:XdeXlgr)r@rrrs rErrs}U t 343$)!rFc[XR5(dgURH=nUS;dM URS5(aM#[ X5[ X5:XaM= g g)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)rx __class__ __slots__ startswithgetattr)rotherrys rE__eq__Message.__eq__s\%00A11:;c9J9Jt'75+<<  rFc.URU5(+$)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 rE__ne__Message.__ne__ s;;u%%%rFrXc SR[URRR 5S-SSS9[[ R "[UR55S5SSS95$)Nz{} {}z::blueT)colorboldz F) rQrr__name__uppertextwrapindentrmarshalrs rE__str__Message.__str__s^uT^^%<%<%B%B%Dt%KSY`de$X__WT\\^5Lf%U]cjopr rrFc[5e)z 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 rEparse Message.parses "##rFc[5errrs rErMessage.marshal) !##rFc[5errbufs rEcast Message.cast,s !##rFc[5err)rbuilders rEbuild Message.build0rrFc0Ulg)z! Resets the serialization cache. N)rrs rEuncacheMessage.uncache3s rFcxXR;aURS:Xaa[R"S5nUR U5nUR U5 UR 5n[U5URU'O,URUR55URU'URU$)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) rNAMEr6BuilderrFinishOutputrM serializer)r serializerrobjrs rErMessage.serialize9s -- --/%--d3jj)s#nn&/4Sz  ,0:/C/CDLLN/S  , ++rF)rrrrrrrr)r __module__ __qualname____firstlineno____doc__ MESSAGE_TYPErrpropertyrsetterrrrrrrAr staticmethodrrrrrr__static_attributes__rFrEr r s+ L I% $$%%%%&&++!!,",))* *. &rr $ $$$$$ ,rFr cP\rSrSrSrSrSrS Sjr\S5r Sr S r g) r iZzI A WAMP ``HELLO`` message. Format: ``[HELLO, Realm|uri, Details|dict]`` r7) realmroles authmethodsauthidauthrole authextra resumableresume_session resume_tokenNc DUb[U[5(de[U5[:Xde[ U5S:deUHEn U S;de[X*[ R RRU 5(aMEe U(a3[U5[:XdeUHn [U 5[:XaMe Ub[U5[:XdeUb[U5[:XdeUb[U5[:XdeUb[U5[:XdeUb[U5[:XdeU b[U 5[:Xde[RU5 XlX lX0lX@lXPlX`lXplXlXlg)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)rxrAr@rvrRautobahnwamproler listrrsr rrrrrrrrrr) rrrrrrrrrrr authmethods rErHello.__init__rsN} 5# 6 676E{d"#"5zA~~DJJ KJek8==+=+=+P+PQU+VWW XW  $, -,) J'3./.*~f!4544>S#898 DOt$;<; DOt$;<;%n)=)DED#tL'9S'@A@  &  "",(rFc [U5S:aUS[R:Xde[U5S:wa#[SR [U555e[ USSSS9n[ USS 5n0nS U;a [S 5e[ US S 5n[U5S:Xa [S 5eUHnUS;a[SR U55e[Un[ XESR U55nSU;a*[ USSR U55 U"S$0USD6nOU"5nXU'M Sn SU;a|USn [U 5[:wa#[SR [U 555eU H9n [U 5[:wdM[SR [U 555e U n Sn SU;a=USn [U 5[:wa#[SR [U 555eU n SnSU;a=USn[U5[:wa#[SR [U555eUnSnSU;a=USn[U5[:wa#[SR [U555eUnSnSU;a;USn[U5[:wa#[SR [U555eSnSU;a;USn[U5[:wa#[S R [U555eSnS!U;a<US!n[U5[:wa#[S"R [U555eOU(a [S#5e[XXUUUUU5 nU$)% 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)rfr8z'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)rRr rrrQr%r(r r@rrArvrrs)rrdetailsr details_rolesrrole_cls details_role role_featuresrdetails_authmethods auth_methodrdetails_authidrdetails_authrolerdetails_authextrarrrrs rEr Hello.parses4y1}aE,>,>!>?> t9> F M McRVi XY Y"47,>4P&tAw0DE ' ! WX X,WW-=?^_ }  " EF F!DJJ#$Y$`$`ae$fgg)$/H/ 0CErEyEyz~EAL\)$\*%=?z@B@BCG@HI ( D< +C D !) '$K!"$ G #")-"8 '(D0#$X$_$_`dex`y$z{{2  $+'(d(k(klpq|l}(~ 3.K w $X.NN#s*#$S$Z$Z[_`n[o$pqq#F  &z2 $%,#$U$\$\]abr]s$tuu'H ' ! ' 4 %&$.#$V$]$]^bct^u$vww)I ' ! ,II$&#$V$]$]^bcl^m$noo w &$%56NN#s*#$[$b$bcghvcw$xyy W $">2LL!S(#$Y$`$`aefras$tuu)#$jkkE+xIWegst rFcJS00nURR5Hn0USUR'URH|nUR S5(aMUS:wdM#[ X#5cM1SUSUR;aS00USUR'[ X#5USURSU'M~ M UR bUR US'URbURUS'URbURUS'URbURUS'URbURUS 'URbURUS 'URbURUS '[RURU/$) Marshal this object into a raw message for subsequent serialization to bytes. :returns: The serialized raw message. :rtype: list rrROLErrrrrrrr)rvaluesr__dict__rrrrrrrrrr rrrrrfeatures rEr Hello.marshal!sB-JJ%%'D*,GG TYY '==))#..7f3DQUI_Ik!)9$)))DD7A26F(3GNtG]GG$TYY/ ;GD )(    '%)%5%5GM " ;; " $ GH  == $"&--GJ  >> %#'>>GK >> %#'>>GK    *(,(;(;G$ %    (&*&7&7GN #""DJJ88rF) rrrrrrrrr)NNNNNNN rrrrrrrrrrrrrrFrEr r ZsT L I" $"A)FiiV%9rFr cV\rSrSrSrSrSrS Sjr\S5r Sr S r g) riIzN A WAMP ``WELCOME`` message. Format: ``[WELCOME, Session|id, Details|dict]`` r8) sessionrrrrr authproviderrresumedrrcustomNc [U5[:Xde[U5[:Xde[U5S:deUHEn U S;de[ X-[ R RRU 5(aMEe Ub[U5[:XdeUb[U5[:XdeUb[U5[:XdeUb[U5[:XdeUb[U5[:XdeUb[U5[:XdeU b[U 5[:XdeU b[U 5[:XdeU b[U 5[:XdeU b[U 5[:XdeU (a%U Hn[RU5(aMe [RU5 XlX lX0lX@lXPlX`lXplXlXlXlXlU =(d 0Ulg)ah :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)r@rsrvrRrxrrrr rArrBrCr rrrrrrrrrrrrr)rrrrrrrrrrrrrrrys rErWelcome.__init__dsfG}#$#E{d"#"5zA~~D// 0/ek8==+=+=+P+PQU+VWW XW}U s 232~f!4544>S#898!T*%5%<=<#tL'9S'@A@ DOt$;<;$w-4"787 DOt$;<;#tL'9S'@A@~f!565 (..q1121      $(" "(l rFc[U5S:aUS[R:Xde[U5S:wa#[SR [U555e[ USS5n[ USS5nURSS 5nURS S 5nURS S 5nURS S 5nURS S 5nURSS 5nS n SU;a;USn [U 5[:Xd#[SR [U 555eS n SU;a;USn [U 5[:Xd#[SR [U 555eS n SU;a<USn [U 5[:Xd#[SR [U 555eOU (a [S5e0n SU;a [S5e[ USS5n [U 5S:Xa [S5eU HnUS;a[SR U55e[Un[ XSR U55nSU;a,[ USSR U55 U"S0XSD6nOU"5nUX'M 0nUH'n[RU5(dMUUUU'M) [XX4XVXxXU U5 nU$) 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 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)rRrrrrQr'r(getr@rrAr rBrC)rrrrrrrrrrrrrrrrrrrryrs rEr Welcome.parses4y1}aG,@,@!@A@ t9> H O OPSTXPY Z[ [#DG-CD&tAw0FG GT*Xt,;;z40[[t4 {{>48 KK T2   i(G=D(#$V$]$]^bcj^k$lmm ' ! ,I ?d*#$X$_$_`den`o$pqq W $">2L %,#$[$b$bcghtcu$vww-  Z[ [ ' ! YZ Z,WW-=?`a }  " GH H!D//#$[$b$bcg$hii)$/H/ 0CEtE{E{}AFBCL\)$\*%=?|@D@DEI@JK ( K=+>z+J K !) 'EK!"$A &&q))#AJq geX0nURUR5 UR(aURUS'UR(aURUS'UR(aURUS'UR(aUR US'UR (aUR US'UR(aURUS'UR(aURUS'UR(aURUS'UR(aURUS '0US 'URR5Hn0US UR'URH|nURS 5(aMUS :wdM#[!X#5cM1S US UR;aS 00US UR'[!X#5US URS U'M~ M ["R$UR&U/$)rrrrrrrrrrrrrr)updaterrrrrrrrrrrr rr rrrrrr s rErWelcome.marshal st{{# ::#zzGG  ;; $ GH  =="&--GJ  ==$(OOGL !   &*&7&7GN # >>#'>>GK <>#'>>GK   &*&7&7GN #JJ%%'D*,GG TYY '==))#..7f3DQUI_Ik!)9$)))DD7A26F(3GNtG]GG$TYY/ ;GD )($$dllG<zJ A WAMP ``ABORT`` message. Format: ``[ABORT, Details|dict, Reason|uri]`` r9)reasonrbNc[U5[:XdeUb[U5[:Xde[RU5 XlX lg)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)r@rAr rr!rb)rr!rbs rErAbort.__init__OsDF|s"#"$w-3"676  rFc[U5S:aUS[R:Xde[U5S:wa#[SR [U555e[ USS5n[ USS5nSnS U;a=US n[U5[:wa#[S R [U555eUn[X#5nU$) rrr9z$invalid message length {0} for ABORTr7z'details' in ABORTr8z'reason' in ABORTNrbz.invalid type {0} for 'message' detail in ABORT) rRrrrrQr(r%r@rA)rrr!rbdetails_messagers rEr Abort.parse_s4y1}aE,>,>!>?> t9> F M McRVi XY Y&tAw0DE#DG-@A  %i0OO$+#$T$[$[\`ap\q$rss%GF$ rFc~0nUR(aURUS'[RXR/$)rrb)rbrrr!rrs rEr Abort.marshals3 <s9 LI  @ :rFrcB\rSrSrSrSrSrS Sjr\S5r Sr S r g) rizS A WAMP ``CHALLENGE`` message. Format: ``[CHALLENGE, Method|string, Extra|dict]`` r;)methodextraNc[U5[:XdeUb[U5[:Xde[R U5 XlU=(d 0Ulg)z :param method: The authentication method. :type method: str :param extra: Authentication method specific information. :type extra: dict or None N)r@rArvr rr+r,)rr+r,s rErChallenge.__init__sJF|s"#"}U t 343 [b rFcd[U5S:aUS[R:Xde[U5S:wa#[SR [U555eUSn[ U5[ :wa#[SR [ U555e[USS5n[X5nU$)rrr9z(invalid message length {0} for CHALLENGEr7z*invalid type {0} for 'method' in CHALLENGEr8z'extra' in CHALLENGE)rRrrrrQr@rAr()rr+r,rs rErChallenge.parses4y1}aI,B,B!BCB t9> J Q QRUVZR[ \] ]a <3  L S STXY_T` ab b$T!W.DE& rFcP[RURUR/$r)rrr+r,rs rErChallenge.marshals&& TZZ@@rF)r,r+rrrrFrErrs9 LI ! 2ArFrcB\rSrSrSrSrSrS Sjr\S5r Sr S r g) riz\ A WAMP ``AUTHENTICATE`` message. Format: ``[AUTHENTICATE, Signature|string, Extra|dict]`` r<) signaturer,Nc[U5[:XdeUb[U5[:Xde[R U5 XlU=(d 0Ulg)z :param signature: The signature for the authentication challenge. :type signature: str :param extra: Authentication method specific information. :type extra: dict or None N)r@rArvr rr5r,)rr5r,s rErAuthenticate.__init__sJI#%&%}U t 343"[b rFcd[U5S:aUS[R:Xde[U5S:wa#[SR [U555eUSn[ U5[ :wa#[SR [ U555e[USS5n[X5nU$)rrr9z+invalid message length {0} for AUTHENTICATEr7z0invalid type {0} for 'signature' in AUTHENTICATEr8z'extra' in AUTHENTICATE)rRrrrrQr@rAr()rr5r,rs rErAuthenticate.parses4y1}aL,E,E!EFE t9> M T TUXY]U^ _` `G  ?c ! R Y YZ^_hZi jk k$T!W.GH9, rFcP[RURUR/$r2)rrr5r,rs rErAuthenticate.marshals))4>>4::FFrF)r,r5rrrrFrErrs9 LI ! 2GrFrcN\rSrSrSrSrSrSr\SS4Sjr\ S5r S r S r g) rizN A WAMP ``GOODBYE`` message. Format: ``[GOODBYE, Details|dict, Reason|uri]`` r=zwamp.close.normalr!rbrNc[U5[:XdeUb[U5[:XdeUb[U5[:Xde[R U5 XlX lX0lg)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)r@rArr rr!rbr)rr!rbrs rErGoodbye.__init__/s`F|s"#"$w-3"676 DOt$;<;  "rFc[U5S:aUS[R:Xde[U5S:wa#[SR [U555e[ USS5n[ USS5nSnSnS U;a=US n[U5[:wa#[S R [U555eUnS U;a;US n[U5[:wa#[S R [U555e[UUUS 9nU$)rrr9z&invalid message length {0} for GOODBYEr7z'details' in GOODBYEr8z'reason' in GOODBYENrbz0invalid type {0} for 'message' detail in GOODBYErz2invalid type {0} for 'resumable' detail in GOODBYEr=) rRrrrrQr(r%r@rAr)rrr!rbrr%rs rEr Goodbye.parseDs4y1}aG,@,@!@A@ t9> H O OPSTXPY Z[ [&tAw0FG#DG-BC  %i0OO$+#$V$]$]^bcr^s$tuu%G ' ! ,II$&#$X$_$_`den`o$pqqV% )+ rFc0nUR(aURUS'UR(aURUS'[RXR/$)rrbr)rbrrrr!r(s rErGoodbye.marshalmsH <>#'>>GK $$g{{;;rF)rbr!r) rrrrrrDEFAULT_REASONrrrrrrrrFrErrsN L)NI -dd#*&&P#>?> W_9OU\UhmunB DC$w-3"676%)@)P)PQP~f!454$](;s(BCB&$*?3*FGF"d;&74&?@? !Bx4''' B49 +>#+EEE2~2h<+?48 CUY\C\]]!R'DJ,@C,GGG " (   &v.  !  , *.'rFc[U5S:aUS[R:Xde[U5S;a#[SR [U555eUSn[ U5[ :wa[SR U55eU[R[R[R[R[R[R[R4;a[SR U55e[USS5n[US S 5n[!US S 5nS nS nS nS nS n S n S n S n S n S n[U5S:Xa[ US5[":XaUSnUR%SS 5nU(a*['U5(d[SR U55eUR%SS 5n U (a6[ U 5[(:wa#[SR [ U 555eUR%SS 5n U (a*[+U 5(d[SR U 55eO[U5S:a>USnUb6[ U5[,:wa#[SR [ U555e[U5S:a;USn[ U5[.:wa#[SR [ U555eSU;a=USn[ U5[ :wa#[SR [ U555eUn SU;a=USn[ U5[(:wa#[SR [ U555eUn SU;a=USn[ U5[(:wa#[SR [ U555eUn SU;aUSnSn[ U5[,:XazUHrn[ U5[.:wa O^S U;d[ US 5[ :wa O@S!U;d[ US!5[(:wa O"S"U;d[ US"5[(:wdMr O S#nU(d [S$5e[UUUUUUUU U U U U US%9 nU$)&rr)r<r=z$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 ERRORr;z'error' in ERRORNr=r<rD0invalid value {0} for 'enc_algo' detail in EVENTrL.invalid type {0} for 'enc_key' detail in EVENTrI6invalid 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 ERRORrMz4invalid type {0} for 'callee_authid' detail in ERRORrNz6invalid type {0} for 'callee_authrole' detail in ERRORrOFrrrTz?invalid type/value {0} for/within 'forward_for' option in ERROR) rJr{rKrDrLrIrrMrNrO)rRrrrrQr@rsrrrrr rr"r'r(r%rMrr)rAr*rrv)rrGrHrrIrJr{rKrDrLrIrrMrNrO detail_calleedetail_callee_authiddetail_callee_authrolevalidrRrs rEr Error.parsesI4y1}aE,>,>!>?> t9I % F M McRVi XY YAw   $ 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-AB&tAw0DE"47,>?  t9>d47mu41gG{{:t4H 1( ; ;#$V$]$]^f$ghhkk)T2G4=C/#$T$[$[\`ah\i$jkk$[[)94@N&=n&M&M#$\$c$cdr$stt4y1}Aw#T d(:'(N(U(UVZ[_V`(abb4y1}a<4''(P(W(WX\]cXd(eff w #H-MM"c)#$S$Z$Z[_`m[n$opp"F g %#*?#; ()S0#$Z$a$abfg{b|$}~~0M  '%,->%? "*+s2#$\$c$cdhieA%BCC4O G #!-0KEK D(%BBx4' *d2i=.AS.Hr)T"X,-?3-F!+tBzN/Cs/J&#$effL!#%##1!"/$3 + - rFc0nURbURUS'URbURUS'URbURUS'URbURUS'UR(aUR bUR US'UR bUR US'URbURUS'URURURXRUR/$UR(aDURURURXRURUR/$UR(a9URURURXRUR/$URURURXR/$)rrrMrNrOrDrLrI)rrMrNrOrKrDrLrIrrGrHrIr{rJr(s rEr Error.marshals ;; " $ GH     )'+'9'9GO $    +)-)=)=G% &    '%)%5%5GM " <<}}(&*mm #||'%)\\ """.,0,?,?()%%t'8'8$,,Q[Q[]a]i]ij j{{))4+<+ 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_transaction_hash _forward_forNcUb[U5[:XdeUb[U5[:XdeUb%[U5[[[[ 4;deUb [U5[ [[ 4;deUb[U5[ :XdeUb UbUcUbeUb[U5[:XdeUb[U5[:XdeUb[U5[:XdeUb[U5[:XdeUb[U5[:XdeU(aUHn[U5[:XaMe U b[U 5[:XdeU (aU Hn[U5[:XaMe U b[U 5[:XdeU (aU Hn[U5[:XaMe U b[U 5[:XdeU (aU Hn[U5[:XaMe U b[U 5[:XdeU (aU Hn[U5[:XaMe U b[U 5[:XdeU (aU Hn[U5[:XaMe Ub[U5(deUcUcUbUbUceUb[U5[:XdeUb[U5(deUb[U5[:XdeU(a~UHxn[U5[ :XdeSU;a[US5[:XdeSU;aUSb[US5[:XdeSU;a[US5[:XaMxe [RUUS9 Xl X l X0l[U5UlXPlX`lXplXlXlXlXlXlXlXlXlUUlUUlUUlUUlg)a9 :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 transaction_hash: An application provided transaction hash for the published event, which may be used in the router to throttle or deduplicate the events on the topic. 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 or None :param forward_for: When this Call is forwarded for a client (or from an intermediary router). :type forward_for: list[dict] Nrrrr) r@rsrArrQrMrvrr)r*r rrbrcrdr|rerfrjrkrlrmrnrorprqrrrsrgrirhrt)rrHtopicrJr{rK acknowledge exclude_meexcludeexclude_authidexclude_authroleeligibleeligible_authideligible_authroleretaintransaction_hashrDrLrIrOr sessionidrrrRs rErPublish.__init__sn$w-3"676}U s 232|tDzdE3-FFGF~f$U1C!CDC$w-5"8987#64=$w-4"787 $ I#-.-%%n)=)EFE (F|s*+*) '40@+AT+IJI ,H~,-,-4>T#9:9 % I#-.-&&$*?4*GHG )F|s*+**!(D1B,Ct,KLK -H~,-,.#4X#>#>?> W_9OU\UhmunB DC$w-3"676%)@)P)PQP"d;&74&?@? !Bx4''' B49 +>#+EEE2~2h<+?48 CUY\C\]]!R'DJ,@C,GGG " 1   '/  '& -!1! /"3 "2" -(rFcr[XR5(dg[RX5(dgURUR:wagUR UR :wagUR UR :wagURUR:wagURUR:wagURUR:wagURUR:wagURUR:wagURUR:wagURUR:wagURUR:wagURUR:wagUR UR :wagUR"UR":wagUR$UR$:wagUR&UR&:wagUR(UR(:wagUR*UR*:wagUR,UR,:waggNFT)rxrr rrHrwrJr{rKrxryrzr{r|r}r~rrrrDrLrIrOrs rErPublish.__eq__s%00~~d** ==DLL ( ;;$** $ :: " <<4;; & ==DLL (    0 0 0   t . ==DLL (   4#6#6 6  ! !T%:%: : >>T]] *  D$8$8 8  " "d&<&< < <<4;; &  ! !T%:%: : >>T]] * ==DLL (   4#6#6 6    0 0 0rFc.URU5(+$rrrs rErPublish.__ne__;;u%%%rFcURc0UR(aURR5UlUR$r)rbrRequestrs rErHPublish.requests0 == T^^ NN224DM}}rFc@Ub[U5[:XdeXlgr)r@rsrbrs rErHrs}U s 232 rFcURcHUR(a7URR5nU(aURS5UlUR$Nutf8rcrTopicrPrrUs rErw Publish.topicA ;; 4>>$$&Ahhv. {{rFc@Ub[U5[:XdeXlgrr@rArcrs rErwr}U s 222 rFc URclUR(a[URR5(a<[R"[ URR 555UlUR$rrdr ArgsLengthcbor2loadsrM ArgsAsBytesrs rErJ Publish.argsQ :: $..~~((**"[[t~~/I/I/K)LM zzrFcLUb[U5[[4;deXlgrr@rrQrdrs rErJr!}U e} <=< rFc URclUR(a[URR5(a<[R"[ URR 555UlUR$rrer KwargsLengthrrrM KwargsAsBytesrs rEr{Publish.kwargsQ << DNN~~**,,${{51M1M1O+PQ ||rFc@Ub[U5[:XdeXlgrr@rvrers rEr{r}U t 343 rFcURcOUR(a>URR5(aURR5UlUR$rrfr PayloadLengthPayloadAsBytesrs rErKPublish.payloadC == T^^~~++-- $ = = ? }}rFc@Ub[U5[:XdeXlgrr@rMrfrs rErKr }U u 444 rFcURc8UR(a'URR5nU(aXlUR$r)rjr Acknowledge)rrxs rErxPublish.acknowledges;    $..446K$/!   rFc@Ub[U5[:XdeXlgr)r@rrjrs rErxrs}U t 333!rFcURc6UR(a%URR5nUSLaXlUR$)NF)rkr ExcludeMe)rrys rEryPublish.exclude_mes@    #113JU"#- rFc@Ub[U5[:XdeXlgr)r@rrkrs rEryr%s}U t 333 rFcLURcUR(a{URR5(a\/n[URR55H-nUR URR U55 M/ XlUR$r)rlr ExcludeLengthrangeappendExclude)rrzjs rErzPublish.exclude*sp == T^^~~++--t~~;;=>ANN4>>#9#9!#<=? ' }}rFcUb[U5[:XdeU(aUHn[U5[:XaMe Xlgr)r@rrsrlrrWxs rErzr4s:}U t 333 Aw#~%~ rFcjURcUR(aURR5(ak/n[URR55H<nUR URR U5R S55 M> XlUR$r)rmrExcludeAuthidLengthrr ExcludeAuthidrP)rr{rs rEr{Publish.exclude_authid<s    'DNN~~1133!#t~~AACDA"))$..*F*Fq*I*P*PQW*XYE'5$###rFcUb[U5[:XdeU(aUHn[U5[:XaMe Xlgr)r@rrArmrs rEr{rFs;}U t 333 Aw#~%~$rFcjURcUR(aURR5(ak/n[URR55H<nUR URR U5R S55 M> XlUR$r)rnrExcludeAuthroleLengthrrExcludeAuthrolerP)rr|rs rEr|Publish.exclude_authroleNs  ! ! )dnn~~3355#% t~~CCEFA$++DNN,J,J1,M,T,TU[,\]G)9&%%%rFcUb[U5[:XdeU(aUHn[U5[:XaMe Xlgr)r@rrArnrs rEr|rXs;}U t 333 Aw#~%~!&rFcLURcUR(a{URR5(a\/n[URR55H-nUR URR U55 M/ XlUR$r)rorEligibleLengthrrEligible)rr}rs rEr}Publish.eligible`sq >> !dnn~~,,..t~~<<>?AOODNN$;$;A$>?@!)~~rFcUb[U5[:XdeU(aUHn[U5[:XaMe Xlgr)r@rrsrors rEr}rjs:}U t 333 Aw#~%~rFcjURcUR(aURR5(ak/n[URR55H<nUR URR U5R S55 M> XlUR$r)rprEligibleAuthidLengthrrEligibleAuthidrP)rr~rs rEr~Publish.eligible_authidrs  (T^^~~2244"$t~~BBDEA#**4>>+H+H+K+R+RSY+Z[F(7%$$$rFcUb[U5[:XdeU(aUHn[U5[:XaMe Xlgr)r@rrArprs rEr~r|s;}U t 333 Aw#~%~ %rFcjURcUR(aURR5(ak/n[URR55H<nUR URR U5R S55 M> XlUR$r)rqrEligibleAuthroleLengthrrEligibleAuthrolerP)rrrs rErPublish.eligible_authroles  " " *t~~~~4466$&!t~~DDFGA%,,T^^-L-LQ-O-V-VW]-^_H*;'&&&rFcUb[U5[:XdeU(aUHn[U5[:XaMe Xlgr)r@rrArqrs rErrs;}U t 333 Aw#~%~"'rFcURc8UR(a'URR5nU(aXlUR$r)rrrRetain)rrs rErPublish.retains6 << DNN^^**,F% ||rFc@Ub[U5[:XdeXlgr)r@rrrrs rErrs}U t 333 rFcURcHUR(a7URR5nU(aURS5UlUR$rrsrTransactionHashrPrs rErPublish.transaction_hashF  ! ! )dnn..0A)*&)9&%%%rFc@Ub[U5[:XdeXlgrr@rArsrs rErr}U s 222!&rFcURc8UR(a'URR5nU(aXlUR$rrgrEncAlgorrDs rErDPublish.enc_algo6 >> !dnn~~--/H!)~~rFcDUbU[[[4;deXlgrENC_ALGO_CRYPTOBOX ENC_ALGO_MQTT ENC_ALGO_XBRrgrs rErDr!}*URR5(aURR5UlUR$rrir EncKeyLength EncKeyAsBytesrs rErLPublish.enc_keyC == T^^~~**,, $ < < > }}rFc@Ub[U5[:XdeXlgrr@rMrirs rErLrrrFcURc8UR(a'URR5nU(aXlUR$rrhr EncSerializerrrIs rErIPublish.enc_serializer;    'DNN!^^99;N'5$###rFcNUbU[[[[4;deXlgr ENC_SER_JSONENC_SER_MSGPACK ENC_SER_CBORENC_SER_UBJSONrhrs rErIr$},We)f fff$rFcUR$rrtrs rErOPublish.forward_for   rFcXlgrrrs rErOr "rFcP[[RRUS5S9$Nrrv)rr GetRootAsPublishrs rEr Publish.casts  3 3 D DS! LMMrFcURnU(a%UR[R"U55nURnU(a%UR[R"U55nUR nU(aURU5nUR nU(aURU5nURnU(aURU5nURnU(aURU5nURnU(af[RRU[U55 [U5Hn UR!U 5 M UR#[U55nUR$n U (a/n U H#n U R'URU 55 M% [RRU[U 55 [U 5Hn UR)U 5 M UR#[U 55n UR*nU (a/nUH#nUR'URU55 M% [RR-U[U55 [U5Hn UR)U 5 M UR#[U55nUR.nU(af[RR1U[U55 [U5Hn UR!U 5 M UR#[U55nUR2nU(a/nUH#n UR'URU 55 M% [RR1U[U55 [U5Hn UR)U 5 M UR#[U55nUR4nU(a/nUH#nUR'URU55 M% [RR7U[U55 [U5Hn UR)U 5 M UR#[U55n[RR9U5 UR:b)[RR=XR:5 U(a[RR?X5 U(a[RRAX5 U(a[RRCX5 U(a[RREX5 URF(a)[RRIXRF5 URJ(a)[RRMXRJ5 U(a[RROX5 URPb)[RRSXRP5 URTb)[RRWXRT5 U(a[RRYX5 U (a[RR[X5 U(a[RR]X5 U(a [RR_UU5 U(a [RRaUU5 U(a [RRcUU5 URdb)[RRgXRd5 Ub)[RRiXR5 [RRkU5n[RlRoU5 [RlRqU[RrRt5 [RlRwUU5 [RlRyU5nU$r)=rJCreateByteVectorrdumpsr{rKrw CreateStringrrLrzr PublishGenPublishStartExcludeAuthidVectorrRreversed PrependUint64 EndVectorr{rPrependUOffsetTRelativer|!PublishStartExcludeAuthroleVectorr} PublishStartEligibleAuthidVectorr~r"PublishStartEligibleAuthroleVector PublishStartrHPublishAddRequestPublishAddTopicPublishAddArgsPublishAddKwargsPublishAddPayloadrDPublishAddEncAlgorIPublishAddEncSerializerPublishAddEncKeyrxPublishAddAcknowledgeryPublishAddExcludeMePublishAddExcludePublishAddExcludeAuthidPublishAddExcludeAuthrolePublishAddEligiblePublishAddEligibleAuthidPublishAddEligibleAuthrolerPublishAddRetainPublishAddTransactionHash PublishEndr MessageStartMessageAddMsgType MessageTypePUBLISH MessageAddMsg MessageEnd)rrrJr{rKrwrrLrzrr{rmror|rnrr}r~rprrqmsg union_msgs rEr Publish.builds"yy ++EKK,=>D --ekk&.ABF,, ..w7G  ((/E00 &334DE ,, ..w7G,,   " " B B7CPWL Y#G,%%g.-''G 5G,,  O(&&w';';F'CD)  " " B B7CP_L` ao.//2/$..s?/CDN 00  " ,!(()=)=h)GH-  " " D DWcRcNd e/0//21&005F1GH ==   " " C CGSQY] [#H-%%g..((X7H.. ! ) ''(<(*>x*HI.  " " E EgsSeOf g01//22 ' 1 1#6H2I J  ++G4 << #  " " 4 4Wll K   " " 2 27 B   " " 1 1' @   " " 3 3G D   " " 4 4W F ==  " " 4 4Wmm L     " " : :7DWDW X   " " 3 3G E    '  " " 8 8BRBR S ?? &  " " 6 6w P   " " 4 4W F   " " : :7 S   " " < d47mU|;1gG{{:t4H 1( ; ;#$X$_$_`h$ijjkk)T2G4=C/#$V$]$]^bcj^k$lmm$[[)94@N&=n&M&M#$^$e$eft$uvv4y1}Aw:dC%77'(P(W(WX\]aXb(cdd4y1}a<c5'99'(R(Y(YZ^_eZf(ghhHG!N    G #!(!7 &'4/#$Z$a$abfgybz${||,K 7 " ' 5 %&$.#$Y$`$`aefwax$yzz*J  $Y/NN#t+#$V$]$]^bcq^r$stt,  #s*'(c(j(jkopzk{(|}}-%G w &$+,<$= !)*d2#$]$d$deijfA%BCC0=C''(j(q(qrvw~r)ABB13N  (&-.@&A #+,4#$_$f$fgkmDhE%FGG4  ?c)'(l(s(stxzCuD)EFF5 7   %j1OO$,#$W$^$^_cds_t$uvv,  ?c)'(d(k(klpqzl{(|}}-'H  '%,->%? "*+t3#$^$e$efjlBgC%DEE1=C''(k(r(rswxtA)BCC25O ' )'./B'C $,-5#$`$g$ghlnFiG%HII5  ?c)'(m(t(tuy{DvE)FGG6!9  w X&FF|t##$U$\$\]abh]i$jkk  (&'9: $%,#$_$f$fgkl|g}$~ G #!-0KEK D(%BBx4' *d2i=.AS.Hr)T"X,-?3-F!+tBzN/Cs/J&#$ghhg//$/& / #. / ", /&/&4/(8/ (/'6/):/$/(8/ (/ &!/"&4#/$#.%/( rFc<0nURbURUS'URbURUS'URbURUS'URbURUS'URbURUS'UR bUR US'UR bUR US'URbURUS'URbURUS 'URbURUS 'UR(aTURbURUS 'URbURUS 'URbURUS 'URbURUS'U$)Nrxryrzr{r|r}r~rrrrDrLrIrO)rxryrzr{r|r}r~rrrrKrDrLrIrOrrEs rEmarshal_optionsPublish.marshal_optionsA s    '%)%5%5GM " ?? &$(OOGL ! << #!%GI     *(,(;(;G$ %  ,*.*?*?G& ' == $"&--GJ     +)-)=)=G% &  ! ! -+/+A+AG' ( ;; " $ GH   ,*.*?*?G& ' <<}}(&*mm #||'%)\\ """.,0,?,?()    '%)%5%5GM "rFcUR5nUR(a2[RURXR UR/$UR (a=[RURXR URUR /$UR(a2[RURXR UR/$[RURXR /$r2)rUrKrrrHrwr{rJrTs rErPublish.marshalg s&&( <<(($,,T\\Z Z{{,,dllGZZQUQZQZ\`\g\ghh,,dllGZZQUQZQZ[[,,dllGZZPPrF)rjrdrorprqrgrirhrlrmrnrkrtrerfrbrrrcrs)NNNNNNNNNNNNNNNNNNNN)&rrrrrrrrrrrrHrrwrJr{rKrxryrzr{r|r}r~rrrrDrLrIrOrrrrrUrrrrFrErrs L9Ix!  $"&!%#'"& $!)l(\+Z&  ^^ \\  [[  ]]  ^^!!""  !! ^^$$%%&&''__%%&&''(( ]]&&''__  ^^$$%%!!""NNN`JJX$LQrFrc>\rSrSrSrSrSrSr\S5r Sr Sr g ) ri{ z\ A WAMP ``PUBLISHED`` message. Format: ``[PUBLISHED, PUBLISH.Request|id, Publication|id]`` )rH publicationc[U5[:Xde[U5[:Xde[RU5 XlX lg)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)r@rsr rrHr[)rrHr[s rErPublished.__init__ sBG}#$#K C'(' &rFc [U5S:aUS[R:Xde[U5S:wa#[SR [U555e[ USS5n[ USS5n[X5nU$)rrr9z(invalid message length {0} for PUBLISHEDr7z'request' in PUBLISHEDr8z'publication' in PUBLISHED)rRrrrrQr')rrHr[rs rErPublished.parse s4y1}aI,B,B!BCB t9> J Q QRUVZR[ \] ]#DG-EF'Q1MN - rFcP[RURUR/$r2)rrrHr[rs rErPublished.marshal s!&& d6F6FGGrF)r[rHNrrrFrErr{ s9 LI ' ,HrFrcZ\rSrSrSrSrSrSrSrSr SS jr \ S 5r S r S rS rg)ri z] A WAMP ``SUBSCRIBE`` message. Format: ``[SUBSCRIBE, Request|id, Options|dict, Topic|uri]`` exactprefixwildcard)rHrwrC get_retainedrONc[U5[:Xde[U5[:XdeUb[U5[:XdeUb5U[R[R [R 4;deUb[U5[LdeUb[U5[:XdeU(a~UHxn[U5[:XdeSU;a[US5[:XdeSU;aUSb[US5[:XdeSU;a[US5[:XaMxe [RU5 Xl X l U=(d [RUlX@lXPlg)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)r@rsrAr MATCH_EXACT MATCH_PREFIXMATCH_WILDCARDrrrvr rrHrwrCrgrO)rrHrwrCrgrOrRs rErSubscribe.__init__ sS0G}#$#E{c!"!}U s 232})*?*?AWAWYbYqYq)r rsr#tL'9T'ABA"d;&74&?@? !Bx4''' B49 +>#+EEE2~2h<+?48 CUY\C\]]!R'DJ,@C,GGG "   3i33 (&rFcJ[U5S:aUS[R:Xde[U5S:wa#[SR [U555e[ USS5n[ USS5n[USS S S 9n[RnS nS nS U;aUS n[U5[:wa#[SR [U555eU[R[R[R4;a[SR U55eUnSU;a;USn[U5[:wa#[SR [U555eSU;aUSnSn[U5[:XazUHrn [U 5[:wa O^SU ;d[U S5[ :wa O@SU ;d[U S5[:wa O"SU ;d[U S5[:wdMr O S nU(d [S5e[XXEUS9n U $)rrr;z(invalid message length {0} for SUBSCRIBEr7z'request' in SUBSCRIBEr8z'options' in SUBSCRIBEr9z'topic' in SUBSCRIBET)rdNrCz0invalid type {0} for 'match' option in SUBSCRIBEz1invalid value {0} for 'match' option in SUBSCRIBErgz7invalid type {0} for 'get_retained' option in SUBSCRIBErOFrrrzCinvalid type/value {0} for/within 'forward_for' option in SUBSCRIBE)rCrgrO)rRrrrrQr'r(r%rir@rArjrkrrrvrs) rrHrErwrCrgrO option_matchr\rRrs rErSubscribe.parse s 4y1}aI,B,B!BCB t9> J Q QRUVZR[ \] ]#DG-EF&tAw0HI"47,B[_`%%  g "7+LL!S(#$V$]$]^bco^p$qrrI$9$99;Q;QS\SkSk#ll#$W$^$^_k$lmm E W $">2LL!T)#$]$d$deijvew$xyy G #!-0KEK D(%BBx4' *d2i=.AS.Hr)T"X,-?3-F!+tBzN/Cs/J&#$ijje\gh rFc0nUR(a-UR[R:waURUS'URbURUS'URbURUS'U$)NrCrgrO)rCrrirgrOrTs rErUSubscribe.marshal_options@ sj ::$** (=(==#zzGG     (&*&7&7GN #    '%)%5%5GM "rFcn[RURUR5UR/$r2)rrrHrUrwrs rErSubscribe.marshalN s*&& d6J6J6LdjjYYrF)rOrgrCrHrwNNN)rrrrrrrirjrkrrrrrUrrrrFrErr s\ LKLNI"! *'X<<| ZrFrc>\rSrSrSrSrSrSr\S5r Sr Sr g) riX za A WAMP ``SUBSCRIBED`` message. Format: ``[SUBSCRIBED, SUBSCRIBE.Request|id, Subscription|id]`` !)rH subscriptionc[U5[:Xde[U5[:Xde[RU5 XlX lg)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)r@rsr rrHrw)rrHrws rErSubscribed.__init__i BG}#$#L!S()( (rFc [U5S:aUS[R:Xde[U5S:wa#[SR [U555e[ USS5n[ USS5n[X5nU$)rrr9z)invalid message length {0} for SUBSCRIBEDr7z'request' in SUBSCRIBEDr8z'subscription' in SUBSCRIBED)rRrrrrQr')rrHrwrs rErSubscribed.parsey 4y1}aJ,C,C!CDC t9> K R RSVW[S\ ]^ ^#DG-FG(a2PQ / rFcP[RURUR/$r2)rrrHrwrs rErSubscribed.marshal !''t7H7HIIrFNrrrFrErrX 9 LI ) ,JrFrcB\rSrSrSrSrSrS Sjr\S5r Sr S r g) ri z A WAMP ``UNSUBSCRIBE`` message. Formats: * ``[UNSUBSCRIBE, Request|id, SUBSCRIBED.Subscription|id]`` * ``[UNSUBSCRIBE, Request|id, SUBSCRIBED.Subscription|id, Options|dict]`` ")rHrwrONc[U5[:Xde[U5[:XdeU(a~UHxn[U5[:XdeSU;a[US5[:XdeSU;aUSb[US5[:XdeSU;a[US5[:XaMxe [R U5 XlX lX0lg)aM :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) r@rsrvrAr rrHrwrO)rrHrwrOrRs rErUnsubscribe.__init__ sG}#$#L!S()( !Bx4''' B49 +>#+EEE2~2h<+?48 CUY\C\]]!R'DJ,@C,GGG "  (&rFc[U5S:aUS[R:Xde[U5S;a#[SR [U555e[ USS5n[ USS5nSn[U5S :a[ US S 5nSnU(aS U;aUS nS n[U5[:XazUHrn[U5[:wa O^S U;d[US 5[:wa O@SU;d[US5[:wa O"SU;d[US5[:wdMr O SnU(d [S5e[XUS9nU$)rrr9r;z/invalid message length {0} for WAMP UNSUBSCRIBEr7z'request' in UNSUBSCRIBEr8z'subscription' in UNSUBSCRIBENr9z'options' in UNSUBSCRIBErOFrrrTzEinvalid type/value {0} for/within 'forward_for' option in UNSUBSCRIBErO) rRrrrrQr'r(r@rrvrsrA)rrHrwrErOr\rRrs rErUnsubscribe.parse sO4y1}aK,D,D!DED t9F " Q X XY\]aYb cd d#DG-GH(a2QR  t9q=*474NOG }/!-0KEK D(%BBx4' *d2i=.AS.Hr)T"X,-?3-F!+tBzN/Cs/J&#$kll'[I rFcUR(a6SUR0n[RURURU/$[RURUR/$rrO)rOrrrHrwrTs rErUnsubscribe.marshal s]   t//G ,,dllD$,-4'(d(k(klprFmG)HII3 7"+GH,=?YZ7&9 rFcURc URbW0nURbURUS'URbURUS'[RURU/$[RUR/$)rr!rw)r!rwrrrHr(s rErUnsubscribed.marshal[ ~ ;; "d&7&7&CG{{&$(KK!  ,*.*;*;' --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] Nrrrrv)r@rsrrQrvrMrArr)r*r rrrrdr|rerfrrrrcrrsrrgrirhrt)rrwr[rJr{rKrpublisher_authidpublisher_authrolerwretainedrx_acknowledged_deliveryrDrLrIrOrrRs rErEvent.__init__ sv#tL'9S'@A@"d;&73&>?>|tDzdE]:;:~f!565$w-5"8987#64T#9:9'40@+AS+HIH&.$7N2OSW2WXW#4X#>#>?> W_9OU\UhmunB DC$w-3"676%)@)P)PQP"d;&74&?@? !Bx4''' B49 +>#+EEE2~2h<+?48 CUY\C\]]!R'DJ,@C,GGG " 1)' '/  #!1#5  !!1(?%! -'rFc[XR5(dg[RX5(dgURUR:wagUR UR :wagUR UR :wagURUR:wagURUR:wagURUR:wagURUR:wagURUR:wagURUR:wagURUR:wagURUR:wagURUR:wagUR UR :wagUR"UR":wagUR$UR$:wagUR&UR&:waggr)rxrr rrwr[rJr{rKrrrrwrrrrDrLrIrOrs rEr Event.__eq__ sy%00~~d**   !2!2 2    0 0 0 :: " <<4;; & ==DLL ( ??dnn ,  ! !T%:%: :  # #t'>'> > ;;$** $ >>T]] *  ! !T%:%: :  ( (D,H,H H >>T]] * ==DLL (   4#6#6 6    0 0 0rFc.URU5(+$rrrs rEr Event.__ne__> rrFcURc0UR(aURR5UlUR$r)rr Subscriptionrs rErwEvent.subscriptionA s5    %$..!%!D !!!rFc@Ub[U5[:XdeXlgr)r@rsrrs rErwrG s}U s 232"rFcURc0UR(aURR5UlUR$r)rr Publicationrs rEr[Event.publicationL s5    $ $ : : URR5(aURR5UlUR$rrrs rErK Event.payloado rrFc@Ub[U5[:XdeXlgrrrs rErKrv rrFcURc8UR(a'URR5nU(aXlUR$r)rr Publisher)rrs rErEvent.publisher{ s6 ?? "t~~002I"+rFc@Ub[U5[:XdeXlgr)r@rsrrs rErr s}U s 222rFcURcHUR(a7URR5nU(aURS5UlUR$r)rrPublisherAuthidrPrs rErEvent.publisher_authid rrFc@Ub[U5[:XdeXlgr)r@rArrs rErr rrFcURcHUR(a7URR5nU(aURS5UlUR$r)rrPublisherAuthrolerPrs rErEvent.publisher_authrole sF  # # +002A+,88F+;('''rFc@Ub[U5[:XdeXlgr)r@rArrs rErr s}U s 222#( rFcURcHUR(a7URR5nU(aURS5UlUR$rrrs rErw Event.topic rrFc@Ub[U5[:XdeXlgrrrs rErwr rrFcURc0UR(aURR5UlUR$r)rrRetainedrs rErEvent.retained s0 >> !dnn!^^446DN~~rFc@Ub[U5[:XdeXlgr)r@rrrs rErr s}U t 333rFcURcHUR(a7URR5nU(aURS5UlUR$rrrs rErEvent.transaction_hash rrFc@Ub[U5[:XdeXlgrrrs rErr rrFcURc8UR(a'URR5nU(aXlUR$r)rrr)rrs rErEvent.x_acknowledged_delivery s<  ( ( 0T^^&*nn&@&@&B #&0G-,,,rFc@Ub[U5[:XdeXlgr)r@rrrs rErr s}U t 333(-%rFcURc8UR(a'URR5nU(aXlUR$rrrs rErDEvent.enc_algo rrFcDUbU[[[4;deXlgrrrs rErDr rrFcURcOUR(a>URR5(aURR5UlUR$rrrs rErL Event.enc_key rrFc@Ub[U5[:XdeXlgrrrs rErLr rrFcURc8UR(a'URR5nU(aXlUR$rrrs rErIEvent.enc_serializer rrFcNUbU[[[[4;deXlgrrrs rErIr r rFcUR$rrrs rErOEvent.forward_for rrFcXlgrrrs rErOr rrFcP[[RRUS5S9$r)rr GetRootAsEventrs rEr Event.casts k//>>sAFGGrFc URnU(a%UR[R"U55nURnU(a%UR[R"U55nUR nU(aURU5nUR nU(aURU5nURnU(aURU5nURnU(aURU5nURnU(aURU5nURn U (aURU 5n [RRU5 UR(a)[RR!XR5 UR"(a)[RR%XR"5 U(a[RR'X5 U(a[RR)X5 U(a[RR+X5 UR,(a)[RR/XR,5 U(a[RR1X5 U(a[RR3X5 U(a[RR5X5 UR6b)[RR9XR65 Ub[RR;X5 UR<b)[RR?XR<5 UR@(a)[RRCXR@5 U (a[RREX5 URF(a)[RRIXRF5 [RRKU5n [RLROU5 [RLRQU[RRRT5 [RLRWX5 [RLRYU5n U $r)-rJrrrr{rKrrrrwrrLr EventGen EventStartrwEventAddSubscriptionr[EventAddPublication EventAddArgsEventAddKwargsEventAddPayloadrEventAddPublisherEventAddPublisherAuthidEventAddPublisherAuthrole EventAddTopicrEventAddRetainedEventAddTransactionHashrEventAddAcknowledgerDEventAddEncAlgoEventAddEncKeyrIEventAddEncSerializerEventEndr r9r:r;EVENTr=r>) rrrJr{rKrrrwrrLr@rAs rEr Event.builds?yy ++EKK,=>D --ekk&.ABF,, ..w7G00 &334DE !44 !(!5!56H!I   ((/E00 &334DE ,, ..w7G''0     5 5g?P?P Q     4 4W>N>N O   - -g <   / / @   0 0 B >>  2 27NN K   8 8 S   : :7 W   . .w > == $  1 1'== I  '  8 8 S  ' ' 3  4 4W>Z>Z [ ==  0 0-- H   / / A     6 6w@S@S T""++G4((1--g{7N7N7T7TU))'7''227; rFc [U5S:aUS[R:Xde[U5S;a#[SR [U555e[ USS5n[ USS5n[ USS 5nS nS nS nS nS nS n [U5S :Xa[US 5[:XaUS nURS S 5nU(a*[U5(d[SR U55eURSS 5nU(a6[U5[:wa#[SR [U555eURSS 5n U (a*[U 5(d[SR U 55eO[U5S :a>US nUb6[U5[:wa#[SR [U555e[U5S :a;US n[U5[:wa#[SR [U555eS n S n S n S n S nS nS nS nSU;a=USn[U5[:wa#[SR [U555eUn SU;a=USn[U5[:wa#[SR [U555eUn SU;a=USn[U5[:wa#[SR [U555eUn SU;a=USn[U5[:wa#[SR [U555eUn SU;a;USn[U5[ :wa#[SR [U555eSU;a=USn[U5[:wa#[S R [U555eUnS!U;a;US!n[U5[ :wa#[S"R [U555eS#U;aUS#nS$n[U5[:XazUHrn[U5[:wa O^S%U;d[US%5[:wa O@S&U;d[US&5[:wa O"S'U;d[US'5[:wdMr O S(nU(d [S)5e[UUUUUU U U U UUUUUU US*9nU$)+rrrDz$invalid message length {0} for EVENTr7z'subscription' in EVENTr8z'publication' in EVENTr9z'details' in EVENTNr<r;rDrVrLrWrIrXz$invalid type {0} for 'args' in EVENTz&invalid type {0} for 'kwargs' in EVENTrz0invalid type {0} for 'publisher' detail in EVENTrz7invalid type {0} for 'publisher_authid' detail in EVENTrz9invalid type {0} for 'publisher_authrole' detail in EVENTrwz,invalid type {0} for 'topic' detail in EVENTrz/invalid type {0} for 'retained' detail in EVENTr7invalid type {0} for 'transaction_hash' detail in EVENTrz>invalid type {0} for 'x_acknowledged_delivery' detail in EVENTrOFrrrTz?invalid type/value {0} for/within 'forward_for' option in EVENT)rJr{rKrrrrwrrrrDrLrIrO)rRrrrrQr'r(r@rMrr)rAr*rrvrsr)rrwr[rrJr{rKrDrLrIrrrrwrrrOrdetail_publisherdetail_publisher_authiddetail_publisher_authrole detail_topicdetail_transaction_hashr\rRrs rEr Event.parseZs4y1}aE,>,>!>?> t9I % F M McRVi XY Y(a2KL 'Q1IJ &tAw0DE t9>d47mu41gG{{:t4H 1( ; ;#$V$]$]^f$ghhkk)T2G4=C/#$T$[$[\`ah\i$jkk$[[)94@N&=n&M&M#$\$c$cdr$stt4y1}Aw#T d(:'(N(U(UVZ[_V`(abb4y1}a<4''(P(W(WX\]cXd(eff ! "& ' !&{3 $%,#$V$]$]^bcs^t$uvv(I  (&-.@&A #+,3#$]$d$deikBfC%DEE6  7 *(/0D(E %-.#5#$_$f$fgkmFhG%HII!:  g "7+LL!S(#$R$Y$YZ^_kZl$mnn E  z*HH~%#$U$\$\]abj]k$lmm  (&-.@&A #+,3#$]$d$deikBfC%DEE6  $ /&-.G&H #+,4#$d$k$klprImJ%KLL G #!-0KEK D(%BBx4' *d2i=.AS.Hr)T"X,-?3-F!+tBzN/Cs/J&#$effL!#'%5'9%%5,C%##1 +-" rFcf0nURbURUS'URbURUS'URbURUS'URbURUS'URbURUS'UR bUR US'UR bUR US'URbURUS'UR(aURbURUS 'URbURUS 'URbURUS '[RURURXR/$UR (a=[RURURXR"UR /$UR"(a2[RURURXR"/$[RURURU/$) rrrrrwrrrrOrDrLrI)rrrrwrrrrOrKrDrLrIrrrwr[r{rJr(s rEr Event.marshals >> %#'>>GK  ,*.*?*?G& '  " " .,0,C,CG( ) :: !#zzGG  == $"&--GJ   ,*.*?*?G& '  ' ' 3151M1MG- .    '%)%5%5GM " <<}}(&*mm #||'%)\\ """.,0,?,?()&&(9(94;K;KWVbVbc c{{**D,=,=t?O?OQXZcZceiepepqq**D,=,=t?O?OQXZcZcdd**D,=,=t?O?OQXYYrF)rdrgrirhrtrerfrrrrrrrcrsr)NNNNNNNNNNNNNNNNN)"rrrrrrrrrrrrwrr[rJr{rKrrrrwrrrrDrLrIrOrrrrrrrrFrErrm sL L0Id]aW[OSOS e(N%N&"" ##!! ""  [[  ]]  ^^  &&''(()) \\ __&&''--##.$.__  ^^$$%%!!""HHPdRRh/ZrFrc>\rSrSrSrSrSrSr\S5r Sr Sr g) EventReceivedi!zX A WAMP ``EVENT_RECEIVED`` message. Format: ``[EVENT_RECEIVED, EVENT.Publication|id]`` iQ)r[cd[U5[:Xde[RU5 Xlg)zT :param publication: The publication ID for the sent event. :type publication: int N)r@rsr rr[)rr[s rErEventReceived.__init__2s+ K C'('&rFc[U5S:aUS[R:Xde[U5S:wa#[SR [U555e[ USS5n[U5nU$)rrr8z-invalid message length {0} for EVENT_RECEIVEDr7z'publication' in EVENT_RECEIVED)rRrrrrQr')rr[rs rErEventReceived.parse=so4y1}aM,F,F!FGF t9> O V VWZ[_W` ab b'Q1RS K( rFc:[RUR/$r2)rrr[rs rErEventReceived.marshalSs**D,<,<==rFNrrrFrErr!s8LI '*>rFrcb\rSrSrSrSrSrS Sjr\S5r Sr S r S r g) ri]a? 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)rH procedurerJr{rKtimeoutreceive_progressrrDrLrIr caller_authidcaller_authrolerONc[U5[:Xde[U5[:XdeUb[U5[[4;deUb[U5[ :XdeUb[U5[ :XdeUb UbUcUbeUb[U5[:XdeUb[U5[:XdeUb[U5[:XdeU b[U 5(deU b[U 5[:XdeU b[U 5(deU cU cU bUbU ceU b[U 5[:XdeU b[U 5[:XdeUb[U5[:XdeUb[U5[:XdeU(a~UHxn[U5[ :XdeSU;a[US5[:XdeSU;aUSb[US5[:XdeSU;a[US5[:XaMxe [RU5 Xl X l X0l[U5UlXPlX`lXplXlXlXlXlXlXlXlXlg)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)r@rsrArrQrvrMrr)r*r rrHrrJr|r{rKrrrrDrLrIrrrrO)rrHrrJr{rKrrrrDrLrIrrrrOrRs rEr Call.__init__sJG}#$#I#%&%|tDzdE]:;:~f!565$w-5"8987#64#>?>$w-3"676%)@)P)PQP W_9OU\UhmunB DC~f!454$](;s(BCB&$*?3*FGF"d;&74&?@? !Bx4''' B49 +>#+EEE2~2h<+?48 CUY\C\]]!R'DJ,@C,GGG "  " &v.   0 0!  , *.&rFcl [U5S:aUS[R:Xde[U5S;a#[SR [U555e[ USS5n[ USS5n[USS 5nS nS nS nS nS nS n [U5S :Xa[US 5[[4;aUS nURS S 5nU(a*[U5(d[SR U55eURSS 5nU(a6[U5[:wa#[SR [U555eURSS 5n U (a*[U 5(d[SR U 55eO[U5S :a>US nUb6[U5[:wa#[SR [U555e[U5S :a;US n[U5[:wa#[SR [U555eS n S n S n S n S nS nS nSU;a]USn[U5[ :wa#[SR [U555eUS:a[SR U55eUn SU;a=USn[U5[":wa#[SR [U555eUn SU;a=USn[U5[:wa#[SR [U555eUn SU;a=USn[U5[ :wa#[SR [U555eUn SU;a=USn[U5[:wa#[SR [U555eUnS U;a=US n[U5[:wa#[S!R [U555eUnS"U;aUS"nS#n[U5[:XazUHrn[U5[:wa O^S$U;d[US$5[ :wa O@S%U;d[US%5[:wa O"S&U;d[US&5[:wdMr O S'nU(d [S(5e[UUUUUU U U UUU U UUUS)9nU$)*rrrDz#invalid message length {0} for CALLr7z'request' in CALLr8z'options' in CALLr9z'procedure' in CALLNr<r;rDz/invalid value {0} for 'enc_algo' detail in CALLrLz-invalid type {0} for 'enc_key' detail in CALLrIz5invalid 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 CALLrz6invalid 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 CALLrOFrrrTz>invalid type/value {0} for/within 'forward_for' option in CALL) rJr{rKrrrrDrLrIrrrrO)rRrrrrQr'r(r%r@rArMrr)r*rrvrsr)rrHrErrJr{rKrDrLrIrrrrrrrOoption_timeoutoption_receive_progressoption_transaction_hash option_calleroption_caller_authidoption_caller_authroler\rRrs rEr Call.parses4y1}aD,=,=!=>= t9I % E L LSQUY WX X#DG-@A&tAw0CD&tAw0EF  t9>d47mU|;1gG{{:t4H 1( ; ;#$U$\$\]e$fggkk)T2G4=C/#$S$Z$Z[_`g[h$ijj$[[)94@N&=n&M&M#$[$b$bcq$rss4y1}Aw#T d(:'(M(T(TUYZ^U_(`aa4y1}a<4''(O(V(VW[\bWc(dee   $Y/NN#s*#$S$Z$Z[_`n[o$pqq!#$T$[$[\j$kll$G  (&-.@&A #+,4#$\$c$cdhjAeB%CDD6   (&-.@&A #+,3#$\$c$cdhjAeB%CDD6  w #H-MM"c)#$R$Y$YZ^_lZm$noo"F g %#*?#; ()S0#$Y$`$`aefza{$|}}0M  '%,->%? "*+s2#$[$b$bcgh~c%ABB4O G #!-0KEK D(%BBx4' *d2i=.AS.Hr)T"X,-?3-F!+tBzN/Cs/J&#$dee7 ""$4$4$""0 !.#2*,  rFc\0nURbURUS'URbURUS'URbURUS'UR(aTURbURUS'UR bUR US'UR bUR US'URbURUS'URbURUS'URbURUS 'URbURUS 'U$) NrrrrDrLrIrrrrO) rrrrKrDrLrIrrrrOrTs rErUCall.marshal_optionss << #!%GI   ,*.*?*?G& '  ,*.*?*?G& ' <<}}(&*mm #||'%)\\ """.,0,?,?() ;; " $ GH     )'+'9'9GO $    +)-)=)=G% &    '%)%5%5GM "rFcUR5nUR(a2[RURXR UR/$UR (a=[RURXR URUR /$UR(a2[RURXR UR/$[RURXR /$r2)rUrKrrrHrr{rJrTs rEr Call.marshals&&( <<%%t||Wnndll[ [{{))4<<..RVR[R[]a]h]hii))4<<..RVR[R[\\))4<<..QQrF)rJrrrrDrLrIrOr{rKrrrHrr) NNNNNNNNNNNNN) rrrrrrrrrrrUrrrrFrErr]sm LI*"&"& $#!%!t'lRRh@RrFrcN\rSrSrSrSrSrSrSrSr S S jr \ S 5r S r S rg)riz 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)rHmoderONc:[U5[:XdeUb[U5[:XdeUSURURUR 4;deUb[U5[ :XdeU(a~UHxn[U5[:XdeSU;a[US5[:XdeSU;aUSb[US5[:XdeSU;a[US5[:XaMxe [RU5 Xl X l X0l g)aP :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) r@rsrASKIP KILLNOWAITKILLrrvr rrHr'rO)rrHr'rOrRs rErCancel.__init__s G}#$#|tDzS010dii$))DDED"d;&74&?@? !Bx4''' B49 +>#+EEE2~2h<+?48 CUY\C\]]!R'DJ,@C,GGG "   'rFc[U5S:aUS[R:Xde[U5S:wa#[SR [U555e[ USS5n[ USS5nSnSnS U;aUS n[U5[:wa#[S R [U555eU[R[R[R4;a[S R U55eUnS U;aUS nS n[U5[:XazUHrn[U5[:wa O^SU;d[US5[:wa O@SU;d[US5[:wa O"SU;d[US5[:wdMr O SnU(d [S5e[XUS9nU$)rrr9z%invalid message length {0} for CANCELr7z'request' in CANCELr8z'options' in CANCELNr'z,invalid type {0} for 'mode' option in CANCELz/invalid value '{0}' for 'mode' option in CANCELrOFrrrTz@invalid type/value {0} for/within 'forward_for' option in CANCEL)r'rO)rRrrrrQr'r(r@rAr)r*r+rrvrs) rrHrEr'rO option_moder\rRrs rEr Cancel.parses4y1}aF,?,?!?@? t9> G N NsSWy YZ Z#DG-BC&tAw0EF W !&/KK C'#$R$Y$YZ^_jZk$lmm6;;0A0A6;;"OO#$U$\$\]h$ijjD G #!-0KEK D(%BBx4' *d2i=.AS.Hr)T"X,-?3-F!+tBzN/Cs/J&#$fggW[A rFc0nURbURUS'URbURUS'[RURU/$)rr'rO)r'rOrrrHrTs rErCancel.marshal/sS 99 "iiGFO    '%)%5%5GM "##T\\7;;rF)rOr'rHr)rrrrrrr)r+r*rrrrrrrrFrErrsJL D DJI '>66pT#9:9#4X#>#>?>$w-3"676%)@)P)PQP W_9OU\UhmunB DC~f!454$](;s(BCB&$*?3*FGF"d;&74&?@? !Bx4''' B49 +>#+EEE2~2h<+?48 CUY\C\]]!R'DJ,@C,GGG "   &v.   !  , *.'rFc[U5S:aUS[R:Xde[U5S;a#[SR [U555e[ USS5n[ USS5nSnSnSnSnSnSnSn Sn Sn Sn Sn [U5S :Xa[US 5[[4;aUS nURS S5nU(a*[U5(d[S R U55eURS S5nU(a6[U5[:wa#[SR [U555eURSS5n U (a*[U 5(d[SR U 55eO[U5S :a>US nUb6[U5[:wa#[SR [U555e[U5S :a;US n[U5[:wa#[SR [U555eSU;a=USn[U5[:wa#[SR [U555eUnSU;a=USn[U5[ :wa#[SR [U555eUn SU;a=USn[U5[:wa#[SR [U555eUn SU;a=USn[U5[:wa#[SR [U555eUn SU;aUSn Sn[U 5[:XazU Hrn[U5[:wa O^SU;d[US5[ :wa O@SU;d[US5[:wa O"SU;d[US5[:wdMr O S nU(d [S!5e[UUUUUUUU U U U U S"9 nU$)#rrr9r;r<z%invalid message length {0} for RESULTr7z'request' in RESULTr8z'details' in RESULTNr;r9rDz1invalid value {0} for 'enc_algo' detail in RESULTrLz/invalid type {0} for 'enc_key' detail in RESULTrIz7invalid value {0} for 'enc_serializer' detail in RESULTz%invalid type {0} for 'args' in RESULTz'invalid type {0} for 'kwargs' in RESULTr5z0invalid type {0} for 'progress' option in RESULTrz.invalid type {0} for 'callee' detail in RESULTrMz5invalid type {0} for 'callee_authid' detail in RESULTrNz7invalid type {0} for 'callee_authrole' detail in RESULTrOFrrrTz@invalid type/value {0} for/within 'forward_for' option in RESULT rJr{rKr5rDrLrIrrMrNrO)rRrrrrQr'r(r@rArMrr)r*rrvrrs)rrHrrJr{rKr5rDrLrIrrMrNrOdetail_progressrYrZr[r\rRrs rEr Result.parses4y1}aF,?,?!?@? t9I % G N NsSWy YZ Z#DG-BC&tAw0EF  t9>d47mU|;1gG{{:t4H 1( ; ;#$W$^$^_g$hiikk)T2G4=C/#$U$\$\]abi]j$kll$[[)94@N&=n&M&M#$]$d$des$tuu4y1}Aw#T d(:'(O(V(VW[\`Wa(bcc4y1}a<4''(Q(X(XY]^dYe(fgg  %j1OO$,#$V$]$]^bcr^s$tuu&H w #H-MM"c)#$T$[$[\`an\o$pqq"F g %#*?#; ()S0#$[$b$bcgh|c}$~0M  '%,->%? "*+s2#$]$d$deikAfB%CDD4O G #!-0KEK D(%BBx4' *d2i=.AS.Hr)T"X,-?3-F!+tBzN/Cs/J&#$fggW"$&&$$2"#0%4!, . rFcf0nURbURUS'URbURUS'URbURUS'URbURUS'URbURUS'UR (a{UR bUR US'URbURUS'URbURUS'[RURXR /$UR(a2[RURXRUR/$UR(a'[RURXR/$[RURU/$ rr5rrMrNrOrDrLrI)r5rrMrNrOrKrDrLrIrrrHr{rJr(s rErResult.marshal=s^ == $"&--GJ  ;; " $ GH     )'+'9'9GO $    +)-)=)=G% &    '%)%5%5GM " <<}}(&*mm #||'%)\\ """.,0,?,?()''w M M{{++T\\7IIt{{[[++T\\7IINN++T\\7CCrF rJrrMrNrDrLrIrOr{rKr5rH NNNNNNNNNNNrrrFrErr@sa L I" $#!%!`'Dxxt#DrFrcv\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSSjr\S5rSrSrSrg)ricz_ A WAMP ``REGISTER`` message. Format: ``[REGISTER, Request|id, Options|dict, Procedure|uri]`` @rdrerfsinglefirstlast roundrobinrandomall)rHrrCinvoke concurrencyforce_reregisterrONc8[U5[:Xde[U5[:XdeUb[U5[:XdeUb5U[R[R [R 4;deUb[U5[:XdeUbSU[R[R[R[R[R4;deUb[U5[:XaUS:deUS;deUb[U5[:XdeU(a~UHxn[U5[:XdeSU;a[US5[:XdeSU;aUSb[US5[:XdeSU;a[US5[:XaMxe [RU5 XlX lU=(d [RUlU=(d [RUlXPlX`lXplg)ai :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)r@rsrArrirjrk INVOKE_SINGLE INVOKE_FIRST INVOKE_LASTINVOKE_ROUNDROBIN INVOKE_RANDOMrrvr rrHrrCrLrMrNrO) rrHrrCrLrMrNrOrRs rErRegister.__init__s:G}#$#I#%&%}U s 232}(*>*>@U@UW_WnWn)o opo~f!454~H,B,BHDYDY[c[o[oqyrLrLNVNdNd,e"e fe"tK'8C'?KRSOUT#6666"d;&74&?@? !Bx4''' B49 +>#+EEE2~2h<+?48 CUY\C\]]!R'DJ,@C,GGG "  "2h22 6 6 6 & 0&rFc <[U5S:aUS[R:Xde[U5S:wa#[SR [U555e[ USS5n[ USS5n[Rn[RnSnSnSnS U;aUS n[U5[:wa#[S R [U555eU[R[R[R4;a[S R U55eUnU[R:XaS n S n O=U[R:XaS n S n O$U[R:XaS n S n O [S5e[USSXS9n SU;aUSn [U 5[:wa#[SR [U 555eU [R[R[R [R"[R$4;a[SR U 55eU nSU;a]USn [U 5[&:wa#[SR [U 555eU S:a[SR U 55eU nUR)SS5nUS;a#[SR [U555eUbUnSU;aUSnS n[U5[*:XazUHrn[U5[,:wa O^SU;d[US5[&:wa O@SU;d[US5[:wa O"SU;d[US5[:wdMr O S nU(d [S5e[XX4UXgS 9nU$)!rrr;z'invalid message length {0} for REGISTERr7z'request' in REGISTERr8z'options' in REGISTERNrCz/invalid type {0} for 'match' option in REGISTERz0invalid value {0} for 'match' option in REGISTERFTz logic errorr9z'procedure' in REGISTER)rdrerLz0invalid type {0} for 'invoke' option in REGISTERz1invalid value {0} for 'invoke' option in REGISTERrMz5invalid type {0} for 'concurrency' option in REGISTERz6invalid value {0} for 'concurrency' option in REGISTERrN)TFNz9invalid type {0} for 'force_reregister option in REGISTERrOrrrzBinvalid type/value {0} for/within 'forward_for' option in REGISTER)rCrLrMrNrO)rRrrrrQr'r(rirPr@rArjrk Exceptionr%rQrRrSrTrsrrrv)rrHrErCrLrMrNrOrnrdrer option_invokeoptions_concurrencyoptions_reregisterr\rRrs rErRegister.parses4y1}aH,A,A!ABA t9> I P PQTUYQZ [\ \#DG-DE&tAw0GH$$''  g "7+LL!S(#$U$\$\]abn]o$pqqH$8$8(:O:OQYQhQh#ii#$V$]$]^j$kll E H(( (%* "$  h++ +%* "#  h-- -%) "$ M* *&tAw0Ibx] w #H-MM"c)#$V$]$]^bcp^q$rssX%;%;X=R=RT\ThThjrkEkEGOG]G]%^^#$W$^$^_l$mnn"F G #")-"8 '(C/#$[$b$bcgh{c|$}~~"Q&#$\$c$cdw$xyy-K$[[);TB %8 8KRR+,   )1  G #!-0KEK D(%BBx4' *d2i=.AS.Hr)T"X,-?3-F!+tBzN/Cs/J&#$hiiwS^(8S rFc0nUR(a-UR[R:waURUS'UR(a-UR[R:waURUS'UR (aUR US'UR bUR US'URbURUS'U$)NrCrLrMrNrO)rCrrirLrPrMrNrOrTs rErURegister.marshal_options&s ::$**(<(<<#zzGG  ;;4;;(*@*@@ $ GH    %)%5%5GM "  ,*.*?*?G& '    '%)%5%5GM "rFcn[RURUR5UR/$r2)rrrHrUrrs rErRegister.marshal:s*%%t||T5I5I5KT^^\\rF)rMrNrOrLrCrrH)NNNNN)rrrrrrrirjrkrPrQrRrSrT INVOKE_ALLrrrrrUrrrrFrErrcs LKLNMLK$MJI!"&!4'liiV(]rFrc>\rSrSrSrSrSrSr\S5r Sr Sr g ) riDz` A WAMP ``REGISTERED`` message. Format: ``[REGISTERED, REGISTER.Request|id, Registration|id]`` A)rH registrationc[U5[:Xde[U5[:Xde[RU5 XlX lg)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)r@rsr rrHrc)rrHrcs rErRegistered.__init__UrzrFc [U5S:aUS[R:Xde[U5S:wa#[SR [U555e[ USS5n[ USS5n[X5nU$)rrr9z)invalid message length {0} for REGISTEREDr7z'request' in REGISTEREDr8z'registration' in REGISTERED)rRrrrrQr')rrHrcrs rErRegistered.parseer}rFcP[RURUR/$r2)rrrHrcrs rErRegistered.marshal|rrF)rcrHNrrrFrErrDrrFrcB\rSrSrSrSrSrS Sjr\S5r Sr S r g) r iz A WAMP `UNREGISTER` message. Formats: * ``[UNREGISTER, Request|id, REGISTERED.Registration|id]`` * ``[UNREGISTER, Request|id, REGISTERED.Registration|id, Options|dict]`` B)rHrcrONc[U5[:Xde[U5[:Xde[RU5 XlX lX0lg)aF :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)r@rsr rrHrcrO)rrHrcrOs rErUnregister.__init__sHG}#$#L!S()( (&rFc[U5S:aUS[R:Xde[U5S;a#[SR [U555e[ USS5n[ USS5nSn[U5S :a[ US S 5nSnU(aS U;aUS nS n[U5[:XazUHrn[U5[:wa O^S U;d[US 5[:wa O@SU;d[US5[:wa O"SU;d[US5[:wdMr O SnU(d [S5e[XUS9nU$)rrrz.invalid message length {0} for WAMP UNREGISTERr7z'request' in UNREGISTERr8z'registration' in UNREGISTERNr9z'options' in UNREGISTERrOFrrrTzDinvalid type/value {0} for/within 'forward_for' option in UNREGISTERr) rRr rrrQr'r(r@rrvrsrA)rrHrcrErOr\rRrs rErUnregister.parsesO4y1}aJ,C,C!CDC t9F " P W WX[\`Xa bc c#DG-FG(a2PQ  t9q=*474MNG }/!-0KEK D(%BBx4' *d2i=.AS.Hr)T"X,-?3-F!+tBzN/Cs/J&#$jkkKH rFcUR(a6SUR0n[RURURU/$[RURUR/$r)rOr rrHrcrTs rErUnregister.marshals]   t//G++T\\4;L;LgV V++T\\4;L;LM MrF)rOrcrHrrrrFrEr r s:LI '*++Z NrFr cB\rSrSrSrSrSrS Sjr\S5r Sr S r g) r!iz A WAMP ``UNREGISTERED`` message. Formats: * ``[UNREGISTERED, UNREGISTER.Request|id]`` * ``[UNREGISTERED, UNREGISTER.Request|id, Details|dict]`` C)rHrcr!Nc [U5[:XdeUb[U5[:XdeUb[U5[:XdeUS:waUbUS:XaUS:wde[R U5 XlX lX0lg)a9 :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)r@rsrAr rrHrcr!)rrHrcr!s rErUnregistered.__init__sG}#$##tL'9S'@A@~f!4541 !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)r@rsrrQrvrMrrAr)r*r rrHrcrJr|r{rKrrrrrrrrDrLrIrO)rrHrcrJr{rKrrrrrrrrDrLrIrOrRs rErInvocation.__init__vsPG}#$#L!S()(|tDzdE]:;:~f!565$w-5"8987#64#>?>$w-3"676%)@)P)PQP W_9OU\UhmunB DC"d;&74&?@? !Bx4''' B49 +>#+EEE2~2h<+?48 CUY\C\]]!R'DJ,@C,GGG "  ( &v.   0 *." 0  ,'rFc [U5S:aUS[R:Xde[U5S;a#[SR [U555e[ USS5n[ USS5n[ USS 5nS nS nS nS nS nS n [U5S :Xa[US 5[:XaUS nURS S 5nU(a*[U5(d[SR U55eURSS 5nU(a6[U5[:wa#[SR [U555eURSS 5n U (a*[U 5(d[SR U 55eO[U5S :a>US nUb6[U5[:wa#[SR [U555e[U5S :a;US n[U5[:wa#[SR [U555eS n S n S n S n S nS nS nS nSU;a]USn[U5[:wa#[SR [U555eUS:a[SR U55eUn SU;a=USn[U5[ :wa#[SR [U555eUn SU;a=USn[U5[:wa#[SR [U555eUn SU;a=USn[U5[:wa#[SR [U555eUn SU;a=USn[U5[:wa#[SR [U555eUnS U;a=US n[U5[:wa#[S!R [U555eUnS"U;a=US"n[U5[:wa#[S#R [U555eUnS$U;aUS$nS%n[U5[:XazUHrn[U5[:wa O^S&U;d[US&5[:wa O@S'U;d[US'5[:wa O"S(U;d[US(5[:wdMr O S)nU(d [S*5e[UUUUUU U U U UUUUUU US+9nU$),rrrDz)invalid message length {0} for INVOCATIONr7z'request' in INVOCATIONr8z'registration' in INVOCATIONr9z'details' in INVOCATIONNr<r;rDz5invalid value {0} for 'enc_algo' detail in INVOCATIONrLz3invalid type {0} for 'enc_key' detail in INVOCATIONrIz;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 INVOCATIONrzd47mu41gG{{:t4H 1( ; ;#$[$b$bck$lmmkk)T2G4=C/#$Y$`$`aefman$opp$[[)94@N&=n&M&M#$a$h$hiw$xyy4y1}Aw#T d(:'(S(Z(Z[_`d[e(fgg4y1}a<4''(U(\(\]abh]i(jkk    $Y/NN#s*#$Y$`$`aeftau$vww!#$Z$a$abp$qrr$G  (&-.@&A #+,4#$b$i$ijnpGkH%IJJ6  w #H-MM"c)#$X$_$_`der`s$tuu"F g %#*?#; ()S0#$_$f$fgkmAhB%CDD0M  '%,->%? "*+s2#$a$h$himoEjF%GHH4O ' !&{3 $%,#$[$b$bcghxcy$z{{(I  (&-.@&A #+,3#$]$d$deikBfC%DEE6  G #!-0KEK D(%BBx4' *d2i=.AS.Hr)T"X,-?3-F!+tBzN/Cs/J&#$jkk%" &!(!(*: &'4)8#,*:"*!((6%02" rFcf0nURbURUS'URbURUS'URbURUS'URbURUS'URbURUS'UR bUR US'UR bUR US'URbURUS'UR(aURbURUS 'URbURUS 'URbURUS '[RURURXR/$UR (a=[RURURXR"UR /$UR"(a2[RURURXR"/$[RURURU/$) rrrrrrrrrOrDrLrI)rrrrrrrrOrKrDrLrIr"rrHrcr{rJrTs rErInvocation.marshals << #!%GI   ,*.*?*?G& ' ;; " $ GH     )'+'9'9GO $    +)-)=)=G% & >> %#'>>GK  ,*.*?*?G& '    '%)%5%5GM " <<}}(&*mm #||'%)\\ """.,0,?,?()++T\\4;L;LgWcWcd d{{"//t?P?PRY[d[dfjfqfqrr"//t?P?PRY[d[dee"//t?P?PRYZZrF)rJrrrrDrLrIrOr{rKrrrcrHrr)NNNNNNNNNNNNNNrrrFrEr"r"Rsj LI,"&#!%"& $!!t'l\\|/[rFr"cJ\rSrSrSrSrSrSrSrS Sjr \ S 5r S r S r g) r#iz 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 Er%r&)rHr'r!rONcb[U5[:XdeUb[U5[:XdeUbX RUR4;deUb[U5[:XdeUb[U5[ :XdeU(a~UHxn[U5[ :XdeSU;a[US5[:XdeSU;aUSb[US5[:XdeSU;a[US5[:XaMxe [RU5 Xl X l X0l X@l g)a :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) r@rsrAr+r*rrvr rrHr'r!rO)rrHr'r!rOrRs rErInterrupt.__init__s,G}#$#|tDzS010|t 4??'CCDC~f!454"d;&74&?@? !Bx4''' B49 +>#+EEE2~2h<+?48 CUY\C\]]!R'DJ,@C,GGG "    'rFc[U5S:aUS[R:Xde[U5S:wa#[SR [U555e[ USS5n[ USS5nSnSnSnS U;a{US n[U5[:wa#[S R [U555eU[R[R4;a[S R U55eUnS U;a[US S 5nSU;aUSnSn[U5[:XazUHrn[U5[:wa O^SU;d[US5[:wa O@SU;d[US5[:wa O"SU;d[US5[:wdMr O SnU(d [S5e[XXES9n U $)rrr9z(invalid message length {0} for INTERRUPTr7z'request' in INTERRUPTr8z'options' in INTERRUPTNr'z/invalid type {0} for 'mode' option in INTERRUPTz2invalid value '{0}' for 'mode' option in INTERRUPTr!z"reason" in INTERRUPTrOFrrrTzCinvalid type/value {0} for/within 'forward_for' option in INTERRUPT)r'r!rO)rRr#rrrQr'r(r@rAr+r*r%rrvrs) rrHrEr'r!rOr.r\rRrs rErInterrupt.parses4y1}aI,B,B!BCB t9> J Q QRUVZR[ \] ]#DG-EF&tAw0HI W !&/KK C'#$U$\$\]abm]n$opp9>>93G3G"HH#$X$_$_`k$lmmD w '(9;RSF G #!-0KEK D(%BBx4' *d2i=.AS.Hr)T"X,-?3-F!+tBzN/Cs/J&#$ijj6S rFc0nURbURUS'URbURUS'URbURUS'[RUR U/$)rr'r!rO)r'r!rOr#rrHrTs rErInterrupt.marshal=sk 99 "iiGFO ;; " $ GH     '%)%5%5GM "&& g>>rF)rOr'r!rHrt)rrrrrrr+r*rrrrrrrrFrEr#r#sFL DJI)'V::x?rFr#cX\rSrSrSrSrSrS Sjr\S5r Sr S r g) r$iRa4 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]`` Fr4Nc T[U5[:XdeUb[U5[[4;deUb[U5[:XdeUb[U5[ :XdeUb UbUcUbeUb[U5[ :XdeUb[U5(deUcUcUbUbUceUb[U5[:XdeUb[U5(deU b[U 5[:XdeU b[U 5[:XdeU b[U 5[:XdeU b[U 5[:XdeU (a~U Hxn [U 5[:XdeSU ;a[U S5[:XdeSU ;aU Sb[U S5[:XdeSU ;a[U S5[:XaMxe [RU5 Xl X l [U5UlX@lXPlX`lXplXlXlXlXlXlg)a :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] Nrrrr7r8s rErYield.__init__rs5lG}#$#|tDzdE]:;:~f!565$w-5"8987#64T#9:9#4X#>#>?> W_9OU\UhmunB DC$w-3"676%)@)P)PQP~f!454$](;s(BCB&$*?3*FGF"d;&74&?@? !Bx4''' B49 +>#+EEE2~2h<+?48 CUY\C\]]!R'DJ,@C,GGG "   &v.     , *.'rFc[U5S:aUS[R:Xde[U5S;a#[SR [U555e[ USS5n[ USS5nSnSnSnSnSnSn[U5S :Xa[US 5[:XaUS nURS S5nU(a*[U5(d[S R U55eURS S5nU(a6[U5[:wa#[SR [U555eURSS5nU(a*[U5(d[SR U55eO[U5S :a>US nUb6[U5[:wa#[SR [U555e[U5S :a;US n[U5[:wa#[SR [U555eSn Sn Sn Sn Sn SU;a=USn[U5[:wa#[SR [U555eUn SU;a=USn[U5[ :wa#[SR [U555eUn SU;a=USn[U5[:wa#[SR [U555eUn SU;a=USn[U5[:wa#[SR [U555eUn SU;aUSn Sn[U 5[:XazU Hrn[U5[:wa O^SU;d[US5[ :wa O@SU;d[US5[:wa O"SU;d[US5[:wdMr O S nU(d [S!5e[UUUUU UUUU U U U S"9 nU$)#rrr;z$invalid message length {0} for YIELDr7z'request' in YIELDr8z'options' in YIELDNr;r9rDz0invalid value {0} for 'enc_algo' detail in YIELDrLz.invalid type {0} for 'enc_key' detail in YIELDrIz6invalid value {0} for 'enc_serializer' detail in YIELDz$invalid type {0} for 'args' in YIELDz&invalid type {0} for 'kwargs' in YIELDr5z/invalid type {0} for 'progress' option in YIELDrz-invalid type {0} for 'callee' detail in YIELDrMz4invalid type {0} for 'callee_authid' detail in YIELDrNz6invalid type {0} for 'callee_authrole' detail in YIELDrOFrrrTz?invalid type/value {0} for/within 'forward_for' option in YIELDr<)rRr$rrrQr'r(r@rMrr)rAr*rrvrrs)rrHrErJr{rKrDrLrIr5rrMrNrOoption_progress option_calleeoption_callee_authidoption_callee_authroler\rRrs rEr Yield.parses4y1}aE,>,>!>?> t9I % F M McRVi XY Y#DG-AB&tAw0DE t9>d47mu41gG{{:t4H 1( ; ;#$V$]$]^f$ghhkk)T2G4=C/#$T$[$[\`ah\i$jkk$[[)94@N&=n&M&M#$\$c$cdr$stt4y1}Aw#T d(:'(N(U(UVZ[_V`(abb4y1}a<4''(P(W(WX\]cXd(eff   %j1OO$,#$U$\$\]abq]r$stt&H w #H-MM"c)#$S$Z$Z[_`m[n$opp"F g %#*?#; ()S0#$Z$a$abfg{b|$}~~0M  '%,->%? "*+s2#$\$c$cdhieA%BCC4O G #!-0KEK D(%BBx4' *d2i=.AS.Hr)T"X,-?3-F!+tBzN/Cs/J&#$effG!#%%##1!"/$3 + - rFcf0nURbURUS'URbURUS'URbURUS'URbURUS'URbURUS'UR (a{UR bUR US'URbURUS'URbURUS'[RURXR /$UR(a2[RURXRUR/$UR(a'[RURXR/$[RURU/$r@)r5rrMrNrOrKrDrLrIr$rrHr{rJrTs rEr Yield.marshalMs^ == $"&--GJ  ;; " $ GH     )'+'9'9GO $    +)-)=)=G% &    '%)%5%5GM " <<}}(&*mm #||'%)\\ """.,0,?,?()&& g||L L{{**DLL'99dkkZZ**DLL'99MM**DLL'BBrFrBrCrrrFrEr$r$Rsa L I" $#!%!]'~yyv#CrFr$)()WAMP message invalidFFFF)rT)r)`rerNrpprintrtypingrrrr autobahn.utilrautobahn.wamp.exceptionrr autobahn.wamp.roler rr6 autobahn.wampr _HAS_WAMP_FLATBUFFERS ImportError__all__compiler^rar_r`rirlrjrmrhrkrBr,r-PAYLOAD_ENC_XBRr.rH ENC_ALGO_NONErrr ENC_ALGOSitemsENC_ALGOS_FROMSTR ENC_SER_NONEr r r r ENC_SER_OPAQUEENC_SER_FLATBUFFERSENC_SERSENC_SERS_FROMSTRr)r*rVrAr+rr%r&rsr'r(r|objectr r rrrrrrrrrrrrrrrrrrrr r!r"r#r$)rWkeys00rErs6 &&B1!)!" /Jjj!EF**%<=**%EF#%**-M"N #GHzz"FGJJ'EF::&DE ZZ(FGJJ'EFJJ78 %%;NS3C*ctTWY\T\~(!Hl,fl,^l9Gl9^r=gr=jM:GM:`BABAJBG7BGJcG9>x_R7_RD ~