8'h`N | d dl mZ d dlZd dlZd dlZd dlmZ d dlmZ d dl m
Z
m Z m Z d dl
mZ d dl
mZ d dl
mZ d d l
mZ d d
l
mZ d d lmZmZmZmZ d d lmZmZmZ d d
l m Z m Z m Z d dl m!Z! d dl"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z. d Z/ G d de Z0e
G d de0 Z1 G d de1 Z2 G d de3 Z4y) )absolute_importN)reduce)wamp)public IdGeneratorObservableMixin)uri)message)types)role) exception)ApplicationError
ProtocolErrorSessionNotReadySerializationError)ISession
IPayloadCodecIAuthenticator)SessionDetails CloseDetailsEncodedPayload)PayloadExceededError) Publication SubscriptionHandler RegistrationEndpointPublishRequestSubscribeRequestUnsubscribeRequest CallRequestInvocationRequestRegisterRequestUnregisterRequestc Z t j | xs t j | S N)inspectismethod
isfunction)fs R/var/www/html/trade_iq/venv/lib/python3.12/site-packages/autobahn/wamp/protocol.pyis_method_or_functionr, < s# A 7'"4"4Q"77 c e Zd ZdZdZd Zed Zed Zed Z ed Z
ed Z ed Z d
d
Z
dd Zd Zy) BaseSessionzi
WAMP session base class.
This class implements :class:`autobahn.wamp.interfaces.ISession`.
Nc X t j | _ | j g d d| _ i | _ t j t t j t i| _ d| _ d| _
d| _ d| _ d| _ d| _ d| _ t' | _ y)z
)joinleavereadyconnect
disconnect) valid_eventsFN)txaio make_loggerlogset_valid_events
traceback_app_ecls_to_uri_patr INVALID_PAYLOADr PAYLOAD_SIZE_EXCEEDEDr _uri_to_ecls_realm _session_id_authid _authrole _authmethod
_authprovider_payload_codecr _request_id_genselfs r+ __init__zBaseSession.__init__H s $$&
# !#
, ,.@ 2 24H
! # +} r- c | j S r& )r@ rH s r+ realmzBaseSession.realmt s {{r- c | j S r& )rA rH s r+
session_idzBaseSession.session_idx r- c | j S r& )rB rH s r+ authidzBaseSession.authid| s ||r- c | j S r& )rC rH s r+ authrolezBaseSession.authrole s ~~ r- c | j S r& )rD rH s r+
authmethodzBaseSession.authmethod rO r- c | j S r& )rE rH s r+ authproviderzBaseSession.authprovider s !!!r- c |Rt |d sJ |j | j |< || j |j d j < yt |d rJ t j
t
j | t j
j g| j |< || j t
j | < y)zM
Implements :func:`autobahn.wamp.interfaces.ISession.define`
N _wampurisr ) hasattrrY r< r? r PatternsixuURI_TARGET_HANDLER)rI r
errors r+ definezBaseSession.define s =9k2 32/8/B/BD ! !) ,>GD i 1 1! 4 8 8 : ; y+6 7603 CEE%L#++JhJh0i/jD ! !) ,.7D ceeEl +r- c d}t |d rt |j }d}t |d r |j }|rBt j
r2|j
D ci c] \ }} |j d | }}} |r |r||d< nd|i}t |t j rRt |j t j k( r |j n t j |j }
nA|j | j v r'| j |j d j" }
nd}
d} | j$ r | j$ j' d|
|| } | rFt) j* |||
| j, | j. | j0 | j2 } | S t) j* |||
|| } | S c c} }w )
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
Nargskwargsutf8 tracebackr zwamp.error.runtime_errorFpayloadenc_algoenc_keyenc_serializer)rZ listrb rc r\ PY2 iteritemsdecode
isinstancer
r typer_ text_typer] __class__r< _urirF encoder
Errorrg rh ri rj )
rI request_typerequestexctbrh rb rc kvr_ encoded_payloadmsgs
r+ _message_from_exceptionz#BaseSession._message_from_exception s 3 >D 3 !ZZF cgg # , , .Aq !#F
')|$&+ c955 6!%cii CMM!ACIIsuuSYYGWE}} 5 55 --cmm/M/M
OC
-- ' % $ & (C
Ms # G c d}d}|j r4| j sDd}| j j | t t j
||j }n t
|j |j |j |j }| j j d|j | \ }|_ |_
|j |k7 ri| j j d||j t t j dj ||j |j } |r|S |j | j$ v r| j$ |j } |j r<|j r ||j i |j }n6 |di |j }n#|j r ||j }n | }|s|j ro|j r8t- j |j g|j i |j }nt- j |j fi |j }nV|j r+t- j |j g|j }n t- j |j }t/ |d r|j |_ t/ |d
r|j0 |_ t/ |d r|j2 |_ t/ |d r|j4 |_ t/ |d r|j6 |_ |S # t $ r]}| j j d| t t j" d
j | |j }Y d}~hd}~ww xY w# t $ r1 | j' t) j* d n# Y nxY wY w xY w)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 activerh TzZURI within encrypted payload ('{decrypted_error}') does not match the envelope ('{error}'))decrypted_errorr_ FURI within encrypted payload ('{}') does not match the envelope ('{}').failed to decrypt application payload 1: {err}err+failed to decrypt application payload 1: {}z While re-constructing exceptionrh callee
callee_authidcallee_authrole forward_for ) rh rF r9 warnr ENC_NO_PAYLOAD_CODECr rg rj ri rn r_ rb rc ENC_TRUSTED_URI_MISMATCHformat ExceptionENC_DECRYPT_ERRORr? onUserErrorr7 create_failurer
rZ r r r r ) rI r} rx enc_errlog_msgr| r eeclss r+ _exception_from_messagez#BaseSession._exception_from_message s7 <<&&R
g&*+;+P+PRYdgdpdpq&4S[[#,,PSPbPbdgdodo&pO<@z+ApplicationSession.onOpen.. ,,T3NO r- c B t j j S r& )r7 as_future onConnect_rI s r+ r z+ApplicationSession.onOpen.. s eoodnn5 r- c ( j | d S )NzWhile calling 'onConnect'r r s r+ r z+ApplicationSession.onOpen.. r r- )r firer7
add_callbacks)rI transportds ` r+ onOpenzApplicationSession.onOpenv sM
$ IIiy 1
t O
5 O
r- c N | j | j j y)zP
Implements :func:`autobahn.wamp.interfaces.ISession.onConnect`
Nr1 r rL rH s r+ r z ApplicationSession.onConnect s
$++##$r- c Z | t | t j k( sJ |t | t k( sJ t | t k( r%|D ] } t | t j k( r J | t | t j k( sJ | t | t j k( sJ |t | t k( sJ | j
r t
d || _ d| _ t j || j ||||||| }
| j j |
y)zK
Implements :func:`autobahn.wamp.interfaces.ISession.join`
Nzalready joinedF) rL roles authmethodsrQ rS authextra resumableresume_session resume_token)rp r\ rq rk dictrA r r@ r r
Hellor r send) rI rL r rQ rS r r r r rU r} s r+ r1 zApplicationSession.join s! }U s}} <=<"d;&74&?@? $ )
:
J'3==898
:~f !>?> 4>S]]#BCB DOt$;<; ,- - # mm%"&"5"5(3#)%-&/&/+9)57
S!r- c R | j r| j j yy)zQ
Implements :func:`autobahn.wamp.interfaces.ISession.disconnect`
N)r closerH s r+ r5 z ApplicationSession.disconnect s
?? OO ! ! # r- c | j duS )zS
Implements :func:`autobahn.wamp.interfaces.ISession.is_connected`
N)r rH s r+ is_connectedz ApplicationSession.is_connected s
d**r- c > | j duxr | j duS )zR
Implements :func:`autobahn.wamp.interfaces.ISession.is_attached`
N)r rA rH s r+ is_attachedz ApplicationSession.is_attached s#
d*Kt/?/?t/KKr- c n t |j t j rK| j j d| j j |j j y| j j d| j j |t j | y)zR
Implements :func:`autobahn.wamp.interfaces.ISession.onUserError`
z {klass}.onUserError(): "{msg}")klassr} z*{klass}.onUserError(): "{msg}"
{traceback})r r} re N) ro valuer
r r9 r rr r
error_messager_ r7 failure_format_tracebackrI r r} s r+ r z ApplicationSession.onUserError s
djj)"<"< = HHMM: $ 7 7 "jj 6 6 8
:
HHNN=nn-- 88>
r- c | j || y# t $ rE | j j dt j
t j Y yw xY w)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})ry N)r r r9 r_ r7 r r r s r+ r z!ApplicationSession._swallow_error sa T3 ' HHNN&11%2F2F2HI
s A A#"A#c . "#$% j t t j rCt j
j } fd} fd}t j ||| yt t j rmt j j j "t j
j " }" fd} fd}t j ||| yt t j rlt j j j }t j
j | } fd} fd}t j ||| yt# dj% j& t t j( r j* s/t j( } j, j/ | d _ t j j j "t j
j " }" fd } fd
}t j ||| yt t j0 rvj2 j4 v r9 j4 j2 D ] }|j6 #j8 xs |j8 } j: r j< s) j> jA d j: y tC jD j: jF jH }
j< jK d
| |
\ } _& _' | | k7 r j> jA d y#jR r
#jR fn tU }
jL r|
tU jL z }
jN r jN n tW }#jX rqt jZ |j\ j^ j` jb | jd j: jf |#jX < fd}# fd}t j
#jh g|
i |}t j ||| yt# dj% j2 t t jj rjl jn v rg jn jq jl }ts j\ |jt }t jv |jx | yt# dj% jl t t jz rjl j| v rˉ j| jq jl }j2 j4 vrg j4 j2 < t j2 |j8 |j6 } j4 j2 j | t jv |jx | yt# dj% jl t t j r։jl j v r j jq jl }|j j4 v r< j4 |j D ] }d
|_D j4 |j = t jv |jx d yt# dj% jl t t j rwjl j v r9 j jl }|j $d}j: r j< s8d} j> jA | t t j | }n tC jD j: jF jH }
j< jK d$|
\ }_& _' $|k7 rI j> jA d |$ t t j d j% |$ } j rG|j j r|r j |d" yjN xs
tW }jL xs
tU } fd#}|j r|j j rt j
|j j t j jL j j j jf d$jN }n-t j
|j j g|i |}t j |d| y j jl = |jx }|rt j || yjN s"|j r|j j rjN xs i } jL rMt j jL j j j jf d$| } nBt j d<j j j jf d$| } t jv || yjL rot jL d%kD r3t j jL } t jv || yt jv |jL d yt jv |d yt# d&j% jl yt t j r`jl j v r$t# d'j% jl j j vr$t# d(j% j j j %%j } j xs %j $d}j: r j< s8d)} j> jA | t t j | }n tC jD j: jF jH }
j< jK d
$|
\ }_& _' $|k7 rI j> jA d*|$ t t j d+j% |$ } |rQ j t j j jl | } j, j/ | y| jR | jR f}
n
tU }
jL r|
tU jL z }
jN r jN n tW }| jX rgj r$ fd.} nd} t j %| j j j $j: / || jX < t j
| jh g|
i |}$% fd0}% fd1}t jl | j jl < t j ||| yt t j ryjl j vr( j> j d2jl 3 y j jl } t j | jx yt t j rjl j v rȉ j jq jl }j j vrFt j |j |j %% j j < n$t# d4j% j t jv |jx % yt# d5j% jl t t j r*jl dk( rM j j }! j> j d7|!j j 8 yjl j v r j jq jl }|j j v r5d
j |j _D j |j = t jv |jx yt# d9j% jl t t j r d}j t j j k( rIjl j v r1 j jq jl jx }n,j t j j k( rIjl jn v r1 jn jq jl jx }nj t j j k( rIjl j| v r1 j| jq jl jx }nLj t j j k( rHjl j v r0 j jq jl jx }n݉j t j j k( rHjl j v r0 j jq jl jx }nnj t j j k( rGjl j v r/ j jq jl jx }|r;t j | sUt j | j yt# d:j% j jl yt# d;j% j& # tP $ r3} j> jA d| j: Y d} ~ yd} ~ ww xY w# tP $ rQ} j> jA d | t t j d!j% | }Y d} ~
d} ~ ww xY w# tP $ rQ} j> jA d,| t t j d-j% | }Y d} ~ d} ~ ww xY w# t $ r% t# d6j% j w xY w)=zY
Implements :func:`autobahn.wamp.interfaces.ITransportHandler.onMessage`
Nc
& | \j j d t j ddj | }j
j
| y j rj _ j _
j _ j _ j _ j" _ j& _ t+ j j j j j j$ j, j
j. j0 j2 j4 j6 j9 d }t; j< |d fd t; j< |fdd t; j< |d fd t; j< |fd d t; j< |d fd
y ) NzSession denied by onWelcome wamp.error.cannot_authenticate{0}) rL sessionrQ rS rU rW r
serializerresumedr r r1 c ( j | d S )NzWhile notifying 'join'r r rI s r+ r z?ApplicationSession.onMessage..success..1 s $"5"5a9Q"R r- c D t j j S r& )r7 r onJoin)r detailsrI s r+ r z?ApplicationSession.onMessage..success..6 s %//$++w"G r- c ( j | d S )NzWhile firing onJoinr r s r+ r z?ApplicationSession.onMessage..success..< s $"5"5a9N"O r- c ( j d S )Nr3 r r s r+ r z?ApplicationSession.onMessage..success..A s $))GT": r- c ( j | d S )NzWhile notifying 'ready'r r s r+ r z?ApplicationSession.onMessage..success..G s $"5"5a9R"S r- ) r9 infor
Abortr r r rL r@ r rA rQ rB rS rC rU rD rW rE r
_router_rolesr r _serializer
SERIALIZER_IDr r r r r7 r )resreplyr r r} rI s @r+ successz-ApplicationSession.onMessage..success s
&CD '
=v}}S?Q! ,,U3 yy&)ii '*{{D$#&::DL%(\\DN'*~~D$),)9)9D&),D& , "kk $ 0 0 #||!% #'#3#3%)%7%7"%--#'??#>#>#L#L # "%--%(%5%5 G$ &$8A ''4R
''G ''4O
'': ''4Sr- c t j dd }j j | j | d S )Nr z Error calling onWelcome handlerzWhile firing onWelcome)r
r r r r )r r rI s r+ r_ z+ApplicationSession.onMessage..errorJ s? #MM9;] E OO((/ ..q2JKKr- c r j d } fd}fd}t j ||| |S )Nr2 c S r& r )r args r+
return_argzAApplicationSession.onMessage..success..return_arg[ s "
r- c ( j | d S )NzWhile firing 'leave' eventr r s r+ _errorz=ApplicationSession.onMessage..success.._error^ s # 2 216R SSr- )r r7 r )r r r r r rI s ` r+ r z-ApplicationSession.onMessage..successW s7 '49A#T'':v> Hr- c ( j | d S NzWhile firing onLeaver r s r+ r z,ApplicationSession.onMessage.._errorc s ..q2HIIr- c X | t d t | t j k( r| j d } t | t j
k7 r#t dj
t | t j | }j j | y )Nz4onChallenge user callback did not return a signaturerd z"signature must be unicode (was {})) r rp r\ binary_typern rq r r
Authenticater r ) signaturer rI s r+ r z-ApplicationSession.onMessage..successl s ( '(^ __I#//9$-$4$4V$< I#--7 '(L(S(STXYbTc(d ee # 0 0 ;EOO((/r- c j | d t j ddj | j }j
j
| t j |j |j t j j }fd}fd}t j ||| |S )NzAuthentication failedr r c . j d | S Nr2 r r r rI s r+ r z.error..success~ s '49 "
r- c ( j | d S r r r s r+ r z;ApplicationSession.onMessage..error.._error s # 2 216L MMr- )r r
r r r r r r r reasonr7 r onLeaver )r r r r r r rI s @r+ r_ z+ApplicationSession.onMessage..errorv s $$S*AB #MM*KV]][^[d[dMe fEOO((/ # 0 0 u}} MG g>A#
N''7F; Hr- z8Received {0} message, and session is not yet establishedc . j d | S r r r s r+ r z-ApplicationSession.onMessage..success s IIgtW5 Jr- c t dj j j }j | | S )Nz7While firing onLeave for reason "{0}" and message "{1}")r r r
r )r errmsgr} rI s r+ r z,ApplicationSession.onMessage.._error s6 V ] ]^a^h^hjmjuju vF ..q&99r- zjreceived encoded payload with enc_algo={enc_algo}, but no payload codec active - ignoring encoded payload!r Fz-envelope topic URI does not match encoded onezNfailed to decode application payload encoded with enc_algo={enc_algo}: {error})r_ rh ) publisherpublisher_authidpublisher_authroletopicretainedrh r c j r}j d j rcj r;t j
j }j j | y j j d y y y )Nbrokerz}successfully processed event with acknowledged delivery, but could not send ACK, since the transport was lost in the meantime)
x_acknowledged_deliveryr x_acknowledged_event_deliveryr r
EventReceived publicationr r9 r )r responser} rI s r+ _successz.ApplicationSession.onMessage.._success sp # : :t?Q?QRZ?[?y?y#'??/6/D/DS__/UH$(OO$8$8$B$(HHMM 3r %s @z :r- c t dj j j }j | | S )Nz&While firing {0} subscribed under {1}.)r fn subscriptionr )r r handlerr} rI s r+ r z,ApplicationSession.onMessage.._error s5 %M%T%T '
C,<,<&>F#'#6#6q&#A Ar- 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}r z4UNSUBSCRIBED received for non-pending request ID {0}r TzXURI within encrypted payload ('{decrypted_proc}') does not match the envelope ('{proc}'))decrypted_procprocr r r r zLcould not deliver progressive call result, because payload decryption failedc * j | d y )NzWhile firing on_progress)r r s r+ r z,ApplicationSession.onMessage.._errorG s $($4$4T;U$Vr- )r r r r z.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 s5 /3|tDzdTY]?Z([/Z/5~f QUAU(V/U+1cgg =CB>Q>Q>X>XY^`dfjlr>sO+:;B==Q`QhQhRVRaRjRjQ`QhQhXgXvXv j@ d
j1 j2 | g }j, j5 | Y d }~y d }~wtB $ r}t j8 t j: j< j t> jD d j1 j2 | g }j, j5 | Y d }~y d }~ww xY w) Nr. Fz,failed to encrypt application payload: {err}r )rg rh ri rj r r r r rf )rb rc r r r r rb zCSkipping 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})#r rw rh rF r9 r ro r
CallResultrt results kwresultsr r
r1 rg ri rj r r r r r debugr r6 r r ru
Invocation MESSAGE_TYPEr r= r r> ) r r| r r r r} r* registrationrI s r+ r z-ApplicationSession.onMessage..success s $($5$5ckk$B26#&<<+/+>+>2l(,
g(> )./9#u?O?O/PBFBUBUB\B\]bdhjmjujuwz xE xE CFBFBUBUB\B\]bdhknjoBp $3'1#u7G7G'H07
ckkFUF]F]GVG_G_FUF]F]M\MkMkEHZZLOL]L]NQNaNaJM//1[ 18
ckkFUF]F]GVG_G_FUF]F]M\MkMk 1m (2#u7G7G'H07
ckkCF;;EH]]EHZZLOL]L]NQNaNaJM//
1[ 18
ckkDG51J $(??#:$(HHNN3x33 AM AW AW Y\ Yd Yd 4e %f$* !@$(OO$8$8$?S 09 ).,0HHMM0^45 -: -. -.).T (: !@,3MM':L:L:Y:Y[^[f[fhx iI iI AR AY AY Zf Zp Zp rs At @u-vE$(OO$8$8$?$?'; !@ -4MM':L:L:Y:Y[^[f[fhx iO iO AW A^ A^ _k _u _u wx Ay @z-{E$(OO$8$8$?$? !@s? A+J' K ' K0 KK O=$A?M(( O=4A?O88O=c
j j = t j | } j | | d }j
rt j | }j t j j j | j |j } j j | y # Y xY w# t $ r}t j t j j j t" j$ dj' j( | g }j j | Y d }~y d }~wt* $ r}t j t j j j t" j, dj' j( | g }j j | Y d }~y d }~ww xY w)NzLerror return value from invoked procedure "{0}" could not be serialized: {1}r8 r9 )r rw r7 failure_messager r; r r~ r
r> r? r rh r r r ru r r= r r6 r r> )r r formatted_tbr r r} r@ rI s r+ r_ z+ApplicationSession.onMessage..error8 s $($5$5ckk$B).)>)>s)C!)$($4$4S&$A 04 #'#5#5383Q3QRU3VL(,(D(D$+$6$6$C$C$'KK$'II$0$'LL )" !@$(OO$8$8$? (,=!)$( (: !@,3MM':L:L:Y:Y[^[f[fhx iI iI AP AW AW Xd Xn Xn pq Ar @s-tE$(OO$8$8$?$? (, (< !@ -4MM':L:L:Y:Y[^[f[fhx iO iO AW A^ A^ _k _u _u wx Ay @z-{E$(OO$8$8$?$? (,!@s1 C 0C C G5 A?E G5,A?G00G5z7INTERRUPT received for non-pending invocation {request})rw z r r@ r endpointr~ r? receive_progress CallDetailsr3 r4 r5 r" Interruptr= cancel
Registeredr r UnregisteredKeyErrorr r registration_idru rv CallPublish Subscribe UnsubscribeRegister
Unregister is_calledr )&rI r} r r r_ r challenger r% r r|
decoded_topicr invoke_args
invoke_kwargsr" futurepublish_requestr rw call_requestr r r) kwrb prog_drS rc r r^ r/ invokedregr r& r* r@ s& `` @@@@r+ onMessagez ApplicationSession.onMessage s=
# #w/ OODNNC8@DL ##Aw6C / ,,SZZEOODLL':
J##Aw7C!2!23 !OOCJJ B OOD$4$4i@0 ( ##Aw6 $$^$e$efifsfs$tuu #w/)) #OO -EOO((/#' ,,SZZEOODLL':
: ##Aw7C /##t':':: )-(;(;CsB
"' ![k![]![ ++FHfE_/Fd ((_(f(fgjgwgw(xyyC!2!23;;$"4"44 '+&8&8&<	$(HHMM )C7E-1 %2 %&
/?(8(Q(Q(q(x(x zH JN )O/&G
|| (//;; & $ 0 0 ;I !J%(ZZ%946'*xx':57!W $0#7#7L\
QTPZPZ >\.]F .3__\=Q=Q=]=] .C>B.C?A.CF !& 3 3FD& I !OOCKK 8 $0#8#8 # !LL7 ; "zzl.B.B|G[G[GcGc),)9r#&88*/*:*:CHHBE**ILIZIZKNK^K^GJ +E
>D +EC +0*:*: +E#**ILIZIZKNK^K^GJ+E >D +EC
!&
h <#&88'*388}q'8.3.>.>.I(-
h(D(-
h (L$)MM(D$A'(X(_(_`c`k`k(lmmA 04HFKFWFWXdai_b_i_ififwfwhkh{h{bfadamam
Go
h.B.B C (-x{{'b['bTa'bHB @H% ,N >Os{{\d=eD - -ckk : ! / /'5 IC!2!23;;d&7&77HHNN#\fifqfqNr " / / sr %A!AX8A!AY A!AZ6 F6A\ X AYX#(AYYAYY AZ3Y"AAZ.Z.AZ3Z6 A\Z?AA\ \ A\\.A]c d _ j rt j t j j dj j t
j j } fd} fd}t
j ||| d _ t
j j } fd} fd}t
j ||| y)zW
Implements :func:`autobahn.wamp.interfaces.ITransportHandler.onClose`
Nz=WAMP transport was lost without closing the session {} beforer r
c . j d | S r r r s r+ r z+ApplicationSession.onClose..success s '41
r- c ( j | d S r r r s r+ r z*ApplicationSession.onClose.._error s **1.DEEr- c , j d S )Nr5 ) was_cleanr )r rI wasCleans r+ r z+ApplicationSession.onClose..success s 99\489D Dr- c ( j | d S )NzWhile firing onDisconnectr r s r+ r z*ApplicationSession.onClose.._error s &&q*EF Fr- ) r rA r r REASON_TRANSPORT_LOSTr r7 r r r onDisconnect)rI r r r r r s `` @r+ onClosezApplicationSession.onClose s
(( ))??X__`d`p`pqG g6A
F 7F 3 #D OOD - - . E G
Aw/r- c t d )zR
Implements :func:`autobahn.wamp.interfaces.ISession.onChallenge`
zBreceived authentication challenge, but onChallenge not implemented)r )rI rn s r+ rJ z ApplicationSession.onChallenge s
\]]r- c y)zM
Implements :func:`autobahn.wamp.interfaces.ISession.onJoin`
Nr rI r s r+ r zApplicationSession.onJoin r- c y)zP
Implements :func:`autobahn.wamp.interfaces.ISession.onWelcome`
Nr )rI r} s r+ rF z ApplicationSession.onWelcome r r- c t j d }| j | j | j | j
| j | j g}g }|D ]1 }|j |j |j 3 |r&| j j dt | |D ] | j j dj j j" j$ t j& j s t j( j | t j* |fdfd |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_idrv c j S r& rS r rw s r+ r zBApplicationSession._errback_outstanding_requests..# s
W-=-= r- c j S r& r r s r+ r zBApplicationSession._errback_outstanding_requests..# s
IYIY r- )r7 create_future_successr r r r r r extendvaluesclearr9 r r] r= rS r rr r rm r\ r )rI rx r all_requests outstandingrequestsrw s @r+ _errback_outstanding_requestsz0ApplicationSession._errback_outstanding_requests s>
' ' - " " OO ! !
$ H x 0 1 NN HHMM9+&
# [G HHNND!(!1!1"-- $ . . 7 7
??7#3#34 W - -s3
#=?Y Z [ r- c @ |j t j k7 r2 j j d|j |j
t
|j |j
} j | } fd}t j ||| |S )zN
Implements :func:`autobahn.wamp.interfaces.ISession.onLeave`
z/session closed with reason {reason} [{message}]r{ c @ j rj y y r& )r r5 r s r+ r5 z.ApplicationSession.onLeave..disconnect2 s ! r- )
r r REASON_DEFAULTr9 r r
r r r7 r )rI r rx r r5 s ` r+ r zApplicationSession.onLeave& s
>>\ 8 8 8 HHMMKT[TbTblsl{l{M | w~~w? . .s 3 " Az:6r- c ^ | j s t d | j sH|sd}t j j || }| j j | d| _ n| j j d | j du xs | j j }|S )zL
Implements :func:`autobahn.wamp.interfaces.ISession.leave`
z session hasn't joined a realmzwamp.close.normalr{ TzBsession was already requested to leave - not sending GOODBYE againN) rA r r r r
rK r r r9 r is_closed)rI r r
r} r s r+ r2 zApplicationSession.leave8 s
!"BC C!!-,,&&fg&FC OO %!%D HHMM^ _OOt+Ht/H/H r- c N t j }| j | y)zS
Implements :func:`autobahn.wamp.interfaces.ISession.onDisconnect`
N)r
TransportLostr )rI rx s r+ r z ApplicationSession.onDisconnectM s %%' **3/r- c t | t j k( sJ |t | t t fv sJ |t | t
k( sJ t
j |dj | j j ddd |j dd }|r%t |t j s t d |rBt j r2|j# D ci c] \ }}|j% d | }}}| j& st) j* | j, j/ }d}| j0 r | j0 j3 d||| }|r|rSt
j4 ||f|j6 |j8 |j: |j< d |j? } nt
j4 |||j6 |j8 |j: |j< } nD|r)t
j4 ||f||d
|j? } nt
j4 ||||
} |rt|j@ |j@ | _ |jB |jB | _! |jD |jD | _" |jF |jF | _# |r>|jH r2tK jL }
tO ||
|du | jP |< nd}
| j& jS | |
S c c}}w # t $ r"} || jP v r
| jP |= | d} ~ ww xY w) zP
Implements :func:`autobahn.wamp.interfaces.IPublisher.publish`
Nz {}.publish()Fr
strictallow_empty_components
allow_nonerZ z,options must be of type a.w.t.PublishOptionsrd Trf rb rc r' )*rp r\ rq rk r0 r r
check_or_raise_urir rr r rQ ro r PublishOptionsr rl rm rn r r
r rG nextrF rt rh rg rh ri rj message_attrcorrelation_idcorrelation_uricorrelation_is_anchorcorrelation_is_last acknowledger7
create_futurer r r ) rI r rb rc rZ rz r{ r r| r} rS r s r+ publishzApplicationSession.publishX s/
E{cmm+,+|tDzdE] :;:~f !565""5+9+@+@ AXAX+Y*/:?.3 5 **Y- :gu/C/CD JK K cgg # , , .Aq !#F
))+ +))..0
" 1 1 8 8udF SO ooj&+@.=.E.E/>/G/G.=.E.E5D5S5S @ )0(<(<(>
@ ooj&+.=.E.E/>/G/G.=.E.E5D5S5S U ooj&+@+/-3@ )0(<(<(> @ ooj&++/-35
%%1%,%;%;"&&2&-&=&=#,,8,3,I,I)**6*1*E*E' w** **,H-;Japx|a|-~D z *H
OO % WL T / //&&z2G s + L%L+ + M4 MMc
B t | r|t |d sJ | t | t j k( sJ | t |t j sJ j st j fd}t | r |d||| S g }t j |j t D ] }|d }d|j v s|j d D ] }|j! s|j# } |j$ xs |}
|
T|j& t" j( j* k( rt
j d }
nt
j d }
|j- |||| |
t/ j0 |d
S ) zS
Implements :func:`autobahn.wamp.interfaces.ISubscriber.subscribe`
Nrr c t j |dj j j ddd j
j
}t j }t || |r |j nd }t |||| j |< |r&t j ||fi |j }nt j || }|rt|j |j |_ |j |j |_ |j" |j" |_ |j$ |j$ |_ j& j) | |S )Nz{}.subscribe()FTr )r
r r rr r rG r r7 r r rN r r ri r r r r r r r ) rM r$ r rZ r rS handler_objr} rI s r+
_subscribez0ApplicationSession.subscribe.._subscribe sD & &u/?/F/Ft~~G^G^/_.3>B27
9 --224J **,H!"c'7+>+>tTK/?
ES[]h/iD , ''
ETW=Q=Q=ST ''
E:))5)0)?)?C&**6*1*A*AC'00<070M0MC-..:.5.I.IC+ OO %Or- r, rY wildcard)matchexactTconsume_exceptions)callablerZ rp r\ rq ro r SubscribeOptionsr r
r r'
getmembersrr r, __dict__
is_handlerr rZ uri_typer[ URI_TYPE_WILDCARDrU r7 gather) rI r& r rZ r
on_repliesrz r* patrs suboptss ` r+ subscribez ApplicationSession.subscribe sp
!e&7GG[>+#&779D&)kk& |j@ d |jC }nt
j8 ||j: |j< |j> |j@ }nD|r)t
j8 |f||d
|jC }nt
j8 |||
}|rt|jD |jD |_" |jF |jF |_# |jH |jH |_$ |jJ |jJ |_% fd } tM jN | }
tQ ||
| jR < j& jU | |
S c c}}w # j4 j7 xY w# jR v r
jR = xY w)
zJ
Implements :func:`autobahn.wamp.interfaces.ICaller.call`
Nz {}.call()Fr rZ z)options must be of type a.w.t.CallOptionsrd Trf r c f t j }j j | y r& )r
Cancelr r )r
cancel_msgr rI s r+ cancellerz*ApplicationSession.call..cancellerk s#
3J OO ,r- )r )+rp r\ rq rk r0 r r
r r rr r rQ ro r CallOptionsr rl rm rn r r
r rG r rF rt r9 failurerg rg rh ri rj r r r r r r7 r r! r r ) rI r6 rb rc rZ rz r{ r| r} r rS r s ` @r+ callzApplicationSession.call s-
I#--/0/|tDzdE] :;:~f !565""9+6+=+=dnn>U>U+V*/:?.3 5 **Y- :gu/@/@A GH H cgg # , , .Aq !#F
))+ +))..0
"&"5"5"<"._register s[ & &y/>/E/EdnnF]F]/^.3>B27
9 --224J **,H#BGW-@-@QUVL! #NN69 = .=j(T]_k.lD
+ &&z9W@T@T@VW &&z9=))5)0)?)?C&**6*1*A*AC'00<070M0MC-..:.5.I.IC+ OO %Or- r, rY Tr )r rZ rp r\ rq ro r RegisterOptionsr r
r r' r rr r, r is_endpointr rZ rU r7 r ) rI r^ r6 rZ r r r rz r* r rs regoptss ` ` r+ registerzApplicationSession.register sR
"y'<S^A_`_ DOs}}$DED*We6K6K"LML~FCMM!BBB))+ + @ H T8Y@ @
J ''(:(:> !T%9%9%A 0 0 @M ''cmm<<
@GGNN
s A .A>c $ | j | S r& )on_leaver s r+ r z_SessionShim.onLeave s }}W%%r- c " | j S r& )
on_disconnectrH s r+ r z_SessionShim.onDisconnect! s !!##r- c p t t sJ j i _ fd} |d |d j } j }|j D ]1 \ }}||v s || |k7 st
dj |||| j j < y )Nc 2 t t j j gz D cg c] }| |j v r|j | ! c} }t | dkD r*t
dj | dj | y c c}w )Nr, zInconsistent {}s: {} ) setrk r r r r]
ValueErrorr r1 )nameaunir rI s r+ at_most_onez3_SessionShim.add_authenticator..at_most_one0 s d 2 2 9 9 ;<
N177?
C
3x!| *11
s $BrQ rS z4Inconsistent authextra values for '{}': '{}' vs '{}') ro r r r r itemsr r r )rI r r r mergedrz r{ s `` r+ add_authenticatorz _SessionShim.add_authenticator& s - 888 '#%D H J "++ '')LLN DAqI~)A,!"3 JQQ1il 4A ] / /0r- c | j j D cg c] }|j c}d }t |t }fd}|D ci c] }| ||
c}S c c}w c c}w )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.
c : | t |j z S r& )r r )r ys r+ extract_keysz4_SessionShim._merged_authextra..extract_keys` s s1668}$ $r- c \ D ]
}| |v s|| c S t dj | )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 '{}')r r )rz r
authextrass r+ first_value_forz7_SessionShim._merged_authextra..first_value_fore sB (
( >$Q<'
( $++A.
r- )r r r r r )rI r r unique_keysr rz r s @r+ r z _SessionShim._merged_authextraS sv ,0+?+?+F+F+HIaakkI
% \:su= !
q! !
+ J*
s A(A-c y r& r r s r+ r z_SessionShim.on_join{ r- c $ | j y r& )r5 r s r+ r z_SessionShim.on_leave~ s r- c N | j | j j y r& r rH s r+ r z_SessionShim.on_connect s $++##$r- c y r& r rH s r+ r z_SessionShim.on_disconnect r r- )r r r r r r r rJ rF r r r r r r r r r r- r+ r r sM O% * ; = &$
+AZ#
P
%
r- r c $ e Zd ZdZeZ ddZd Zy)ApplicationSessionFactoryz(
WAMP endpoint session factory.
Nc B |xs t j d | _ y)z
:param config: The default component configuration.
:type config: instance of :class:`autobahn.wamp.types.ComponentConfig`
r r N)r r r r s r+ rJ z"ApplicationSessionFactory.__init__ s F 5 5I F r- c J | j | j }| |_ |S )z
Creates a new WAMP application session.
:returns: -- An instance of the WAMP application session class as
given by `self.session`.
)r r factory)rI r s r+ __call__z"ApplicationSessionFactory.__call__ s" ,,t{{+ r- r& )r r r r r r rJ r r r- r+ r r s !GG r- r )5
__future__r r\ r7 r' functoolsr autobahnr
autobahn.utilr r r
autobahn.wampr r
r r r
autobahn.wamp.exceptionr r r r autobahn.wamp.interfacesr r r autobahn.wamp.typesr r r autobahn.exceptionr autobahn.wamp.requestr r r r r r r r r! r" r# r$ r, r/ r r objectr r r- r+ r s 6 '
> > ! # h h L L L L 3 8|/ |~ [ [ [|,g
% g
\ r-