<j^ ^SrSSKJr SSKrSSKrSSKrSSKJrJr SSK J r SSK J r J r \ (a SSKJr SS KJr \"S 5V^s/sHm\"U4S j\"S 555PM snr"S S 5r"SS5rSrSrSrSrSr\rSrSrSrSr Sr!Sr"Sr#"SS\ 5r$"SS\ 5r%\%RL\%RN\%RP4r)Sr*Sr+Sr,S r-S!r.S"r/S#r0S#r1\Rd"S$S5r3"S%S&\45r5"S'S(\ 5r6"S)S*\ 5r7"S+S,\ 5r8S6S-jr9"S.S/5r:"S0S15r;"S2S35r<"S4S55r=gs snf)7zY wsproto/frame_protocol ~~~~~~~~~~~~~~~~~~~~~~ WebSocket frame protocol implementation. ) annotationsN)IncrementalDecodergetincrementaldecoder)IntEnum) TYPE_CHECKING NamedTuple) Generator) Extensionc3,># UH oT- v M g7fN).0abs g/root/GenerationalWealth/GenerationalWealth/venv/lib/python3.13/site-packages/wsproto/frame_protocol.py rs.:aE:sc(\rSrSrSSjrSSjrSrg)XorMaskerSimplecXlgr _masking_key)self masking_keys r__init__XorMaskerSimple.__init__s'c[U5nU(aUnSUR5up4pVUSSS2RU5USSS2'USSS2RU5USSS2'USSS2RU5USSS2'USSS2RU5USSS2'[U5S-nURUSURSU-UlU$U$)Nc34# UHn[Uv M g7fr) _XOR_TABLE)rns rr*XorMaskerSimple.process..!sC1BA*Q-1Bsr ) bytearrayr translatelen)rdata data_arrayrrcd key_rotations rprocessXorMaskerSimple.processs JC1B1BCJA!(1o77:JssO)!$Q$/99![TU]U5 X lgr)superrcode)rmsgrr __class__s rrParseFailed.__init__s  r)rr)rsstrrrr\r2r3) r5r6r7r8r\rarr9 __classcell__)rts@rrnrns.,7,F,F) rrnc4\rSrSr%S\S'S\S'S\S'Srg)RsvBitsrOrsv1rsv2rsv3rNr5r6r7r8__annotations__r9rrrryrys J J JrrycH\rSrSr%S\S'S\S'S\S'S\S 'S \S 'S rg )HeaderrOfinryrsvrIopcodeint payload_len bytes | NonerrNr~rrrrrs I L Nrrc>\rSrSr%S\S'S\S'S\S'S\S'S rg ) FramerIrzbytes | str | tuple[int, str]payloadrOframe_finishedmessage_finishedrNr~rrrrrs N **rrcl[U5U::aU$USUnURSSS9RS5$)Nutf-8ignore)errors)r*decodeencode)r+nbytess r_truncate_utf8rs@ 4yF  =D ;;wx; 0 7 7 @@rc^\rSrSrS S SjjrS SjrSSjrSSjrSSjrSSjr SS jr S r g)BufferiNcb[5UlSUlU(aURU5 ggNr)r(buffer bytes_usedfeed)r initial_bytess rrBuffer.__init__s&k   IIm $ rc.U=RU- slgr)r)r new_bytess rr Buffer.feeds y rcU(d [5$URURURU-nU=R[U5- slU$r)r(rrr*)rrr+s rconsume_at_mostBuffer.consume_at_most sA; {{4??T__v-EF 3t9$ rcr[UR5UR- U:agURU5$r)r*rrr)rrs rconsume_exactlyBuffer.consume_exactlys0 t{{ doo - 6##F++rcDURSUR2 SUlgrrrrPs rcommit Buffer.commits KK)$//) *rcSUlgr)rrPs rrollbackBuffer.rollbacks rc,[UR5$r)r*rrPs r__len__Buffer.__len__!s4;;rrr)rrr2r3)rbytesr2r3)rrr2r()rrr2zbytearray | Noner2r3)r2r) r5r6r7r8rrrrrrrr9rrrrrs%% !,   rrc(\rSrSrSSjrSSjrSrg)MessageDecoderi%c SUlSUlgr)rdecoderrPs rrMessageDecoder.__init__&s%) 26 rcURR5(aeURc<UR[RLa Sn[ U5eURUlO8UR[RLaSUR<3n[ U5eUR[R La[ S5"5UlUR=(a URnURc URnON[UR[[45(deURRURU5n['URXARU5nU(aSUlSUlU$![a(n[ [!U5["R$5eSnAff=f)Nzunexpected CONTINUATIONzexpected CONTINUATION, got r)rrQrIrUrnrVrrrrr isinstancerr(rUnicodeDecodeErrorrvr\rer)rframersfinishedr+excs r process_frameMessageDecoder.process_frame*s_<<))++++ ;; ||v222/!#&&,,DK \\!4!4 4/ /?@Cc" " <<6;; &09;DL''BE,B,B << ==DemmeY-?@@ @@ T||**5==(Cdkk4)=)=xH DKDL & T!#c(K,R,RSS Ts6&F G#GG)rrNrrrr2r)r5r6r7r8rrr9rrrrr%s 7 rrc|\rSrSrS S SjjrS SjrS SjrSSjrSSjrSSjr S r g) FrameDecoderiMNcXlU=(d /Ul[5UlSUlSUlSUlSUlSUlgr) client extensionsrrheadereffective_opcodemaskerpayload_requiredpayload_consumed)rrrs rrFrameDecoder.__init__NsD $*h %) /3>B ! !rc:URRU5 gr)rrr>s r receive_bytesFrameDecoder.receive_bytes\s rcUR(dUR5(dgURceURceURce[ UR 5UR :agURRUR- nUR RU5nU(dURRS:agUR R5 U=R[ U5- slURURR:HnURRU5nURHKnURU[U55n[U[ 5(a Sn[#Xe5e[%U5nMM U(aq[%5nURHSnUR'XRR(5n[U[ 5(a Sn[#Xh5eUcMOXx- nMU X'- n[+UR[U5X0RR(5n U(aSUlSUlSUlU $[,R.UlU $)Nrerror in extension)r parse_headerrrr*rrrrrrr0rframe_inbound_payload_datarrr\rnr(frame_inbound_completerrrIrU) rpayload_remainingrr extensionpayload_rsfinalresultrs rprocess_bufferFrameDecoder.process_buffer_s{{4#4#4#6#6{{&&&{{&&&$$000 t{{ d33 3 KK33d6K6KK++--.?@4;;22Q6  W-((DKK,C,CC++%%g.I ;;D%.QH(K00*!#00)G ) KE!__ "99$ Pfk22.C%c22%OE -  Gd++U7^X{{W DK$(D !DK %+$7$7D ! rcURRS5nUcURR5 g[US[-5n[ [US[ -5[US[-5[US[-55nUS[-n[U5nUR5(aU(d Sn[U5e[US[-5nUS[-nUR!XG5nUcURR5 gUR#XCU5 U(aUR$(a Sn[U5eU(dUR$(d S n[U5eU(aJURRS 5n U cURR5 g['U 5UlO[+5UlURR-5 [/X#XHS5UlUR0R2UlUR0R2R5(aXlOSUlSUlg ![a SUS3n[U5ef=f) Nr&FrzInvalid opcode z#xz)Invalid attempt to fragment control framer z'client received unexpected masked framez)server received unexpected unmasked framer%T)rrrrOFIN_MASKry RSV1_MASK RSV2_MASK RSV3_MASK OPCODE_MASKrI ValueErrorrnrQ MASK_MASKPAYLOAD_LEN_MASKparse_extended_payload_lengthextension_processingrrrr;rrrrrrr) rr+rrrrshas_maskpayload_len_shortrrs rrFrameDecoder.parse_headers!{{**1- < KK "47X%& a9$ % a9$ % a9$ %  a;& #F^F     c=Cc" "Q)+, G&6688S   KK " !!&{;  ;Cc" " =Cc" " ++55a8K" $$&)+6DK'/DK SvDA $ 2 2 ;;   ' ' ) )$/ !$%D ! !Q ##F2;/Cc" " #s " I((JcUR5(aU[:a Sn[U5eU[:XaRURR S5nUcg[ R"SU5unU[::a Sn[U5eU$U[:XafURR S5nUcg[ R"SU5unU[::a Sn[U5eUS- (a S n[U5eU$) Nz$Control frame with payload len > 125r&!Hz6Payload length used 2 bytes when 1 would have sufficedrK!Qz6Payload length used 8 bytes when 2 would have sufficed?z'8-byte payload length with non-zero MSB) rQMAX_PAYLOAD_NORMALrnPAYLOAD_LENGTH_TWO_BYTErrstructunpackPAYLOAD_LENGTH_EIGHT_BYTEMAX_PAYLOAD_TWO_BYTE)rrrrsr+s rr*FrameDecoder.parse_extended_payload_lengths     +0B"B8Cc" " 1 1;;..q1D|#]]46N[00N!1*!5 5;;..q1D|#]]46N[22N!b @!#&&rc>/SQnURHXnURXX#5n[U[5(a Sn[ Xv5e[ U5HupU (dMSXH'M MZ [ XB5H"upU (dMU (aMSn[ U5e g)N)FFFrTzReserved bit set unexpectedly)rframe_inbound_headerrr\rn enumeratezip) rrrrrsv_usedrrrsbitusedexpectedfounds rr!FrameDecoder.extension_processings)I33D#SF&+..*!#..&v. 4$(HM/ ) #81OHuXX5!#&& 2r)rrrrrrrrr)rrOrzlist[Extension] | Noner2r3r+rr2r3)r2z Frame | NonerS)rrIrrr2 int | None)rrIrryrrr2r3) r5r6r7r8rrrrrrr9rrrrrMsvAE " "(> "  "1f7r  +.   D''#*'9<' 'rrc\rSrSrSSjrSSjrSSjrSSjrSSjrSSSjjr SSS jjr SSS jjr SSS jjr SS jr SSS jjrSrg) FrameProtocolicXlUVs/sHo3R5(dMUPM snUl[URUR5Ul[ 5UlUR5UlSUl gs snfr) renabledrr_frame_decoderr_message_decoder_parse_more_gen _parse_more_outbound_opcode)rrrexts rrFrameProtocol.__init__sf *4F*3 3*F+4;;H . 0//1/3Gs BBc4URn[U[[45(deU(d[R S4nO[ U5S:Xa Sn[U5e[R"SUSS5unU[:d U[:a Sn[U5e[R"[5 [ U5nSSS5 U[;a Sn[U5e[U[5(dU[ ::a Sn[U5eUSSR#S 5nXE4n[+UR,X!R.UR05$!,(df  N=f![$a+n[S ['U5-[R(5eSnAff=f) Nr zCLOSE with 1 byte payloadrr&zCLOSE with invalid codez#remote CLOSE with local-only reasonz CLOSE with unknown reserved coderzError decoding CLOSE reason: )rrrr(r\rcr*rnrrMIN_CLOSE_REASONMAX_CLOSE_REASON contextlibsuppressrLOCAL_ONLY_CLOSE_REASONSMAX_PROTOCOL_CLOSE_REASONrrrvrerrrr)rrr+rsrrreasonrs r_process_closeFrameProtocol._process_close sd}}$ 23333 ..3D Y!^-Cc" "mmD$r(3GT&&$1A*A/!#&&$$Z0"4(1//;!#&&dK00T=V5V8!#&& ab1 >DU\\4)=)=u?U?UVV#10& !3c#h>:: s$7 EE" E" F,&FFc## URVs/sHoR5(dMUPM snUlSnU(dURR5nUblURR 5(dUR RU5nO1UR[R:XaURU5nSnUv U(dMggs snf7f)NFT) rrrrrrQrrrIrXr)rr closedrs rrFrameProtocol._parse_more_gen.s +///K/3[[]3/K''668E ||--// 11??FE\\V\\1 //6E!FK&LsC!CCB%C!C!c:URRU5 gr)rrr>s rrFrameProtocol.receive_bytesCs ))$/rc#D# URH nUc gUv M g7fr)r )revents rreceived_framesFrameProtocol.received_framesFs"%%E} &s Nc~[5nU[RLaSnUcU(a Sn[U5eU[;a[R nUbKU[[ R"SU55- nUb%U[URS5[S- 5- nUR[RU5$)Nz&cannot specify a reason without a coderrr&)r(r\rc TypeErrorrr_rpackrrr_serialize_framerIrX)rrrrrrss rcloseFrameProtocol.closeMs+ ;-- -D MM'*,>,B$$V\\7;;rcBUR[RU5$r)r$rIrYrrs rpingFrameProtocol.ping_$$V[['::rcBUR[RU5$r)r$rIrZr(s rpongFrameProtocol.pongbr+rc[U[[[45(a[R nOD[U[ 5(a"[RnURS5nO Sn[U5eURcX0l O,URULa Sn[U5e[RnU(aSUl URX1U5$)NrzMust provide bytes or textz!Data type mismatch inside message) rrr( memoryviewrIrWrvrVrr"r rUr$)rrrrrss r send_dataFrameProtocol.send_dataes gy*= > >]]F  % %[[FnnW-G.CC.  ($* !  " "& 05CC. ((F $(D !$$Vc::rc[U5S-n[UR5S-[UR5S--[UR5S--n[U5nXE-U-$)Nr%)rr{r|r})rrrrfin_bitsrsv_bits opcode_bitss r_make_fin_rsv_opcode"FrameProtocol._make_fin_rsv_opcode~s]s8q=MQ&3sxx=A+=>#chh-STBTU&k "[00rc H[U5n[SSS5n[UR5H"nUR XU[ U5U5upBM$ UR X4U5n[U5nSnU[::aUn Sn OU[::a [n Un O [n Un SnUR(aU S-n [Xi/5n U bpUR5(a Sn [U 5eU(a$U [[R "SU 55- n O#U [[R "SU 55- n UR(aR[["R$"S55n ['U 5n[X-UR)[U55-5$[X-5$)NFTrCz"payload too long for control framerrr%)r(ryreversedrframe_outboundrr:r*rrrrrrQrrr#osurandomrr0)rrrrrrfin_rsv_opcodepayload_length quad_payload first_payloadsecond_payloadrrsrrs rr$FrameProtocol._serialize_framesrG$eUE*!$//2I$33D#uW~WZC3223VDW / /*M!N 3 33M+N5M+NL ;; V #MN:;  %!!: o%)FKKn$EFF)FKKn$EFF ;;$BJJqM2K$[1FV1FNN9WCU4VVW W)**r)rrr r rr)rrOrzlist[Extension]r2r3r)r2z#Generator[Frame | None, None, None]r)r2zGenerator[Frame, None, None])NN)rrrrz str | Noner2r()r)rrr2r()rT)rzbytes | bytearray | strrrOr2r()rrOrryrrIr2r)rrIrzbytes | bytearrayrrOr2r()r5r6r7r8rrrrrr%r)r-r1r:r$r9rrrrrs 4!WF*0<$;;CG;.;;?; ;21MQ5+5+'85+EI5+ 5+5+rr)r+rrrr2r)>rT __future__rrr?rcodecsrrenumrtypingrrcollections.abcr rr rangerr"rr;rrrrMAX_PAYLOAD_EIGHT_BYTEMAX_FRAME_PAYLOADrrrrrrrrIr\rcrdrlrrMIN_PROTOCOL_CLOSE_REASONrMIN_LIBRARY_CLOSE_REASONMAX_LIBRARY_CLOSE_REASONMIN_PRIVATE_CLOSE_REASONMAX_PRIVATE_CLOSE_REASONrr# NULL_MASK Exceptionrnryrrrrrrr)rsprrVs # <,)%9>c C 1e.5:.. C 2 "*        !W!6T 'T r  $$   KKa )j ZJ A! ! H%%Po'o'd{+{+SDs "E