o @Bi`N@s`ddlmZddlZddlZddlZddlmZddlmZddl m Z m Z m Z ddl mZddl mZddl mZdd l mZdd l mZdd lmZmZmZmZdd lmZmZmZdd lmZmZmZddl m!Z!ddl"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.ddZ/Gddde Z0e Gddde0Z1Gddde1Z2Gddde3Z4dS))absolute_importN)reduce)wamp)public IdGeneratorObservableMixin)uri)message)types)role) exception)ApplicationError ProtocolErrorSessionNotReadySerializationError)ISession IPayloadCodecIAuthenticator)SessionDetails CloseDetailsEncodedPayload)PayloadExceededError) Publication SubscriptionHandler RegistrationEndpointPublishRequestSubscribeRequestUnsubscribeRequest CallRequestInvocationRequestRegisterRequestUnregisterRequestcCst|p t|SN)inspectismethod isfunction)fr)V/var/www/html/Trade-python/venv/lib/python3.10/site-packages/autobahn/wamp/protocol.pyis_method_or_function<sr+c@seZdZdZdZddZeddZeddZed d Z ed d Z ed dZ eddZ dddZ dddZddZdS) BaseSessionzi WAMP session base class. This class implements :class:`autobahn.wamp.interfaces.ISession`. NcCsnt|_|jgddd|_i|_tjttj t i|_ d|_ d|_ d|_d|_d|_d|_d|_t|_dS)z )joinleavereadyconnect disconnect) valid_eventsFN)txaio make_loggerlogset_valid_events traceback_app_ecls_to_uri_patr INVALID_PAYLOADrPAYLOAD_SIZE_EXCEEDEDr _uri_to_ecls_realm _session_id_authid _authrole _authmethod _authprovider_payload_codecr_request_id_genselfr)r)r*__init__Hs"   zBaseSession.__init__cC|jSr$)r<rDr)r)r*realmtzBaseSession.realmcCrGr$)r=rDr)r)r* session_idxrIzBaseSession.session_idcCrGr$)r>rDr)r)r*authid|rIzBaseSession.authidcCrGr$)r?rDr)r)r*authrolerIzBaseSession.authrolecCrGr$)r@rDr)r)r* authmethodrIzBaseSession.authmethodcCrGr$)rArDr)r)r* authproviderrIzBaseSession.authprovidercCsz|durt|ds J|j|j|<||j|jd<dSt|dr$Jtt|tjjg|j|<||jt|<dS)zM Implements :func:`autobahn.wamp.interfaces.ISession.define` N _wampurisr) hasattrrOr8r;rPatternsixuURI_TARGET_HANDLER)rEr errorr)r)r*defines zBaseSession.definec Csd}t|dr t|j}d}t|dr|j}|r$tjr$dd|D}|r1|r-||d<nd|i}t|tj rIt |j tj krB|j nt |j }n|j|jvrY|j|jdj}nd}d} |jri|jd |||} | r}tj|||| 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 NargskwargscSi|] \}}|d|qSutf8decode.0kvr)r)r*  z7BaseSession._message_from_exception.. tracebackrzwamp.error.runtime_errorFpayloadenc_algoenc_keyenc_serializer)rPlistrWrXrRPY2 iteritems isinstancer r typerU text_typerS __class__r8_urirBencoder Errorrfrgrhri) rE request_typerequestexctbrgrWrXrUencoded_payloadmsgr)r)r*_message_from_exceptionsN      $ 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 activergT.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_errorrUFURI within encrypted payload ('{}') does not match the envelope ('{}')zWhile re-constructing exceptionrgcallee callee_authidcallee_authrole forward_forr))rgrBr5warnr ENC_NO_PAYLOAD_CODECrrfrirhr]rUrWrX ExceptionENC_DECRYPT_ERRORformatENC_TRUSTED_URI_MISMATCHr; onUserErrorr3create_failurer rPrrrr) rEryrvenc_errlog_msgrxreeclsr)r)r*_exception_from_messages                 z#BaseSession._exception_from_messager$NN)__name__ __module__ __qualname____doc__r5rFpropertyrHrJrKrLrMrNrVrzrr)r)r)r*r,@s&,        Ar,c@sHeZdZdZd7ddZeddZeddZed d Zed d Z e       d8d dZ eddZ eddZ eddZ eddZddZddZeddZeddZedd Zed!d"Zd#d$Zed%d&Zed9d'd(Zed)d*Zed+d,Zed9d-d.Zd/d0Zed1d2Zed:d3d4Zd5d6ZdS);ApplicationSessionz WAMP endpoint session. NcCs|t||p tjdd|_tj|_d|_d|_ d|_ d|_ d|_ i|_ i|_i|_i|_i|_i|_i|_i|_i|_dS)zF Implements :func:`autobahn.wamp.interfaces.ISession` realm1rHNF)r,rFr ComponentConfigconfigr DEFAULT_CLIENT_ROLES_session_roles _transportr=r< _goodbye_sent_transport_is_closing _publish_reqs_subscribe_reqs_unsubscribe_reqs _call_reqs_register_reqs_unregister_reqs_subscriptions_registrations _invocationsrErr)r)r*rFEs"  zApplicationSession.__init__cCs |dus t|ts J||_dS)zX Implements :func:`autobahn.wamp.interfaces.ISession.set_payload_codec` N)rmrrB)rE payload_codecr)r)r*set_payload_codecgs z$ApplicationSession.set_payload_codeccCrG)zX Implements :func:`autobahn.wamp.interfaces.ISession.get_payload_codec` )rBrDr)r)r*get_payload_codecosz$ApplicationSession.get_payload_codeccsL|_d|}t|dfddt|fddfdddS)zV Implements :func:`autobahn.wamp.interfaces.ITransportHandler.onOpen` r0Nc |dS)NzWhile notifying 'connect'_swallow_errorfailrDr)r* z+ApplicationSession.onOpen..cs tjSr$)r3 as_future onConnect_rDr)r*rrcr)NzWhile calling 'onConnect'rrrDr)r*rr)rfirer3 add_callbacks)rE transportdr)rDr*onOpenvs   zApplicationSession.onOpencCs||jjdS)zP Implements :func:`autobahn.wamp.interfaces.ISession.onConnect` Nr-rrHrDr)r)r*rszApplicationSession.onConnectc Cs|dus t|tjks J|dust|tksJt|tkr-|D] } t| tjks,Jq!|dus:t|tjks:J|dusGt|tjksGJ|dusSt|tksSJ|jrZtd||_d|_t j ||j |||||||d } |j | dS)zK Implements :func:`autobahn.wamp.interfaces.ISession.join` Nzalready joinedF) rHroles authmethodsrKrL authextra resumableresume_session resume_token)rnrRrorjdictr=rr<rr Hellorrsend) rErHrrKrLrrrrrMryr)r)r*r-s.   zApplicationSession.joincCs|jr |jdSdS)zQ Implements :func:`autobahn.wamp.interfaces.ISession.disconnect` N)rcloserDr)r)r*r1szApplicationSession.disconnectcCs |jduS)zS Implements :func:`autobahn.wamp.interfaces.ISession.is_connected` N)rrDr)r)r* is_connecteds zApplicationSession.is_connectedcCs|jduo |jduS)zR Implements :func:`autobahn.wamp.interfaces.ISession.is_attached` N)rr=rDr)r)r* is_attachedszApplicationSession.is_attachedcCsPt|jtjr|jjd|jj|jddS|jj d|jj|t |ddS)zR Implements :func:`autobahn.wamp.interfaces.ISession.onUserError` z{klass}.onUserError(): "{msg}")klassryz*{klass}.onUserError(): "{msg}" {traceback})rryrdN) rmvaluer r r5rrpr error_messagerUr3failure_format_tracebackrErryr)r)r*rs  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})rwN)rrr5rUr3rrrr)r)r*rs   z!ApplicationSession._swallow_errorc" 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,rwt j-|j.j/j0j1| j2jj3d |j,<fdd}fdd}tjj4g| Ri|}t|||qdStdjttj5rӈj6j7vrˈj78j6}t9j.|j:d}t;|j<|dStdj6ttj=rj6j>vrj>8j6}jjvrgjj<t?j|j|j}jj@|t;|j<|dStdj6ttjArXj6jBvrPjB8j6}|jCjvrGj|jCD]}d|_Dq;j|jC=t;|jj6ttjord}jptjqj]krj6jFvrjF8j6j<}nwjptjrj]kr j6j7vr j78j6j<}n_jptjsj]kr$j6j>vr$j>8j6j<}nGjptjtj]kr<j6jBvr<jB8j6j<}n/jptjuj]krTj6jhvrTjh8j6j<}njptjvj]krkj6jmvrkjm8j6j<}|rtw|stU|xdSdStd?jpj6td@j)BzY Implements :func:`autobahn.wamp.interfaces.ITransportHandler.onMessage` Nc s.|durjdtdd|}j|dSjr"j_j _ j _ j _j_j_j_tjj j jjjjjjjjjjd d}t|dfddt|fdddt|dfd dt|fd ddt|dfd ddS) NzSession denied by onWelcomewamp.error.cannot_authenticate{0}) rHsessionrKrLrMrNr serializerresumedrrr-cr)NzWhile notifying 'join'rrrDr)r*r1rz?ApplicationSession.onMessage..success..cstjSr$)r3ronJoinrdetailsrEr)r*r6scr)NzWhile firing onJoinrrrDr)r*r<rcs dS)Nr/rrrDr)r*rArcr)NzWhile notifying 'ready'rrrDr)r*rGr)r5infor AbortrrrrHr<rr=rKr>rLr?rMr@rNrAr _router_rolesrr _serializer SERIALIZER_IDrrrrr3r)resreplyrryrErr*successsf        z-ApplicationSession.onMessage..successcs$tdd}j||dS)NrzError calling onWelcome handlerzWhile firing onWelcome)r rrrr)rrrDr)r*rUJs   z+ApplicationSession.onMessage..errorcs8d}fdd}fdd}t||||S)Nr.csSr$r)rargr)r* return_arg[zAApplicationSession.onMessage..success..return_argcr)NzWhile firing 'leave' eventrrrDr)r*_error^ z=ApplicationSession.onMessage..success.._error)rr3r)rrrrrrr*rWs   crNzWhile firing onLeaverrrDr)r*rcrz,ApplicationSession.onMessage.._errorcsb|durtdt|tjkr|d}t|tjkr$tdt|t|}j |dS)Nz4onChallenge user callback did not return a signaturer[z"signature must be unicode (was {})) rrnrR binary_typer]rorr Authenticaterr) signaturerrDr)r*rls  csv|dtdd|j}j|t|j |jt j }fdd}fdd}t ||||S)NzAuthentication failedrrcd|SNr.rrrr)r*r~z.error..successcrrrrrDr)r*rrz;ApplicationSession.onMessage..error.._error)rr rrrrrr rreasonr3ronLeaver)rrrrrrDrr*rUvs   z8Received {0} message, and session is not yet establishedcrrrrrr)r*rrcsdjj}||S)Nz7While firing onLeave for reason "{0}" and message "{1}")rrr rrerrmsgrr)r*rs zjreceived encoded payload with enc_algo={enc_algo}, but no payload codec active - ignoring encoded payload!r|FzNfailed to decode application payload encoded with enc_algo={enc_algo}: {error})rUrgz-envelope topic URI does not match encoded one) publisherpublisher_authidpublisher_authroletopicretainedrgrcsLjr"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_deliveryrr EventReceived publicationrr5r)rresponserr)r*_successs  z.ApplicationSession.onMessage.._successcsdjj}||S)Nz&While firing {0} subscribed under {1}.)rfn subscriptionrr)handlerryrEr)r*rs 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{Tr}r~rzXURI 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)rrrDr)r*rG)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..7trying to send encrypted payload, but no keyring activeFT)rfprogressrgrhri)rWrXr)rnrjtuplerrRrkrlrgrBrrrr Yieldrurfrhrirr)rWrXrx progress_msg)ryr rEr)r*rs2 z.ApplicationSession.onMessage..progress)rcaller caller_authidcaller_authrole procedurergc 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|gd}j|WYd}~dSd}~wt!y}z t jt jjjtj"d j|gd}j|WYd}~dSd}~ww) Nr Fz,failed to encrypt application payload: {err}r~)rfrgrhrirrrrre)rWrXrrrrrWzCSkipping result of "{}", request {} because transport disconnected.zNsuccess return value from invoked procedure "{0}" could not be serialized: {1}Ssuccess return value from invoked procedure "{0}" exceeds transport size limit: {1})#rrurgrBr5rrmr CallResultrrresults kwresultsrr rrfrhrirrrrrdebugrrrrrs Invocation MESSAGE_TYPEr r9rr:)rrxrrr)ryr  registrationrEr)r*rs      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}rr)rrur3failure_messagerr7rrzr rrrrgrrrrsr r9rrrr:)rr formatted_tbrr)ryrrEr)r*rU8sD    z7INTERRUPT received for non-pending invocation {request}ruz.successcrrrrrDr)r*rrz*ApplicationSession.onClose.._errorcsjddS)Nr1) was_cleanrr)rEwasCleanr)r*rscr)NzWhile firing onDisconnectrrrDr)r*rr) rr=r rREASON_TRANSPORT_LOSTrr3rrr onDisconnect)rErZrrrr))rrErZr*onCloses    zApplicationSession.onClosecCstd)zR Implements :func:`autobahn.wamp.interfaces.ISession.onChallenge` zBreceived authentication challenge, but onChallenge not implemented)r)rErLr)r)r*r(szApplicationSession.onChallengecCdS)zM Implements :func:`autobahn.wamp.interfaces.ISession.onJoin` Nr)rErr)r)r*rzApplicationSession.onJoincCr^)zP Implements :func:`autobahn.wamp.interfaces.ISession.onWelcome` Nr))rEryr)r)r*r$r`zApplicationSession.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_idrtcsjSr$)r1rr!r)r*r#szBApplicationSession._errback_outstanding_requests..)r3create_future_successrrrrrrextendvaluesclearr5rr;rr1rcrprrKr:r)rErvr all_requests outstandingrequestsr)r!r*_errback_outstanding_requestss8    z0ApplicationSession._errback_outstanding_requestscsX|jtjkrjjd|j|jdt|j|j}|}fdd}t ||||S)zN Implements :func:`autobahn.wamp.interfaces.ISession.onLeave` z/session closed with reason {reason} [{message}]rXcsjr dSdSr$)rr1rrDr)r*r12s z.ApplicationSession.onLeave..disconnect) rrREASON_DEFAULTr5rr r rkr3r)rErrvrr1r)rDr*r&s   zApplicationSession.onLeavecCsb|jstd|js |sd}tjj||d}|j|d|_n|j d|jdup.|jj }|S)zL Implements :func:`autobahn.wamp.interfaces.ISession.leave` zsession hasn't joined a realmzwamp.close.normalrXTzBsession was already requested to leave - not sending GOODBYE againN) r=rrrr r)rrr5r is_closed)rErr ryrmr)r)r*r.8s  zApplicationSession.leavecCst}||dS)zS Implements :func:`autobahn.wamp.interfaces.ISession.onDisconnect` N)r TransportLostrk)rErvr)r)r*r\MszApplicationSession.onDisconnectc Os$t|tjks J|dust|ttfvsJ|dus#t|tks#Jtj|d|j j dddd| dd}|rDt |t jsDtd|rRtjrRdd|D}|jsYt|j}d}|jrl|jd |||}|r|rtj||f|j|j|j|jd |}n+tj|||j|j|j|jd }n|rtj||f||d |}n tj||||d }|r|jdur|j|_|j dur|j |_ |j!dur|j!|_!|j"dur|j"|_"|r|j#rt$%}t&|||dud |j'|<nd}z |j(|W|Sty} z ||j'vr |j'|=| d} ~ ww) zP Implements :func:`autobahn.wamp.interfaces.IPublisher.publish` Nz {}.publish()Fr strictallow_empty_components allow_noner8z,options must be of type a.w.t.PublishOptionscSrYrZr\r^r)r)r*rblrcz.ApplicationSession.publish..TrerWrXr))rnrRrorjrrr check_or_raise_urirrprr/rmr PublishOptionsrrkrlrr rnrCnextrBrrrFrfrgrhri message_attrcorrelation_idcorrelation_uricorrelation_is_anchorcorrelation_is_last acknowledger3 create_futurerrr) rErrWrXr8rcrxryr1rr)r)r*publishXs           zApplicationSession.publishc s&t|r|dust|dsJ|dust|tjksJ|dus(t|tjs(Jjs/t fdd}t|r@|d|||Sg}t |j tD]B}|d}d|jvr|jdD]1}|r|} |jpg|} | dur|jtjjkrztjdd} ntjd d} ||||| | qYqItj|d d S) zS Implements :func:`autobahn.wamp.interfaces.ISubscriber.subscribe` Nrpcstj|djjddddj}t}t |||r |j nd}t ||||j |<|r._subscriber rOwildcard)matchexactTconsume_exceptions)callablerPrnrRrormr SubscribeOptionsrr rnr% getmembersrpr+__dict__ is_handlerrr8uri_typerQURI_TYPE_WILDCARDr3r3gather) rErrr8r on_repliesr`r patrqsuboptsr)rDr* subscribes.    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)rmrr6r"rrr rnremover;rCrvr3r}rrr rHrrd)rErscountrcr1ryr)r)r* _unsubscribes"    zApplicationSession._unsubscribec s$t|tjks J|dust|ttfvsJ|dus#t|tks#Jtj|dj j dddd| dd}|rDt |t jsDtd|rRtjrRdd|D}jsYtjd}jrxz jd |||}Wn j|r|rtj|f|j|j|j|jd | }n+tj||j|j|j|jd }n|rtj|f||d | }n tj|||d }|r|j!dur|j!|_!|j"dur|j"|_"|j#dur|j#|_#|j$dur|j$|_$fd d }t%j&|d}t'|||j(<z j)|W|Sj(vrj(=)zJ Implements :func:`autobahn.wamp.interfaces.ICaller.call` Nz {}.call()Fror8z)options must be of type a.w.t.CallOptionscSrYrZr\r^r)r)r*rb2rcz+ApplicationSession.call..Trerscst}j|dSr$)r Cancelrr)r cancel_msgrcrEr)r* cancellerks z*ApplicationSession.call..canceller)r)*rnrRrorjrrr rtrrprr/rmr CallOptionsrrkrlrr rnrCrvrBrrr5failurerErfrgrhrirwrxryrzr{r3r}r rr) rErrWrXr8rxryrr1r)rr*calls            zApplicationSession.callc st|r|dust|dsJ|dust|tjksJ|dus(t|tjs(Jdus4ttjs4Jjs;t fdd}t|rM|d|||Sg}t |j tD]*}|d}d|jvr|jdD]} | r| } | jpt|} ||||| | qfqVtj|ddS) zN Implements :func:`autobahn.wamp.interfaces.ICallee.register` Nrpcstj|djjddddj}t}t |||r |j nd}dur-d|}t ||||j |<|rFtj ||fi|}nt ||}|rr|jdurW|j|_|jdur`|j|_|jduri|j|_|jdurr|j|_j||S)Nz {}.register()FTroz{}{})r rtrrprrCrvr3r}rr,r"rrIrwrxryrzr{rr)r+rrr8rcr1 endpoint_objryprefixrEr)r* _registers4         z.ApplicationSession.register.._registerr rOTr)rrPrnrRrormr RegisterOptionsrr rnr%rrpr+r is_endpointrr8r3r3r) rEr<rr8rrrr`r rrqregoptsr)rr*registers(   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` )rmrr6r"rrr rnrCrvr3r}r#rr rJr)rErrcr1ryr)r)r* _unregisters   zApplicationSession._unregisterr$)NNNNNNNr)NNN)rrrrrFrrrrrr-r1rrrrrWr]r(rr$rkrr.r\r~rrrrrr)r)r)r*r?sx "     +    X #   &    ` B" g  Arc@steZdZdZdZddZddZddZd d Zd d Z d dZ ddZ ddZ ddZ ddZddZddZdS) _SessionShima 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 :class:`autobahn.asyncio.wamp.Session` or :class:`autobahn.twisted.wamp.Session` depending on which async framework you're using. NcC ||Sr$)on_joinr_r)r)r*r z_SessionShim.onJoincCsx|jr6dd|jDd}dd|jDd}|}|j|jjt|j|p-d|p0d|ddS|dS)NcSg|] }|jddqS)rKN_argsgetr_xr)r)r* z*_SessionShim.onConnect..cSr)rLNrrr)r)r*rrrdefault)rrKrLr) _authenticatorsrf_merged_authextrar-rrHrjkeys on_connect)rErKrLrr)r)r*rs  z_SessionShim.onConnectcCs<z|j|j}Wntytd|jw|||S)Nz.Received challenge for unknown authmethod '{}')rr&rC RuntimeErrorr on_challenge)rErL authenticatorr)r)r*r(s  z_SessionShim.onChallengecCsV|jdus |jdur dSz|j|j}Wnty#td|jw|||jS)Nz.Received onWelcome for unknown authmethod '{}')rMrrCrr on_welcomer)rEryrr)r)r*r$s z_SessionShim.onWelcomecCrr$)on_leaver_r)r)r*rrz_SessionShim.onLeavecCs|Sr$) on_disconnectrDr)r)r*r\!sz_SessionShim.onDisconnectcsttsJjduri_fdd}|d|dj}}|D]\}}||vrB|||krBtd||||q)jj<dS)NcsLtfddtjgD}t|dkr$tdd|dS)Ncs g|] }|jvr|jqSr))rr_anamer)r*r1s  zG_SessionShim.add_authenticator..at_most_one..r zInconsistent {}s: {} )setrjrrfr; ValueErrorrr-)runirrErr* at_most_one0s  z3_SessionShim.add_authenticator..at_most_onerKrLz4Inconsistent authextra values for '{}': '{}' vs '{}') rmrrrritemsrrr)rErrrmergedr`rar)rr*add_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|]}|jqSr))rrr)r)r*r^sz2_SessionShim._merged_authextra..cSs|t|BSr$)rr)ryr)r)r* extract_keys`r 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)r`r) authextrasr)r*first_value_fores z7_SessionShim._merged_authextra..first_value_forcsi|]}||qSr)r))r_r`)rr)r*rbssz2_SessionShim._merged_authextra..)rrfrr)rEr unique_keysr))rrr*rSs   z_SessionShim._merged_authextracCdSr$r)r_r)r)r*r{rz_SessionShim.on_joincCs |dSr$)r1r_r)r)r*r~rz_SessionShim.on_leavecCs||jjdSr$rrDr)r)r*rsz_SessionShim.on_connectcCrr$r)rDr)r)r*rrz_SessionShim.on_disconnect)rrrrrrrr(r$rr\rrrrrrr)r)r)r*rs  -( 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)r rrrr)r)r*rFsz"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)rErr)r)r*__call__s z"ApplicationSessionFactory.__call__r$)rrrrrrrFrr)r)r)r*rs   r)5 __future__rrRr3r% functoolsrautobahnr autobahn.utilrrr autobahn.wamprr r r r autobahn.wamp.exceptionr rrrautobahn.wamp.interfacesrrrautobahn.wamp.typesrrrautobahn.exceptionrautobahn.wamp.requestrrrrrrrrr r!r"r#r+r,rrobjectrr)r)r)r*sJ         8)/