+ iY2a0t$^RIHt^RIt^RIt^RIt^RIt^RIt^RIt^RI H t H t ^RI H t ^RIHtHt^RI Ht^RIHt.R"Ot!R R]P.4t]P2t]P6t]P:t]P>t ]PBt"]PFt$]]]3t%] ]"]$3t&!R R ]P.4t']'PPR]'PRR]'PTR]'PVR]'PXR]'PZR]'P\R]'P^R]'P`R]'PbR]'PdR]'PfR]'PhR]'PjR]'PlR/t7R]8R&]'PP]'PR]'PT]'PV]'P\]'P^]'P`]'Pb]'Pd]'Pf]'Ph]'Pj0 t9]'PP]'PR]'PX0t:]Pv!RR 44t<]Pv!R R 44t=^R!I>H?t?R# ]d ^RIHtEL.i;i)#) annotationsN) GeneratorSequence)Callable) PayloadTooBig ProtocolError) BytesLike) apply_maskOpcode CloseCodeFrameClosec6]tRt^&tRt^^^uttt^^ ^ utt t Rt R#)r z#Opcode values for WebSocket frames.N) __name__ __module__ __qualname____firstlineno____doc__CONTTEXTBINARYCLOSEPINGPONG__static_attributes__rX/home/wkmabra/.openclaw/workspace/venv/lib/python3.14/site-packages/websockets/frames.pyr r &s%-tTD$dDE4rcV]tRt^8tRtRtRtRtRtRt Rt Rt R t R t R tR tR tRtRtRtRtR#)r z-Close code values for WebSocket close frames.iiiiiiiiiiiiiiirN)rrrrrNORMAL_CLOSURE GOING_AWAYPROTOCOL_ERRORUNSUPPORTED_DATANO_STATUS_RCVDABNORMAL_CLOSURE INVALID_DATAPOLICY_VIOLATIONMESSAGE_TOO_BIGMANDATORY_EXTENSIONINTERNAL_ERRORSERVICE_RESTARTTRY_AGAIN_LATER BAD_GATEWAY TLS_HANDSHAKErrrrr r 8sT7NJNNLONOOKMrOKz going awayzprotocol errorzunsupported datazno status received [internal]zabnormal closure [internal]zinvalid frame payload datazpolicy violationzmessage too bigzmandatory extensionzinternal errorzservice restartztry again laterz bad gatewayz TLS handshake failure [internal]zdict[int, str]CLOSE_CODE_EXPLANATIONSc]tRt^zt$RtR]R&R]R&RtR]R&R tR]R &R tR]R &R t R]R &] !] PPR R44tRRlt]RRRR/RRll4tRR/RRlltRRltRtR#)r a" WebSocket frame. Attributes: opcode: Opcode. data: Payload data. fin: FIN bit. rsv1: RSV1 bit. rsv2: RSV2 bit. rsv3: RSV3 bit. Only these fields are needed. The MASK bit, payload length and masking-key are handled on the fly when parsing and serializing frames. r opcoder dataTboolfinFrsv1rsv2rsv3WEBSOCKETS_MAX_LOG_SIZE75cV^8dQhRR/#returnstrr)formats"r __annotate__Frame.__annotate__s090909rc Rp\VP4 R\VP4^8XdRMR 2pVP'dRMRpVP\Jd/\ \ VP4P44pEMVP\JdVPp\V4VP^,8dCVP^,^, ^,pRPVR^V,RWV)R.4pRPR V44pMVP\Jd*\\PVP44pMDVP'd1\ \ VP4P44pR pMR p\V4VP8d8VP^,^, pVR^V,R,WF)R,pRP\#RWV.44pVPP$ RV RV R2# \\ 3dTPp\T4TP^,8dCTP^,^, ^,pRPTR^T,RYV)R.4pRPR T44pR pEL*i;i)z5 Return a human-readable representation of a frame. Nz bytes continuedrs c3("TFqR xK R#5i02xNr.0bytes& r Frame.__str__..s=fdCjMftextc3("TFqR xK R#5irIrrKs& rrNrOsA&$* &rPbinaryz''z...z, z [])lenr3r5r2OP_TEXTreprbytesdecode OP_BINARY MAX_LOG_SIZEjoinOP_CLOSEr?rparseUnicodeDecodeErrorAttributeErrorfiltername)selfcodinglength non_finalr3rScutmetadatas& r__str__ Frame.__str__s[  N#5s499~/B(LM(((B ;;' !dii(//12D [[I %YYF6{T..!33((A-1a76)AG#4k6$%="QR88=f==D [[H $u{{499-.D YYY "E$)),3356D t9t(( (##q(1,C !c'?U*T$%[8D99VD69*EFG++""#1TF"XJa88!'7 "v;!2!2a!77,,1A5!;C XXviC'8+vde}&UVFxxA&AA!  "s=.H;;BKKmax_sizeN extensionsc ,V^8dQhRRRRRRRRR R /#) r= read_exactz9Callable[[int], Generator[None, None, bytes | bytearray]]maskr4rkz int | Nonerl%Sequence[extensions.Extension] | Noner>zGenerator[None, None, Frame]r)r@s"rrArBsCGGMG G  G : G &Grc# "V!^4RjxL p\P!RV4wrgV^,'dRMRpV^@,'dRMRp V^ ,'dRMRp V^,'dRMRp \V^,4p T^,'dRMRT8wd \ R4hT^,pT^~8Xd+T!^4RjxL p\P!RT4wpM0T^8Xd*T!^4RjxL p\P!RT4wpTeY8d \ Y4hT'dT!^4RjxL pT!T4RjxL pT'd \ TX4pT!YYY4pTf.p\T4FpTPTTR 7pK TP4T#EL \dp \ R4T hRp ? ii;iEL LLL5i) aq Parse a WebSocket frame. This is a generator-based coroutine. Args: read_exact: Generator-based coroutine that reads the requested bytes or raises an exception if there isn't enough data. mask: Whether the frame should be masked i.e. whether the read happens on the server side. max_size: Maximum payload size in bytes. extensions: List of extensions, applied in reverse order. Raises: EOFError: If the connection is closed without a full WebSocket frame. PayloadTooBig: If the frame's payload size exceeds ``max_size``. ProtocolError: If the frame contains incorrect values. N!BBTFzinvalid opcodezincorrect masking!Hz!Q)rk) structunpackr ValueErrorrrr reversedrYcheck)clsrnrorkrlr3head1head2r5r6r7r8r2excre mask_bytesframe extensions&&$$$ rr^ Frame.parses:%Q-'}}UD1 j((dez))tuz))tuz))tu ;EJ./FJ&&DEd : 34 4# S=(m+D dD1IV s](m+D dD1IV  F$51 1 $.qM1J%V,, dJ/DF#T8  J!*-I$$UX$>E.   W( ; 01s : ;,, 2-s GF0>GG!G4G9F3 G/G G 0G:G;9G5 GGGG GAG3 G> G  GGGGGc$V^8dQhRRRRRR/#)r=ror4rlrpr>rXr)r@s"rrArBs*:!:!:!: :!  :!rc VP4Vf.pVFpVPV4pK \P!4pVP'd^M^VP 'd^@M^,VP 'd^ M^,VP'd^M^,VP,pV'd^M^p\VP4pV^~8d/VP\P!RWVV,44MdVR8d0VP\P!RWV^~,V44M.VP\P!RWV^,V44V'd(\P!^4pVPV4V'd\!VPX4p M VPp VPV 4VP#4#)a Serialize a WebSocket frame. Args: mask: Whether the frame should be masked i.e. whether the write happens on the client side. extensions: List of extensions, applied in order. Raises: ProtocolError: If the frame contains incorrect values. rriz!BBHz!BBQ)rxencodeioBytesIOr5r6r7r8r2rUr3writertpacksecrets token_bytesr getvalue) rcrorlroutputrzr{rer}r3s &$$ r serializeFrame.serializesj$  J#I##D)D$ 888Z!YYYzA /!YYYzA /"YYYzA /kk   # TYY C< LLUE6>B C e^ LLVUCKH I LLVUCKH I  ,,Q/J LL $ dii4D99D T  rcV^8dQhRR/#r=r>Noner)r@s"rrArBNs@@t@rc :VP'g%VP'gVP'd \R4hVP\ 9dE\ VP4^}8d \R4hVP'g \R4hR#R#)z Check that reserved bits and opcode have acceptable values. Raises: ProtocolError: If a reserved bit or the opcode is invalid. zreserved bits must be 0zcontrol frame too longzfragmented control frameN) r6r7r8rr2 CTRL_OPCODESrUr3r5rcs&rrx Frame.checkNsp 999 TYYY 9: : ;;, &499~##$<==888#$>?? 'rr)rrrrr__annotations__r5r6r7r8intosenvirongetr[ri classmethodr^rrxrrrrr r zs N OCD$D$D$rzz~~&?FGL09dG $ G =A GGR:!=A :!x@@rcj]tRtRt$RtR]R&R]R&RRlt]R R l4tR R lt R Rlt Rt R#)ri`zk Code and reason for WebSocket close frames. Attributes: code: Close code. reason: Close reason. zCloseCode | intcoder?reasoncV^8dQhRR/#r<r)r@s"rrAClose.__annotate__nsrc ,RVPu;8:dR8dMMRpM?RVPu;8:dR8dMMRpM \PVPR4pVP RV R2pVP'dV R VP 2pV#) zE Return a human-readable representation of a close code and reason. i registeredz private useunknownz ()rG)rr0rr)rc explanationresults& rri Close.__str__ns~ 499 #t #&K TYY % %'K155diiKKII;b Q/ ;;;xq .F rc V^8dQhRRRR/#)r=r3r r>rr)r@s"rrArs999u9rc j\V\4'd \R4h\V4^8dR\P !RVR,4wpVR,P 4pV!W#4pVP4V#\V4^8XdV!\PR4#\R4h)z Parse the payload of a close frame. Args: data: Payload of the close frame. Raises: ProtocolError: If data is ill-formed. UnicodeDecodeError: If the reason isn't valid UTF-8. z.only compressed outgoing frames use memoryviewrs:Nr=N:r=NNrDzclose frame too short) isinstance memoryviewAssertionErrorrUrtrurYrxr r$r)ryr3rrcloses&& rr^ Close.parses dJ ' ' !QR R t9>mmD$r(3GT"X__&F%E KKML Y!^y//4 4 78 8rcV^8dQhRR/#)r=r>rXr)r@s"rrArsCC5Crc VP4\P!RVP4VPP 4,#)z* Serialize the payload of a close frame. rs)rxrtrrrrrs&rrClose.serializes4 {{4+dkk.@.@.BBBrcV^8dQhRR/#rr)r@s"rrArs 7 7t 7rc VP\9g)RVPu;8:dR8gM\R4hR#R#)z{ Check that the close code has a valid value for a close frame. Raises: ProtocolError: If the close code is invalid. rrzinvalid status codeN)rEXTERNAL_CLOSE_CODESrrs&rrx Close.checks6 11TTYY5M5M 56 66N1rrN) rrrrrrrirr^rrxrrrrrr`s=  K$992C 7 7r)rl) r OP_CONTrVrZr]OP_PINGOP_PONG DATA_OPCODESrr r r)@__conditional_annotations__ __future__r dataclassesenumrrrrtcollections.abcrrtypingr exceptionsrrr speedupsr ImportErrorutils__all__IntEnumr rrrrVrrZrr]rrrrrrr r r!r"r#r$r%r&r'r(r)r*r+r,r-r.r0rrOK_CLOSE_CODES dataclassr rrDrl)rs@rrsk""  /4"$  )T\\) ++ ++ MM << ++ ++* ')  .d , .  2 =  = 8  2 0 !!#8 . 0 0 = ?+,       !!     "   b@b@b@J J7J7J7\{ "!!"sI$$ I54I5