h^XSSKrSSKrSSKJr SSKrSSKJr SSKJr SSK J r SSK J r SSK JrJr SSKJrJr SS KJr SS KJrJrJrJr SS KJr S r"S S\5r\"SS\55r\"SS\55r"SS\5r \"SS\ 55r!\"SS\ 55r"g)N)Optional)Factory)Int32StringReceiver)ConnectionDone)CancelledError)public_LazyHexFormatter)create_transport_detailstransport_channel_id)TransportDetails) ProtocolErrorSerializationError TransportLostInvalidUriError)PayloadExceededError)WampRawSocketServerProtocolWampRawSocketClientProtocolWampRawSocketServerFactoryWampRawSocketClientFactoryc\rSrSr%Sr\R "5rSr\ \ \ S'Sr \ \ \ S'Sr\S\ \4Sj5rS rS rS rS rS rSrSrSrSrSrg)WampRawSocketProtocol4z= Base class for Twisted-based WAMP-over-RawSocket protocols. Npeer is_serverc SUlSUlgN)_max_message_size_transport_detailsselfs ^C:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\autobahn/twisted/rawsocket.py__init__WampRawSocketProtocol.__init__=s!&"&returncUR$)zJ Implements :func:`autobahn.wamp.interfaces.ITransport.transport_details` )rr s r"transport_details'WampRawSocketProtocol.transport_detailsBs &&&r%cNSRXR5n[U5e)NzqRawSocket connection: length of received message exceeded (message was {} bytes, but current maximum is {} bytes))format MAX_LENGTHr)r!lengthemsgs r"lengthLimitExceeded)WampRawSocketProtocol.lengthLimitExceededIs<CJJKQSbSbc"4((r%c<[URUR5Ul[R URlURRUl[R"5Ul SUl SUl SUl SUlSUlg)NFr%)r transportrrr CHANNEL_FRAMING_RAWSOCKETchannel_framingrtxaio create_future is_closed_session _serializer_handshake_complete_handshake_bytes _max_len_sendr s r"connectionMade$WampRawSocketProtocol.connectionMadeOs #;4>>4>>"Z2B2\2\/++00 ,,.   $) !$"r%cURR(a=S[URURRS50nXRlUR R5UlURRSURURRURRS9 URRU5nURRSURRURUS9 g![aInURRSURRUS9 UR!5 SnAgSnAff=f)Nz tls-uniquez2{klass}._on_handshake_complete(): calling {method})sessionklassmethodz@{klass}._on_handshake_complete(): {session} started (res={res}).)rAr@reszX{klass}._on_handshake_complete(): ApplicationSession constructor / onOpen raised ({err})rAerr)r is_securer r2r channel_idfactory_factoryr8logdebug __class____name__onOpen Exceptionwarnabort)r!rGrCes r"_on_handshake_complete,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  sC D E0'?E++E0cURRSURRUS9 [R "UR U5 [UR[5nUR(aURRU5 SUl g![a9nURRSURRUS9 SnANFSnAff=f)Nz({klass}.connectionLost(reason="{reason}")rAreasonzC{klass}.connectionLost(): ApplicationSession.onClose raised "{err}"rD)rJrKrLrMr5resolver7 isinstancevaluerr8onCloserOrP)r!rVwasCleanrRs r"connectionLost$WampRawSocketProtocol.connectionLosts AI`I`iop dnnd+ @!&,,?H}} %%h/   @ HHMM_ $ 7 7Q  @ @sAB C#*/CC#c8URRSURR[ U5S9 UR R U5HMnURRSURRUS9 URRU5 MO g![a9nURRSURRUS9 SnAgSnAf[aInURRSURRUS9 UR5 SnAgSnAf[aInURRSURRUS9 UR5 SnAgSnAf[aInURRS URRUS9 UR5 SnAgSnAf[ aInURRS URRUS9 UR5 SnAgSnAf["acnURR%5 URRS URRUS9 UR5 SnAgSnAff=f) Nz,{klass}.stringReceived(): RX {octets} octetsrAoctetsz.{klass}.stringReceived: RX WAMP message: {msg})rAmsgzM{klass}.stringReceived: WAMP CancelledError - connection will continue! {err}rDzI{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})rJtracerLrMr r9 unserializer8 onMessagerrKrrPrQr rrrOfailure)r!payloadrarRs r"stringReceived$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  sUA,B'' J1/C%% J2?D66 J?F J?G J%?H)) J6AJJcUR5(GaURRSURRXR S9 UR R U5up#[U5nSURs=:aU:aDO OASRX@R5nURRU5 [U5eURU5 URRSURR[U5S9 g[5e![an[SRU55eSnAff=f) z= Implements :func:`autobahn.wamp.interfaces.ITransport.send` zB{klass}.send() (serializer={serializer}): TX WAMP message: "{msg}")rAra serializerrzQtried to send RawSocket message with size {} exceeding payload limit of {} octetsz"{klass}.send(): TX {octets} octetsr_zIWampRawSocketProtocol: unable to serialize WAMP application payload ({0})N)isOpenrJrbrLrMr9 serializelenr<r+rPr sendStringr rr)r!rarf_ payload_lenr.rRs r"sendWampRawSocketProtocol.sends ;;== HHNN_!%!8!8cN^N^  ` e!--77<  "'l t))7K7nuu#%7%79DHHMM$'.t44OOG,HHNN#G)-)@)@IZ[bIc#e / !& @()t){){|})~ @sD(( E2E  EcURSL$)z? Implements :func:`autobahn.wamp.interfaces.ITransport.isOpen` N)r8r s r"rkWampRawSocketProtocol.isOpens}}D((r%cvUR5(aURR5 g[5e)z> Implements :func:`autobahn.wamp.interfaces.ITransport.close` N)rkr2loseConnectionrr s r"closeWampRawSocketProtocol.closes' ;;== NN ) ) +/ !r%cUR5(aQ[URS5(aURR5 gURR 5 g[ 5e)z> Implements :func:`autobahn.wamp.interfaces.ITransport.abort` abortConnectionN)rkhasattrr2rzrvrr s r"rQWampRawSocketProtocol.abortsI ;;==t~~'899..0--// !r%) r;r:r<rr9r8rr7r)rM __module__ __qualname____firstlineno____doc__r5 make_loggerrJrrstr__annotations__rboolr#propertyr r(r/r=rSr\rgrqrkrwrQ__static_attributes__r%r"rr4s    CD(3- $Ix~$' '8,<#='' ) ""H;2 +Z"4) " "r%rc\rSrSrSrSrSrg)rzu Twisted-based WAMP-over-RawSocket server protocol. Implements: * :class:`autobahn.wamp.interfaces.ITransport` c~UR(a[RX5 gS[UR5- nU=RUSU- sl[UR5S:XGaUR R S[UR5S9 [URSS5nUS:wa+UR RSUS9 UR5 OUR R S 5 S S [URSS 5S- --Ul UR R S URS 9 [URSS 5S-nX@RR;aM[R"URRU5UlUR R SUS9 OMUR RSUURRR!5S9 UR5 [#[$R&"[$R "UR(S 555nS U-Ul[-[/US - S-URR0-/55nUR2R5S5 UR2R5U5 UR2R5S5 SUlUR75 UR R SURS9 XSnU(aURU5 gg)NzDWampRawSocketServerProtocol: opening handshake received - 0x{octets})r`rzmWampRawSocketServerProtocol: 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}'rjzWampRawSocketServerProtocol: opening handshake - no suitable serializer found (client requested {serializer}, and we have {serializers}rj serializersTzFWampRawSocketServerProtocol: opening handshake completed: {serializer})r:r dataReceivedrmr;rJrKr ordrPrQr<rH _serializerscopyr9keysintmathceilrr,bytes bytearrayRAWSOCKET_SERIALIZER_IDr2writerS)r!data remaining_magicser_idreply_max_len_exp reply_octet2s r"r(WampRawSocketServerProtocol.dataReceiveds  # # ! . .t :C 5 566I  ! !T*9%5 5 !4(()Q.Z,T-B-BCT221Q78S=HHMML$" JJLHHNN#]^&'1D4I4I!A4N0OST0T+U%V"t"00T221Q784?\\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%r,r:r<r9N)rMr}r~rrrrrr%r"rrs R(r%rc$\rSrSrSrSrSrSrg)ri\zu Twisted-based WAMP-over-RawSocket client protocol. Implements: * :class:`autobahn.wamp.interfaces.ITransport` c"[RU5 [R"URR5Ul[ [ R"[ R"URS555nSU-Ul [[US- S-URR-/55nURRS5 URRU5 URRS5 g)Nrrrrr)rr=rrHr9rrrrJrr,rrrr2r)r!request_max_len_exprequest_octet2s r"r=*WampRawSocketClientProtocol.connectionMadefs,,T299T\\%=%=>"$))DHHT5K5KQ,O"PQ00y!A%! +t/?/?/W/W W*Y Z[ W% ^, [)r%c"UR(a[RX5 gS[UR5- nU=RUSU- sl[UR5S:XGaUR R S[UR5S9 [URSS5S:wa@UR R S[URS5S9 UR5 S S [URSS 5S- --Ul UR R S URS 9 [URSS 5S -nX0RR:wa?UR RSUURRS9 UR5 SUlUR5 UR R SURS9 XSnU(aURU5 gg)NrzEWampRawSocketClientProtocol: opening handshake received - {handshake}) handshakerrrzpWampRawSocketClientProtocol: 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)r:rrrmr;rJrKr rrQr<r9rerrorrS)r!rrrs r"r(WampRawSocketClientProtocol.dataReceivedys  # # ! . .t :C 5 566I  ! !T*9%5 5 !4(()Q.[/0E0EF t,,Qq12d:HHNNK/0E0Ea0HI#JJL&'1D4I4I!A4N0OST0T+U%V"n**T221Q784?--EEEHHNNf#)$($4$4$L$L# JJL+/(++-n#// #D!!$'r%rN)rMr}r~rrr=rrrr%r"rr\s*&6(r%rcV\rSrSrSr\R "5rSrSr S Sjr Sr Sr g) WampRawSocketFactoryiz= Base class for Twisted-based WAMP-over-RawSocket factories. cZ^[T5(aTUlO U4SjUlSUlg)z :param factory: A callable that produces instances that implement :class:`autobahn.wamp.interfaces.ITransportHandler` :type factory: callable c>T$Nr)rHsr"/WampRawSocketFactory.__init__..sGr%rN)callablerIr)r!rHs `r"r#WampRawSocketFactory.__init__s( G  #DM+DM"'r%cSUlgr)rr s r"resetProtocolOptions)WampRawSocketFactory.resetProtocolOptionss !&r%NcURRSURRUS9 Ub![ U5[ :Xa US:aUS::deUbXR :waXlggg)NzI{klass}.setProtocolOptions(maxMessagePayloadSize={maxMessagePayloadSize}))rAmaxMessagePayloadSizeir)rJrKrLrMtyperr)r!rs r"setProtocolOptions'WampRawSocketFactory.setProtocolOptionss b!^^44La  c$,6K1LPS1SXmqtXtzOSXzX YY ,1FJ`J`1`%: "2a ,r%c\URRSURRUS9 UR 5nXlUR UlUR UlURRSURRX"R URS9 U$)Nz"{klass}.buildProtocol(addr={addr}))rAaddrzf{klass}.buildProtocol() -> proto={proto}, max_message_size={max_message_size}, MAX_LENGTH={MAX_LENGTH})rAprotomax_message_sizer,)rJrKrLrMprotocolrHrr,)r!rps r" buildProtocol"WampRawSocketFactory.buildProtocols ;4>>CZCZaef MMO -- "44 !^^44APcPcpqp|p|  ~r%)rIrr) rMr}r~rrr5rrJr#rrrrrr%r"rrs+    C '';r%rc&\rSrSrSr\rSSjrSrg)riz< Twisted-based WAMP-over-RawSocket server protocol factory. Nc[RX5 Uc/nSSKJn UR U"SS95 UR U"55 SSKJn UR U"SS95 UR U"55 SSKJn UR U"SS95 UR U"55 SSKJn UR U"SS95 UR U"55 U(d [S 5e0Ul UHnXpRUR'M g![ a Nf=f![ a Nf=f![ a Nf=f![ a Nwf=f) 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 ImportErrorrrrrOrr)r!rHrrrrrsers r"r##WampRawSocketServerFactory.__init__sU %%d4  K C"">$#?@"">#34  F""#4T#BC""#4#67  E""#3D#AB""#3#56  C"">$#?@"">#34 GHHC=@  c99 :?        sG1D1D.1D>21E D+*D+. D;:D;> E  E  EE)rr) rMr}r~rrrrr#rrr%r"rrs+H6Ar%rc&\rSrSrSr\rSSjrSrg)riz< Twisted-based WAMP-over-RawSocket client protocol factory. Ncl[RX5 SUlUcSSKJn U"5nUcSSKJn U"5nUcSSKJn U"5nUcSSKJn U"5nUc [S5eX l g![ a NTf=f![ a NSf=f![ a NRf=f![ a NQf=f) 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#noisyrrrrrrrOr9)r!rHrjrrrrs r"r##WampRawSocketClientFactory.__init__%s %%d4   C+-    F.0    E-/    C+-   BC C%A        sF A6 B B B&6 BB BB B#"B#& B32B3)r9rr) rMr}r~rrrrr#rrr%r"rrs+H7&r%r)#rrtypingrr5twisted.internet.protocolrtwisted.protocols.basicrtwisted.internet.errorrtwisted.internet.deferr autobahn.utilrr autobahn.twisted.utilr r autobahn.wamp.typesr autobahn.wamp.exceptionr rrrautobahn.exceptionr__all__rrrrrrrr%r"rs6  -7113P0ee3 F"/F"R[("7[([(|R("7R(R(j'7'T=A!5=A=A@>&!5>&>&r%