o >hRC@sddlZddlZddlZddlmZddlmZmZmZddl Z ddl m Z ddl m Z mZddlmZzddlZddlZddlmZWn eyOdZYnwd Zd Zed Zed Zed ZedZedZedZedZedZ edZ!edZ"edZ#dZ$dZ%dZ&e$e%e&gZ'gdZ(dZ)dZ*dZ+dZ,e)de*de+de,diZ-dde-.DZ/dZ0dZ1dZ2dZ3d Z4d!Z5d"Z6e0de1d#e2d$e3d%e4d&e5d'e6d(iZ7d)de7.DZ8d*d+Z9d,d-Z:dyd/d0Z;d1ed2ee<fd3d4Z=   dzd1ed6ed8e>d9e>d:e>d2eZ@d|d1ed6erAr1r2r3r4opaquer5cCr:r;r;r<r;r;r@rArBcCt|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_algor;r;r@r(sr(cCrG)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 )rHrI PAYLOAD_ENC_STANDARD_SERIALIZERSrJrK)enc_serializerr;r;r@r)sr)(cCsht|tkr |}nt|tkrt|d}n |durd}nd|}t||kr2|d|dS|S)Nascii-z{}z..)rHrIbytesbinasciib2a_hexdecodeformatlen)datamax_lensr;r;r@b2as    r[r>returncCsLt|tkrdSt|rt|rdSt|rdSdSt|r$dSdS)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)rHrI_URI_PAT_REALM_NAMErK_URI_PAT_REALM_NAME_ENS_URI_PAT_REALM_NAME_ENS_REVERSE_URI_PAT_REALM_NAME_ETH)r>r;r;r@r*s     r*WAMP message invalidmessagestrictallow_empty_componentsallow_last_empty allow_nonec Cs|dur|rdStd|t|tkr%|dur|s%td|t||r4|r,t}n|r1t}nt}n |r9t}n|r>t}nt }| |sStd|||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})) rrVrHrI_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_EMPTYrKpattern)r>rfrgrhrirjpatr;r;r@r$s*   r$cCs|dur td|t|tkrtd|t||r5t|s't|r)|Std||tjtjt|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}"))rrVrHrIrarKrdrq)r>rf allow_ethr;r;r@r%7s,  r%cCsDt|tkrtd|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)rHintrrV)r>rfr;r;r@r&^s r&cCsRt|tkrtd|t||D]}t|ts&td|t||q|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}')rHdictrrVkeys isinstancerI)r>rfkr;r;r@r'ss   r'cCs^|dur-t|tkrtd|t||D]}t|ts*td|t||q|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}')ru)kwargsrfryr;r;r@_validate_kwargss   r{c@seZdZdZdZ dZd%ddZeddZej ddZed d Z e j d d Z ed d Z e j dd Z eddZ e j ddZ ddZ ddZdefddZeddZddZeddZdd Zd!d"Zd#d$ZdS)&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_internalcCs.||_i|_d|_d|_d|_d|_d|_dSNr|)selffrom_fbsr;r;r@__init__s zMessage.__init__cC|jSr)rrr;r;r@correlation_idzMessage.correlation_idcC"|dus t|tks J||_dSr)rHrIrrr>r;r;r@r cCrr)rrr;r;r@correlation_urirzMessage.correlation_uricCrr)rHrIrrr;r;r@rrcCrr)rrr;r;r@correlation_is_anchorrzMessage.correlation_is_anchorcCrr)rHboolrrr;r;r@rrcCrr)rrr;r;r@correlation_is_lastrzMessage.correlation_is_lastcCrr)rHrrrr;r;r@rrcCsLt||jsdS|jD]}|dvr#|ds#t||t||ks#dSq dS)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)r~rrrr_T)rx __class__ __slots__ startswithgetattr)rotherryr;r;r@__eq__s  zMessage.__eq__cC || 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 rrrr;r;r@__ne__ s zMessage.__ne__r\c Cs<dt|jjddddttt|ddddS)Nz{} {}z::blueT)colorboldz F) rVrr__name__uppertextwrapindentrmarshalrr;r;r@__str__szMessage.__str__cCt)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)wmsgr;r;r@parses z Message.parsecCrrrrr;r;r@r)zMessage.marshalcCrrrbufr;r;r@cast,rz Message.castcCrrr)rbuilderr;r;r@build0rz Message.buildcCs i|_dS)z1 Resets the serialization cache. N)r~rr;r;r@uncache3s zMessage.uncachecCsh||jvr/|jdkr%td}||}|||}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 r5i) r~NAMEr5BuilderrFinishOutputrR serializer)r serializerrobjrr;r;r@r9s     zMessage.serializer)r __module__ __qualname____doc__ MESSAGE_TYPErrpropertyrsetterrrrrrrIr staticmethodrrrrrrr;r;r;r@r sB              r c@sFeZdZdZdZ dZ       d ddZeddZd d Z dS) r zU A WAMP ``HELLO`` message. Format: ``[HELLO, Realm|uri, Details|dict]`` r6) realmroles authmethodsauthidauthrole authextra resumableresume_session resume_tokenNc Csj|dus t|ts Jt|tksJt|dksJ|D]} | dvs%Jt|| tjjj| s3Jq|rKt|t ks>J|D] } t| tksJJq@|dusWt|tksWJ|dusct|tkscJ|dusot|tksoJ|dus{t|t ks{J|dust|t ksJ| dust| 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)rxrIrHrvrWautobahnwamproler listrrtr rrrrrrrrrr) rrrrrrrrrrr authmethodr;r;r@rrs4'   zHello.__init__c Cst|dkr |dtjksJt|dkrtdt|t|dddd}t|dd }i}d |vr8td t|d d }t|dkrItd |D]:}|dvrXtd|t|}t||d|}d|vr~t|dd||d$i|d}n|}|||<qKd} d|vr|d} t| t krtdt| | D]} t| t krtdt| q| } d} d|vr|d} t| t krtdt| | } d}d|vr|d}t|t krtdt||}d}d|vr|d}t|t krtdt||}d}d|vr#|d}t|t kr#tdt|d}d|vr>|d}t|t kr>td t|d}d!|vrZ|d!}t|t krYtd"t|n|ratd#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. rr8z$invalid message length {0} for HELLOr6z'realm' in HELLOT)rjr7z'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;)rWr rrrVr$r'r rHrrIrvrrt)rrdetailsr details_rolesrrole_cls details_role role_featuresrdetails_authmethods auth_methodrdetails_authidrdetails_authrolerdetails_authextrarrrrr;r;r@rs           z Hello.parsecCs,dii}|jD]?}i|d|j<|jD]2}|dsG|dkrGt||durGd|d|jvr9dii|d|j<t|||d|jd|<qq |jdurS|j|d<|jdur]|j|d<|jdurg|j|d<|j durq|j |d <|j dur{|j |d <|j dur|j |d <|j dur|j |d <t j|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 rrrrrfeaturer;r;r@r!s2                z Hello.marshal)NNNNNNN rrrrrrrrrrr;r;r;r@r Zs  C  kr c@LeZdZdZdZ dZ          d ddZeddZd d Z dS) r zZ A WAMP ``WELCOME`` message. Format: ``[WELCOME, Session|id, Details|dict]`` r7) sessionrrrrr authproviderrresumedrrcustomNc Cst|tksJt|tksJt|dksJ|D]} | dvs"Jt|| tjjj| s0Jq|dus=t|t ks=J|dusIt|t ksIJ|dusUt|t ksUJ|dusat|t ksaJ|dusmt|t ksmJ|dusyt|tksyJ| dust| t ksJ| dust| t ksJ| dust| t ksJ| dust| tksJ| r| D] }t |sJqt |||_||_||_||_||_||_||_||_| |_| |_| |_| 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)rHrtrvrWrxrrrr rIrrJrKr rrrrrrrrrrrrr)rrrrrrrrrrrrrrryr;r;r@rds@3  zWelcome.__init__c CsBt|dkr |dtjksJt|dkrtdt|t|dd}t|dd}|dd }|d d }|d d }|d d }|d d }|dd }d } d|vri|d} t| t ksitdt| d } d|vr|d} t| t kstdt| d } d|vr|d} t| t kstdt| n| rtdi} d|vrtdt|dd} t| dkrtd| D]<}|dvrtd|t |}t| |d|}d|vrt|dd||di| |d}n|}|| |<qi}|D]}t |r||||<qt|| ||||||| | | | }|S) rrr8z&invalid message length {0} for WELCOMEr6z'session' in WELCOMEr7z'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;)rWr rrrVr&r'getrHrrIr rJrK)rrrrrrrrrrrrrrrrrrrryrr;r;r@rsh              z Welcome.parsecCs@i}||j|jr|j|d<|jr|j|d<|jr |j|d<|jr(|j|d<|jr0|j|d<|jr8|j|d<|jr@|j|d<|j rH|j |d<|j rP|j |d <i|d <|j D]?}i|d |j <|jD]2}|d s|d krt||d urd|d |j vrdii|d |j <t|||d |j d|<qeqYtj|j|gS)rrrrrrrrrrrrrNr)updaterrrrrrrrrrrrrrrrr rrrr;r;r@r s>            zWelcome.marshal NNNNNNNNNNrr;r;r;r@r Is& U  Sr c@8eZdZdZdZ dZd ddZeddZd d Z dS) rzV A WAMP ``ABORT`` message. Format: ``[ABORT, Details|dict, Reason|uri]`` r8)reasonrfNcCsBt|tksJ|dust|tksJt|||_||_dS)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)rHrIr rrrf)rrrfr;r;r@rOs    zAbort.__init__cCst|dkr |dtjksJt|dkrtdt|t|dd}t|dd}d}d |vrG|d }t|tkrEtd t||}t||}|S) rrr8z$invalid message length {0} for ABORTr6z'details' in ABORTr7z'reason' in ABORTNrfz.invalid type {0} for 'message' detail in ABORT) rWrrrrVr'r$rHrI)rrrrfdetails_messagerr;r;r@r_s   z Abort.parsecCs"i}|jr |j|d<tj||jgS)rrf)rfrrrrrr;r;r@rs z Abort.marshalrrr;r;r;r@r>s   rc@r) rz_ A WAMP ``CHALLENGE`` message. Format: ``[CHALLENGE, Method|string, Extra|dict]`` rC)methodextraNcCFt|tksJ|dust|tksJt|||_|pi|_dS)z :param method: The authentication method. :type method: str :param extra: Authentication method specific information. :type extra: dict or None N)rHrIrvr rrr)rrrr;r;r@r   zChallenge.__init__cC~t|dkr |dtjksJt|dkrtdt||d}t|tkr1tdt|t|dd}t||}|S)rrr8z(invalid message length {0} for CHALLENGEr6z*invalid type {0} for 'method' in CHALLENGEr7z'extra' in CHALLENGE)rWrrrrVrHrIr')rrrrr;r;r@r   zChallenge.parsecCtj|j|jgSr)rrrrrr;r;r@rzChallenge.marshalrrr;r;r;r@r   rc@r) rzh A WAMP ``AUTHENTICATE`` message. Format: ``[AUTHENTICATE, Signature|string, Extra|dict]`` rD) signaturerNcCr)z :param signature: The signature for the authentication challenge. :type signature: str :param extra: Authentication method specific information. :type extra: dict or None N)rHrIrvr rrr)rrrr;r;r@rrzAuthenticate.__init__cCr)rrr8z+invalid message length {0} for AUTHENTICATEr6z0invalid type {0} for 'signature' in AUTHENTICATEr7z'extra' in AUTHENTICATE)rWrrrrVrHrIr')rrrrr;r;r@rrzAuthenticate.parsecCrr)rrrrrr;r;r@rrzAuthenticate.marshalrrr;r;r;r@rrrc@sDeZdZdZdZ dZ dZeddfddZedd Z d d Z dS) rzZ A WAMP ``GOODBYE`` message. Format: ``[GOODBYE, Details|dict, Reason|uri]`` rEzwamp.close.normalrrfrNcCs`t|tksJ|dust|tksJ|dus t|tks Jt|||_||_||_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)rHrIrr rrrfr)rrrfrr;r;r@r/s   zGoodbye.__init__cCst|dkr |dtjksJt|dkrtdt|t|dd}t|dd}d}d}d |vrI|d }t|tkrGtd t||}d |vr`|d }t|t kr`td t|t|||d }|S)rrr8z&invalid message length {0} for GOODBYEr6z'details' in GOODBYEr7z'reason' in GOODBYENrfz0invalid type {0} for 'message' detail in GOODBYErz2invalid type {0} for 'resumable' detail in GOODBYEr) rWrrrrVr'r$rHrIr)rrrrfrrrr;r;r@rDs*   z Goodbye.parsecCs2i}|jr |j|d<|jr|j|d<tj||jgS)rrfr)rfrrrrrr;r;r@rms   zGoodbye.marshal) rrrrrDEFAULT_REASONrrrrrr;r;r;r@rs  (rc@r) ra A WAMP ``ERROR`` message. Formats: * ``[ERROR, REQUEST.Type|int, REQUEST.Request|id, Details|dict, Error|uri]`` * ``[ERROR, REQUEST.Type|int, REQUEST.Request|id, Details|dict, Error|uri, Arguments|list]`` * ``[ERROR, REQUEST.Type|int, REQUEST.Request|id, Details|dict, Error|uri, Arguments|list, ArgumentsKw|dict]`` * ``[ERROR, REQUEST.Type|int, REQUEST.Request|id, Details|dict, Error|uri, Payload|binary]`` ) request_typerequesterrorargsrzpayloadrLenc_keyrNr callee_authidcallee_authrole forward_forNcCsJt|tksJt|tksJt|tksJ|dus&t|ttfvs&J|dus2t|tks2J|dus>t|tks>J|dusP|durN|durN|dusPJ|dusZt|sZJ|durf|durf| dusp|durn|duspJ|dus|t|tks|J| dust| sJ| dust| tksJ| dust| tksJ| dust| tksJ| dust| tksJ| r| D]:}t|tksJd|vrt|dtksJd|vr|ddust|dtksJd|vrt|dtksJqt |||_ ||_ ||_ ||_t||_||_||_||_| |_| |_| |_| |_| |_dS)a :param request_type: The WAMP message type code for the original request. :type request_type: int :param request: The WAMP request ID of the original request (`Call`, `Subscribe`, ...) this error occurred for. :type request: int :param error: The WAMP or application error URI for the error that occurred. :type error: str :param args: Positional values for application-defined exception. Must be serializable using any serializers in use. :type args: list or None :param kwargs: Keyword values for application-defined exception. Must be serializable using any serializers in use. :type kwargs: dict or None :param payload: Alternative, transparent payload. If given, ``args`` and ``kwargs`` must be left unset. :type payload: bytes or None :param enc_algo: If using payload transparency, the encoding algorithm that was used to encode the payload. :type enc_algo: str or None :param enc_key: If using payload transparency with an encryption algorithm, the payload encryption key. :type enc_key: str or None :param enc_serializer: If using payload transparency, the payload object serializer that was used encoding the payload. :type enc_serializer: str or None :param callee: The WAMP session ID of the effective callee that responded with the error. Only filled if callee is disclosed. :type callee: None or int :param callee_authid: The WAMP authid of the responding callee. Only filled if callee is disclosed. :type callee_authid: None or unicode :param callee_authrole: The WAMP authrole of the responding callee. Only filled if callee is disclosed. :type callee_authrole: None or unicode :param forward_for: When this Error is forwarded for a client/callee (or from an intermediary router). :type forward_for: list[dict] Nrrr)rHrtrIrtuplervrRr(r)r rrrrr r{rzr rLr rNrr r r)rrrrr rzr rLr rNrr r rffr;r;r@rsF9$,(   zError.__init__cCsjt|dkr |dtjksJt|dvrtdt||d}t|tkr/td||tjtjt jt jt jt jt jfvrHtd|t|dd}t|d d }t|d d }d }d }d }d }d } d } d } d } d } d }t|dkrt|dtkr|d}|dd }|rt|std||dd } | rt| tkrtdt| |dd } | rt| std| n6t|dkr|d}|d urt|tkrtdt|t|dkr|d}t|tkrtdt|d|vr|d}t|tkrtdt||} d|vr-|d}t|tkr+tdt||} d|vrH|d}t|tkrFtdt||} d|vr|d}d}t|tkr|D]<}t|tkrgn2d |vsut|d tkrwn"d!|vst|d!tkrnd"|vst|d"tkrnq\d#}|std$t|||||||| | | | | |d% }|S)&rr)rDrEz$invalid message length {0} for ERRORr6z,invalid type {0} for 'request_type' in ERRORz-invalid value {0} for 'request_type' in ERRORr7z'request' in ERRORr8z'details' in ERRORrCz'error' in ERRORNrErDrL0invalid value {0} for 'enc_algo' detail in EVENTr .invalid type {0} for 'enc_key' detail in EVENTrN6invalid 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 ERRORr z4invalid type {0} for 'callee_authid' detail in ERRORr z6invalid type {0} for 'callee_authrole' detail in ERRORrFrrrTz?invalid type/value {0} for/within 'forward_for' option in ERROR) r rzr rLr rNrr r r)rWrrrrVrHrtrrrrrrr!r&r'r$rRrr(rIr)rrv)rrrrrr rzr rLr rNrr r r detail_calleedetail_callee_authiddetail_callee_authrolevalidrrr;r;r@rs              z Error.parsecCs i}|jdur |j|d<|jdur|j|d<|jdur |j|d<|jdur*|j|d<|jrX|jdur7|j|d<|jdurA|j|d<|jdurK|j|d<|j|j |j ||j |jgS|j rj|j|j |j ||j |j |j gS|j rz|j|j |j ||j |j gS|j|j |j ||j gS) rNrr r rrLr rN)rr r rr rLr rNrrrrrzr rr;r;r@rs,              z Error.marshalrrr;r;r;r@r~s(  g  rc@szeZdZdZdZ dZ                    dNddZddZd d Ze d d Z e j d d Z e ddZ e j ddZ e ddZ e j ddZ e ddZej ddZe ddZej ddZe ddZej ddZe ddZej ddZe d d!Zej d"d!Ze d#d$Zej d%d$Ze d&d'Zej d(d'Ze d)d*Zej d+d*Ze d,d-Zej d.d-Ze d/d0Zej d1d0Ze d2d3Zej d4d3Ze d5d6Zej d7d6Ze d8d9Zej d:d9Ze d;d<Zej d=d<Ze d>d?Zej d@d?Ze dAdBZej dCdBZedDdEZdFdGZ edHdIZ!dJdKZ"dLdMZ#dS)OraZ 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_forNcCs|dus t|tks J|dust|tksJ|dus(t|ttttfvs(J|dus7t|tttfvs7J|dusCt|tksCJ|dusU|durS|durS|dusUJ|dusat|tksaJ|dusmt|tksmJ|dusyt|tksyJ|dust|tksJ|dust|tksJ|r|D] }t|tksJq| dust| tksJ| r| D] }t|tksJq| dust| tksJ| r| D] }t|tksJq| dust| tksJ| r| D] }t|tksJq| dust| tksJ| r| D] }t|tks Jq| dust| tksJ| r/| D] }t|tks-Jq"|dus;t|s;J|durJ|durJ|dusV|durT|dusVJ|dusdt|tksdJ|duspt |spJ|dus~t|tks~J|r|D]C}t|tksJd|vrt|dtksJd|vr|ddust|dtksJd|vrt|dtksJqt j ||d||_ ||_ ||_t||_||_||_||_||_| |_| |_| |_| |_| |_||_||_||_||_||_||_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 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) rHrtrIrrrRrvrr(r)r rrrrr{rrr"r#r$r%r&r'r(r)r*r+rr!r r,)rrtopicr rzr  acknowledge exclude_meexcludeexclude_authidexclude_authroleeligibleeligible_authideligible_authroleretaintransaction_hashrLr rNrr sessionidrrrr;r;r@rsW $6 .$  zPublish.__init__cCsTt||jsdSt||sdS|j|jkrdS|j|jkr dS|j|jkr(dS|j|jkr0dS|j|jkr8dS|j |j kr@dS|j |j krHdS|j |j krPdS|j |j krXdS|j |j kr`dS|j|jkrhdS|j|jkrpdS|j|jkrxdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkrdSdSNFT)rxrr rrr.r rzr r/r0r1r2r3r4r5r6r7r8rLr rNrrr;r;r@rsV                     zPublish.__eq__cCrrrrr;r;r@r zPublish.__ne__cC"|jdur|jr|j|_|jSr)rr}Requestrr;r;r@r zPublish.requestcCrr)rHrtrrr;r;r@rrcC0|jdur|jr|j}|r|d|_|jSNutf8rr}TopicrUrrZr;r;r@r.   z Publish.topiccCrrrHrIrrr;r;r@r.rcC6|jdur|jr|jrtt|j|_|jSrrr} ArgsLengthcbor2loadsrR ArgsAsBytesrr;r;r@r  z Publish.argscC&|dust|ttfvsJ||_dSrrHrrrrr;r;r@r  cCrGrrr} KwargsLengthrJrKrR KwargsAsBytesrr;r;r@rzrMzPublish.kwargscCrrrHrvrrr;r;r@rzrcC,|jdur|jr|jr|j|_|jSrrr} PayloadLengthPayloadAsBytesrr;r;r@r   zPublish.payloadcCrrrHrRrrr;r;r@r  rcC*|jdur|jr|j}|r||_|jSr)r"r} Acknowledge)rr/r;r;r@r/  zPublish.acknowledgecCrr)rHrr"rr;r;r@r/rcCs.|jdur|jr|j}|dur||_|jS)NF)r#r} ExcludeMe)rr0r;r;r@r0s  zPublish.exclude_mecCrr)rHrr#rr;r;r@r0%rcCP|jdur%|jr%|jr%g}t|jD] }||j|q||_|jSr)r$r} ExcludeLengthrangeappendExclude)rr1jr;r;r@r1* zPublish.excludecC@|dus t|tks J|r|D] }t|tksJq||_dSr)rHrrtr$rr>xr;r;r@r14  cCV|jdur(|jr(|jr(g}t|jD]}||j|dq||_|jSr@)r%r}ExcludeAuthidLengthrarb ExcludeAuthidrU)rr2rdr;r;r@r2< zPublish.exclude_authidcCrfr)rHrrIr%rgr;r;r@r2FricCrjr@)r&r}ExcludeAuthroleLengthrarbExcludeAuthrolerU)rr3rdr;r;r@r3NrmzPublish.exclude_authrolecCrfr)rHrrIr&rgr;r;r@r3XricCr_r)r'r}EligibleLengthrarbEligible)rr4rdr;r;r@r4`rezPublish.eligiblecCrfr)rHrrtr'rgr;r;r@r4jricCrjr@)r(r}EligibleAuthidLengthrarbEligibleAuthidrU)rr5rdr;r;r@r5rrmzPublish.eligible_authidcCrfr)rHrrIr(rgr;r;r@r5|ricCrjr@)r)r}EligibleAuthroleLengthrarbEligibleAuthrolerU)rr6rdr;r;r@r6rmzPublish.eligible_authrolecCrfr)rHrrIr)rgr;r;r@r6ricCr[r)r*r}Retain)rr7r;r;r@r7r]zPublish.retaincCrr)rHrr*rr;r;r@r7rcCr?r@r+r}TransactionHashrUrDr;r;r@r8rEzPublish.transaction_hashcCrrrHrIr+rr;r;r@r8rcCr[rrr}EncAlgorrLr;r;r@rLr]zPublish.enc_algocC$|dus |tttfvs J||_dSrENC_ALGO_CRYPTOBOX ENC_ALGO_MQTT ENC_ALGO_XBRrrr;r;r@rL cCrUrr!r} EncKeyLength EncKeyAsBytesrr;r;r@r rYzPublish.enc_keycCrrrHrRr!rr;r;r@r rcCr[rr r} EncSerializerrrNr;r;r@rNr]zPublish.enc_serializercC&|dus|ttttfvsJ||_dSr ENC_SER_JSONENC_SER_MSGPACK ENC_SER_CBORENC_SER_UBJSONr rr;r;r@rNrPcCrrr,rr;r;r@rzPublish.forward_forcC ||_dSrrrr;r;r@r cCttj|ddSNrr-)rr GetRootAsPublishrr;r;r@rz Publish.castcCs||j}|r |t|}|j}|r|t|}|j}|r$||}|j}|r.||}|j}|r8||}|j }|rB||}|j }|rct j |t|t|D]} || qT|t|}|j} | rg} | D] } | || qlt j |t| t| D]} || q|t| } |j}| rg}|D] }|||qt j |t|t|D]} || q|t|}|j}|rt j |t|t|D]} || q|t|}|j}|rg}|D] } ||| qt j |t|t|D]} || q|t|}|j}|rIg}|D] }|||q t j |t|t|D]} || q9|t|}t j ||jdur]t j ||j|rgt j |||rqt j |||r{t j !|||rt j "|||j#rt j $||j#|j%rt j &||j%|rt j '|||j(durt j )||j(|j*durt j +||j*|rt j ,||| rt j -|| |rt j .|||rt j /|||rt j 0|||rt j 1|||j2dur t j 3||j2|durt j 4||jt j 5|}t j67|t j68|t j9j:t j6;||t j6<|}|Sr)=r CreateByteVectorrJdumpsrzr r. CreateStringr8r r1r PublishGenPublishStartExcludeAuthidVectorrWreversed PrependUint64 EndVectorr2rbPrependUOffsetTRelativer3!PublishStartExcludeAuthroleVectorr4 PublishStartEligibleAuthidVectorr5r6"PublishStartEligibleAuthroleVector PublishStartrPublishAddRequestPublishAddTopicPublishAddArgsPublishAddKwargsPublishAddPayloadrLPublishAddEncAlgorNPublishAddEncSerializerPublishAddEncKeyr/PublishAddAcknowledger0PublishAddExcludeMePublishAddExcludePublishAddExcludeAuthidPublishAddExcludeAuthrolePublishAddEligiblePublishAddEligibleAuthidPublishAddEligibleAuthroler7PublishAddRetainPublishAddTransactionHash PublishEndr MessageStartMessageAddMsgType MessageTypePUBLISH MessageAddMsg MessageEnd)rrr rzr r.r8r r1rr2r%ror3r&rr4r5r(r6r)msg union_msgr;r;r@rs                       z Publish.buildc$Cst|dkr |dtjksJt|dvrtdt|t|dd}t|dd}t|dd }d }d }d }t|d krt|d t t fvr|d }| d d }|r`t |s`td|| dd }|rwt|t krwtdt|| dd } | rt | std| n>t|d kr|d }t|tt t fvrtdt|t|d kr|d }t|tt t fvrtdt|d }d }d } d } d } d } d } d }d }d }d }d }d }d }d|vr|d}t|tkrtdt||} d|vr|d}t|tkrtdt||} d|vrD|d}t|tkr,tdt||D]}t|tkr@tdt|q.|} d|vru|d}t|tkr]tdt||D]}t|t krqtdt|q_|} d|vr|d}t|tkrtd t||D]}t|t krtd!t|q|}d"|vr|d"}t|tkrtd#t||D]}t|tkrtd$t|q|}d%|vr|d%}t|tkrtd&t||D]}t|t krtd't|q|}d(|vr9|d(} t| tkr!td)t| | D]}t|t kr5td*t|q#| }d+|vrR|d+}t|tkrRtd,t|d-|vrk|d-}t|t krktd.t|d/|vr|d/}d0}!t|tkr|D]<}"t|"tkrn2d1|"vst|"d1tkrn"d2|"vst|"d2t krnd3|"vst|"d3t krnqd4}!|!std5t||fid6|d7|d8|d| d| d| d| d|d"|d%|d(|d+|d-|d |d|d| d/|}#|#S)9rrrCrDrEz&invalid message length {0} for PUBLISHr6z'request' in PUBLISHr7z'options' in PUBLISHr8z'topic' in PUBLISHNrDrCrLz2invalid value {0} for 'enc_algo' option in PUBLISHr z0invalid type {0} for 'enc_key' option in PUBLISHrNz8invalid value {0} for 'enc_serializer' option in PUBLISHz&invalid type {0} for 'args' in PUBLISHz(invalid type {0} for 'kwargs' in PUBLISHr/z4invalid type {0} for 'acknowledge' option in PUBLISHr0z3invalid type {0} for 'exclude_me' option in PUBLISHr1z0invalid type {0} for 'exclude' option in PUBLISHz9invalid type {0} for value in 'exclude' option in PUBLISHr2z7invalid type {0} for 'exclude_authid' option in PUBLISHz@invalid type {0} for value in 'exclude_authid' option in PUBLISHr3z9invalid type {0} for 'exclude_authrole' option in PUBLISHzBinvalid type {0} for value in 'exclude_authrole' option in PUBLISHr4z1invalid type {0} for 'eligible' option in PUBLISHz:invalid type {0} for value in 'eligible' option in PUBLISHr5z8invalid type {0} for 'eligible_authid' option in PUBLISHzAinvalid type {0} for value in 'eligible_authid' option in PUBLISHr6z:invalid type {0} for 'eligible_authrole' option in PUBLISHzCinvalid type {0} for value in 'eligible_authrole' option in PUBLISHr7z/invalid type {0} for 'retain' option in PUBLISHr8z9invalid type {0} for 'transaction_hash' option in PUBLISHrFrrrTzAinvalid type/value {0} for/within 'forward_for' option in PUBLISHr rzr )rWrrrrVr&r'r$rHrIrRrr(r)rrvrrt)$rroptionsr.r rzr rLr rNr/r0r1r2r3r4r5r6r7r8roption_acknowledgeoption_exclude_meoption_exclude _sessionidoption_exclude_authid_authidoption_exclude_authrole _authroleoption_eligible sessionIdoption_eligible_authidoption_eligible_authrolerrrr;r;r@rt sT                         z Publish.parsecCs&i}|jdur |j|d<|jdur|j|d<|jdur |j|d<|jdur*|j|d<|jdur4|j|d<|jdur>|j|d<|jdurH|j|d<|jdurR|j|d<|jdur\|j|d <|j durf|j |d <|j r|j durs|j |d <|j dur}|j |d <|j dur|j |d <|jdur|j|d<|S)Nr/r0r1r2r3r4r5r6r7r8rLr rNr)r/r0r1r2r3r4r5r6r7r8r rLr rNrrrr;r;r@marshal_optionsA s>                            zPublish.marshal_optionscCr|}|jrtj|j||j|jgS|jr"tj|j||j|j|jgS|jr0tj|j||j|jgStj|j||jgSr)rr rrrr.rzr rr;r;r@rg zPublish.marshal)NNNNNNNNNNNNNNNNNNNN)$rrrrrrrrrrrrr.r rzr r/r0r1r2r3r4r5r6r7r8rLr rNrrrrrrrr;r;r;r@rs < /-                                        M &rc@6eZdZdZdZ dZddZeddZdd Z d S) rzh A WAMP ``PUBLISHED`` message. Format: ``[PUBLISHED, PUBLISH.Request|id, Publication|id]`` )r publicationcC:t|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)rHrtr rrr)rrrr;r;r@r    zPublished.__init__cCft|dkr |dtjksJt|dkrtdt|t|dd}t|dd}t||}|S)rrr8z(invalid message length {0} for PUBLISHEDr6z'request' in PUBLISHEDr7z'publication' in PUBLISHED)rWrrrrVr&)rrrrr;r;r@r   zPublished.parsecCrr)rrrrrr;r;r@r rzPublished.marshalNrr;r;r;r@r{   rc@sReZdZdZdZ dZdZdZdZ   ddd Z e d d Z d d Z ddZ dS)rzi A WAMP ``SUBSCRIBE`` message. Format: ``[SUBSCRIBE, Request|id, Options|dict, Topic|uri]`` exactprefixwildcard)rr.rK get_retainedrNcCs8t|tksJt|tksJ|dust|tksJ|dus,|tjtjtjfvs,J|dus8t|tus8J|dusDt|tksDJ|r|D]:}t|t ksRJd|vr^t|dtks`Jd|vrr|ddustt|dtkstJd|vrt|dtksJqHt |||_ ||_ |ptj|_||_||_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)rHrtrIr MATCH_EXACT MATCH_PREFIXMATCH_WILDCARDrrrvr rrr.rKrr)rrr.rKrrrr;r;r@r s$ (   zSubscribe.__init__c Cst|dkr |dtjksJt|dkrtdt|t|dd}t|dd}t|dd d d }tj}d }d }d |vrf|d }t |t krStdt ||tjtj tj fvrdtd||}d|vr}|d}t |t kr}tdt |d|vr|d}d}t |tkr|D]4} t | tkrn+d| vst | dtkrnd| vst | dt krnd| vst | dt krnqd }|stdt|||||d} | S)rrrCz(invalid message length {0} for SUBSCRIBEr6z'request' in SUBSCRIBEr7z'options' in SUBSCRIBEr8z'topic' in SUBSCRIBET)rhNrKz0invalid type {0} for 'match' option in SUBSCRIBEz1invalid value {0} for 'match' option in SUBSCRIBErz7invalid type {0} for 'get_retained' option in SUBSCRIBErFrrrzCinvalid type/value {0} for/within 'forward_for' option in SUBSCRIBE)rKrr)rWrrrrVr&r'r$rrHrIrrrrrvrt) rrrr.rKrr option_matchrrrr;r;r@r sN     zSubscribe.parsecCsLi}|jr|jtjkr|j|d<|jdur|j|d<|jdur$|j|d<|S)NrKrr)rKrrrrrr;r;r@r@ s     zSubscribe.marshal_optionscCtj|j||jgSr)rrrrr.rr;r;r@rN zSubscribe.marshalNNN)rrrrrrrrrrrrrrr;r;r;r@r s   , > rc@r) rzm A WAMP ``SUBSCRIBED`` message. Format: ``[SUBSCRIBED, SUBSCRIBE.Request|id, Subscription|id]`` !)r subscriptioncCr)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)rHrtr rrr)rrrr;r;r@ri rzSubscribed.__init__cCr)rrr8z)invalid message length {0} for SUBSCRIBEDr6z'request' in SUBSCRIBEDr7z'subscription' in SUBSCRIBED)rWrrrrVr&)rrrrr;r;r@ry rzSubscribed.parsecCrr)rrrrrr;r;r@r rzSubscribed.marshalNrr;r;r;r@rX rrc@r) rz A WAMP ``UNSUBSCRIBE`` message. Formats: * ``[UNSUBSCRIBE, Request|id, SUBSCRIBED.Subscription|id]`` * ``[UNSUBSCRIBE, Request|id, SUBSCRIBED.Subscription|id, Options|dict]`` ")rrrNcCst|tksJt|tksJ|rO|D]:}t|tksJd|vr*t|dtks,Jd|vr>|ddus@t|dtks@Jd|vrLt|dtksNJqt|||_||_||_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) rHrtrvrIr rrrr)rrrrrr;r;r@r s (  zUnsubscribe.__init__cC.t|dkr |dtjksJt|dvrtdt|t|dd}t|dd}d}t|d kr;t|d d }d}|rd |vr|d }d }t|tkr|D]4}t|t kr[n+d |vsgt|d t krind|vsut|dt krwnd|vst|dt krnqQd}|stdt|||d}|S)rrr8rCz/invalid message length {0} for WAMP UNSUBSCRIBEr6z'request' in UNSUBSCRIBEr7z'subscription' in UNSUBSCRIBENr8z'options' in UNSUBSCRIBErFrrrTzEinvalid type/value {0} for/within 'forward_for' option in UNSUBSCRIBEr) rWrrrrVr&r'rHrrvrtrI)rrrrrrrrr;r;r@r 8     zUnsubscribe.parsecC2|jrd|ji}tj|j|j|gStj|j|jgSrr)rrrrrrr;r;r@r zUnsubscribe.marshalrrr;r;r;r@r s    -rc@r) rz A WAMP ``UNSUBSCRIBED`` message. Formats: * ``[UNSUBSCRIBED, UNSUBSCRIBE.Request|id]`` * ``[UNSUBSCRIBED, UNSUBSCRIBE.Request|id, Details|dict]`` #)rrrNcCt|tksJ|dust|tksJ|dus t|tks J|dkr(|dus2|dkr0|dks2Jt|||_||_||_dS)a :param request: The request ID of the original ``UNSUBSCRIBE`` request or ``0`` is router triggered unsubscribe ("router revocation signaling"). :type request: int :param subscription: If unsubscribe was actively triggered by router, the ID of the subscription revoked. :type subscription: int or None :param reason: The reason (an URI) for an active (router initiated) revocation. :type reason: str or None. Nr)rHrtrIr rrrr)rrrrr;r;r@r s$  zUnsubscribed.__init__cCt|dkr |dtjksJt|dvrtdt|t|dd}d}d}t|dkrZt|dd}d |vrO|d }t|tkrMtd t||}d |vrZt |d d }t|||}|S) rrr7r8z+invalid message length {0} for UNSUBSCRIBEDr6z'request' in UNSUBSCRIBEDNr7z'details' in UNSUBSCRIBEDrz:invalid type {0} for 'subscription' detail in UNSUBSCRIBEDrz'reason' in UNSUBSCRIBED) rWrrrrVr&r'rHrtr$)rrrrrdetails_subscriptionrr;r;r@r5 "    zUnsubscribed.parsecCZ|jdus |jdur'i}|jdur|j|d<|jdur |j|d<tj|j|gStj|jgS)rNrr)rrrrrrr;r;r@r[      zUnsubscribed.marshalNNrr;r;r;r@r s    %rc@seZdZdZdZ dZ     dCddZddZd d Ze d d Z e j d d Z e ddZ e j ddZ e ddZ e j ddZ e ddZej ddZe ddZej ddZe ddZej ddZe ddZej ddZe d d!Zej d"d!Ze d#d$Zej d%d$Ze d&d'Zej d(d'Ze d)d*Zej d+d*Ze d,d-Zej d.d-Ze d/d0Zej d1d0Ze d2d3Zej d4d3Ze d5d6Zej d7d6Ze d8d9Zej d:d9Zed;d<Zd=d>Zed?d@ZdAdBZdS)Dra A WAMP ``EVENT`` message. Formats: * ``[EVENT, SUBSCRIBED.Subscription|id, PUBLISHED.Publication|id, Details|dict]`` * ``[EVENT, SUBSCRIBED.Subscription|id, PUBLISHED.Publication|id, Details|dict, PUBLISH.Arguments|list]`` * ``[EVENT, SUBSCRIBED.Subscription|id, PUBLISHED.Publication|id, Details|dict, PUBLISH.Arguments|list, PUBLISH.ArgumentsKw|dict]`` * ``[EVENT, SUBSCRIBED.Subscription|id, PUBLISHED.Publication|id, Details|dict, PUBLISH.Payload|binary]`` $) _subscription _publicationrrrrr r! _publisher_publisher_authid_publisher_authroler _retainedr+_x_acknowledged_deliveryr,NcCs|dus t|tks J|dust|tksJ|dus&t|ttfvs&J|dus2t|tks2J|dus>t|tks>J|dusP|durN|durN|dusPJ|dus\t|tks\J|dusht|tkshJ|dustt|tkstJ| dust| tksJ| dust| tksJ| dust| tksJ| dust| tksJ| dust| sJ| dur|dur|dus|dur| dusJ|dust|tksJ|dust |sJ|dust|tksJ|r-|D]A}t|tksJd|vrt|dtksJd|vr|ddust|dtksJd|vr*t|dtks,Jqt j ||d||_ ||_ ||_t||_||_||_||_||_| |_| |_| |_| |_| |_||_||_||_dS)a :param subscription: The subscription ID this event is dispatched under. :type subscription: int :param publication: The publication ID of the dispatched event. :type publication: int :param args: Positional values for application-defined exception. Must be serializable using any serializers in use. :type args: list or tuple or None :param kwargs: Keyword values for application-defined exception. Must be serializable using any serializers in use. :type kwargs: dict or None :param payload: Alternative, transparent payload. If given, ``args`` and ``kwargs`` must be left unset. :type payload: bytes or None :param publisher: The WAMP session ID of the publisher. Only filled if publisher is disclosed. :type publisher: None or int :param publisher_authid: The WAMP authid of the publisher. Only filled if publisher is disclosed. :type publisher_authid: None or unicode :param publisher_authrole: The WAMP authrole of the publisher. Only filled if publisher is disclosed. :type publisher_authrole: None or unicode :param topic: For pattern-based subscriptions, the event MUST contain the actual topic published to. :type topic: str or None :param retained: Whether the message was retained by the broker on the topic, rather than just published. :type retained: 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 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] Nrrrr-)rHrtrrrvrRrIrr(r)r rrrrr{rrrrrrrr+rrr!r r,)rrrr rzr rpublisher_authidpublisher_authroler.retainedr8x_acknowledged_deliveryrLr rNrrrr;r;r@r sR;$, ."  zEvent.__init__cCs$t||jsdSt||sdS|j|jkrdS|j|jkr dS|j|jkr(dS|j|jkr0dS|j|jkr8dS|j |j kr@dS|j |j krHdS|j |j krPdS|j |j krXdS|j |j kr`dS|j|jkrhdS|j|jkrpdS|j|jkrxdS|j|jkrdS|j|jkrdS|j|jkrdSdSr:)rxrr rrrr rzr rrrr.rr8rrLr rNrrr;r;r@r sJ                  z Event.__eq__cCrrrrr;r;r@r> r;z Event.__ne__cCr<r)rr} Subscriptionrr;r;r@rA r>zEvent.subscriptioncCrr)rHrtrrr;r;r@rG rcCr<r)rr} Publicationrr;r;r@rL r>zEvent.publicationcCrr)rHrtrrr;r;r@rR rcCrGrrHrr;r;r@r W rMz Event.argscCrNrrOrr;r;r@r ^ rPcCrGrrQrr;r;r@rzc rMz Event.kwargscCrrrTrr;r;r@rzj rcCrUrrVrr;r;r@r o rYz Event.payloadcCrrrZrr;r;r@r v rcCr[r)rr} Publisher)rrr;r;r@r{ r]zEvent.publishercCrr)rHrtrrr;r;r@r rcCr?r@)rr}PublisherAuthidrUrDr;r;r@r rEzEvent.publisher_authidcCrr)rHrIrrr;r;r@r rcCr?r@)rr}PublisherAuthrolerUrDr;r;r@r rEzEvent.publisher_authrolecCrr)rHrIrrr;r;r@r rcCr?r@rBrDr;r;r@r. rEz Event.topiccCrrrFrr;r;r@r. rcCr<r)rr}Retainedrr;r;r@r r>zEvent.retainedcCrr)rHrrrr;r;r@r rcCr?r@rwrDr;r;r@r8 rEzEvent.transaction_hashcCrrryrr;r;r@r8 rcCr[r)rr}r\)rrr;r;r@r r]zEvent.x_acknowledged_deliverycCrr)rHrrrr;r;r@r rcCr[rrzr|r;r;r@rL r]zEvent.enc_algocCr}rr~rr;r;r@rL rcCrUrrrr;r;r@r  rYz Event.enc_keycCrrrrr;r;r@r  rcCr[rrrr;r;r@rN r]zEvent.enc_serializercCrrrrr;r;r@rN rPcCrrrrr;r;r@r rzEvent.forward_forcCrrrrr;r;r@r rcCrr)rr GetRootAsEventrr;r;r@rrz Event.castc Cs6|j}|r |t|}|j}|r|t|}|j}|r$||}|j}|r.||}|j}|r8||}|j }|rB||}|j }|rL||}|j } | rV|| } t j ||jrgt j ||j|jrrt j ||j|r{t j |||rt j |||rt j |||jrt j ||j|rt j |||rt j |||rt j |||jdurt j ||j|durt j |||jdurt j ||j|j rt j !||j | rt j "|| |j#rt j $||j#t j %|} t j&'|t j&(|t j)j*t j&+|| t j&,|} | Sr)-r rrJrrzr rrrr.r8r r EventGen EventStartrEventAddSubscriptionrEventAddPublication EventAddArgsEventAddKwargsEventAddPayloadrEventAddPublisherEventAddPublisherAuthidEventAddPublisherAuthrole EventAddTopicrEventAddRetainedEventAddTransactionHashrEventAddAcknowledgerLEventAddEncAlgoEventAddEncKeyrNEventAddEncSerializerEventEndr rrrEVENTrr) rrr rzr rrr.r8r rrr;r;r@rsz            z Event.buildcCst|dkr |dtjksJt|dvrtdt|t|dd}t|dd}t|dd }d }d }d }d }d }d } t|d krt|d tkr|d }| d d }|rdt |sdtd|| dd }|r{t|t kr{tdt|| dd } | rt | std| n6t|d kr|d }|d urt|t krtdt|t|d kr|d }t|tkrtdt|d } d } d } d } d }d }d }d }d|vr|d}t|tkrtdt||} d|vr |d}t|t krtdt||} d|vr$|d}t|t kr"tdt||} d|vr?|d}t|t kr=tdt||} d|vrX|d}t|tkrXtdt|d|vrs|d}t|t krqtd t||}d!|vr|d!}t|tkrtd"t|d#|vr|d#}d$}t|t kr|D]<}t|tkrn2d%|vst|d%tkrn"d&|vst|d&t krnd'|vst|d't krnqd(}|std)t|||||| | | | |||||| |d*}|S)+rrrz$invalid message length {0} for EVENTr6z'subscription' in EVENTr7z'publication' in EVENTr8z'details' in EVENTNrDrCrLrr rrNrz$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 EVENTr.z,invalid type {0} for 'topic' detail in EVENTrz/invalid type {0} for 'retained' detail in EVENTr87invalid type {0} for 'transaction_hash' detail in EVENTrz>invalid type {0} for 'x_acknowledged_delivery' detail in EVENTrFrrrTz?invalid type/value {0} for/within 'forward_for' option in EVENT)r rzr rrrr.rr8rrLr rNr)rWrrrrVr&r'rHrRrr(rIr)rrvrtr)rrrrr rzr rLr rNrrrr.rr8rrdetail_publisherdetail_publisher_authiddetail_publisher_authrole detail_topicdetail_transaction_hashrrrr;r;r@rZs                 z Event.parsecCJi}|jdur |j|d<|jdur|j|d<|jdur |j|d<|jdur*|j|d<|jdur4|j|d<|jdur>|j|d<|jdurH|j|d<|jdurR|j|d <|jr~|j dur_|j |d <|j duri|j |d <|j durs|j |d <t j |j|j||jgS|jrt j |j|j||j|jgS|jrt j |j|j||jgSt j |j|j|gS) rNrrrr.rr8rrrLr rN)rrrr.rr8rrr rLr rNrrrrrzr rr;r;r@r<                      z Event.marshal)NNNNNNNNNNNNNNNNN) rrrrrrrrrrrrrr rzr rrrr.rr8rrLr rNrrrrrrr;r;r;r@rm s 2 g'                                 R  rc@r) EventReceivedzd A WAMP ``EVENT_RECEIVED`` message. Format: ``[EVENT_RECEIVED, EVENT.Publication|id]`` iQ)rcCs$t|tksJt|||_dS)zl :param publication: The publication ID for the sent event. :type publication: int N)rHrtr rr)rrr;r;r@r2s  zEventReceived.__init__cCsVt|dkr |dtjksJt|dkrtdt|t|dd}t|}|S)rrr7z-invalid message length {0} for EVENT_RECEIVEDr6z'publication' in EVENT_RECEIVED)rWr(rrrVr&)rrrr;r;r@r=s  zEventReceived.parsecCs tj|jgSr)r(rrrr;r;r@rSs zEventReceived.marshalNrr;r;r;r@r(!s  r(c@sZeZdZdZdZ dZ             d ddZeddZd d Z d d Z 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 procedurer rzr timeoutreceive_progressr8rLr rNr caller_authidcaller_authrolerNcCst|tksJt|tksJ|dust|ttfvsJ|dus*t|tks*J|dus6t|tks6J|dusH|durF|durF|dusHJ|dusTt|tksTJ|dus`t|tks`J|duslt|tkslJ| dusvt| svJ| dust| tksJ| dust | sJ| dur| dur| dus|dur| dusJ| dust| tksJ| dust| tksJ|dust|tksJ|dust|tksJ|r|D]?}t|tksJd|vrt|dtksJd|vr|ddust|dtksJd|vrt|dtksJqt |||_ ||_ ||_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)rHrtrIrrrvrRrr(r)r rrr*r r{rzr r+r,r8rLr rNrr-r.r)rrr*r rzr r+r,r8rLr rNrr-r.rrr;r;r@rsNE$,."   z Call.__init__cCst|dkr |dtjksJt|dvrtdt|t|dd}t|dd}t|dd }d }d }d }d }d }d } t|d krt|d t t fvr|d }| d d }|rft |sftd|| dd }|r}t|t kr}tdt|| dd } | rt | std| n6t|d kr|d }|d urt|tkrtdt|t|d kr|d }t|tkrtdt|d } d } d } d } d }d }d }d|vr|d}t|tkrtdt||dkrtd||} d|vr|d}t|tkrtdt||} d|vr/|d}t|t kr-tdt||} d|vrJ|d}t|tkrHtdt||} d|vre|d}t|t krctdt||}d |vr|d }t|t kr~td!t||}d"|vr|d"}d#}t|tkr|D]<}t|tkrn2d$|vst|d$tkrn"d%|vst|d%t krnd&|vst|d&t krnqd'}|std(t|||||| | | ||| | |||d)}|S)*rrrz#invalid message length {0} for CALLr6z'request' in CALLr7z'options' in CALLr8z'procedure' in CALLNrDrCrLz/invalid value {0} for 'enc_algo' detail in CALLr z-invalid type {0} for 'enc_key' detail in CALLrNz5invalid value {0} for 'enc_serializer' detail in CALLz#invalid type {0} for 'args' in CALLz%invalid type {0} for 'kwargs' in CALLr+z-invalid type {0} for 'timeout' option in CALLz.invalid value {0} for 'timeout' option in CALLr,z6invalid type {0} for 'receive_progress' option in CALLr8z6invalid type {0} for 'transaction_hash' detail in CALLrz,invalid type {0} for 'caller' detail in CALLr-z3invalid type {0} for 'caller_authid' detail in CALLr.z5invalid type {0} for 'caller_authrole' detail in CALLrFrrrTz>invalid type/value {0} for/within 'forward_for' option in CALL) r rzr r+r,r8rLr rNrr-r.r)rWrrrrVr&r'r$rHrIrRrr(r)rrvrtr)rrrr*r rzr rLr rNr+r,r8rr-r.roption_timeoutoption_receive_progressoption_transaction_hash option_calleroption_caller_authidoption_caller_authrolerrrr;r;r@rs                 z Call.parsecCsi}|jdur |j|d<|jdur|j|d<|jdur |j|d<|jrA|jdur-|j|d<|jdur7|j|d<|jdurA|j|d<|jdurK|j|d<|jdurU|j|d<|j dur_|j |d <|j duri|j |d <|S) Nr+r,r8rLr rNrr-r.r) r+r,r8r rLr rNrr-r.rrr;r;r@rs.                    zCall.marshal_optionscCrr)rr rrrr*rzr rr;r;r@rrz Call.marshal) NNNNNNNNNNNNN) rrrrrrrrrrrr;r;r;r@r]s0  v  rc@sDeZdZdZdZ dZdZdZdZddd Z e d d Z d 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)rmoderNcCst|tksJ|dust|tksJ|d|j|j|jfvs!J|dus-t|tks-J|rl|D]:}t|tks;Jd|vrGt|dtksIJd|vr[|ddus]t|dtks]Jd|vrit|dtkskJq1t |||_ ||_ ||_ 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) rHrtrISKIP KILLNOWAITKILLrrvr rrr9r)rrr9rrr;r;r@rs (  zCancel.__init__c Csdt|dkr |dtjksJt|dkrtdt|t|dd}t|dd}d}d}d |vrZ|d }t|tkrGtd t||tj tj tj fvrXtd ||}d |vr|d }d }t|t kr|D]4}t|t krvn+d|vst|dtkrnd|vst|dtkrnd|vst|dtkrnqld}|stdt|||d}|S)rrr8z%invalid message length {0} for CANCELr6z'request' in CANCELr7z'options' in CANCELNr9z,invalid type {0} for 'mode' option in CANCELz/invalid value '{0}' for 'mode' option in CANCELrFrrrTz@invalid type/value {0} for/within 'forward_for' option in CANCEL)r9r)rWrrrrVr&r'rHrIr:r;r<rrvrt) rrrr9r option_moderrrr;r;r@rsB    z Cancel.parsecCs:i}|jdur |j|d<|jdur|j|d<tj|j|gS)rNr9r)r9rrrrrr;r;r@r/s     zCancel.marshalr) rrrrrr:r<r;rrrrrr;r;r;r@rs   8rc@NeZdZdZdZ dZ           d ddZeddZd d Z dS) raO A WAMP ``RESULT`` message. Formats: * ``[RESULT, CALL.Request|id, Details|dict]`` * ``[RESULT, CALL.Request|id, Details|dict, YIELD.Arguments|list]`` * ``[RESULT, CALL.Request|id, Details|dict, YIELD.Arguments|list, YIELD.ArgumentsKw|dict]`` * ``[RESULT, CALL.Request|id, Details|dict, Payload|binary]`` 2 rr rzr progressrLr rNrr r rNc Cs<t|tksJ|dust|ttfvsJ|dus"t|tks"J|dus.t|tks.J|dus@|dur>|dur>|dus@J|dusLt|tksLJ|dusVt|sVJ|dusbt|tksbJ|duslt |slJ|durx|durx|dus|dur|dusJ| dust| tksJ| dust| tksJ| dust| tksJ| dust| tksJ| r| D]:} t| tksJd| vrt| dtksJd| vr| ddust| dtksJd| vrt| dtksJqt |||_ ||_ t||_||_||_||_||_||_| |_| |_| |_| |_dS)as :param request: The request ID of the original `CALL` request. :type request: int :param args: Positional values for application-defined event payload. Must be serializable using any serializers in use. :type args: list or tuple or None :param kwargs: Keyword values for application-defined event payload. Must be serializable using any serializers in use. :type kwargs: dict or None :param payload: Alternative, transparent payload. If given, ``args`` and ``kwargs`` must be left unset. :type payload: bytes or None :param progress: If ``True``, this result is a progressive call result, and subsequent results (or a final error) will follow. :type progress: bool or None :param enc_algo: If using payload transparency, the encoding algorithm that was used to encode the payload. :type enc_algo: str or None :param enc_key: If using payload transparency with an encryption algorithm, the payload encryption key. :type enc_key: str or None :param enc_serializer: If using payload transparency, the payload object serializer that was used encoding the payload. :type enc_serializer: str or None :param callee: The WAMP session ID of the effective callee that responded with the result. Only filled if callee is disclosed. :type callee: None or int :param callee_authid: The WAMP authid of the responding callee. Only filled if callee is disclosed. :type callee_authid: None or unicode :param callee_authrole: The WAMP authrole of the responding callee. Only filled if callee is disclosed. :type callee_authrole: None or unicode :param forward_for: When this Result is forwarded for a client/callee (or from an intermediary router). :type forward_for: list[dict] NrrrrHrtrrrvrRrr(rIr)r rrr r{rzr rArLr rNrr r rrrr rzr rArLr rNrr r rrr;r;r@r`sB6$,(   zResult.__init__cCs<t|dkr |dtjksJt|dvrtdt|t|dd}t|dd}d}d}d}d}d}d}d} d} d} d} d} t|d krt|d tt fvr|d }| d d}|rit |sitd || d d}|rt|tkrtdt|| dd} | rt | std| n6t|d kr|d }|durt|t krtdt|t|d kr|d }t|tkrtdt|d|vr|d}t|tkrtdt||}d|vr|d}t|tkrtdt||} d|vr|d}t|tkrtdt||} d|vr2|d}t|tkr0tdt||} d|vr|d} d}t| t kr| D]<}t|tkrQn2d|vs_t|dtkran"d|vsot|dtkrqnd|vst|dtkrnqFd }|std!t|||||||| | | | | d" }|S)#rrr8rCrDz%invalid message length {0} for RESULTr6z'request' in RESULTr7z'details' in RESULTNrCr8rLz1invalid value {0} for 'enc_algo' detail in RESULTr z/invalid type {0} for 'enc_key' detail in RESULTrNz7invalid value {0} for 'enc_serializer' detail in RESULTz%invalid type {0} for 'args' in RESULTz'invalid type {0} for 'kwargs' in RESULTrAz0invalid type {0} for 'progress' option in RESULTrz.invalid type {0} for 'callee' detail in RESULTr z5invalid type {0} for 'callee_authid' detail in RESULTr z7invalid type {0} for 'callee_authrole' detail in RESULTrFrrrTz@invalid type/value {0} for/within 'forward_for' option in RESULT r rzr rArLr rNrr r r)rWrrrrVr&r'rHrIrRrr(r)rrvrrt)rrrr rzr rArLr rNrr r rdetail_progressrrrrrrr;r;r@rs                z Result.parsecCi}|jdur |j|d<|jdur|j|d<|jdur |j|d<|jdur*|j|d<|jdur4|j|d<|jr^|jdurA|j|d<|jdurK|j|d<|jdurU|j|d <t j |j ||jgS|j rlt j |j ||j |j gS|j rxt j |j ||j gSt j |j |gS rNrArr r rrLr rN)rArr r rr rLr rNrrrrzr rr;r;r@r=0                zResult.marshal NNNNNNNNNNNrr;r;r;r@r@s(  b  zrc@sneZdZdZdZ dZdZdZdZdZ dZ d Z d Z d Z d Z dddZeddZddZddZd S)rzk A WAMP ``REGISTER`` message. Format: ``[REGISTER, Request|id, Options|dict, Procedure|uri]`` @rrrsinglefirstlast roundrobinrandomall)rr*rKinvoke concurrencyforce_reregisterrNc Cst|tksJt|tksJ|dust|tksJ|dus,|tjtjtjfvs,J|dus8t|tks8J|dusL|tjtjtj tj tj fvsLJ|dus\t|tkrZ|dks\J|dvsbJ|dusnt|t ksnJ|r|D]:}t|t ks|Jd|vrt|dtksJd|vr|ddust|dtksJd|vrt|dtksJqrt|||_||_|ptj|_|ptj|_||_||_||_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)rHrtrIrrrr INVOKE_SINGLE INVOKE_FIRST INVOKE_LASTINVOKE_ROUNDROBIN INVOKE_RANDOMrrvr rrr*rKrRrSrTr) rrr*rKrRrSrTrrr;r;r@rs. (  (    zRegister.__init__c Cst|dkr |dtjksJt|dkrtdt|t|dd}t|dd}tj}tj}d}d}d}d |vrb|d }t |t krOtd t ||tjtj tj fvr`td ||}|tjkrld } d } n|tj krvd } d } n|tj krd } d } nt dt|dd| | d} d|vr|d} t | t krtdt | | tjtjtjtjtjfvrtd| | }d|vr|d} t | tkrtdt | | dkrtd| | }|dd}|dvrtdt ||dur|}d|vrS|d}d }t |tkrL|D]<}t |tkrn2d|vs&t |dtkr(n"d|vs6t |dt kr8nd|vsFt |dt krHnq d }|sStdt|| |||||d }|S)!rrrCz'invalid message length {0} for REGISTERr6z'request' in REGISTERr7z'options' in REGISTERNrKz/invalid type {0} for 'match' option in REGISTERz0invalid value {0} for 'match' option in REGISTERFTz logic errorr8z'procedure' in REGISTER)rhrirRz0invalid type {0} for 'invoke' option in REGISTERz1invalid value {0} for 'invoke' option in REGISTERrSz5invalid type {0} for 'concurrency' option in REGISTERz6invalid value {0} for 'concurrency' option in REGISTERrT)TFNz9invalid type {0} for 'force_reregister option in REGISTERrrrrzBinvalid type/value {0} for/within 'forward_for' option in REGISTER)rKrRrSrTr)rWrrrrVr&r'rrUrHrIrr Exceptionr$rVrWrXrYrtrrrv)rrrrKrRrSrTrrrhrir* option_invokeoptions_concurrencyoptions_reregisterrrrr;r;r@rs          zRegister.parsecCsxi}|jr|jtjkr|j|d<|jr|jtjkr|j|d<|jr&|j|d<|jdur0|j|d<|jdur:|j|d<|S)NrKrRrSrTr)rKrrrRrUrSrTrrr;r;r@r&s       zRegister.marshal_optionscCrr)rrrrr*rr;r;r@r:rzRegister.marshal)NNNNN)rrrrrrrrrUrVrWrXrY INVOKE_ALLrrrrrrr;r;r;r@rcs0  6 k rc@r) rzl A WAMP ``REGISTERED`` message. Format: ``[REGISTERED, REGISTER.Request|id, Registration|id]`` A)r registrationcCr)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)rHrtr rrr`)rrr`r;r;r@rUrzRegistered.__init__cCr)rrr8z)invalid message length {0} for REGISTEREDr6z'request' in REGISTEREDr7z'registration' in REGISTERED)rWrrrrVr&)rrr`rr;r;r@rerzRegistered.parsecCrr)rrrr`rr;r;r@r|rzRegistered.marshalNrr;r;r;r@rDrrc@r) rz A WAMP `UNREGISTER` message. Formats: * ``[UNREGISTER, Request|id, REGISTERED.Registration|id]`` * ``[UNREGISTER, Request|id, REGISTERED.Registration|id, Options|dict]`` B)rr`rNcCs@t|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)rHrtr rrr`r)rrr`rr;r;r@rs    zUnregister.__init__cCr)rrrz.invalid message length {0} for WAMP UNREGISTERr6z'request' in UNREGISTERr7z'registration' in UNREGISTERNr8z'options' in UNREGISTERrFrrrTzDinvalid type/value {0} for/within 'forward_for' option in UNREGISTERr) rWrrrrVr&r'rHrrvrtrI)rrr`rrrrrr;r;r@rrzUnregister.parsecCrr)rrrrr`rr;r;r@rrzUnregister.marshalrrr;r;r;r@rs    -rc@r) r z A WAMP ``UNREGISTERED`` message. Formats: * ``[UNREGISTERED, UNREGISTER.Request|id]`` * ``[UNREGISTERED, UNREGISTER.Request|id, Details|dict]`` C)rr`rNcCr)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)rHrtrIr rrr`r)rrr`rr;r;r@rs $  zUnregistered.__init__cCr) rrrz+invalid message length {0} for UNREGISTEREDr6z'request' in UNREGISTEREDNr7z'details' in UNREGISTEREDr`z:invalid type {0} for 'registration' detail in UNREGISTEREDrz'reason' in UNREGISTERED) rWr rrrVr&r'rHrtr$)rrr`rrdetails_registrationrr;r;r@rrzUnregistered.parsecCr)rNrr`)rr`r rrrr;r;r@r@rzUnregistered.marshalrrr;r;r;r@r s    %r c@sTeZdZdZdZ dZ              d ddZeddZd d Z dS) r!a A WAMP ``INVOCATION`` message. Formats: * ``[INVOCATION, Request|id, REGISTERED.Registration|id, Details|dict]`` * ``[INVOCATION, Request|id, REGISTERED.Registration|id, Details|dict, CALL.Arguments|list]`` * ``[INVOCATION, Request|id, REGISTERED.Registration|id, Details|dict, CALL.Arguments|list, CALL.ArgumentsKw|dict]`` * ``[INVOCATION, Request|id, REGISTERED.Registration|id, Details|dict, Payload|binary]`` D)rr`r rzr r+r,rr-r.r*r8rLr rNrNcCst|tksJt|tksJ|dust|ttfvsJ|dus*t|tks*J|dus6t|tks6J|dusH|durF|durF|dusHJ|dusTt|tksTJ|dus`t|tks`J|duslt|tkslJ| dusxt| tksxJ| dust| tksJ| dust| tksJ| dust| tksJ| dust| sJ|dust|tksJ|dust |sJ| dur|dur|dus|dur| dusJ|dust|tksJ|r#|D]?}t|tksJd|vrt|dtksJd|vr|ddust|dtksJd|vr t|dtks"Jqt |||_ ||_ ||_t||_||_||_||_||_| |_| |_| |_| |_| |_||_||_||_dS)a :param request: The WAMP request ID of this request. :type request: int :param registration: The registration ID of the endpoint to be invoked. :type registration: 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 timeout: If present, let the callee automatically cancels the invocation after this ms. :type timeout: int or None :param receive_progress: Indicates if the callee should produce progressive results. :type receive_progress: bool 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 procedure: For pattern-based registrations, the invocation MUST include the actual procedure being called. :type procedure: str 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 forward_for: When this Call is forwarded for a client (or from an intermediary router). :type forward_for: list[dict] Nrrr)rHrtrrrvrRrrIr(r)r rrr`r r{rzr r+r,rr-r.r*r8rLr rNr)rrr`r rzr r+r,rr-r.r*r8rLr rNrrr;r;r@rvsRH$,."   zInvocation.__init__cCst|dkr |dtjksJt|dvrtdt|t|dd}t|dd}t|dd }d }d }d }d }d }d } t|d krt|d tkr|d }| d d }|rdt |sdtd|| dd }|r{t|t kr{tdt|| dd } | rt | std| n6t|d kr|d }|d urt|t krtdt|t|d kr|d }t|tkrtdt|d } d } d } d } d }d }d }d }d|vr|d}t|tkrtdt||dkrtd||} d|vr|d}t|tkrtdt||} d|vr/|d}t|tkr-tdt||} d|vrJ|d}t|t krHtdt||} d|vre|d}t|t krctdt||}d |vr|d }t|t kr~td!t||}d"|vr|d"}t|t krtd#t||}d$|vr|d$}d%}t|t kr|D]<}t|tkrn2d&|vst|d&tkrn"d'|vst|d't krnd(|vst|d(t krnqd)}|std*t|||||| | | | |||||| |d+}|S),rrrz)invalid message length {0} for INVOCATIONr6z'request' in INVOCATIONr7z'registration' in INVOCATIONr8z'details' in INVOCATIONNrDrCrLz5invalid value {0} for 'enc_algo' detail in INVOCATIONr z3invalid type {0} for 'enc_key' detail in INVOCATIONrNz;invalid value {0} for 'enc_serializer' detail in INVOCATIONz)invalid type {0} for 'args' in INVOCATIONz+invalid type {0} for 'kwargs' in INVOCATIONr+z3invalid type {0} for 'timeout' detail in INVOCATIONz4invalid value {0} for 'timeout' detail in INVOCATIONr,zt|||_ ||_ ||_ ||_ 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) rHrtrIr<r;rrvr rrr9rr)rrr9rrrr;r;r@rs (  zInterrupt.__init__c Cs|t|dkr |dtjksJt|dkrtdt|t|dd}t|dd}d}d}d}d |vrZ|d }t|tkrItd t||tj tj fvrXtd ||}d |vret |d d }d|vr|d}d}t|t kr|D]4}t|t krn+d|vst|dtkrnd|vst|dtkrnd|vst|dtkrnqwd}|stdt||||d} | S)rrr8z(invalid message length {0} for INTERRUPTr6z'request' in INTERRUPTr7z'options' in INTERRUPTNr9z/invalid type {0} for 'mode' option in INTERRUPTz2invalid value '{0}' for 'mode' option in INTERRUPTrz"reason" in INTERRUPTrFrrrTzCinvalid type/value {0} for/within 'forward_for' option in INTERRUPT)r9rr)rWr"rrrVr&r'rHrIr<r;r$rrvrt) rrrr9rrr=rrrr;r;r@rsH    zInterrupt.parsecCsNi}|jdur |j|d<|jdur|j|d<|jdur |j|d<tj|j|gS)rNr9rr)r9rrr"rrrr;r;r@r=s      zInterrupt.marshalr) rrrrrr<r;rrrrrr;r;r;r@r"s +  ) 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]`` Fr@Nc Cs<t|tksJ|dust|ttfvsJ|dus"t|tks"J|dus.t|tks.J|dus@|dur>|dur>|dus@J|dusLt|tksLJ|dusVt|sVJ|durb|durb|dusl|durj|duslJ|dusxt|tksxJ|dust |sJ| dust| tksJ| dust| tksJ| dust| tksJ| dust| tksJ| r| D]:} t| tksJd| vrt| dtksJd| vr| ddust| dtksJd| vrt| dtksJqt |||_ ||_ 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] NrrrrBrCr;r;r@rrsB6$,(   zYield.__init__cCs8t|dkr |dtjksJt|dvrtdt|t|dd}t|dd}d}d}d}d}d}d}t|d krt|d tkr|d }| d d}|r]t |s]td || d d}|rtt|t krttdt|| dd}|rt |std|n6t|d kr|d }|durt|t krtdt|t|d kr|d }t|tkrtdt|d} d} d} d} d} d|vr|d}t|tkrtdt||} d|vr|d}t|tkrtdt||} d|vr|d}t|t krtdt||} d|vr0|d}t|t kr.tdt||} d|vr|d} d}t| t kr| D]<}t|tkrOn2d|vs]t|dtkr_n"d|vsmt|dt krond|vs}t|dt krnqDd }|std!t||||| |||| | | | d" }|S)#rrrDz$invalid message length {0} for YIELDr6z'request' in YIELDr7z'options' in YIELDNrCr8rLz0invalid value {0} for 'enc_algo' detail in YIELDr z.invalid type {0} for 'enc_key' detail in YIELDrNz6invalid value {0} for 'enc_serializer' detail in YIELDz$invalid type {0} for 'args' in YIELDz&invalid type {0} for 'kwargs' in YIELDrAz/invalid type {0} for 'progress' option in YIELDrz-invalid type {0} for 'callee' detail in YIELDr z4invalid type {0} for 'callee_authid' detail in YIELDr z6invalid type {0} for 'callee_authrole' detail in YIELDrFrrrTz?invalid type/value {0} for/within 'forward_for' option in YIELDrE)rWr#rrrVr&r'rHrRrr(rIr)rrvrrt)rrrr rzr rLr rNrArr r roption_progress option_calleeoption_callee_authidoption_callee_authrolerrrr;r;r@rs               z Yield.parsecCrGrH)rArr r rr rLr rNr#rrrzr rr;r;r@rMrIz Yield.marshalrJrr;r;r;r@r#Rs(  _  {r#)rO)reFFFF)reT)re)`rerSrpprintrtypingrrrr autobahn.utilrautobahn.wamp.exceptionrrautobahn.wamp.roler rJr5 autobahn.wampr ImportError_HAS_WAMP_FLATBUFFERS__all__compilerardrbrcrlrormrprkrnrJr+r,PAYLOAD_ENC_XBRr-rM ENC_ALGO_NONErrr ENC_ALGOSitemsENC_ALGOS_FROMSTR ENC_SER_NONErrrrENC_SER_OPAQUEENC_SER_FLATBUFFERSENC_SERSENC_SERS_FROMSTRr(r)r[rIr*rr$r%rtr&r'r{objectr r r rrrrrrrrrrrrr(rrrrrrr r!r"r#r;r;r;r@s      %              3'  $0pvPEEf.XBBne9<d%bBhdm