U uch@sddlmZmZmZmZmZmZmZddlZddl Z ddl m Z ddl m Z ddlmZmZmZddlmZddlmZddlmZdd lmZdd lmZdd lmZmZmZmZdd lmZmZm Z m!Z!m"Z"dd l#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*ddl+m,Z,ddl-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9ddZ:GdddeZ;eGddde;Ze<Gddde?Z@dS))UnionOptionalDictAnyClassVarListCallableN)reduce)wamp)public IdGeneratorObservableMixin)uri)message)types)role) exception)ApplicationError ProtocolErrorSerializationErrorTypeCheckError)ISession IPayloadCodecIAuthenticator ITransportIMessage) ChallengeSessionDetails CloseDetailsEncodedPayloadSubscribeOptions CallResultRegisterOptions)PayloadExceededError) Publication SubscriptionHandler RegistrationEndpointPublishRequestSubscribeRequestUnsubscribeRequest CallRequestInvocationRequestRegisterRequestUnregisterRequestcCst|pt|SN)inspectismethod isfunction)fr5Y/var/www/html/VPFITNESS/school/venv/lib/python3.8/site-packages/autobahn/wamp/protocol.pyis_method_or_function;sr7c@s6eZdZdZdZddZeeedddZ e e ddd Z e e dd d Z eeedd d ZeeedddZeeedddZeeedddZeeedddZeeedddZeeedddZeeeeefdddZd#eeedddZd$dd Zd!d"ZdS)% BaseSessionzi WAMP session base class. This class implements :class:`autobahn.wamp.interfaces.ISession`. NcCst|_|jdddddgdd|_i|_tjttj t i|_ d|_ d|_ d|_d|_d|_d|_d|_d|_tj|_d|_d|_t|_dS)Njoinleavereadyconnect disconnect)Z valid_eventsF)txaioZ make_loggerlogZset_valid_events traceback_app_ecls_to_uri_patrINVALID_PAYLOADrPAYLOAD_SIZE_EXCEEDEDr# _uri_to_ecls _transport_realm _session_id_authid _authrole _authmethod _authprovider _authextrarZDEFAULT_CLIENT_ROLES_session_roles_session_details_payload_codecr _request_id_genselfr5r5r6__init__Gs8  zBaseSession.__init__returncCs|jS)zY Implements :func:`autobahn.wamp.interfaces.ITransportHandler.transport` )rErQr5r5r6 transportzszBaseSession.transportcCs|jdk o|jS)zS Implements :func:`autobahn.wamp.interfaces.ISession.is_connected` N)rEZisOpenrQr5r5r6 is_connectedszBaseSession.is_connectedcCs|jdk o|S)zR Implements :func:`autobahn.wamp.interfaces.ISession.is_attached` N)rGrWrQr5r5r6 is_attachedszBaseSession.is_attachedcCs|jS)zV Implements :func:`autobahn.wamp.interfaces.ISession.session_details` )rNrQr5r5r6session_detailsszBaseSession.session_detailscCs|jSr0)rFrQr5r5r6realmszBaseSession.realmcCs|jSr0)rGrQr5r5r6 session_idszBaseSession.session_idcCs|jSr0)rHrQr5r5r6authidszBaseSession.authidcCs|jSr0)rIrQr5r5r6authroleszBaseSession.authrolecCs|jSr0)rJrQr5r5r6 authmethodszBaseSession.authmethodcCs|jSr0)rKrQr5r5r6 authproviderszBaseSession.authprovidercCs|jSr0)rLrQr5r5r6 authextraszBaseSession.authextra)rerrorcCsx|dkr>t|dr4|j|j|<||j|jd<qttdn6t|dslt|tjjg|j|<||j|<ntddS)zM Implements :func:`autobahn.wamp.interfaces.ISession.define` N _wampurisrzNcannot define WAMP exception from class with no decoration ("_wampuris" unset)z\cannot define WAMP exception: error URI is explicit, but class is decorated ("_wampuris" set)hasattrrbrArDr RuntimeErrorPatternZURI_TARGET_HANDLER)rRrrar5r5r6defines     zBaseSession.definec Csd}t|drt|j}d}t|dr,|j}|rF|r>||d<nd|i}t|tjrnt|jt krf|jn|j}n$|j |j kr|j |j dj }nd}d} |j r|j d|||} | rtj|||| j| j| j| jd} nt|||||} | S) a Create a WAMP error message from an exception. :param request_type: The request type this WAMP error message is for. :type request_type: int :param request: The request ID this WAMP error message is for. :type request: int :param exc: The exception. :type exc: Instance of :class:`Exception` or subclass thereof. :param tb: Optional traceback. If present, it'll be included with the WAMP error message. :type tb: list or None Nargskwargs tracebackrzwamp.error.runtime_errorFpayloadenc_algoenc_keyenc_serializer)rclistrgrh isinstancerrtyperastr __class__rA_urirOencoderErrorrkrlrmrn) rR request_typerequestexctbrlrgrhraencoded_payloadmsgr5r5r6_message_from_exceptionsD      z#BaseSession._message_from_exceptionc Csrd}d}|jr|js8d}|j|ttj||jd}nz6t|j|j|j|j }|j d|j |\}|_ |_ WnJtk r}z,|jjd|dttjd||jd}W5d}~XYncreate_failurerrcrrrr) rRr|ryenc_errlog_msgr{reZeclsr5r5r6_exception_from_messages               z#BaseSession._exception_from_message)N)NN)__name__ __module__ __qualname____doc__r?rSpropertyrrrVr boolrWrXrrYrrrZintr[r\r]r^r_rrr`rrfr}rr5r5r5r6r8?s83 ;r8c @sVeZdZdZdEeejdddZeejdddZ e ee d d d Z e ee dd d Z e edddZe ddZe dFeeeeeeeeeeeefeeeeeedddZe ddZe ddZddZddZeddd Ze d!d"Ze eed#d$d%Z e e!d&d'd(Z"e e#j$eed)d*d+Z%d,d-Z&e e'd&d.d/Z(e dGeeeed0d1d2Z)e d3d4Z*e eee+d5d6d7Z,e dHe-e.efeeee/eee-e0ee0fd8d9d:Z1d;d<Z2e ee-ee3fd=d>d?Z4e dIe-e.efeeee5eeeee-e6ee6fd@dAdBZ7dCdDZ8dS)JApplicationSessionz WAMP application session for applications (networking framework agnostic parts). Implements (partially): * :class:`autobahn.wamp.interfaces.ITransportHandler` * :class:`autobahn.wamp.interfaces.ISession` N)configcCsht||ptjdd|_d|_d|_d|_i|_i|_ i|_ i|_ i|_ i|_ i|_i|_i|_dS)zF Implements :func:`autobahn.wamp.interfaces.ISession` realm1rZFN)r8rSrComponentConfig_config _goodbye_sentZ_transport_is_closingrO _publish_reqs_subscribe_reqs_unsubscribe_reqs _call_reqs_register_reqs_unregister_reqs_subscriptions_registrations _invocationsrRrr5r5r6rSps zApplicationSession.__init__rTcCs|jSr0)rrQr5r5r6rszApplicationSession.config) payload_codeccCs ||_dS)zX Implements :func:`autobahn.wamp.interfaces.ISession.set_payload_codec` NrO)rRrr5r5r6set_payload_codecsz$ApplicationSession.set_payload_codeccCs|jS)zX Implements :func:`autobahn.wamp.interfaces.ISession.get_payload_codec` rrQr5r5r6get_payload_codecsz$ApplicationSession.get_payload_codec)rVcs`jjdj|d|_d|}t|dfddt|fddfdddS) zV Implements :func:`autobahn.wamp.interfaces.ITransportHandler.onOpen` z{func}(transport={transport}))funcrVr<Ncs |dS)NzWhile notifying 'connect'_swallow_errorfailrQr5r6z+ApplicationSession.onOpen..cs tjSr0)r> as_future onConnect_rQr5r6rrcs |dS)NzWhile calling 'onConnect'rrrQr5r6rr)r?debugonOpenrEfirer> add_callbacks)rRrVdr5rQr6rs   zApplicationSession.onOpencCs$|jjd|jd||jjdS)zP Implements :func:`autobahn.wamp.interfaces.ISession.onConnect` z{func}()rN)r?rrr9rrZrQr5r5r6rszApplicationSession.onConnect)rZ authmethodsr\r]r` resumableresume_session resume_tokenc CsV|jrtd|jstd||_d|_tj||j|||||||d } |j| dS)zK Implements :func:`autobahn.wamp.interfaces.ISession.join` zsession already joinedzno transport set for sessionF) rZrolesrr\r]r`rrrN) rGrrErFrrZHellorMsend) rRrZrr\r]r`rrrr|r5r5r6r9s"  zApplicationSession.joincCs|jr|jdS)zQ Implements :func:`autobahn.wamp.interfaces.ISession.disconnect` N)rEcloserQr5r5r6r=szApplicationSession.disconnectcCsXt|dr6t|jtjr6|jjd|jj|j dn|jj d|jj|t |ddS)zR Implements :func:`autobahn.wamp.interfaces.ISession.onUserError` valuez{klass}.onUserError(): "{msg}")klassr|z*{klass}.onUserError(): "{msg}" {traceback})rr|riN) rcrprrrr?rrsr error_messagerar>failure_format_tracebackrRrr|r5r5r6rszApplicationSession.onUserErrorc CsDz|||Wn.tk r>|jjdttdYnXdS)a This is an internal generic error-handler for errors encountered when calling down to on*() handlers that can reasonably be expected to be overridden in user code. Note that it *cancels* the error, so use with care! Specifically, this should *never* be added to the errback chain for a Deferred/coroutine that will make it out to user code. zInternal error: {tb})rzN)rrr?rar>rrrr5r5r6rs  z!ApplicationSession._swallow_errorcsfdd}|S)z Does parameter type checking and validation against type hints and appropriately tells the user code and the caller (through router). c stjf||}g}jD]\}}||kr t|ddtkrdd|jD}t|||js|d ||t ||j q t|||s |d ||j t ||j q |rt d |tjf||IdHS)N __origin__cSsg|] }|jqSr5)r).0argr5r5r6 !szFApplicationSession.type_check.._type_check..z'{}' expected types={} got={}z'{}' expected type={} got={}z, )r1 getcallargs__annotations__itemsgetattrr__args__rpappendrrqrrr9r>r)rgrh argumentsresponsenamekindZexpected_typesrr5r6 _type_checks& z2ApplicationSession.type_check.._type_checkr5)rRrrr5rr6 type_checks zApplicationSession.type_check)r|c" s jdkr ttjrPtj}fdd}fdd}t|||nttjrt j jtj }fdd}fdd}t|||nbttj rt jj}tj|}fd d}fd d}t|||ntd j nttjrjs4t}j|d_t j jtj }fd d}fd d}t||| n`ttjrXjjkrDjjD]}|jjp|j} jrjsjj djddSz4t!j"jj#j$} j%d| | \} _&_'Wn@t(k rd} z jj d| jdWYdSd} ~ XYnX| | krj ddSj)rj)fnt*} j&r| t*j&} j'rj'nt+}j,rt j-|j.j/j0j1| j2j3jj4d |j,<fdd}fdd}tjj5f| |}t|||qntdj nttj6rֈj7j8krˆj89j7}t:|j;rt<|j;rdSt=j.|j>d}t?|j;|ntdj7 nttj@rj7jAkrpjA9j7}t:|j;r t<|j;r dSjjkr:gjj<tBj|j|j}jjC|t?|j;|ntdj7 nbttjDr$j7jEkrjE9j7}t:|j;rt<|j;rdS|jFjkrj|jFD] }d|_Gqj|jF=t?|j;dntdj7nttjHrj7jIkrjIj7}|jJd}jr0jsd}j |tKtKjL|}nz4t!j"jj#j$} j%d| \}_&_'WnFt(k r} z&jj d | d!tKtKjMd"| }W5d} ~ XYn2X|kr0jj d#|d$tKtKjNd%|}jOr|jPjQr|rVR|d&nj'pbt+}j&ppt*}fd'd}|jPr|jPjSrt|jPjQt jTj&jUjVjWj4d(j'}ntj|jPjQf||}t|d|qjIj7=|j;}t:|rt<|rdS|r,tX||nֈj'sF|jPr|jPjSrj'pPi}j&rt jTj&jUjVjWj4d(|}n"t jTfjUjVjWj4d(|}t?||nRj&rtYj&d)krt jTj&}t?||nt?|j&dn t?|dntd*j7nttjZ rj7j[krHtd+j7 qj\j]krjtd,j\ qj]j\j^}jJpjJd}j rhjsd-}j |tKtKjL|}nz4t!j"jj#j$} j%d| \}_&_'WnFt(k r6} z&jj d.| d!tKtKjMd/| }W5d} ~ XYn2X|k rhjj d0|d$tKtKjNd1|}| r_tjZj`j7|}j|n|j)dk r|j)f} nt*} j& r| t*j&} j' rЈj'nt+}|j, r&ja rfd2d3}nd}t jb|jcjdjej2jd4||j,<tj|j5f| |}fd5d}fd6d}tfj7|j[j7<t|||ndttjg rΈj7j[k rjjhd7j7d8nj[j7} ti| j;nttjj r|j7jkk rhjk9j7}t:|j; rt<|j; rdSj\j]k rHtlj\|jJ|j^j]j\<ntd9j\t?|j;ntd:j7njttjm rjj7dk rzj]j\}!Wn&tnk rtd;j\YnXjjhd<|!jJj\d=nj7jok rVjo9j7}t:|j; r"t<|j; r"dS|jpj]k rHdj]|jp_Gj]|jp=t?|j;ntd>j7n|ttjq rd}jrtjsj`k rj7jIk rjI9j7j;}njrtjtj`k r܈j7j8k r܈j89j7j;}njrtjuj`k r j7jAk r jA9j7j;}njrtjvj`k r<j7jEk r<jE9j7j;}n^jrtjwj`k rlj7jkk rljk9j7j;}n.jrtjxj`k rj7jok rjo9j7j;}| rt<| stX|yntd?jrj7ntd@jdS)AzY Implements :func:`autobahn.wamp.interfaces.ITransportHandler.onMessage` Ncs<|dk r:jjd|dtdd|}j|dSjrHj_j _ j _ j _j_j_j_j_tjj j jjjjjjjjjdddd _dj}t|dfdd t|fd d dt|dfd d t|fd d dt|dfd d dS)Nz"Session denied by onWelcome: {res})reswamp.error.cannot_authenticate{0}F) rZsessionr\r]r^r_r`Z serializerrVZresumedrrr9cs |dS)NzWhile notifying 'join'rrrQr5r6rnrz?ApplicationSession.onMessage..success..cstjjSr0)r>ronJoinrNrrQr5r6rsrcs |dS)NzWhile firing onJoinrrrQr5r6ryrcs dS)Nr;rrrQr5r6r~rcs |dS)NzWhile notifying 'ready'rrrQr5r6rr)r?rrAbortrrErrZrFrrGr\rHr]rIr^rJr_rKr`rLr _router_rolesrZ _serializerZ SERIALIZER_IDZtransport_detailsrNrr>r)rreplyrr|rRr5r6successAsr      z-ApplicationSession.onMessage..successcs$tdd}j||dS)NrzError calling onWelcome handlerzWhile firing onWelcome)rrrErr)rrrQr5r6ras  z+ApplicationSession.onMessage..errorcs8d}fdd}fdd}t||||S)Nr:csSr0r5rrr5r6 return_argszAApplicationSession.onMessage..success..return_argcs |dS)NzWhile firing 'leave' eventrrrQr5r6_errorsz=ApplicationSession.onMessage..success.._error)rr>r)rrrrdetailsrRrr6rs   cs |dSNzWhile firing onLeaverrrQr5r6rsz,ApplicationSession.onMessage.._errorcs^|dkrtdt|tkr&|d}t|tkrDtdt|t|}j |dS)Nz4onChallenge user callback did not return a signatureutf8z"signature must be unicode (was {})) rrqbytesrrrrrZ AuthenticaterEr) signaturerrQr5r6rs    csv|dtdd|j}j|t|j |jt j }fdd}fdd}t ||||S)NzAuthentication failedrrcsd|SNr:rrrr5r6rsz.error..successcs |dSrrrrQr5r6rsz;ApplicationSession.onMessage..error.._error)rrrrrrErrrreasonr>ronLeaver)rrrrrrQrr6ras   z8Received {0} message, and session is not yet establishedcsd|Srrrrr5r6rscsdjj}||S)Nz7While firing onLeave for reason "{0}" and message "{1}")rrrrrerrmsgrr5r6rszjreceived encoded payload with enc_algo={enc_algo}, but no payload codec active - ignoring encoded payload!rFzNfailed to decode application payload encoded with enc_algo={enc_algo}: {error})rarlz-envelope topic URI does not match encoded one) publisherpublisher_authidpublisher_authroletopictransaction_hashretainedrlrcsBjr>jdjr>jr2tj}j|n j ddS)NZbrokerz}successfully processed event with acknowledged delivery, but could not send ACK, since the transport was lost in the meantime) Zx_acknowledged_deliveryrZx_acknowledged_event_deliveryrErZ EventReceived publicationrr?r)rrrr5r6_successs  z.ApplicationSession.onMessage.._successcsdjj}||S)Nz&While firing {0} subscribed under {1}.)rfn subscriptionrr)handlerr|rRr5r6rs z5EVENT received for non-subscribed subscription ID {0} was_encryptedz1PUBLISHED received for non-pending request ID {0}z2SUBSCRIBED received for non-pending request ID {0}rz4UNSUBSCRIBED received for non-pending request ID {0}r~TrrrzXURI within encrypted payload ('{decrypted_proc}') does not match the envelope ('{proc}'))decrypted_procprocrzLcould not deliver progressive call result, because payload decryption failedcs|ddS)NzWhile firing on_progress)rrrQr5r6rs)rrrrz.RESULT received for non-pending request ID {0}z6INVOCATION received for request ID {0} already invokedz:INVOCATION received for non-registered registration ID {0}z.progress)r caller caller_authidcaller_authrole procedurerrlc s:jj=d}jrjs,d}j|nnz:t|tjrRj d|j |j }nj d|g}Wn2t k r}zjjd|dW5d}~XYnX|rt|tjrt jj|j|j|j|j|j|j|j|jd }nt jj|j|j|j|jd}nHt|tjr0t jj|j |j |j|j|j|jd}nt jj|gd}jdkrjjd jjdSzj|Wntk r}z>t jt jjjtj d |j!|j"j|gd}j|W5d}~XYn^t#k r4}z>t jt jjjtj$d |j!|j"j|gd}j|W5d}~XYnXdS) Nr Fz,failed to encrypt application payload: {err}r)rkrlrmrnrrrrrj)rgrhrrrrrgzCSkipping result of "{}", request {} because transport disconnected.zasuccess return value (args={}, kwargs={}) from invoked procedure "{}" could not be serialized: {}zfsuccess return value (args={}, kwargs={}) from invoked procedure "{}" exceeds transport size limit: {})%rrxrlrOr?rrprr!ruresultsZ kwresultsrrrrkrmrnrrrrrErrrrrrv Invocation MESSAGE_TYPErrBrgrhr#rC)rr{rrrZ error_reply)r|r  registrationrRr5r6r8s     c s jj=t|}z||Wn YnXd}jrFt|}tj j j|j |j }zj |Wntk r}z6tjtj j jtjdj|gd}j |W5d}~XYnVtk r}z6tjtj j jtjdj|gd}j |W5d}~XYnXdS)NzLerror return value from invoked procedure "{0}" could not be serialized: {1}rzSsuccess return value from invoked procedure "{0}" exceeds transport size limit: {1})rrxr>Zfailure_messagerr@rr}rrrrrlrErrrvrrBrrr#rC)rrZ formatted_tbrr)r|rrRr5r6ras:   z7INTERRUPT received for non-pending invocation {request}rxzr onWelcomerrrrrrrmethodextra onChallengerrrsGoodbyerrErEventrrrrrlrOr?rrrkrnrmrrgrhrobjr r details_argZ EventDetailsrrrrrrrrZ PublishedrxrpopZ is_futureon_reply is_calledr$rresolveZ Subscribedrr%rZ UnsubscribedrZsubscription_idactiveZResultrrrrrrr optionsZ on_progressrrr!rrrrejectlenrrrrendpointr}rZreceive_progressZ CallDetailsrrrr-Z InterruptrcancelZ Registeredrr'Z UnregisteredKeyErrorrZregistration_idrvrwCallPublish Subscribe UnsubscribeRegister Unregisterr)"rRr|rrrar challengerrrr{Z decoded_topicrZ invoke_argsZ invoke_kwargsrfutureZpublish_requestrrxZ call_requestrrrkwrgZprog_dr&rhrr-r Zinvokedregr5)rrr|r rrRr6 onMessage/sT  F        4                       J'     zApplicationSession.onMessagecsd_jrbtjtjjdjdtj}fdd}fdd}t |||d_tj }fdd}fd d}t |||dS) zW Implements :func:`autobahn.wamp.interfaces.ITransportHandler.onClose` Nz=WAMP transport was lost without closing the session {} beforerrcsd|Srrrrr5r6r(sz+ApplicationSession.onClose..successcs |dSrrrrQr5r6r-sz*ApplicationSession.onClose.._errorcsjddS)Nr=)Z was_cleanrr)rRwasCleanr5r6r5scs |dS)NzWhile firing onDisconnectrrrQr5r6r9s) rErGrrZREASON_TRANSPORT_LOSTrr>rrr onDisconnect)rRr<rrrr5)rrRr<r6onCloses    zApplicationSession.onClose)r6rUcCs tddS)zR Implements :func:`autobahn.wamp.interfaces.ISession.onChallenge` zBreceived authentication challenge, but onChallenge not implementedN)rd)rRr6r5r5r6r =s zApplicationSession.onChallengercCsdS)zM Implements :meth:`autobahn.wamp.interfaces.ISession.onJoin` Nr5rRrr5r5r6rHszApplicationSession.onJoin)welcomerUcCsdS)zP Implements :meth:`autobahn.wamp.interfaces.ISession.onWelcome` Nr5)rRr@r5r5r6rNszApplicationSession.onWelcomecstd}|j|j|j|j|j|jg}g}|D]}|| | q.|rb|j j dt |d|D]X|j jdjjjjdtjstj|t|fddfddqf|S)zB Errback any still outstanding requests with exc. Nz'Cancelling {count} outstanding requests)countzncleaning up outstanding {request_type} request {request_id}, firing errback on user handler {request_on_reply})Zrequest_on_reply request_idrwcsjSr0)r&rrr5r6rwrzBApplicationSession._errback_outstanding_requests..)r>create_future_successrrrrrrextendvaluesclearr?infor,rr&rBrsrr'r+r)rRryrZ all_requestsZ outstandingZrequestsr5rr6_errback_outstanding_requestsTs8    z0ApplicationSession._errback_outstanding_requestscsX|jtjkr"jjd|j|jdt|j|j}|}fdd}t ||||S)zN Implements :meth:`autobahn.wamp.interfaces.ISession.onLeave` z/session closed with reason {reason} [{message}]r;csjrdSr0)rEr=rrQr5r6r=sz.ApplicationSession.onLeave..disconnect) rrZREASON_DEFAULTr?rrrrHr>r)rRrryrr=r5rQr6rzs   zApplicationSession.onLeaver;cCsj|js|jddS|jsH|s$d}tjj||d}|j|d|_n |jd|jdkpd|jj }|S)zL Implements :meth:`autobahn.wamp.interfaces.ISession.leave` z6session is not joined on a realm - no session to leaveNzwamp.close.normalr;TzBsession was already requested to leave - not sending GOODBYE again) rGr?rrr rr!rEr is_closed)rRrrr|rIr5r5r6r:s   zApplicationSession.leavecCst}||dS)zS Implements :meth:`autobahn.wamp.interfaces.ISession.onDisconnect` N)r TransportLostrH)rRryr5r5r6r=szApplicationSession.onDisconnect)rrUc Os$t|tkst|dks,t|ttfks,t|dksDt|tksDttj|d|j j dddd| dd}|rt |t jstd|jst|j}d}|jr|jd|||}|r|rtj||f|j|j|j|jd|}ntj|||j|j|j|jd}n8|r6tj||f||d |}ntj||||d }|r|jdk rb|j|_|jdk rv|j|_|jdk r|j|_|j dk r|j |_ |r|j!rt"#}t$|||dk d |j%|<nd}z|j&|Wn<tk r} z||j%kr |j%|=| W5d} ~ XYnX|S) zP Implements :meth:`autobahn.wamp.interfaces.IPublisher.publish` Nz {}.publish()FrstrictZallow_empty_componentsZ allow_noner*z,options must be of type a.w.t.PublishOptionsTrjrgrhr)'rqrrrror rrcheck_or_raise_urirrsrr%rprZPublishOptionsrrErrJrPnextrOrur1rkrlrmrn message_attrcorrelation_idcorrelation_uricorrelation_is_anchorcorrelation_is_lastZ acknowledger> create_futurer)rr) rRrrgrhr*rBr{r|r&rr5r5r6publishs         zApplicationSession.publish)rrr* check_typesrUc s6t|r|dk s"t|dr|r"t|dks:t|tks:t|dksRt|tjsRtjs`t fdd}t|r|d||||Sg}t |j tD]}|d}d|jkr|jdD]j} | r| } | jp|} | dkr| jtjjkrtjdd} n tjd d} ||||| | | jqqtj|d d SdS) zS Implements :meth:`autobahn.wamp.interfaces.ISubscriber.subscribe` Nrsc stj|djjddddj}t}|r> |}t |||rN|j nd}t ||||j |<|rtj||f|}n t||}|r|jdk r|j|_|jdk r|j|_|jdk r|j|_|jdk r|j|_j||S)Nz{}.subscribe()FTrK)rrNrrsrrPrOr>rUrr&r$r*rr2rPrQrRrSrTrEr) r#rrr*rWrBr&Z handler_objr|rQr5r6 _subscribes4         z0ApplicationSession.subscribe.._subscriber rbZwildcard)matchexactTZconsume_exceptions)callablercrrqrrrprr rErrJr1 getmembersrsr7__dict__Z is_handlerrr*Zuri_typereZURI_TYPE_WILDCARDr _check_typesr>gather) rRrrr*rWrX on_replieskr patrtZsuboptsr5rQr6 subscribe s,"     zApplicationSession.subscribecCst|tst|jst|j|jks(t||j|jksrUr+rrr3rrC)rRrZscountrBr&r|r5r5r6 _unsubscribeQs"   zApplicationSession._unsubscribe)rrUc s$t|tkst|dks,t|ttfks,t|dksDt|tksDttj|dj j dddd| dd}|rt |t jstdjstjd}jrzjd|||}WnjYnX|r0|rtj|f|j|j|j|jd|}ntj||j|j|j|jd}n8|rVtj|f||d |}ntj|||d }|r|jdk r|j|_|j dk r|j |_ |j!dk r|j!|_!|j"dk r|j"|_"fd d }t#j$|d }t%|||j&<zj'|Wn"j&krj&=YnX|S) a{ Implements :meth:`autobahn.wamp.interfaces.ICaller.call` .. note:: Regarding type hints for ``*args`` and ``**kwargs``, doesn't work as we can receive any Python types as list items or dict values, and because of what is discussed here https://adamj.eu/tech/2021/05/11/python-type-hints-args-and-kwargs/ Nz {}.call()FrKr*z)options must be of type a.w.t.CallOptionsTrjrMcst}j|dSr0)rZCancelrEr)rZ cancel_msgrBrRr5r6 cancellers z*ApplicationSession.call..canceller)rh)(rqrrrror rrrNrrsrr%rprZ CallOptionsrrErrJrPrOrOrur?Zfailurer0rkrlrmrnrPrQrRrSrTr>rUr,rr) rRrrgrhr*r{r|rhr&r5rgr6callss            zApplicationSession.call)r-rr*prefixrWrUc st|r|dk s"t|dr|r"tjs0tfdd}t|rV|d||||Sg}t|jt D]X}|d} d| j krh| j dD]6} | r| } | j p|} |||| | | | jqqhtj|ddSdS) zN Implements :meth:`autobahn.wamp.interfaces.ICallee.register` Nrsc stj|djjddddj}t}|r> |}t |||rN|j nd}dk rhd|}t ||||j |<|rtj||f|}n t||}|r|jdk r|j|_|jdk r|j|_|jdk r|j|_|jdk r|j|_j||S)Nz {}.register()FTrKz{}{})rrNrrsrrPrOr>rUrr(r$r.rr4rPrQrRrSrTrEr) r#rrr*rWrBr&Z endpoint_objr|rjrRr5r6 _registers8          z.ApplicationSession.register.._registerr rbTr[)r\rcrrErrJr1r]rsr7r^Z is_endpointrr*rr_r>r`) rRr-rr*rjrWrlrarbr rcrtZregoptsr5rkr6registers ""  zApplicationSession.registercCszt|tst|jst|j|jks(t|js6t|j }t }t |||j|j|<t||j}|j||S)zT Called from :meth:`autobahn.wamp.protocol.Registration.unregister` )rpr'rr)rrrErrJrPrOr>rUr/rrr5r)rRrrBr&r|r5r5r6 _unregisters   zApplicationSession._unregister)N)NNNNNNN)NN)NNN)NNNN)9rrrrrrrrSrrr rrrrrrrrrrrrrr9r=rrrrr:r>rr rrrrrrHrrr:r=r$rVrrr r%rdrfr!rir"r'rmrnr5r5r5r6res   %  o # & ZE"hArc@steZdZdZdZddZddZddZd d Zd d Z d dZ ddZ ddZ ddZ ddZddZddZdS) _SessionShimar shim that lets us present pep8 API for user-classes to override, but also backwards-compatible for existing code using ApplicationSession "directly". **NOTE:** this is not public or intended for use; you should import either autobahn.asyncio.wamp.Session or autobahn.twisted.wamp.Session depending on which async framework yo're using. NcCs ||Sr0)on_joinr?r5r5r6rCsz_SessionShim.onJoincCsn|jrbdd|jDd}dd|jDd}|}|j|jjt|j|||dn|dS)NcSsg|]}|jddqS)r\N_argsgetrxr5r5r6rKsz*_SessionShim.onConnect..cSsg|]}|jddqS)r]Nrqrtr5r5r6rLs)rr\r]r`) _authenticatorsrE_merged_authextrar9rrZrokeys on_connect)rRr\r]r`r5r5r6rFs z_SessionShim.onConnectc CsRz|j|j}Wn4tk rDtd|jtt|jYnX|||S)NzBReceived challenge for unknown authmethod '{}' [authenticators={}]) rwrr/rdrrrsortedryZ on_challenge)rRr6 authenticatorr5r5r6r [s z_SessionShim.onChallengec Csl|jdks|jdkrdSz|j|j}Wn4tk r\td|jtt|jYnX|||j S)NzBReceived onWelcome for unknown authmethod '{}' [authenticators={}]) r^rwr/rdrrrr{ryZ on_welcomer`)rRr|r|r5r5r6rgs z_SessionShim.onWelcomecCs ||Sr0)on_leaver?r5r5r6rvsz_SessionShim.onLeavecCs|Sr0) on_disconnectrQr5r5r6r=ysz_SessionShim.onDisconnectcsttstjdkri_fdd}|d|dj}}|D]2\}}||krR|||krRtd||||qRjj <dS)NcsLtfddtjgD}t|dkrHtdd|dS)Ncs g|]}|jkr|jqSr5)rrrarr5r6rs zG_SessionShim.add_authenticator..at_most_one..r zInconsistent {}s: {} )setrorwrEr, ValueErrorrr9)runir|rRrr6 at_most_ones  z3_SessionShim.add_authenticator..at_most_oner\r]z4Inconsistent authextra values for '{}': '{}' vs '{}') rprrrwr`rxrrrr)rRr|rr`Zmergedrbvr5rr6add_authenticator~s$ z_SessionShim.add_authenticatorcsHdd|jDdd}t|t}fddfdd|DS) a: internal helper :returns: a single 'authextra' dict, consisting of all keys from any authenticator's authextra. Note that when the authenticator was added, we already checked that any keys it does contain has the same value as any existing authextra. cSsg|] }|jqSr5)r`rr5r5r6rsz2_SessionShim._merged_authextra..cSs|t|BSr0)rry)ruyr5r5r6 extract_keyssz4_SessionShim._merged_authextra..extract_keyscs0D]}||kr||Sqtd|dS)z for anything already in self._authenticators, we checked that it has the same value for any keys in its authextra -- so here we just extract the first one zNo values for '{}'N)rr)rbr`) authextrasr5r6first_value_fors z7_SessionShim._merged_authextra..first_value_forcsi|]}||qSr5r5)rrb)rr5r6 sz2_SessionShim._merged_authextra..)rwrEr r)rRrZ unique_keysr5)rrr6rxs   z_SessionShim._merged_authextracCsdSr0r5r?r5r5r6rpsz_SessionShim.on_joincCs |dSr0)r=r?r5r5r6r}sz_SessionShim.on_leavecCs||jjdSr0)r9rrZrQr5r5r6rzsz_SessionShim.on_connectcCsdSr0r5rQr5r5r6r~sz_SessionShim.on_disconnect)rrrrrwrrr rrr=rrxrpr}rzr~r5r5r5r6ro4s  -(roc@s&eZdZdZeZdddZddZdS)ApplicationSessionFactoryz( WAMP endpoint session factory. NcCs|ptjdd|_dS)z :param config: The default component configuration. :type config: instance of :class:`autobahn.wamp.types.ComponentConfig` rrN)rrrrr5r5r6rSsz"ApplicationSessionFactory.__init__cCs||j}||_|S)z Creates a new WAMP application session. :returns: -- An instance of the WAMP application session class as given by `self.session`. )rrfactory)rRrr5r5r6__call__s z"ApplicationSessionFactory.__call__)N)rrrrrrrSrr5r5r5r6rs r)Atypingrrrrrrrr>r1 functoolsr autobahnr Z autobahn.utilr r r Z autobahn.wamprrrrrZautobahn.wamp.exceptionrrrrZautobahn.wamp.interfacesrrrrrZautobahn.wamp.typesrrrrr r!r"Zautobahn.exceptionr#Zautobahn.wamp.requestr$r%r&r'r(r)r*r+r,r-r.r/r7r8rroZ abc_registerobjectrr5r5r5r6sH$       $ 8(Y.