af^ddlZddlZddlmZddlZddlmZddlmZddl m Z ddl m Z ddl mZmZddlmZmZdd lmZdd lmZmZmZmZdd lmZd ZGd deZeGddeZeGddeZGddeZ eGdde Z!eGdde Z"dS)N)Optional)Factory)Int32StringReceiver)ConnectionDone)CancelledError)public_LazyHexFormatter)create_transport_detailstransport_channel_id)TransportDetails) ProtocolErrorSerializationError TransportLostInvalidUriError)PayloadExceededError)WampRawSocketServerProtocolWampRawSocketClientProtocolWampRawSocketServerFactoryWampRawSocketClientFactoryceZdZUdZejZdZee e d<dZ ee e d<dZ edeefdZdZd Zd Zd Zd Zd ZdZdZdZdS)WampRawSocketProtocolzE Base class for Twisted-based WAMP-over-RawSocket protocols. Npeer is_serverc"d|_d|_dSN)_max_message_size_transport_detailsselfs L/var/www/html/env/lib/python3.11/site-packages/autobahn/twisted/rawsocket.py__init__zWampRawSocketProtocol.__init__=s!&"&returnc|jS)zZ Implements :func:`autobahn.wamp.interfaces.ITransport.transport_details` )rrs r!transport_detailsz'WampRawSocketProtocol.transport_detailsBs &&r#cVd||j}t|)NzqRawSocket connection: length of received message exceeded (message was {} bytes, but current maximum is {} bytes))format MAX_LENGTHr)r lengthemsgs r!lengthLimitExceededz)WampRawSocketProtocol.lengthLimitExceededIsECJJKQSWSbcc"4(((r#ct|j|j|_tj|j_|jj|_tj |_ d|_ d|_ d|_ d|_d|_dS)NFr#)r transportrrr CHANNEL_FRAMING_RAWSOCKETchannel_framingrtxaio create_future is_closed_session _serializer_handshake_complete_handshake_bytes _max_len_sendrs r!connectionMadez$WampRawSocketProtocol.connectionMadeOs #;4>4>"Z"Z2B2\/+0 ,..   $) !$"r#cZ |jjr.dt|j|jjdi}||j_|j|_|j d|j|j j |jj |j |}|j d|j j |j|dS#t$rF}|j d|j j ||Yd}~dSd}~wwxYw)Nz tls-uniquez2{klass}._on_handshake_complete(): calling {method})sessionklassmethodz@{klass}._on_handshake_complete(): {session} started (res={res}).)r<r;reszX{klass}._on_handshake_complete(): ApplicationSession constructor / onOpen raised ({err})r<err)r is_securer r.r channel_idfactory_factoryr4logdebug __class____name__onOpen Exceptionwarnabort)r rBr>es r!_on_handshake_completez,WampRawSocketProtocol._on_handshake_completessM ;&0 @!"6t~tG^Ghjv"w"w 6@'2 L1133DM HNNOY]Yf!%!8AU  W W W-&&t,,C HNN]eiese|#'=c  ; ; ; ; ;     HMMt $ 7Q  @ @ @ JJLLLLLLLLL  sB)C D*$;D%%D*c|jd|jj|t j|j| t|jt}|j r|j |n>#t$r1}|j d|jj|Yd}~nd}~wwxYwd|_ dS)Nz({klass}.connectionLost(reason="{reason}")r<reasonzC{klass}.connectionLost(): ApplicationSession.onClose raised "{err}"r?)rErFrGrHr1resolver3 isinstancevaluerr4onCloserJrK)r rPwasCleanrMs r!connectionLostz$WampRawSocketProtocol.connectionLosts AI`ioppp dnd+++ @!&,??H} 0 %%h/// @ @ @ HMM_ $ 7Q  @ @ @ @ @ @ @ @ @ s;A?? B: 'B55B:c|jd|jjt | |j|D]C}|jd|jj||j|DdS#t$r2}|j d|jj|Yd}~dSd}~wt$rF}|j d|jj|| Yd}~dSd}~wt$rF}|j d|jj|| Yd}~dSd}~wt$rF}|j d |jj|| Yd}~dSd}~wt $rF}|j d |jj|| Yd}~dSd}~wt"$r_}|j|j d |jj|| Yd}~dSd}~wwxYw) Nz,{klass}.stringReceived(): RX {octets} octetsr<octetsz.{klass}.stringReceived: RX WAMP message: {msg})r<msgzM{klass}.stringReceived: WAMP CancelledError - connection will continue! {err}r?zI{klass}.stringReceived: WAMP InvalidUriError - aborting connection! {err}zG{klass}.stringReceived: WAMP ProtocolError - aborting connection! {err}zN{klass}.stringReceived: WAMP PayloadExceededError - aborting connection! {err}zL{klass}.stringReceived: WAMP SerializationError - aborting connection! {err}zC{klass}.stringReceived: WAMP Exception - aborting connection! {err})rEtracerGrHr r5 unserializer4 onMessagerrFrrKrLr rrrJfailure)r payloadrZrMs r!stringReceivedz$WampRawSocketProtocol.stringReceiveds E!^4=Nw=W=W  Y Y Y( '33G<< - -O%)^%<#GGG '',,,, - -  " " " HNNk!%!8   " " " " " " " " "    HMMf $ 7  ! ! ! JJLLLLLLLLL    HMMd $ 7  ! ! ! JJLLLLLLLLL#    HMMk $ 7  ! ! ! JJLLLLLLLLL!    HMMi $ 7  ! ! ! JJLLLLLLLLL    H      HMM` $ 7  ! ! ! JJLLLLLLLLL  sUAB I1 'C  I1;D I1(;E)) I16;F77 I1;H I1AI,,I1c|r2|jd|jj||j |j|\}}t|}d|jcxkr|krGnnDd ||j}|j |t|| ||jd|jjt|dS#t$r'}td |d}~wwxYwt) zM Implements :func:`autobahn.wamp.interfaces.ITransport.send` zB{klass}.send() (serializer={serializer}): TX WAMP message: "{msg}")r<rZ serializerrzQtried to send RawSocket message with size {} exceeding payload limit of {} octetsz"{klass}.send(): TX {octets} octetsrXzIWampRawSocketProtocol: unable to serialize WAMP application payload ({0})N)isOpenrEr[rGrHr5 serializelenr8r(rKr sendStringr rr)r rZr__ payload_lenr+rMs r!sendzWampRawSocketProtocol.sends{ ;;== " HNN_!%!8cdN^  ` ` ` e!-77<<  "'ll t)7777K77777nuu#T%799DHMM$'''.t444OOG,,,HNN#G)-)@IZ[bIcIc#eeeee& @ @ @()t){){|})~)~ @ // !sD E"EEc|jduS)zO Implements :func:`autobahn.wamp.interfaces.ITransport.isOpen` N)r4rs r!rczWampRawSocketProtocol.isOpens}D((r#c||r|jdSt)zN Implements :func:`autobahn.wamp.interfaces.ITransport.close` N)rcr.loseConnectionrrs r!closezWampRawSocketProtocol.closes8 ;;== " N ) ) + + + + +// !r#c|rKt|jdr|jdS|jdSt )zN Implements :func:`autobahn.wamp.interfaces.ITransport.abort` abortConnectionN)rchasattrr.rorlrrs r!rLzWampRawSocketProtocol.abortsg ;;== "t~'899 0..00000--/////// !r#)rH __module__ __qualname____doc__r1 make_loggerrErrstr__annotations__rboolr"propertyr r&r,r9rNrVr`rircrmrLr#r!rr4s %   CD(3- $Ix~$$$''' '8,<#='''X' ))) """"""H;;;2   +++Z"""4))) """ " " " " "r#rceZdZdZdZdS)rz Twisted-based WAMP-over-RawSocket server protocol. Implements: * :class:`autobahn.wamp.interfaces.ITransport` cj|jrt||dSdt|jz }|xj|d|z c_t|jdkr|jdt|jt|jdd}|dkr1|j d|| n|jd d d t|jdd dz zz|_ |jd |j t|jdd dz}||j j vrFtj|j j ||_|jd|nM|j d||j j | t#t%jt%j|jd }d |z|_t-t/|d z dz|jjzg}|jd|j||jdd|_||jd|j||d}|r||dSdS)NzDWampRawSocketServerProtocol: opening handshake received - 0x{octets})rYrzmWampRawSocketServerProtocol: invalid magic byte (octet 1) in opening handshake: was {magic}, but expected 127magicz8WampRawSocketServerProtocol: correct magic byte received z^WampRawSocketServerProtocol: client requests us to send out most {max_bytes} bytes per message) max_byteszJWampRawSocketServerProtocol: client wants to use serializer '{serializer}'rbzWampRawSocketServerProtocol: opening handshake - no suitable serializer found (client requested {serializer}, and we have {serializers}rb serializersTzFWampRawSocketServerProtocol: opening handshake completed: {serializer})r6r dataReceivedrer7rErFr ordrKrLr8rC _serializerscopyr5keysintmathceilrr)bytes bytearrayRAWSOCKET_SERIALIZER_IDr.writerN)r data remaining_magicser_idreply_max_len_exp reply_octet2s r!rz(WampRawSocketServerProtocol.dataReceivedsY  #P ( ! . .tT : : : : :C 5666I  ! !T*9*%5 5 ! !4())Q..Z,T-BCCT21Q3788S==HMML$" JJLLLLHNN#]^^^&'1D4I!A#4N0O0OST0T+U%V"t"0T21Q37884?T\666'+y1J61R'S'SD$HNNd#)# HMMb#)$(L$=$B$B$D$D" JJLLL%( $(4;QST2U2U(V(V$W$W!#$%6"6 %Y'!+1T5E5]]0_&`&` a a $$W---$$\222$$[111+/(++---\#/ #D (!!$''''' ( (r#N)rHrqrrrsrryr#r!rrs2R(R(R(R(R(r#rceZdZdZdZdZdS)rz Twisted-based WAMP-over-RawSocket client protocol. Implements: * :class:`autobahn.wamp.interfaces.ITransport` ct|tj|jj|_t t jt j|j d}d|z|_ tt|dz dz|jj zg}|jd|j||jddS)Nrrr|rr)rr9rrCr5rrrrErr)rrrr.r)r request_max_len_exprequest_octet2s r!r9z*WampRawSocketClientProtocol.connectionMadefs,,T2229T\%=>>"$)DHT5KQ,O,O"P"PQQ00y!A%! +t/?/W W*Y Z Z[[ W%%% ^,,, [)))))r#c2|jrt||dSdt|jz }|xj|d|z c_t|jdkr|jdt|jt|jdddkrH|jdt|jd| d d t|jdd dz zz|_ |jd |j t|jdd d z}||j j kr;|j d||j j | d|_||jd|j ||d}|r||dSdS)Nr|zEWampRawSocketClientProtocol: opening handshake received - {handshake}) handshakerr}r~zpWampRawSocketClientProtocol: invalid magic byte (octet 1) in opening handshake: was 0x{magic}, but expected 0x7frrrzXWampRawSocketClientProtocol: server requests us to send out most {max} bytes per message)maxrzWampRawSocketClientProtocol: opening handshake - no suitable serializer found (server replied {serializer}, and we requested {serializers})rTzXWampRawSocketClientProtocol: opening handshake completed (using serializer {serializer})r)r6rrrer7rErFr rrLr8r5rerrorrN)r rrrs r!rz(WampRawSocketClientProtocol.dataReceivedysD  #4 ( ! . .tT : : : : :C 5666I  ! !T*9*%5 5 ! !4())Q..[/0EFF t,QqS122d::HNNK/0Ea0HII#JJLLL&'1D4I!A#4N0O0OST0T+U%V"n*T21Q37884?T-EEEHNNf#)$($4$L# JJLLL+/(++---n#/ #D (!!$''''' ( (r#N)rHrqrrrsr9rryr#r!rr\s<***&6(6(6(6(6(r#rcJeZdZdZejZdZdZddZ dZ dS)WampRawSocketFactoryzE Base class for Twisted-based WAMP-over-RawSocket factories. cXtr|_n fd|_d|_dS)z :param factory: A callable that produces instances that implement :class:`autobahn.wamp.interfaces.ITransportHandler` :type factory: callable cSNry)rCsr!z/WampRawSocketFactory.__init__..sGr#rN)callablerDr)r rCs `r!r"zWampRawSocketFactory.__init__s; G   ,#DMM+OOODM"'r#cd|_dSr)rrs r!resetProtocolOptionsz)WampRawSocketFactory.resetProtocolOptionss!&r#Nc|jd|jj||&t |t kr |dkr|dksJ|||jkr ||_dSdSdS)NzI{klass}.setProtocolOptions(maxMessagePayloadSize={maxMessagePayloadSize}))r<maxMessagePayloadSizeir)rErFrGrHtyperr)r rs r!setProtocolOptionsz'WampRawSocketFactory.setProtocolOptionss b!^4La  c c c$,6K1L1LPS1S1SXmqtXtXtzOSXzXzXzXY ,1F$J`1`1`%:D " " " - ,1`1`r#c |jd|jj||}||_|j|_|j|_|jd|jj||j|j|S)Nz"{klass}.buildProtocol(addr={addr}))r<addrzf{klass}.buildProtocol() -> proto={proto}, max_message_size={max_message_size}, MAX_LENGTH={MAX_LENGTH})r<protomax_message_sizer))rErFrGrHprotocolrCrr))r rps r! buildProtocolz"WampRawSocketFactory.buildProtocols ;4>CZaefff MMOO - "4 !^4APQPcpqp|  ~ ~ ~r#r) rHrqrrrsr1rtrEr"rrrryr#r!rrsq %   C ' ' '''';;;;r#rceZdZdZeZddZdS)rzD Twisted-based WAMP-over-RawSocket server protocol factory. Nc>t|||cg} ddlm}||d||n#t $rYnwxYw ddlm}||d||n#t $rYnwxYw ddlm}||d||n#t $rYnwxYw ddlm}||d||n#t $rYnwxYw|std i|_ |D]}||j |j <dS) a :param factory: A callable that produces instances that implement :class:`autobahn.wamp.interfaces.ITransportHandler` :type factory: callable :param serializers: A list of WAMP serializers to use (or ``None`` for all available serializers). :type serializers: list of objects implementing :class:`autobahn.wamp.interfaces.ISerializer` NrCBORSerializerT)batchedMsgPackSerializerUBJSONSerializerJsonSerializerz%could not import any WAMP serializers) rr"autobahn.wamp.serializerrappend ImportErrorrrrrJrr)r rCrrrrrsers r!r"z#WampRawSocketServerFactory.__init__s[ %%dG444  K CCCCCC"">>$#?#?#?@@@"">>#3#34444     FFFFFF""#4#4T#B#B#BCCC""#4#4#6#67777     EEEEEE""#3#3D#A#A#ABBB""#3#3#5#56666     CCCCCC"">>$#?#?#?@@@"">>#3#34444     I GHHH A AC=@D c9 : : A AsKAA%% A21A26AB99 CC AD DDAE!! E.-E.r)rHrqrrrsrrr"ryr#r!rrs?+H6A6A6A6A6A6Ar#rceZdZdZeZddZdS)rzD Twisted-based WAMP-over-RawSocket client protocol factory. Nct||d|_|" ddlm}|}n#t $rYnwxYw|" ddlm}|}n#t $rYnwxYw|" ddlm}|}n#t $rYnwxYw|" ddlm}|}n#t $rYnwxYw|td||_ dS) a :param factory: A callable that produces instances that implement :class:`autobahn.wamp.interfaces.ITransportHandler` :type factory: callable :param serializer: The WAMP serializer to use (or ``None`` for "best" serializer, chosen as the first serializer available from this list: CBOR, MessagePack, UBJSON, JSON). :type serializer: object implementing :class:`autobahn.wamp.interfaces.ISerializer` FNrrrrrz$could not import any WAMP serializer) rr"noisyrrrrrrrJr5)r rCrbrrrrs r!r"z#WampRawSocketClientFactory.__init__%s %%dG444   CCCCCC+^--        FFFFFF..00        EEEEEE--//        CCCCCC+^--       BCC C%sE7 AA A A('A(.A?? B  B B## B0/B0r)rHrqrrrsrrr"ryr#r!rrs9+H7&7&7&7&7&7&r#r)#rrtypingrr1twisted.internet.protocolrtwisted.protocols.basicrtwisted.internet.errorrtwisted.internet.deferr autobahn.utilrr autobahn.twisted.utilr r autobahn.wamp.typesr autobahn.wamp.exceptionr rrrautobahn.exceptionr__all__rrrrrrryr#r!rs[6  ------77777711111111111133333333PPPPPPPP000000eeeeeeeeeeee333333 F"F"F"F"F"/F"F"F"R[([([([([("7[([([(|R(R(R(R(R("7R(R(R(j'''''7'''T=A=A=A=A=A!5=A=A=A@>&>&>&>&>&!5>&>&>&>&>&r#