8'hC$ddlmZ ddlZddlZddlZddlZddlm Z m Z ddl m Z m Z mZddlmZmZddlZdZej(dZdZdZd ZGd d ej2ZGd d eZdZddddddZGddeZGddeZ GddeZ!Gdde"Z#Gdde"Z$e Gdde#e$e!Z%e Gd d!e#e$e Z&Gd"d#e"Z'e Gd$d%e'Z(e Gd&d'e'Z)y#e$rddlZYwxYw)()absolute_importN)public_LazyHexFormatter) ProtocolErrorSerializationError TransportLost)peer2strget_serializers)WampRawSocketServerProtocolWampRawSocketClientProtocolWampRawSocketServerFactoryWampRawSocketClientFactoryceZdZdZej eZdZeZe jZ dZ e dZdZdZdZdZd Zd Zd Zd Zy )PrefixProtocolz!Lc||_|jd}t||_|jj d|jd|_d|_tj|_ y)Npeernamez3RawSocker Asyncio: Connection made with peer {peer})peer) transportget_extra_infor rlogdebug_buffer_headertxaio create_future _wait_closed)selfrrs V/var/www/html/trade_iq/venv/lib/python3.12/site-packages/autobahn/asyncio/rawsocket.pyconnection_madezPrefixProtocol.connection_madeCs_"'' 3TN  LSWS\S\]  !//1rct|dr |jStj}|j d|S)Nr!T)hasattrr!rr set_result)r"fs r# is_closedzPrefixProtocol.is_closedLs7 4 ($$ $##%A LL Hrc|jjdd|_|jj d|j |y)Nz"RawSocker Asyncio: Connection lostT)rrrr!r'_on_connection_lostr"excs r#connection_lostzPrefixProtocol.connection_lostUs< ;< $$T*   %rcyNr,s r#r+z"PrefixProtocol._on_connection_lost[s rcn|jj||jjyr0)rerrorrclose)r"msgs r#protocol_errorzPrefixProtocol.protocol_error^s" s rc t|}||jkDr tdtj|j t|}|j j||j j|y)Nz Data too big)lenmax_length_send ValueErrorstructpack prefix_formatrwrite)r"datalheaders r# sendStringzPrefixProtocol.sendStringbsb I t## #^, ,T//T; V$ T"rctr0NotImplementedErrorr"r?s r#pingzPrefixProtocol.pingj !##rctr0rDrFs r#pongzPrefixProtocol.pongmrHrc~|xj|z c_d}t|j}||jk\rm|jr|j\}}n|j|||jz}t |dddz}|t kDr|j dytj|jd|ddzd}||jkDr|j dy||jz |k\rd|_||jz }||jz}|j|||z}||z }||z}|tk(r|j|n@|tk(r|j|n%|t k(r|j|n ||f|_n||jk\rm|j|d|_y)NrrzInvalid frame typez Frame too big)rr8 prefix_lengthrordFRAME_TYPE_PONGr6r;unpackr= max_lengthFRAME_TYPE_DATAstringReceivedFRAME_TYPE_PINGrGrJ)r"r?pos remaining frame_type frame_lengthrAs r# data_receivedzPrefixProtocol.data_receivedps   % 4---||+/<<( Lc#0B0B*BC !- : /''(<=%}}T-?-?PQPRASTUVW $//1''84---=# t)))T/// ||Cl(:;|#\) 0''-?2IIdO?2IIdO *<7 A4---D||CD) rctr0rDrFs r#rTzPrefixProtocol.stringReceivedrHrN)__name__ __module__ __qualname__r=r;calcsizerNrRr9r make_loggerrr$propertyr)r.r+r6rBrGrJrZrTr1rr#rr;ssM#FOOM2M!J O %   C2&  #$$&*P$rrc0eZdZdZdZdZdZdZdZy)RawSocketProtocolcd}|rZttjtj|ddz }|dkDr t dd|dzz|_||_yd|_d|_y)Nr zMaximum length is 16Mr)intmathceilrr:rR _length_exp)r"max_sizeexps r#__init__zRawSocketProtocol.__init__sf dii1 567!;CRx !899#'lDO"D !D #DOrc>tj||d|_y)NF)rr$_handshake_done)r"rs r#r$z!RawSocketProtocol.connection_mades&&tY7$rctr0rDr"s r#_on_handshake_completez(RawSocketProtocol._on_handshake_completerHrct|jdd}|dtk7r td|ddz}|ddz }d|dzz|_|ddk7s|ddk7r td ||fS) NrzInvalid magic byte in handshakerrfrrezReserved bytes must be zero) bytearrayr MAGIC_BYTEHandshakeErrorr9)r"bufserlexps r#parse_handshakez!RawSocketProtocol.parse_handshakes Ra() q6Z  !BC C!ftm1v{ 4!8} q6Q;#a&A+ !>? ?Dyrctr0rDrqs r#process_handshakez#RawSocketProtocol.process_handshakerHrc |jjdt||jrtj ||S|xj |z c_t|j dk\rX |jd|_|j|j dd}d|_|rtj ||yyy#t$r+}|jdj|Yd}~yd}~wwxYw)Nz'RawSocker Asyncio: data received {data})r?rtzHandshake error : {err}errTr) rrrrorrZrr8r~rxr6formatrr)r"r?es r#rZzRawSocketProtocol.data_receiveds @GXY]G^_   !//d; ; LLD L4<< A%**,(,$++-||AB'" "00t<&&''(A(H(HQ(H(OPs7C D!C>>DN) r\r]r^rmr$rrr|r~rZr1rr#rcrcs  $%$ $=rrczillegal (must not be used)zserializer unsupportedz#maximum message length unacceptablez*use of reserved bits (unsupported feature)z maximum connection count reached)rrrrurtceZdZddZy)rxcttj||s|y|dtj|zzy)Nz : %s) ExceptionrmERRMAPget)r"r5codes r#rmzHandshakeError.__init__s-4DWcGfjjQUFVrr)r"rhss r#r$z'RawSocketClientProtocol.connection_madesg))$ : 9j"..!3d6H6HH$%&  ABrN)r\r]r^rr~rarr$r1rr#rrs'F$$CrrceZdZdZdZy)RawSocketServerProtocolctr0rDrs r#supports_serializerz+RawSocketServerProtocol.supports_serializerrHrcfd}j\}}j|s(|tdtdj ||j |y)Nc |dz|dzz}jjttt|ddgy)Nrtrfr)rr>rrvrw)r{rb2r"s r# send_responsez@RawSocketServerProtocol.process_handshake..send_responses:ftm,B NN y*b!Q1G'H!I Jrrz!Serializer unsupported : {ser_id})r)r|rERR_SERIALIZER_UNSUPPORTEDrxrrj)r"rr_lexps` r#r~z)RawSocketServerProtocol.process_handshakesa K,,. ''/ 4a 8 !D!K!KSY!K!Z[ [d&&/rN)r\r]r^rr~r1rr#rrs $0rrc$eZdZdZdZdZdZy)WampRawSocketMixinGeneralcl|jjd |jj|_|jj ||jj dy#t$r7}|jjd||jYd}~yd}~wwxYw)Nz)WampRawSocketProtocol: Handshake completezApplicationSession started.zMWampRawSocketProtocol: ApplicationSession constructor / onOpen raised ({err})r) rrfactory_factory_sessiononOpeninforwarnabort)r"rs r#rrz0WampRawSocketMixinGeneral._on_handshake_completes BC 9 LL113DM MM  & HHMM7 8   HHMMiopM q JJLL s:A33 B3<-B..B3c|jjdt| |jj |D]:}|jjd||j j |<y#t$r7}|jjd||jYd}~yd}~wt$r7}|jjd||jYd}~yd}~wwxYw)Nz*WampRawSocketProtocol: RX octets: {octets}octetsz-WampRawSocketProtocol: RX WAMP message: {msg}r5zHWampRawSocketProtocol: WAMP Protocol Error ({err}) - aborting connectionrzHWampRawSocketProtocol: WAMP Internal Error ({err}) - aborting connection) rrr _serializer unserializer onMessagerrrr)r"payloadr5rs r#rTz(WampRawSocketMixinGeneral.stringReceiveds CL]^eLfg ''33G< -NTWX '', -  HHMMdjkM l JJLL  HHMMdjkM l JJLL s$AB C? -B<< C?-C::C?ct|jrt|jjd| |jj |\}}|j ||jjdt |yt#t$r}tdj|d}~wwxYw)zM Implements :func:`autobahn.wamp.interfaces.ITransport.send` z-WampRawSocketProtocol: TX WAMP message: {msg}rz*WampRawSocketProtocol: TX octets: {octets}rzIWampRawSocketProtocol: unable to serialize WAMP application payload ({0})N) isOpenrrr serializerBrrrrr)r"r5r_rs r#sendzWampRawSocketMixinGeneral.send-s ;;= HHNNJPSN T p!--77<  (KTefmTno/ ! 5()t*0&)55 5sB B7B22B7c:t|dxr|jduS)zO Implements :func:`autobahn.wamp.interfaces.ITransport.isOpen` rN)r&rrqs r#rz WampRawSocketMixinGeneral.isOpen?stZ(FT]]$-FFrN)r\r]r^rrrTrrr1rr#rrs 9 "$Grrc"eZdZdZdZdZdZy)WampRawSocketMixinAsynciozE Base class for asyncio-based WAMP-over-RawSocket protocols. c |du}|jj|d|_y#t$r.}|jj d|Yd}~d|_yd}~wwxYw)Nz@WampRawSocketProtocol: ApplicationSession.onClose raised ({err})r)ronCloserrr)r"r-wasCleanrs r#r+z-WampRawSocketMixinAsyncio._on_connection_lostLs` ed{H MM ! !( +  e HHMM\bcM d d  es) A AA cl|jr|jjyt)zN Implements :func:`autobahn.wamp.interfaces.ITransport.close` N)rrr4rrqs r#r4zWampRawSocketMixinAsyncio.closeUs% ;;= NN "/ !rc|jrLt|jdr|jjy|jj yt )zN Implements :func:`autobahn.wamp.interfaces.ITransport.abort` rN)rr&rrr4rrqs r#rzWampRawSocketMixinAsyncio.abort^sC ;;=t~~w/$$&$$&/ !rN)r\r]r^__doc__r+r4rr1rr#rrGs" "rrceZdZdZdZddZy)r z asyncio-based WAMP-over-RawSocket server protocol. Implements: * :class:`autobahn.wamp.interfaces.ITransport` cr||jjvrOtj|jj||_|jj d|y|jj d||jjj |jy)NzDWampRawSocketProtocol: client wants to use serializer '{serializer}') serializerTzWampRawSocketProtocol: opening handshake - no suitable serializer found (client requested {serializer}, and we have {serializers})r serializersF)r _serializerscopyrrrkeysrrs r#rz/WampRawSocketServerProtocol.supports_serializervs T\\.. .#yy)B)B6)JKD  HHNNV!   HHNNT! LL55::<   JJLrcyzW Implements :func:`autobahn.wamp.interfaces.ITransport.get_channel_id` Nr1r"channel_id_types r#get_channel_idz*WampRawSocketServerProtocol.get_channel_idrNz tls-unique)r\r]r^rrrr1rr#r r ls"rr c(eZdZdZedZddZy)r z asyncio-based WAMP-over-RawSocket client protocol. Implements: * :class:`autobahn.wamp.interfaces.ITransport` ct|ds.tj|jj|_|jjS)Nr)r&rrrRAWSOCKET_SERIALIZER_IDrqs r#rz)WampRawSocketClientProtocol.serializer_ids9t]+#yy)A)ABD 777rcyrr1rs r#rz*WampRawSocketClientProtocol.get_channel_idrrNr)r\r]r^rrarrr1rr#r r s 88 rr cBeZdZdZej ZedZy)WampRawSocketFactoryzm Adapter class for asyncio-based WebSocket client and server factories.def dataReceived(self, data): c4|j}||_|Sr0)protocolr)r"protos r#__call__zWampRawSocketFactory.__call__s   rN) r\r]r^rrr`rrrr1rr#rrs+ %   C  rrceZdZdZeZddZy)r zD asyncio-based WAMP-over-RawSocket server protocol factory. Nctr|_n fd|_|t}|s td|Dcic]}|j|c}|_ycc}w)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` cSr0r1rsr#z5WampRawSocketServerFactory.__init__..GrNz%could not import any WAMP serializers)callablerr rrr)r"rrrzs ` r#rmz#WampRawSocketServerFactory.__init__s[ G #DM+DM  )+K GHHITU#S88#=UUsAr0)r\r]r^rr rrmr1rr#r r s+HVrr ceZdZdZeZddZy)rz; asyncio-based WAMP-over-RawSocket client factory. Nctr|_n fd|_|t}|r |d}| td||_y)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` cSr0r1rsr#rz5WampRawSocketClientFactory.__init__..rrNrz$could not import any WAMP serializer)rrr rr)r"rrrs ` r#rmz#WampRawSocketClientFactory.__init__sV G #DM+DM  )+K+[^-  BC C%rr0)r\r]r^rr rrmr1rr#rrs+H&rr)* __future__rasyncio ImportErrortrolliusr;rhr autobahn.utilrrautobahn.wamp.exceptionrrrautobahn.asyncio.utilr r r__all__ use_asynciorSrUrPrwProtocolrrcrrrrxrrobjectrrr r rr rr1rr#rs6' 3TT;    ^$W%%^$B5=5=p$,3)  XYX C/C6 0/ 0"3G3Gn""""J";=VXoD";=VXo. 6 V!5VVD!&!5!&!&u sD DD