h^XddlZddlZddlmZddlZddlmZddlmZddl m Z ddl m Z ddl mZmZddlmZmZdd lmZdd lmZmZmZmZdd lmZd ZGd deZeGddeZeGddeZGddeZ eGdde Z!eGdde Z"y)N)Optional)Factory)Int32StringReceiver)ConnectionDone)CancelledError)public_LazyHexFormatter)create_transport_detailstransport_channel_id)TransportDetails) ProtocolErrorSerializationError TransportLostInvalidUriError)PayloadExceededError)WampRawSocketServerProtocolWampRawSocketClientProtocolWampRawSocketServerFactoryWampRawSocketClientFactoryceZdZUdZej ZdZee e d<dZ ee e d<dZ edeefdZdZd Zd Zd Zd Zd ZdZdZdZy)WampRawSocketProtocolzE Base class for Twisted-based WAMP-over-RawSocket protocols. Npeer is_serverc d|_d|_yN)_max_message_size_transport_detailsselfs V/var/www/Befach/backend/env/lib/python3.12/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#cPdj||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.lengthLimitExceededIsCCJJKQSWSbSbc"4((r#c:t|j|j|_tj |j_|jj|_tj|_ d|_ d|_ d|_ d|_d|_y)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>>"Z2B2\2\/++00 ,,.   $) !$"r#c |jjr>dt|j|jjdi}||j_|j j|_|jjd|j|jj|jj|jj|}|jjd|jj|j|y#t$rL}|jjd|jj||j!Yd}~yd}~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_completess* ;&&00!"6t~~tG^G^GhGhjv"w 6@''2 LL113DM HHNNOY]YfYf!%!8!8AUAU  W--&&t,C HHNN]eiesese|e|#'==c  ;   HHMMt $ 7 7Q  @ JJLL  sCD E4(AE//E4c|jjd|jj|t j |j | t|jt}|jr|jj|d|_ y#t$rC}|jjd|jj|Yd}~d|_ yd}~wwxYw)Nz({klass}.connectionLost(reason="{reason}")r<reasonzC{klass}.connectionLost(): ApplicationSession.onClose raised "{err}"r?)rErFrGrHr1resolver3 isinstancevaluerr4onCloserJrK)r rPwasCleanrMs r!connectionLostz$WampRawSocketProtocol.connectionLosts AI`I`iop dnnd+ @!&,,?H}} %%h/   @ HHMM_ $ 7 7Q  @ @  @sAB C)&2C$$C)cX|jjd|jjt | |j j |D]O}|jjd|jj||jj|Qy#t$r<}|jjd|jj|Yd}~yd}~wt$rL}|jjd|jj||jYd}~yd}~wt$rL}|jjd|jj||jYd}~yd}~wt$rL}|jjd |jj||jYd}~yd}~wt $rL}|jjd |jj||jYd}~yd}~wt"$rf}|jj%|jjd |jj||jYd}~yd}~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!^^44=Nw=W  Y( ''33G<O%)^^%<%<#G '',=  " HHNNk!%!8!8   " "  HHMMf $ 7 7  ! JJLL  HHMMd $ 7 7  ! JJLL#  HHMMk $ 7 7  ! JJLL!  HHMMi $ 7 7  ! JJLL  HH    HHMM` $ 7 7  ! JJLL  sYA-B++ J)42C++ J)7AD>> J) AF J)AG$$ J)0AH77 J)AJ$$J)c|jr|jjd|jj||j  |j j |\}}t|}d|jcxkr|krEnnBdj||j}|jj|t||j||jjd|jjt|yt#t$r}tdj|d}~wwxYw) 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" ;;= HHNN_!%!8!8cdN^N^  ` e!--77<  "'l t))7K7nuu#T%7%79DHHMM$'.t44OOG,HHNN#G)-)@)@IZ[bIc#e / !& @()t){){|})~ @sD** E3E  Ec|jduS)zO Implements :func:`autobahn.wamp.interfaces.ITransport.isOpen` N)r4rs r!rczWampRawSocketProtocol.isOpens}}D((r#cl|jr|jjyt)zN Implements :func:`autobahn.wamp.interfaces.ITransport.close` N)rcr.loseConnectionrrs r!closezWampRawSocketProtocol.closes% ;;= NN ) ) +/ !r#c|jrLt|jdr|jjy|jj yt )zN Implements :func:`autobahn.wamp.interfaces.ITransport.abort` abortConnectionN)rchasattrr.rorlrrs r!rLzWampRawSocketProtocol.abortsD ;;=t~~'89..0--// !r#)rH __module__ __qualname____doc__r1 make_loggerrErrstr__annotations__rboolr"propertyr r&r,r9rNrVr`rircrmrLr#r!rr4s %   CD(3- $Ix~$' '8,<#='' ) ""H;2 +Z"4) " "r#rceZdZdZdZy)rz Twisted-based WAMP-over-RawSocket server protocol. Implements: * :class:`autobahn.wamp.interfaces.ITransport` c|jrtj||ydt|jz }|xj|d|z c_t|jdk(r|j j dt|jt|jdd}|dk7r.|j jd||jn|j j d d d t|jdd dz zz|_ |j j d |j t|jdd dz}||jjvrOtj|jj||_|j j d|nP|j jd||jjj!|jt#t%j&t%j |j(d }d |z|_t-t/|d z dz|jj0zg}|j2j5d|j2j5||j2j5dd|_|j7|j j d|j||d}|r|j|yy)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.dataReceiveds  # # ! . .tT :C 5 566I  ! !T*9%5 5 !4(()Q.Z,T-B-BCT221Q78S=HHMML$" JJLHHNN#]^&'1D4I4I!A4N0OST0T+U%V"t"00T221Q784?T\\666'+yy1J1J61R'SD$HHNNd#)# HHMMb#)$(LL$=$=$B$B$D" JJL%( $((4;Q;QST2U(V$W!#$%6"6 %Y'!+1T5E5E5]5]]0_&` a $$W-$$\2$$[1+/(++-\#// #D!!$'r#N)rHrqrrrsrryr#r!rrs R(r#rceZdZdZdZdZy)rz Twisted-based WAMP-over-RawSocket client protocol. Implements: * :class:`autobahn.wamp.interfaces.ITransport` ctj|tj|jj|_t t jt j|jd}d|z|_ tt|dz dz|jjzg}|jjd|jj||jjdy)Nrrr|rr)rr9rrCr5rrrrErr)rrrr.r)r request_max_len_exprequest_octet2s r!r9z*WampRawSocketClientProtocol.connectionMadefs,,T299T\\%=%=>"$))DHHT5K5KQ,O"PQ00y!A%! +t/?/?/W/W W*Y Z[ W% ^, [)r#c,|jrtj||ydt|jz }|xj|d|z c_t|jdk(r|j j dt|jt|jdddk7rC|j j dt|jd|jd d t|jdd dz zz|_ |j j d |j t|jdd d z}||jjk7rB|j jd||jj|jd|_|j|j j d|j||d}|r|j|yy)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.dataReceivedys  # # ! . .tT :C 5 566I  ! !T*9%5 5 !4(()Q.[/0E0EF t,,Qq12d:HHNNK/0E0Ea0HI#JJL&'1D4I4I!A4N0OST0T+U%V"n**T221Q784?T--EEEHHNNf#)$($4$4$L$L# JJL+/(++-n#// #D!!$'r#N)rHrqrrrsr9rryr#r!rr\s*&6(r#rcLeZdZdZej ZdZdZddZ dZ y)WampRawSocketFactoryzE Base class for Twisted-based WAMP-over-RawSocket factories. c\tr|_d|_yfd|_d|_y)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__s1 G #DM "',DM"'r#cd|_yr)rrs r!resetProtocolOptionsz)WampRawSocketFactory.resetProtocolOptionss !&r#Nc|jjd|jj||t |t k(r |dk\r|dksJ|||j k7r||_yyy)NzI{klass}.setProtocolOptions(maxMessagePayloadSize={maxMessagePayloadSize}))r<maxMessagePayloadSizeir)rErFrGrHtyperr)r rs r!setProtocolOptionsz'WampRawSocketFactory.setProtocolOptionss b!^^44La  c$,6K1LPS1SXmqtXtzOSXzX YY ,1F$J`J`1`%:D "2a ,r#cl|jjd|jj||j }||_|j |_|j |_|jjd|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>>CZCZaef MMO -- "44 !^^44APQPcPcpqp|p|  ~r#r) rHrqrrrsr1rtrEr"rrrryr#r!rrs- %   C '';r#rceZdZdZeZddZy)rzD Twisted-based WAMP-over-RawSocket server protocol factory. Nctj|||g} ddlm}|j |d|j | ddlm}|j |d|j | ddlm}|j |d|j | ddlm}|j |d|j ||s td i|_ |D]}||j|j<y#t $rYwxYw#t $rYwxYw#t $rYwxYw#t $rYmwxYw) 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__sY %%dG4  K C"">$#?@"">#34  F""#4T#BC""#4#67  E""#3D#AB""#3#56  C"">$#?@"">#34 GHHC=@D  c99 :?        sG4D$4D34E;4E$ D0/D03 D?>D? E E EEr)rHrqrrrsrrr"ryr#r!rrs+H6Ar#rceZdZdZeZddZy)rzD Twisted-based WAMP-over-RawSocket client protocol factory. Nc^tj||d|_| ddlm}|}| ddlm}|}| ddlm}|}| ddlm}|}| td||_ y#t $rYPwxYw#t $rYOwxYw#t $rYNwxYw#t $rYMwxYw) 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 %%dG4   C+-    F.0    E-/    C+-   BC C%A        sF A3 B B B 3 A?>A? B B BB B,+B,r)rHrqrrrsrrr"ryr#r!rrs+H7&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!rs6  -7113P0ee3 F"/F"R[("7[([(|R("7R(R(j'7'T=A!5=A=A@>&!5>&>&r#