o >hh@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|p t|SN)inspectismethod isfunction)fr5v/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/autobahn/wamp/protocol.pyis_method_or_function;sr7c@s8eZdZdZdZddZedeefddZ e de fdd Z e de fd d Z edeefd d ZedeefddZedeefddZedeefddZedeefddZedeefddZedeefddZedeeeeffddZd$dedeefddZd%d d!Zd"d#ZdS)& BaseSessionzi WAMP session base class. This class implements :class:`autobahn.wamp.interfaces.ISession`. NcCst|_|jgddd|_i|_tjttj t i|_ d|_ d|_ d|_d|_d|_d|_d|_d|_tj|_d|_d|_t|_dS)N)joinleavereadyconnect disconnect) valid_eventsF)txaio make_loggerlogset_valid_events traceback_app_ecls_to_uri_patrINVALID_PAYLOADrPAYLOAD_SIZE_EXCEEDEDr# _uri_to_ecls _transport_realm _session_id_authid _authrole _authmethod _authprovider _authextrarDEFAULT_CLIENT_ROLES_session_roles_session_details_payload_codecr _request_id_genselfr5r5r6__init__Gs*   zBaseSession.__init__returncC|jS)zY Implements :func:`autobahn.wamp.interfaces.ITransportHandler.transport` )rHrUr5r5r6 transportzszBaseSession.transportcCs|jduo |jS)zS Implements :func:`autobahn.wamp.interfaces.ISession.is_connected` N)rHisOpenrUr5r5r6 is_connectedszBaseSession.is_connectedcCs|jduo|S)zR Implements :func:`autobahn.wamp.interfaces.ISession.is_attached` N)rJr\rUr5r5r6 is_attachedszBaseSession.is_attachedcCrY)zV Implements :func:`autobahn.wamp.interfaces.ISession.session_details` )rRrUr5r5r6session_detailszBaseSession.session_detailscCrYr0)rIrUr5r5r6realmzBaseSession.realmcCrYr0)rJrUr5r5r6 session_idrazBaseSession.session_idcCrYr0)rKrUr5r5r6authidrazBaseSession.authidcCrYr0)rLrUr5r5r6authrolerazBaseSession.authrolecCrYr0)rMrUr5r5r6 authmethodrazBaseSession.authmethodcCrYr0)rNrUr5r5r6 authproviderrazBaseSession.authprovidercCrYr0)rOrUr5r5r6 authextrarazBaseSession.authextrarerrorcCsv|durt|dr|j|j|<||j|jd<dStdt|ds7t|tjjg|j|<||j|<dStd)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)hasattrrirDrGr RuntimeErrorPatternURI_TARGET_HANDLER)rVrrhr5r5r6defines   zBaseSession.definec Csd}t|dr t|j}d}t|dr|j}|r#|r||d<nd|i}t|tjr7t|jt kr3|jn|j}n|j |j vrG|j |j dj }nd}d} |j rW|j d|||} | rktj|||| j| j| j| jd} | St|||||} | 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)rjlistrorp isinstancerrtyperhstr __class__rD_urirSencoderErrorrsrtrurv) rV request_typerequestexctbrtrorprhencoded_payloadmsgr5r5r6_message_from_exceptionsF      z#BaseSession._message_from_exceptionc Csrd}d}|jr{|jsd}|j|ttj||jd}n_zt|j|j|j|j }|j d|j |\}|_ |_ Wn&ty]}z|jjd|dttjd||jd}WYd}~n"d}~ww|j |kr{|jjd||j d ttjd ||j |jd}|r|S|j |jvr|j|j }z'|j r|j r||j i|j }n|di|j }n |j r||j }n|}Wntyz |td WnYYnw|s|j r|j rtj|j g|j Ri|j }n!tj|j fi|j }n|j rtj|j g|j R}nt|j }t|d r|j|_t|d r|j|_t|dr#|j|_t|dr-|j|_t|dr7|j|_|S)z Create a user (or generic) exception from a WAMP error message. :param msg: A WAMP error message. :type msg: instance of :class:`autobahn.wamp.message.Error` N5received encoded payload, but no payload codec activertT.failed to decrypt application payload 1: {err}err+failed to decrypt application payload 1: {}zZURI within encrypted payload ('{decrypted_error}') does not match the envelope ('{error}'))decrypted_errorrhFURI within encrypted payload ('{}') does not match the envelope ('{}')zWhile re-constructing exceptionrtcallee callee_authidcallee_authrole forward_forr5)rtrSrAwarnrENC_NO_PAYLOAD_CODECrrsrvrudecoderhrorp ExceptionENC_DECRYPT_ERRORformatENC_TRUSTED_URI_MISMATCHrG onUserErrorr?create_failurerrjrrrr) rVrrenc_errlog_msgrreeclsr5r5r6_exception_from_messages                 z#BaseSession._exception_from_messager0NN)__name__ __module__ __qualname____doc__rArWpropertyrrrZr boolr\r]rr^rzr`intrbrcrdrerfrrrgrrnrrr5r5r5r6r8?s:3  ;r8c@seZdZdZdPdeejfddZedejfddZ e d ee fd d Z e dee fd d Z e defddZe ddZe       dQdedeeedeedeedeeeefdeedeedeefddZe ddZe dd Zd!d"Zd#d$Zd%efd&d'Ze d(d)Ze d*edefd+d,Z e d-e!fd.d/Z"e d0e#j$deefd1d2Z%d3d4Z&e d-e'fd5d6Z(e dRd7eed8eefd9d:Z)e d;d<Z*e d=edee+fd>d?Z,e  dSd@e-e.efd=eedAee/dBeede-e0ee0ff dCdDZ1dEdFZ2e dGede-ee3ffdHdIZ4e   dTdJe-e.efdGeedAee5dKeedBeede-e6ee6ff dLdMZ7dNdOZ8dS)UApplicationSessionz WAMP application session for applications (networking framework agnostic parts). Implements (partially): * :class:`autobahn.wamp.interfaces.ITransportHandler` * :class:`autobahn.wamp.interfaces.ISession` NconfigcCsht||p tjdd|_d|_d|_d|_i|_i|_ i|_ i|_ i|_ i|_ i|_i|_i|_dS)zF Implements :func:`autobahn.wamp.interfaces.ISession` realm1r`FN)r8rWrComponentConfig_config _goodbye_sent_transport_is_closingrS _publish_reqs_subscribe_reqs_unsubscribe_reqs _call_reqs_register_reqs_unregister_reqs_subscriptions_registrations _invocationsrVrr5r5r6rWps  zApplicationSession.__init__rXcCrYr0)rrUr5r5r6rrazApplicationSession.config payload_codeccCs ||_dS)zX Implements :func:`autobahn.wamp.interfaces.ISession.set_payload_codec` NrS)rVrr5r5r6set_payload_codecs z$ApplicationSession.set_payload_codeccCrY)zX Implements :func:`autobahn.wamp.interfaces.ISession.get_payload_codec` rrUr5r5r6get_payload_codecr_z$ApplicationSession.get_payload_codecrZcs`jjdj|d|_d|}t|dfddt|fddfdddS) zV Implements :func:`autobahn.wamp.interfaces.ITransportHandler.onOpen` z{func}(transport={transport}))funcrZr<Nc |dS)NzWhile notifying 'connect'_swallow_errorfailrUr5r6 z+ApplicationSession.onOpen..cs tjSr0)r? as_future onConnect_rUr5r6rrcr)NzWhile calling 'onConnect'rrrUr5r6rr)rAdebugonOpenrHfirer? add_callbacks)rVrZdr5rUr6rs   zApplicationSession.onOpencCs$|jjd|jd||jjdS)zP Implements :func:`autobahn.wamp.interfaces.ISession.onConnect` z{func}()rN)rArrr9rr`rUr5r5r6rszApplicationSession.onConnectr` authmethodsrcrdrg 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) r`rolesrrcrdrgrrrN) rJrrHrIrrHellorQsend) rVr`rrcrdrgrrrrr5r5r6r9s"  zApplicationSession.joincCs|jr |jdSdS)zQ Implements :func:`autobahn.wamp.interfaces.ISession.disconnect` N)rHcloserUr5r5r6r=szApplicationSession.disconnectcCsZt|drt|jtjr|jjd|jj|j ddS|jj d|jj|t |ddS)zR Implements :func:`autobahn.wamp.interfaces.ISession.onUserError` valuez{klass}.onUserError(): "{msg}")klassrz*{klass}.onUserError(): "{msg}" {traceback})rrrqN) rjrxrrrrArr{r error_messagerhr?failure_format_tracebackrVrrr5r5r6rs  zApplicationSession.onUserErrorc CsBz |||WdSty |jjdttdYdSw)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})rN)rrrArhr?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 stjg|Ri|}g}jD]G\}}||vr[t|ddtkrDdd|jD}t|||jsC|d ||t ||j qt|||s[|d ||j t ||j q|ret d |tjg|Ri|IdHS)N __origin__cSg|]}|jqSr5)r).0argr5r5r6 !zFApplicationSession.type_check.._type_check..z'{}' expected types={} got={}z'{}' expected type={} got={}z, )r1 getcallargs__annotations__itemsgetattrr__args__rxappendrryrrr9r?r)rorp argumentsresponsenamekindexpected_typesrr5r6 _type_checks, z2ApplicationSession.type_check.._type_checkr5)rVrrr5rr6 type_checks zApplicationSession.type_checkrc" s jdurttjr(tj}fdd}fdd}t|||dSttjrSt j jtj }fdd}fdd}t|||dSttj r}t jj}tj|}fd d}fd d}t|||dStd jttjrjst}j|d_t j jtj }fd d}fd d}t|||dSttjrjjvrjjD]}|jjp|j} jr;jsjj djddSzt!j"jj#j$} j%d| | \} _&_'Wnt(y,} zjj d| jdWYd} ~ dSd} ~ ww| | kr;j ddSj)rCj)fnt*} j&rQ| t*j&} j'rXj'nt+}j,ryt j-|j.j/j0j1| j2j3jj4d |j,<fdd}fdd}tjj5g| Ri|}t|||qdStdjttj6rj7j8vr݈j89j7}t:|j;rt<|j;rdSt=j.|j>d}t?|j;|dStdj7ttj@r;j7jAvr3jA9j7}t:|j;r t<|j;r dSjjvrgjj<tBj|j|j}jjC|t?|j;|dStdj7ttjDrj7jEvrjE9j7}t:|j;r`t<|j;r`dS|jFjvryj|jFD]}d|_Gqmj|jF=t?|j;ddStdj7ttjHrj7jIvrjIj7}|jJd}jrjsd}j |tKtKjL|}nWzt!j"jj#j$} j%d| \}_&_'Wn$t(y} zjj d | d!tKtKjMd"| }WYd} ~ nd} ~ ww|krjj d#|d$tKtKjNd%|}jOru|jPjQrs|r%R|d&dSj'p+t+}j&p2t*}fd'd}|jPr\|jPjSr\t|jPjQt jTj&jUjVjWj4d(j'}ntj|jPjQg|Ri|}t|d|dSdSjIj7=|j;}t:|rt<|rdS|rtX||dSj's|jPr|jPjSrوj'pi}j&rt jTj&jUjVjWj4d(|}nt jTdAjUjVjWj4d(|}t?||dSj&rtYj&d)krt jTj&}t?||dSt?|j&ddSt?|ddStd*j7ttjZrDj7j[vr$td+j7j\j]vr3td,j\j]j\j^}jJpBjJd}jrjs\d-}j |tKtKjL|}nWzt!j"jj#j$} j%d| \}_&_'Wn$t(y} zjj d.| d!tKtKjMd/| }WYd} ~ nd} ~ ww|krjj d0|d$tKtKjNd1|}|rȈ_tjZj`j7|}j|dS|j)dur|j)f} nt*} j&r| t*j&} j'rj'nt+}|j,rjarfd2d3}nd}t jb|jcjdjej2jd4||j,<tj|j5g| Ri|}fd5d}fd6d}tfj7|j[j7<t|||dSttjgrkj7j[vr]jjhd7j7d8dSj[j7} ti| j;dSttjjrj7jkvrjk9j7}t:|j;rt<|j;rdSj\j]vrtlj\|jJ|j^j]j\<ntd9j\t?|j;dStd:j7ttjmr5j7dkrzj]j\}!Wntnytd;j\wjjhd<|!jJj\d=dSj7jovr-jo9j7}t:|j;rt<|j;rdS|jpj]vr%dj]|jp_Gj]|jp=t?|j;dStd>j7ttjqrd}jrtjsj`krVj7jIvrVjI9j7j;}nwjrtjtj`krnj7j8vrnj89j7j;}n_jrtjuj`krj7jAvrjA9j7j;}nGjrtjvj`krj7jEvrjE9j7j;}n/jrtjwj`krj7jkvrjk9j7j;}njrtjxj`kr͈j7jovr͈jo9j7j;}|rt<|stX|ydSdStd?jrj7td@j)BzY Implements :func:`autobahn.wamp.interfaces.ITransportHandler.onMessage` Ncs<|durjjd|dtdd|}j|dSjr$j_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) r`sessionrcrdrerfrg serializerrZresumedrrr9cr)NzWhile notifying 'join'rrrUr5r6rnrz?ApplicationSession.onMessage..success..cstjjSr0)r?ronJoinrRrrUr5r6rsscr)NzWhile firing onJoinrrrUr5r6ryrcs dS)Nr;rrrUr5r6r~rcr)NzWhile notifying 'ready'rrrUr5r6rr)rArrAbortrrHrr`rIrrJrcrKrdrLrerMrfrNrgrOr _router_rolesr _serializer SERIALIZER_IDtransport_detailsrRrr?r)rreplyrrrVr5r6successAsj       z-ApplicationSession.onMessage..successcs$tdd}j||dS)NrzError calling onWelcome handlerzWhile firing onWelcome)rrrHrr)rrrUr5r6rhs   z+ApplicationSession.onMessage..errorcs8d}fdd}fdd}t||||S)Nr:csSr0r5rrr5r6 return_argzAApplicationSession.onMessage..success..return_argcr)NzWhile firing 'leave' eventrrrUr5r6_error z=ApplicationSession.onMessage..success.._error)rr?r)rrrrdetailsrVrr6rs   crNzWhile firing onLeaverrrUr5r6rrz,ApplicationSession.onMessage.._errorcs^|durtdt|tkr|d}t|tkr"tdt|t|}j |dS)Nz4onChallenge user callback did not return a signatureutf8z"signature must be unicode (was {})) rrybytesrrzrr AuthenticaterHr) signaturerrUr5r6rs    csv|dtdd|j}j|t|j |jt j }fdd}fdd}t ||||S)NzAuthentication failedrrcd|SNr:rrrr5r6rz.error..successcrrrrrUr5r6rrz;ApplicationSession.onMessage..error.._error)rrrrrrHrrrreasonr?ronLeaver)rrrrrrU)rr6rhs   z8Received {0} message, and session is not yet establishedcr rrrrr5r6rrcsdjj}||S)Nz7While firing onLeave for reason "{0}" and message "{1}")rrrrrerrmsgrr5r6rs zjreceived 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})rhrtz-envelope topic URI does not match encoded one) publisherpublisher_authidpublisher_authroletopictransaction_hashretainedrtrcsLjr"jdjr$jrtj}j|dSj ddSdSdS)Nbrokerz}successfully processed event with acknowledged delivery, but could not send ACK, since the transport was lost in the meantime) x_acknowledged_deliveryrx_acknowledged_event_deliveryrHr EventReceived publicationrrAr)rrrr5r6_successs  z.ApplicationSession.onMessage.._successcsdjj}||S)Nz&While firing {0} subscribed under {1}.)rfn subscriptionrr)handlerrrVr5r6rs 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}rTrrrzXURI 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)rrrUr5r6r)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 procedurerrtc s<jj=d}jrNjsd}j|n8zt|tjr)j d|j |j }n j d|g}Wnt yM}zjjd|dWYd}~nd}~ww|r~t|tjrnt jj|j|j|j|j|j|j|j|jd }n3t jj|j|j|j|jd}n#t|tjrt jj|j |j |j|j|j|jd}n t jj|gd}jdurjd jjdSz j|WdSty}z$t jt jjjtj d |j!|j"j|gd}j|WYd}~dSd}~wt#y}z$t jt jjjtj$d |j!|j"j|gd}j|WYd}~dSd}~ww) Nr)Fz,failed to encrypt application payload: {err}r)rsrtrurvrrrrrr)rorprrrrrozCSkipping 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: {})%rrrtrSrArrxrr!r}results kwresultsrrr-rsrurvrrrrrHrrr2rrr~ Invocation MESSAGE_TYPErrErorpr#rF)rrrrr error_reply)rr& registrationrVr5r6r8s      c s jj=t|}z||WnYd}jr!t|}tj j j|j |j }z j |WdStyd}z tjtj j jtjdj|gd}j |WYd}~dSd}~wty}z tjtj j jtjdj|gd}j |WYd}~dSd}~ww)NzLerror return value from invoked procedure "{0}" could not be serialized: {1}r3zSsuccess return value from invoked procedure "{0}" exceeds transport size limit: {1})rrr?failure_messagerrCrrrr6r7rrtrHrrr~rrErr2r#rF)rr formatted_tbrr)rr9rVr5r6rhsD    z7INTERRUPT received for non-pending invocation {request}rz.successcrrrrrUr5r6r-rz*ApplicationSession.onClose.._errorcsjddS)Nr=) was_cleanrr)rVwasCleanr5r6r5scr)NzWhile firing onDisconnectrrrUr5r6r9r) rHrJrrREASON_TRANSPORT_LOSTrr?rrr onDisconnect)rVrtrrrr5)rrVrtr6onCloses    zApplicationSession.onCloserfcCstd)zR Implements :func:`autobahn.wamp.interfaces.ISession.onChallenge` zBreceived authentication challenge, but onChallenge not implemented)rk)rVrfr5r5r6rB=s zApplicationSession.onChallengercCdS)zM Implements :meth:`autobahn.wamp.interfaces.ISession.onJoin` Nr5rVrr5r5r6rHzApplicationSession.onJoinwelcomecCrx)zP Implements :meth:`autobahn.wamp.interfaces.ISession.onWelcome` Nr5)rVr{r5r5r6r?NrzzApplicationSession.onWelcomecstd}|j|j|j|j|j|jg}g}|D] }|| | q|r1|j j dt |d|D],|j jdjjjjdtjsPtj|t|fddfddq3|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})request_on_reply request_idrcsjSr0)rKrr<r5r6rwszBApplicationSession._errback_outstanding_requests..)r?create_future_successrrrrrrextendvaluesclearrAinforVrrKr~r{rrLrUr)rVrr all_requests outstandingrequestsr5r<r6_errback_outstanding_requestsTs8    z0ApplicationSession._errback_outstanding_requestscsX|jtjkrjjd|j|jdt|j|j}|}fdd}t ||||S)zN Implements :meth:`autobahn.wamp.interfaces.ISession.onLeave` z/session closed with reason {reason} [{message}]rrcsjr dSdSr0)rHr=rrUr5r6r=s z.ApplicationSession.onLeave..disconnect) rrREASON_DEFAULTrArrrrr?r)rVrrrr=r5rUr6rzs   zApplicationSession.onLeaverrcCsj|js |jddS|js$|sd}tjj||d}|j|d|_n|jd|jdup2|jj }|S)zL Implements :meth:`autobahn.wamp.interfaces.ISession.leave` z6session is not joined on a realm - no session to leaveNzwamp.close.normalrrTzBsession was already requested to leave - not sending GOODBYE again) rJrArrr rrCrHr is_closed)rVrrrrr5r5r6r:s   zApplicationSession.leavecCst}||dS)zS Implements :meth:`autobahn.wamp.interfaces.ISession.onDisconnect` N)r TransportLostr)rVrr5r5r6rvszApplicationSession.onDisconnectrc Ost|tksJ|dust|ttfvsJ|dus"t|tks"Jtj|d|jj dddd| dd}|rCt |t j sCtd|jsJt|j}d}|jr]|jd|||}|r|rwtj||f|j|j|j|jd|}n+tj|||j|j|j|jd}n|rtj||f||d |}n tj||||d }|r|jdur|j|_|jdur|j|_|jdur|j|_|jdur|j|_|r|j rt!"}t#|||dud |j$|<nd}z |j%|W|Sty} z ||j$vr|j$|=| d} ~ ww) zP Implements :meth:`autobahn.wamp.interfaces.IPublisher.publish` Nz {}.publish()Frstrictallow_empty_components allow_nonerSz,options must be of type a.w.t.PublishOptionsTrrrorpr#)&ryrzrwr+r,rcheck_or_raise_urirr{rrIrxrPublishOptionsrrHrrrTnextrSr}rarsrtrurv message_attrcorrelation_idcorrelation_uricorrelation_is_anchorcorrelation_is_last acknowledger? create_futurer)rr) rVrrorprSr~rrrKrr5r5r6publishs          zApplicationSession.publishr"rS check_typesc s.t|r|dust|dr|rJ|dust|tksJ|dus)t|tjs)Jjs0t fdd}t|rB|d||||Sg}t |j t D]D}|d}d|jvr|jdD]3} | r| } | jpi|} | dur| jtjjkr|tjdd} ntjd d} ||||| | | jq[qKtj|d d S) zS Implements :meth:`autobahn.wamp.interfaces.ISubscriber.subscribe` Nr{c stj|djjddddj}t}|r |}t |||r'|j nd}t ||||j |<|rCtj||fi|}nt||}|ro|jdurT|j|_|jdur]|j|_|jdurf|j|_|jduro|j|_j||S)Nz{}.subscribe()FTr)rrrr{rrTrr?rrr&rFr*rrbrrrrrrHr) rEr rrSrr~rK handler_objrrUr5r6 _subscribes4         z0ApplicationSession.subscribe.._subscriber(riwildcard)matchexactTconsume_exceptions)callablerjryrzrxrr rHrrr1 getmembersr{r7__dict__ is_handlerrrSuri_typerlURI_TYPE_WILDCARDr _check_typesr?gather) rVr"rrSrr on_replieskr&patr|suboptsr5rUr6 subscribe s."     zApplicationSession.subscribecCst|tsJ|js J|j|jvsJ||j|jvsJ|js%t|j|j|d|_t |j|j}|dkr_|j }t }t|||j|j|<t||j}|j||St |S)zU Called from :meth:`autobahn.wamp.protocol.Subscription.unsubscribe` Fr)rxr%rQr=rrHrrremoverVrTrr?rr+rrrcrr)rVr!scountr~rKrr5r5r6 _unsubscribeQs"    zApplicationSession._unsubscriber2c st|tksJ|dust|ttfvsJ|dus"t|tks"Jtj|djj dddd| dd}|rCt |t j sCtdjsJtjd}jriz jd|||}Wn j|r|rtj|f|j|j|j|jd|}n+tj||j|j|j|jd}n|rtj|f||d |}n tj|||d }|r|jdur|j|_|jdur|j|_|j dur|j |_ |j!dur|j!|_!fd d }t"j#|d }t$|||j%<z j&|W|Sj%vrj%=) 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()FrrSz)options must be of type a.w.t.CallOptionsTrrrcst}j|dSr0)rCancelrHr)r cancel_msgr~rVr5r6 cancellers z*ApplicationSession.call..canceller)r)'ryrzrwr+r,rrrr{rrIrxr CallOptionsrrHrrrTrrSr}rAfailurer`rsrtrurvrrrrrr?rr,rr) rVr2rorprSrrrrKr5rr6callss            zApplicationSession.callrWprefixc st|r|dust|dr|rJjstfdd}t|r+|d||||Sg}t|jtD],}|d} d| j vr`| j dD]} | r_| } | j pR|} | ||| | | | jqDq4tj|ddS) zN Implements :meth:`autobahn.wamp.interfaces.ICallee.register` Nr{c stj|djjddddj}t}|r |}t |||r'|j nd}dur4d|}t ||||j |<|rMtj||fi|}nt||}|ry|jdur^|j|_|jdurg|j|_|jdurp|j|_|jdury|j|_j||S)Nz {}.register()FTrz{}{})rrrr{rrTrr?rrr(rFr.rrdrrrrrrHr) rEr r2rSrr~rK endpoint_objrrrVr5r6 _registers8          z.ApplicationSession.register.._registerr(riTr)rrjrHrrr1rr{r7r is_endpointrrSrrr?r) rVrWr2rSrrrrrr&rr|regoptsr5rr6registers"""  zApplicationSession.registercCszt|tsJ|js J|j|jvsJ|jst|j }t }t |||j|j |<t||j}|j||S)zT Called from :meth:`autobahn.wamp.protocol.Registration.unregister` )rxr'rQr=rrHrrrTrr?rr/rrrer)rVr9r~rKrr5r5r6 _unregisters   zApplicationSession._unregisterr0)NNNNNNNr)NNN)NNNN)9rrrrrrrrWrrr rrrrrrrzrrrrrr9r=rrrrrqrwrrBrrrr>r?rrrr:rvr$rrrr r%rrr!rr"r'rrr5r5r5r6res    %  o # &  Z E"h Arc@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. NcC ||Sr0)on_joinryr5r5r6rC z_SessionShim.onJoincCsp|jr2dd|jDd}dd|jDd}|}|j|jjt|j|||ddS|dS)NcSg|] }|jddqS)rcN_argsgetrxr5r5r6rKz*_SessionShim.onConnect..cSr)rdNrrr5r5r6rLr)rrcrdrg) _authenticatorsr_merged_authextrar9rr`rwkeys on_connect)rVrcrdrgr5r5r6rFs  z_SessionShim.onConnectc CsLz|j|j}Wntytd|jtt|jw|||S)NzBReceived challenge for unknown authmethod '{}' [authenticators={}]) rr@r^rkrrzsortedr on_challenge)rVrf authenticatorr5r5r6rB[s  z_SessionShim.onChallengec Csf|jdus |jdur dSz|j|j}Wnty+td|jtt|jw|||j S)NzBReceived onWelcome for unknown authmethod '{}' [authenticators={}]) rerr^rkrrzrr on_welcomerg)rVrrr5r5r6r?gs z_SessionShim.onWelcomecCrr0)on_leaveryr5r5r6rvrz_SessionShim.onLeavecCs|Sr0) on_disconnectrUr5r5r6rvysz_SessionShim.onDisconnectcsttsJjduri_fdd}|d|dj}}|D]\}}||vrB|||krBtd||||q)jj<dS)NcsLtfddtjgD}t|dkr$tdd|dS)Ncs g|] }|jvr|jqSr5)rrarr5r6rs  zG_SessionShim.add_authenticator..at_most_one..r(zInconsistent {}s: {} )setrwrrrV ValueErrorrr9)runirrVrr6 at_most_ones  z3_SessionShim.add_authenticator..at_most_onercrdz4Inconsistent authextra values for '{}': '{}' vs '{}') rxrrrgrrrrr)rVrrrgmergedrvr5rr6add_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. cSrr5)rgrr5r5r6rrz2_SessionShim._merged_authextra..cSs|t|BSr0)rr)ryr5r5r6 extract_keysr'z4_SessionShim._merged_authextra..extract_keyscs,D] }||vr||Sqtd|)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 '{}')rr)rrg) authextrasr5r6first_value_fors z7_SessionShim._merged_authextra..first_value_forcsi|]}||qSr5r5)rr)rr5r6 sz2_SessionShim._merged_authextra..)rrr r)rVr unique_keysr5)rrr6rs   z_SessionShim._merged_authextracCdSr0r5ryr5r5r6rrz_SessionShim.on_joincCs |dSr0)r=ryr5r5r6rrz_SessionShim.on_leavecCs||jjdSr0)r9rr`rUr5r5r6rsz_SessionShim.on_connectcCrr0r5rUr5r5r6rrz_SessionShim.on_disconnect)rrrrrrrrBr?rrvrrrrrrr5r5r5r6r4s  -( rc@s(eZdZdZeZ dddZddZdS)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)rrrrr5r5r6rWsz"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)rVrr5r5r6__call__s z"ApplicationSessionFactory.__call__r0)rrrrrrrWrr5r5r5r6rs   r)Atypingrrrrrrrr?r1 functoolsr autobahnr autobahn.utilr r r autobahn.wamprrrrrautobahn.wamp.exceptionrrrrautobahn.wamp.interfacesrrrrrautobahn.wamp.typesrrrrr r!r"autobahn.exceptionr#autobahn.wamp.requestr$r%r&r'r(r)r*r+r,r-r.r/r7r8rr abc_registerobjectrr5r5r5r6sJ$       $ 8(Y .