U ucRC@sddlZddlZddlZddlmZddlmZmZmZddl Z ddl m Z ddl m Z mZddlmZz ddlZddlZddlmZWnek rdZYnXd Zd Zed Zed Zed ZedZedZedZedZedZ edZ!edZ"edZ#dZ$dZ%dZ&e$e%e&gZ'dddddgZ(dZ)dZ*dZ+d Z,e)d!e*de+de,diZ-d"d#e-.DZ/dZ0dZ1dZ2d Z3d$Z4d%Z5d&Z6e0d!e1de2de3de4de5d'e6diZ7d(d#e7.DZ8d)d*Z9d+d,Z:dtd.d/Z;eee<d0d1d2Z=dueee>e>e>ed?ZDGd@dAdAeEZFGdBdCdCeFZGGdDdEdEeFZHGdFdGdGeFZIGdHdIdIeFZJGdJdKdKeFZKGdLdMdMeFZLGdNdOdOeFZMGdPdQdQeFZNGdRdSdSeFZOGdTdUdUeFZPGdVdWdWeFZQGdXdYdYeFZRGdZd[d[eFZSGd\d]d]eFZTGd^d_d_eFZUGd`dadaeFZVGdbdcdceFZWGdddedeeFZXGdfdgdgeFZYGdhdidieFZZGdjdkdkeFZ[GdldmdmeFZ\GdndodoeFZ]GdpdqdqeFZ^GdrdsdseFZ_dS)zN)pformat)AnyDictOptional)hlval) ProtocolErrorInvalidUriError)ROLE_NAME_TO_CLASS) message_fbsFT)#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_]+)?$Z cryptoboxZmqttxbrjsonZmsgpackZcborZubjson flatbuffersnullcCsi|]\}}||qSr5.0valuekeyr5r5X/var/www/html/BOARDBOSS/school/venv/lib/python3.8/site-packages/autobahn/wamp/message.py sr;opaquecCsi|]\}}||qSr5r5r6r5r5r:r;scCst|tko|tkpt|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_algor5r5r:r(sr(cCst|tko|tkpt|S)am For WAMP payload transparency mode, check if the provided ``enc_serializer`` identifier in the WAMP message is a valid one. Currently, the only standard defined identifier are * ``"json"`` * ``"msgpack"`` * ``"cbor"`` * ``"ubjson"`` * ``"flatbuffers"`` Users can select arbitrary identifiers too, but these MUST start with ``"x_"``. :param enc_serializer: The payload transparency serializer identifier to check. :type enc_serializer: str :returns: Returns ``True`` if and only if the payload transparency serializer identifier is valid. :rtype: bool )r@rA PAYLOAD_ENC_STANDARD_SERIALIZERSrBrC)enc_serializerr5r5r:r)sr)(cCslt|tkr|}n6t|tkr0t|d}n|dkr>d}n d|}t||krd|d|dS|SdS)Nascii-z{}z..)r@rAbytesbinasciib2a_hexdecodeformatlen)dataZmax_lensr5r5r:b2as    rR)r8returncCsRt|tkrdSt|r            r c@s6eZdZdZdZdZd ddZeddZd d Z dS) r zU A WAMP ``HELLO`` message. Format: ``[HELLO, Realm|uri, Details|dict]`` r1) realmroles authmethodsauthidauthrole authextra resumableresume_session resume_tokenNc Csr|dkst|tstt|tks&tt|dks6t|D],} | dksJtt|| tjjj | s:tq:|rt|t ks|t|D]} t| tkstq|dkst|tkst|dkst|tkst|dkst|tkst|dkst|t kst|dkst|t kst| dks.t| tks.tt |||_||_||_||_||_||_||_||_| |_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 NrZ subscriber publishercallercallee)rkrAr|r@rirOautobahnwamproler listrrgr ryrrrrrrrrr) rwrrrrrrrrrr authmethodr5r5r:ryrs4'  zHello.__init__c Cst|dkr|dtjkstt|dkrtdt | | D]&} t | t krBtdt | qB| } d} d|kr|d} t | t krtdt | | } d}d|kr|d}t |t krtdt ||}d}d|kr|d}t |t krtdt ||}d}d|krR|d}t |t krRtdt |d}d|kr|d}t |tkrtd t |d}d!|kr|d!}t |t krtd"t |n|rtd#t||| | ||||| }|S)$ Verifies and parses an unserialized raw message into an actual WAMP message instance. :param wmsg: The unserialized raw message. :type wmsg: list :returns: An instance of this class. rr3z$invalid message length {0} for HELLOr1z'realm' in HELLOT)r^r2z'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 HELLO)rOr rr|rrNr$r'r r@rrArirrg)rrdetailsr details_rolesrrole_cls details_role role_featuresrZdetails_authmethodsZ auth_methodrZdetails_authidrZdetails_authrolerZdetails_authextrarrrrr5r5r:rs           z Hello.parsecCs0dii}|jD]~}i|d|j<|jD]d}|ds*|dkr*t||dk r*d|d|jkrrdii|d|j<t|||d|jd|<q*q|jdk r|j|d<|jdk r|j|d<|jdk r|j|d<|j dk r|j |d <|j dk r|j |d <|j dk r |j |d <|j dk r"|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 rrrwrrfeaturer5r5r:r!s.                 z Hello.marshal)NNNNNNN rrrrrrryrrrr5r5r5r:r Zs C kr c @s6eZdZdZdZdZd ddZeddZd d Z dS) r zZ A WAMP ``WELCOME`` message. Format: ``[WELCOME, Session|id, Details|dict]`` r2) sessionrrrrr authproviderrresumedrrcustomNc Cst|tkstt|tks tt|dks0t|D],} | dksDtt|| tjjj | s4tq4|dkszt|t kszt|dkst|t kst|dkst|t kst|dkst|t kst|dkst|t kst|dkst|tkst| dkst| t kst| dks*t| t ks*t| dksFt| t ksFt| dksbt| tksbt| r| D]}t |sltqlt|||_||_||_||_||_||_||_||_| |_| |_| |_| 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 rZbrokerZdealerN)r@rgr|rirOrkrrrr rArrBrCr ryrrrrrrrrrrrr)rwrrrrrrrrrrrrrrlr5r5r:ryds@3  zWelcome.__init__c CsRt|dkr|dtjkstt|dkrs  rc@s6eZdZdZdZdZd ddZeddZd d Z dS) rz_ A WAMP ``CHALLENGE`` message. Format: ``[CHALLENGE, Method|string, Extra|dict]`` r<)methodextraNcCsFt|tkst|dks(t|tks(tt|||_|p>i|_dS)z :param method: The authentication method. :type method: str :param extra: Authentication method specific information. :type extra: dict or None N)r@rAr|rir ryrr)rwrrr5r5r:rys  zChallenge.__init__cCs~t|dkr|dtjkstt|dkri|_dS)z :param signature: The signature for the authentication challenge. :type signature: str :param extra: Authentication method specific information. :type extra: dict or None N)r@rAr|rir ryrr)rwrrr5r5r:rys  zAuthenticate.__init__cCs~t|dkr|dtjkstt|dkrzwamp.close.normalrrZrNcCs`t|tkst|dks(t|tks(t|dks@t|tks@tt|||_||_||_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) r@rAr|rr ryrrZr)rwrrZrr5r5r:ry/s  zGoodbye.__init__cCst|dkr|dtjkstt|dkr|d}t|tkr:tdt||} d|krt|d}t|tkrptdt||} d|kr|d}t|tkrtdt||} d|krf|d}d}t|tkrX|D]}t|tkrqTd |kst|d tkr qTd!|ks(t|d!tkr.qTd"|ksJt|d"tkrqTqd#}|sftd$t|||||||| | | | | |d% }|S)&rr)r=r>z$invalid message length {0} for ERRORr1z,invalid type {0} for 'request_type' in ERRORz-invalid value {0} for 'request_type' in ERRORr2z'request' in ERRORr3z'details' in ERRORr<z'error' in ERRORNr>r=rD0invalid value {0} for 'enc_algo' detail in EVENTr.invalid type {0} for 'enc_key' detail in EVENTrF6invalid value {0} for 'enc_serializer' detail in EVENTz$invalid type {0} for 'args' in ERRORz&invalid type {0} for 'kwargs' in ERRORrz-invalid type {0} for 'callee' detail in ERRORrz4invalid type {0} for 'callee_authid' detail in ERRORrz6invalid type {0} for 'callee_authrole' detail in ERRORrFrrrTz?invalid type/value {0} for/within 'forward_for' option in ERROR) rrmrrDrrFrrrr)rOrrr|rrNr@rgrrrrrrr!r&r'r$rJrr(rAr)rri)rrrrrrrmrrDrrFrrrr detail_calleedetail_callee_authiddetail_callee_authrolevalidrrr5r5r:rs            z Error.parsecCsi}|jdk r|j|d<|jdk r,|j|d<|jdk r@|j|d<|jdk rT|j|d<|jr|jdk rn|j|d<|jdk r|j|d<|jdk r|j|d<|j|j |j ||j |jgS|j r|j|j |j ||j |j |j gS|j r|j|j |j ||j |j gS|j|j |j ||j gSdS) rNrrrrrDrrF)rrrrrrDrrFrrrrrmrrr5r5r:rs,              z Error.marshal) NNNNNNNNNNrr5r5r5r:r~s$  g rc@sPeZdZdZdZdZdNddZddZd 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_forNcCsF|dkst|tkst|dks0t|tks0t|dksPt|ttttfksPt|dksnt|tttfksnt|dkst|tkst|dks|dk r|dkr|dkst|dkst|tkst|dkst|tkst|dkst|tkst|dkst|tkst|dks*t|tks*t|rN|D]}t|tks4tq4| dksjt| tksjt| r| D]}t|tksttqt| dkst| tkst| r| D]}t|tkstq| dkst| tkst| r| D]}t|tkstq| dks*t| tks*t| rN| D]}t|tks4tq4| dksjt| tksjt| r| D]}t|tksttqt|dkst |st|dkr|dkr|dks|dk r|dk st|dkst|tkst|dkst |st|dks,t|tks,t|r|D]}t|tksLtd|krht|dtksltd|kr|ddkst|dtkstd|krt|dtks6tq6t 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] Nrrrrx)!r@rgr|rArrrJrirr(r)r ryrrrrnrrrrrrrrrrrrrrrr)rwrtopicrrmr acknowledge exclude_meexcludeexclude_authidexclude_authroleeligibleeligible_authideligible_authroleretaintransaction_hashrDrrFrrxZ sessionidrrrr5r5r:rysW $6 .$ zPublish.__init__cCs`t||jsdSt||s dS|j|jkr0dS|j|jkr@dS|j|jkrPdS|j|jkr`dS|j|jkrpdS|j |j krdS|j |j krdS|j |j krdS|j |j krdS|j |j krdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkr&dS|j|jkr8dS|j|jkrJdS|j|jkr\dSdSNFT)rkrr rrrrrmrrrrrrrrrr r rDrrFrrr5r5r:rsV               zPublish.__eq__cCs || Srvrrr5r5r:rszPublish.__ne__cCs"|jdkr|jr|j|_|jSrv)rrpRequestrzr5r5r:rs zPublish.requestcCs"|dkst|tkst||_dSrv)r@rgr|rr}r5r5r:rscCs0|jdkr*|jr*|j}|r*|d|_|jSNutf8rrpZTopicrMrwrQr5r5r:rs   z Publish.topiccCs"|dkst|tkst||_dSrvr@rAr|rr}r5r5r:rscCs6|jdkr0|jr0|jr0tt|j|_|jSrvrrpZ ArgsLengthcbor2loadsrJZ ArgsAsBytesrzr5r5r:rs z Publish.argscCs&|dkst|ttfkst||_dSrvr@rrr|rr}r5r5r:rscCs6|jdkr0|jr0|jr0tt|j|_|jSrvrrpZ KwargsLengthrrrJZ KwargsAsBytesrzr5r5r:rms zPublish.kwargscCs"|dkst|tkst||_dSrvr@rir|rr}r5r5r:rmscCs,|jdkr&|jr&|jr&|j|_|jSrvrrpZ PayloadLengthZPayloadAsBytesrzr5r5r:rs  zPublish.payloadcCs"|dkst|tkst||_dSrvr@rJr|rr}r5r5r:r scCs*|jdkr$|jr$|j}|r$||_|jSrv)rrp Acknowledge)rwrr5r5r:rs  zPublish.acknowledgecCs"|dkst|tkst||_dSrv)r@rr|rr}r5r5r:rscCs.|jdkr(|jr(|j}|dkr(||_|jS)NF)rrpZ ExcludeMe)rwrr5r5r:rs  zPublish.exclude_mecCs"|dkst|tkst||_dSrv)r@rr|rr}r5r5r:r%scCsP|jdkrJ|jrJ|jrJg}t|jD]}||j|q,||_|jSrv)rrpZ ExcludeLengthrangeappendZExclude)rwrjr5r5r:r*s zPublish.excludecCs@|dkst|tkst|r6|D]}t|tks tq ||_dSrv)r@rr|rgrrwr8xr5r5r:r4s cCsV|jdkrP|jrP|jrPg}t|jD]}||j|dq,||_|jSr )rrpZExcludeAuthidLengthrrZ ExcludeAuthidrM)rwrrr5r5r:r<s zPublish.exclude_authidcCs@|dkst|tkst|r6|D]}t|tks tq ||_dSrv)r@rr|rArrr5r5r:rFs cCsV|jdkrP|jrP|jrPg}t|jD]}||j|dq,||_|jSr )rrpZExcludeAuthroleLengthrrZExcludeAuthrolerM)rwrrr5r5r:rNs zPublish.exclude_authrolecCs@|dkst|tkst|r6|D]}t|tks tq ||_dSrv)r@rr|rArrr5r5r:rXs cCsP|jdkrJ|jrJ|jrJg}t|jD]}||j|q,||_|jSrv)rrpZEligibleLengthrrZEligible)rwrrr5r5r:r`s zPublish.eligiblecCs@|dkst|tkst|r6|D]}t|tks tq ||_dSrv)r@rr|rgrrr5r5r:rjs cCsV|jdkrP|jrP|jrPg}t|jD]}||j|dq,||_|jSr )rrpZEligibleAuthidLengthrrZEligibleAuthidrM)rwrrr5r5r:rrs zPublish.eligible_authidcCs@|dkst|tkst|r6|D]}t|tks tq ||_dSrv)r@rr|rArrr5r5r:r|s cCsV|jdkrP|jrP|jrPg}t|jD]}||j|dq,||_|jSr )rrpZEligibleAuthroleLengthrrZEligibleAuthrolerM)rwrrr5r5r:rs zPublish.eligible_authrolecCs@|dkst|tkst|r6|D]}t|tks tq ||_dSrv)r@rr|rArrr5r5r:rs cCs*|jdkr$|jr$|j}|r$||_|jSrv)rrpZRetain)rwr r5r5r:r s  zPublish.retaincCs"|dkst|tkst||_dSrv)r@rr|rr}r5r5r:r scCs0|jdkr*|jr*|j}|r*|d|_|jSr rrpZTransactionHashrMrr5r5r:r s   zPublish.transaction_hashcCs"|dkst|tkst||_dSrvr@rAr|rr}r5r5r:r scCs*|jdkr$|jr$|j}|r$||_|jSrvrrpZEncAlgorwrDr5r5r:rDs  zPublish.enc_algocCs$|dks|tttfkst||_dSrvENC_ALGO_CRYPTOBOX ENC_ALGO_MQTT ENC_ALGO_XBRr|rr}r5r5r:rDscCs,|jdkr&|jr&|jr&|j|_|jSrvrrpZ EncKeyLengthZ EncKeyAsBytesrzr5r5r:rs  zPublish.enc_keycCs"|dkst|tkst||_dSrvr@rJr|rr}r5r5r:rscCs*|jdkr$|jr$|j}|r$||_|jSrvrrpZ EncSerializerrwrFr5r5r:rFs  zPublish.enc_serializercCs&|dks|ttttfkst||_dSrv ENC_SER_JSONENC_SER_MSGPACK ENC_SER_CBORENC_SER_UBJSONr|rr}r5r5r:rFscCs|jSrvrrzr5r5r:rszPublish.forward_forcCs ||_dSrvr1r}r5r5r:rscCsttj|ddSNrr)rr ZGetRootAsPublishrr5r5r:rsz Publish.castcCs|j}|r|t|}|j}|r4|t|}|j}|rH||}|j}|r\||}|j}|rp||}|j }|r||}|j }|rt j |t|t|D]} || q|t|}|j} | r*g} | D]} | || qt j |t| t| D]} || q |t| } |j}| rg}|D]}|||q>t j |t|t|D]} || qp|t|}|j}|rt j |t|t|D]} || q|t|}|j}|rz&invalid message length {0} for PUBLISHr1z'request' in PUBLISHr2z'options' in PUBLISHr3z'topic' in PUBLISHNr=r<rDz2invalid value {0} for 'enc_algo' option in PUBLISHrz0invalid type {0} for 'enc_key' option in PUBLISHrFz8invalid value {0} for 'enc_serializer' option in PUBLISHz&invalid type {0} for 'args' in PUBLISHz(invalid type {0} for 'kwargs' in PUBLISHrz4invalid type {0} for 'acknowledge' option in PUBLISHrz3invalid type {0} for 'exclude_me' option in PUBLISHrz0invalid type {0} for 'exclude' option in PUBLISHz9invalid type {0} for value in 'exclude' option in PUBLISHrz7invalid type {0} for 'exclude_authid' option in PUBLISHz@invalid type {0} for value in 'exclude_authid' option in PUBLISHrz9invalid type {0} for 'exclude_authrole' option in PUBLISHzBinvalid type {0} for value in 'exclude_authrole' option in PUBLISHrz1invalid type {0} for 'eligible' option in PUBLISHz:invalid type {0} for value in 'eligible' option in PUBLISHrz8invalid type {0} for 'eligible_authid' option in PUBLISHzAinvalid type {0} for value in 'eligible_authid' option in PUBLISHrz:invalid type {0} for 'eligible_authrole' option in PUBLISHzCinvalid type {0} for value in 'eligible_authrole' option in PUBLISHr z/invalid type {0} for 'retain' option in PUBLISHr z9invalid type {0} for 'transaction_hash' option in PUBLISHrFrrrTzAinvalid type/value {0} for/within 'forward_for' option in PUBLISH)rrmrrrrrrrrrr r rDrrFr)rOrrr|rrNr&r'r$r@rArJrr(r)rrirrg)$rroptionsrrrmrrDrrFrrrrrrrrr r rZoption_acknowledgeZoption_exclude_meZoption_excludeZ _sessionidZoption_exclude_authidZ_authidZoption_exclude_authroleZ _authroleZoption_eligibleZ sessionIdZoption_eligible_authidZoption_eligible_authrolerrrr5r5r:rt s"  $                z Publish.parsecCs,i}|jdk r|j|d<|jdk r,|j|d<|jdk r@|j|d<|jdk rT|j|d<|jdk rh|j|d<|jdk r||j|d<|jdk r|j|d<|jdk r|j|d<|jdk r|j|d <|j dk r|j |d <|j r|j dk r|j |d <|j dk r|j |d <|j dk r|j |d <|jdk r(|j|d<|S)Nrrrrrrrrr r rDrrFr)rrrrrrrrr r rrDrrFrrwr@r5r5r:marshal_optionsA s>                            zPublish.marshal_optionscCsv|}|jr$tj|j||j|jgS|jrDtj|j||j|j|jgS|jr`tj|j||j|jgStj|j||jgSdSrN)rBrrrrrrmrrAr5r5r:rg szPublish.marshal)NNNNNNNNNNNNNNNNNNNN)$rrrrrrryrrrrrrrrmrrrrrrrrrr r rDrrFrrrrrrBrr5r5r5r:rs < /-                                        M&rc@s4eZdZdZdZdZddZeddZdd Z d S) rzh A WAMP ``PUBLISHED`` message. Format: ``[PUBLISHED, PUBLISH.Request|id, Publication|id]`` )r publicationcCs:t|tkstt|tks tt|||_||_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)r@rgr|r ryrrE)rwrrEr5r5r:ry s  zPublished.__init__cCsft|dkr|dtjkstt|dkrt|tkstt|tks t|dks8t|tks8t|dksX|tjtjtjfksXt|dkspt|tkspt|dkst|t kst|r |D]v}t|t kstd|krt|dtkstd|kr|ddkst|dtkstd|krt|dtkstqt |||_ ||_|p*tj|_||_||_dS)a :param request: The WAMP request ID of this request. :type request: int :param topic: The WAMP or application URI of the PubSub topic to subscribe to. :type topic: str :param match: The topic matching method to be used for the subscription. :type match: str :param get_retained: Whether the client wants the retained message we may have along with the subscription. :type get_retained: bool or None :param forward_for: When this Subscribe is forwarded over a router-to-router link, or via an intermediary router. :type forward_for: list[dict] Nrrr)r@rgr|rAr MATCH_EXACT MATCH_PREFIXMATCH_WILDCARDrrrir ryrrrCrJr)rwrrrCrJrrr5r5r:ry s$ (  zSubscribe.__init__c Cst|dkr|dtjkstt|dkrrc@s4eZdZdZdZdZddZeddZdd Z d S) rzm A WAMP ``SUBSCRIBED`` message. Format: ``[SUBSCRIBED, SUBSCRIBE.Request|id, Subscription|id]`` !)r subscriptioncCs:t|tkstt|tks tt|||_||_dS)z :param request: The request ID of the original ``SUBSCRIBE`` request. :type request: int :param subscription: The subscription ID for the subscribed topic (or topic pattern). :type subscription: int N)r@rgr|r ryrrP)rwrrPr5r5r:ryi s  zSubscribed.__init__cCsft|dkr|dtjkstt|dkrZed?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 _publicationrrrrrr _publisher_publisher_authid_publisher_authroler _retainedr_x_acknowledged_deliveryrNcCs|dkst|tkst|dks0t|tks0t|dksLt|ttfksLt|dksdt|tksdt|dks|t|tks|t|dks|dk r|dkr|dkst|dkst|tkst|dkst|tkst|dkst|tkst| dkst| tkst| dks t| tks t| dks`_. :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)r@rgr|rrrirJrArr(r)r ryrXrYrrnrrrZr[r\rr]rr^rrrr)rwrPrErrmrrpublisher_authidpublisher_authrolerretainedr x_acknowledged_deliveryrDrrFrrxrr5r5r:ry sR;$6 .$ zEvent.__init__cCs*t||jsdSt||s dS|j|jkr0dS|j|jkr@dS|j|jkrPdS|j|jkr`dS|j|jkrpdS|j |j krdS|j |j krdS|j |j krdS|j |j krdS|j |j krdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkrdS|j|jkr&dSdSr )rkrr rrPrErrmrrr_r`rrar rbrDrrFrrr5r5r:r sJ               z Event.__eq__cCs || Srvrrr5r5r:r> sz Event.__ne__cCs"|jdkr|jr|j|_|jSrv)rXrpZ Subscriptionrzr5r5r:rPA s zEvent.subscriptioncCs"|dkst|tkst||_dSrv)r@rgr|rXr}r5r5r:rPG scCs"|jdkr|jr|j|_|jSrv)rYrpZ Publicationrzr5r5r:rEL s zEvent.publicationcCs"|dkst|tkst||_dSrv)r@rgr|rYr}r5r5r:rER scCs6|jdkr0|jr0|jr0tt|j|_|jSrvrrzr5r5r:rW s z Event.argscCs&|dkst|ttfkst||_dSrvrr}r5r5r:r^ scCs6|jdkr0|jr0|jr0tt|j|_|jSrvrrzr5r5r:rmc s z Event.kwargscCs"|dkst|tkst||_dSrvrr}r5r5r:rmj scCs,|jdkr&|jr&|jr&|j|_|jSrvrrzr5r5r:ro s  z Event.payloadcCs"|dkst|tkst||_dSrvrr}r5r5r:rv scCs*|jdkr$|jr$|j}|r$||_|jSrv)rZrpZ Publisher)rwrr5r5r:r{ s  zEvent.publishercCs"|dkst|tkst||_dSrv)r@rgr|rZr}r5r5r:r scCs0|jdkr*|jr*|j}|r*|d|_|jSr )r[rpZPublisherAuthidrMrr5r5r:r_ s   zEvent.publisher_authidcCs"|dkst|tkst||_dSrv)r@rAr|r[r}r5r5r:r_ scCs0|jdkr*|jr*|j}|r*|d|_|jSr )r\rpZPublisherAuthrolerMrr5r5r:r` s   zEvent.publisher_authrolecCs"|dkst|tkst||_dSrv)r@rAr|r\r}r5r5r:r` scCs0|jdkr*|jr*|j}|r*|d|_|jSr rrr5r5r:r s   z Event.topiccCs"|dkst|tkst||_dSrvrr}r5r5r:r scCs"|jdkr|jr|j|_|jSrv)r]rpZRetainedrzr5r5r:ra s zEvent.retainedcCs"|dkst|tkst||_dSrv)r@rr|r]r}r5r5r:ra scCs0|jdkr*|jr*|j}|r*|d|_|jSr r rr5r5r:r  s   zEvent.transaction_hashcCs"|dkst|tkst||_dSrvr!r}r5r5r:r  scCs*|jdkr$|jr$|j}|r$||_|jSrv)r^rpr)rwrbr5r5r:rb s  zEvent.x_acknowledged_deliverycCs"|dkst|tkst||_dSrv)r@rr|r^r}r5r5r:rb scCs*|jdkr$|jr$|j}|r$||_|jSrvr"r#r5r5r:rD s  zEvent.enc_algocCs$|dks|tttfkst||_dSrvr$r}r5r5r:rD scCs,|jdkr&|jr&|jr&|j|_|jSrvr(rzr5r5r:r s  z Event.enc_keycCs"|dkst|tkst||_dSrvr)r}r5r5r:r scCs*|jdkr$|jr$|j}|r$||_|jSrvr*r+r5r5r:rF s  zEvent.enc_serializercCs&|dks|ttttfkst||_dSrvr,r}r5r5r:rF scCs|jSrvr1rzr5r5r:r szEvent.forward_forcCs ||_dSrvr1r}r5r5r:r scCsttj|ddSr2)rr ZGetRootAsEventrr5r5r:rsz Event.castc CsN|j}|r|t|}|j}|r4|t|}|j}|rH||}|j}|r\||}|j}|rp||}|j }|r||}|j }|r||}|j } | r|| } t j ||jrt j ||j|jrt j ||j|rt j |||r t j |||rt j |||jr6t j ||j|rJt j |||r^t j |||rrt j |||jdk rt j ||j|dk rt j |||jdk rt 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&,|} | Srv)-rr3rr4rmrr_r5r`rr rr ZEventGenZ EventStartrPZEventAddSubscriptionrEZEventAddPublicationZ EventAddArgsZEventAddKwargsZEventAddPayloadrZEventAddPublisherZEventAddPublisherAuthidZEventAddPublisherAuthroleZ EventAddTopicraZEventAddRetainedZEventAddTransactionHashrbZEventAddAcknowledgerDZEventAddEncAlgoZEventAddEncKeyrFZEventAddEncSerializerZEventEndr r7r8r9ZEVENTr:r;) rwrrrmrr_r`rr rr=r>r5r5r:rsz             z Event.buildcCst|dkr|dtjkstt|dkrinvalid type {0} for 'x_acknowledged_delivery' detail in EVENTrFrrrTz?invalid type/value {0} for/within 'forward_for' option in EVENT)rrmrrr_r`rrar rbrDrrFr)rOrrr|rrNr&r'r@rJrr(rAr)rrirgr)rrPrErrrmrrDrrFrr_r`rrar rrbZdetail_publisherZdetail_publisher_authidZdetail_publisher_authroleZ detail_topicdetail_transaction_hashrrrr5r5r:rZs                z Event.parsecCsRi}|jdk r|j|d<|jdk r,|j|d<|jdk r@|j|d<|jdk rT|j|d<|jdk rh|j|d<|jdk r||j|d<|jdk r|j|d<|jdk r|j|d <|jr|j dk r|j |d <|j dk r|j |d <|j dk r|j |d <t j |j|j||jgS|jrt j |j|j||j|jgS|jreZdZdZdZdZd 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 procedurerrmrtimeoutreceive_progressr rDrrFr caller_authidcaller_authrolerNcCst|tkstt|tks t|dks| dkr>| dksV|dk rR| dk sVt| dksrt| tksrt| dkst| tkst|dkst|tkst|dkst|tkst|rX|D]}t|tkstd|krt|dtkstd|kr0|ddks4t|dtks4td|krPt|dtkstqt |||_ ||_||_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)r@rgr|rArrrirJrr(r)r ryrrgrrnrmrrhrir rDrrFrrjrkr)rwrrgrrmrrhrir rDrrFrrjrkrrr5r5r:rysNE$6 .$  z Call.__init__cCst|dkr|dtjkstt|dkrinvalid type/value {0} for/within 'forward_for' option in CALL) rrmrrhrir rDrrFrrjrkr)rOrrr|rrNr&r'r$r@rArJrr(r)rrirgr)rrr@rgrrmrrDrrFrhrir rrjrkrZoption_timeoutZoption_receive_progressZoption_transaction_hashZ option_callerZoption_caller_authidZoption_caller_authrolerrrr5r5r:rs  $             z Call.parsecCsi}|jdk r|j|d<|jdk r,|j|d<|jdk r@|j|d<|jr|jdk rZ|j|d<|jdk rn|j|d<|jdk r|j|d<|jdk r|j|d<|jdk r|j|d<|j dk r|j |d <|j dk r|j |d <|S) Nrhrir rDrrFrrjrkr) rhrir rrDrrFrrjrkrrAr5r5r:rBs.                    zCall.marshal_optionscCsv|}|jr$tj|j||j|jgS|jrDtj|j||j|j|jgS|jr`tj|j||j|jgStj|j||jgSdSrC)rBrrrrrgrmrrAr5r5r:rsz Call.marshal) NNNNNNNNNNNNN) rrrrrrryrrrBrr5r5r5r:r]s,  v  rc@sBeZdZdZdZdZdZdZdZddd 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|tkst|dks(t|tks(t|d|j|j|jfksBt|dksZt|tksZt|r|D]t}t|tksvtd|krt|dtkstd|kr|ddkst|dtkstd|krt|dtksbtqbt |||_ ||_ ||_ 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)r@rgr|rASKIP KILLNOWAITKILLrrir ryrrpr)rwrrprrr5r5r:rys ( zCancel.__init__c Cs|t|dkr|dtjkstt|dkr|d} d}t| tkr0| D]}t|tkrq,d|kst|dtkrq,d|kst|dt krq,d|ks"t|dt krq,qd }|s>td!t|||||||| | | | | d" }|S)#rrr3r<r=z%invalid message length {0} for RESULTr1z'request' in RESULTr2z'details' in RESULTNr<r3rDz1invalid value {0} for 'enc_algo' detail in RESULTrz/invalid type {0} for 'enc_key' detail in RESULTrFz7invalid value {0} for 'enc_serializer' detail in RESULTz%invalid type {0} for 'args' in RESULTz'invalid type {0} for 'kwargs' in RESULTrwz0invalid type {0} for 'progress' option in RESULTrz.invalid type {0} for 'callee' detail in RESULTrz5invalid type {0} for 'callee_authid' detail in RESULTrz7invalid type {0} for 'callee_authrole' detail in RESULTrFrrrTz@invalid type/value {0} for/within 'forward_for' option in RESULT rrmrrwrDrrFrrrr)rOrrr|rrNr&r'r@rArJrr(r)rrirrg)rrrrrmrrwrDrrFrrrrZdetail_progressrrrrrrr5r5r:rs  $           z Result.parsecCsi}|jdk r|j|d<|jdk r,|j|d<|jdk r@|j|d<|jdk rT|j|d<|jdk rh|j|d<|jr|jdk r|j|d<|jdk r|j|d<|jdk r|j|d <t j |j ||jgS|j rt j |j ||j |j gS|j rt j |j ||j gSt j |j |gSdS rNrwrrrrrDrrF)rwrrrrrrDrrFrrrrmrrr5r5r:r=s0                zResult.marshal) NNNNNNNNNNNrr5r5r5r:r@s$  b zrc@sbeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d ZdddZeddZddZddZd S)rzk A WAMP ``REGISTER`` message. Format: ``[REGISTER, Request|id, Options|dict, Procedure|uri]`` @rGrHrIZsinglefirstlastZ roundrobinrandomall)rrgrCinvoke concurrencyforce_reregisterrNc Cst|tkstt|tks t|dks8t|tks8t|dksX|tjtjtjfksXt|dkspt|tkspt|dks|tjtj tj tj tj fkst|dkst|tkr|dkst|dkst|dkst|t kst|rh|D]}t|tkstd|krt|dtkstd|krD|ddksHt|dtksHtd|krbt|dtkstqt|||_||_|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)r@rgr|rArrKrLrM INVOKE_SINGLE INVOKE_FIRST INVOKE_LASTINVOKE_ROUNDROBIN INVOKE_RANDOMrrir ryrrgrCrrrr) rwrrgrCrrrrrr5r5r:rys. (   .  zRegister.__init__c Cst|dkr|dtjkstt|dkr`_. :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@rgr|rrrirJrrAr(r)r ryrrrrnrmrrhrirrjrkrgr rDrrFr)rwrrrrmrrhrirrjrkrgr rDrrFrrr5r5r:ryvsRH$6 .$  zInvocation.__init__cCs6t|dkr|dtjkstt|dkreZdZdZdZdZdZdZd ddZe d d Z d d Z dS)r"z A WAMP ``INTERRUPT`` message. Format: ``[INTERRUPT, INVOCATION.Request|id, Options|dict]`` See: https://wamp-proto.org/static/rfc/draft-oberstet-hybi-crossbar-wamp.html#rfc.section.14.3.4 Ernro)rrprrNcCst|tkst|dks(t|tks(t|dksD||j|jfksDt|dks\t|tks\t|dkstt|tkstt|r|D]t}t|tkstd|krt|dtkstd|kr|ddkst|dtkstd|krt|dtks|tq|t |||_ ||_ ||_ ||_ 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)r@rgr|rArsrrrrir ryrrprr)rwrrprrrr5r5r:rys ( zInterrupt.__init__c Cst|dkr|dtjkstt|dkrs    %               3 ' $0pvPEEf.XBBne9<d%bBhdm