iY2%SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKJ r J r SSK J r SSK JrJr SSK Jr SSKJr /S Qr"S S \R,5r\R0r\R4r\R8r\R<r\R@r!\RDr#\\\4r$\\!\#4r%"S S \R,5r&\&RNS\&RPS\&RRS\&RTS\&RVS\&RXS\&RZS\&R\S\&R^S\&R`S\&RbS\&RdS\&RfS\&RhS\&RjS0r6S\7S'\&RN\&RP\&RR\&RT\&RZ\&R\\&R^\&R`\&Rb\&Rd\&Rf\&Rh1 r8\&RN\&RP\&RV1r9\Rt"SS 55r;\Rt"S!S"55rr> g!\a SSKJr GN,f=f)$) annotationsN) GeneratorSequence)Callable) PayloadTooBig ProtocolError) BytesLike) apply_mask) OpcodeOP_CONTOP_TEXT OP_BINARYOP_CLOSEOP_PINGOP_PONG DATA_OPCODES CTRL_OPCODES CloseCodeFrameClosec0\rSrSrSrSurrrSurr r Sr g)r &z#Opcode values for WebSocket frames.)rr) N) __name__ __module__ __qualname____firstlineno____doc__CONTTEXTBINARYCLOSEPINGPONG__static_attributes__rN/home/mande/repo/quber/.venv/lib/python3.13/site-packages/websockets/frames.pyr r &s-)D$(E4r+r cT\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrSrSrSrSrg)r8z-Close code values for WebSocket close frames.iiiiiiiiiiiiiiirN)rr r!r"r#NORMAL_CLOSURE GOING_AWAYPROTOCOL_ERRORUNSUPPORTED_DATANO_STATUS_RCVDABNORMAL_CLOSURE INVALID_DATAPOLICY_VIOLATIONMESSAGE_TOO_BIGMANDATORY_EXTENSIONINTERNAL_ERRORSERVICE_RESTARTTRY_AGAIN_LATER BAD_GATEWAY TLS_HANDSHAKEr*rr+r,rr8sT7NJNNLONOOKMr+rOKz 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 \rSrSr%SrS\S'S\S'SrS\S 'S rS\S 'S rS\S 'S r S\S '\ "\ RRSS55rSSjr\SSS.SSjj5rSS.SSjjrSSjrSrg)rza" 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_SIZE75c*Sn[UR5S[UR5S:XaSOS3nUR(aSOSnUR[La.[ [ UR5R55nGOUR[LasURn[U5URS-:a2URS-S- S-nSRUSS U-S XV*S/5nS RS U55nOUR[La)[[RUR55nOCUR(a0[ [ UR5R55nS nOSn[U5UR:a#URS-S- nUSS U-S-XF*S-nSR[#SXU/55nURR$S USUS3$![[ 4aw URn[U5URS-:a2URS-S- S-nSRUSS U-S XV*S/5nS RSU55nSnNf=f)z5 Return a human-readable representation of a frame. Nz byters continuedr+rs c3(# UHoSv M g7f02xNr.0bytes r, Frame.__str__..s=fdCjMftextc3(# UHoSv M g7frRrrTs r,rWrXsA&$* &rYbinaryz''z...z, z [])lenrCrErBrreprbytesdecoder MAX_LOG_SIZEjoinrstrrparseUnicodeDecodeErrorAttributeErrorfiltername)selfcodinglength non_finalrCr\cutmetadatas r,__str__ Frame.__str__sW  N#5s499~/B(LM((B ;;' !dii(//12D [[I %YYF6{T..!33((A-1a76)AG#4k6$%="QR88=f==D [[H $u{{499-.D YY "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 BJJN)max_size extensionsc#^# U"S5ShvN n[R"SU5upgUS-(aSOSnUS-(aSOSn US-(aSOSn US -(aSOSn [US -5n US-(aSOSU:wa [ S 5eUS -nUS:Xa*U"S5ShvN n[R"SU5unO/US :Xa)U"S5ShvN n[R"SU5unUbX:a [ X5eU(aU"S5ShvN nU"U5ShvN nU(a [ UW5nU"XXX5nUc/n[U5HnURUUS9nM UR5 U$GNv![an [ S 5U eSn A ff=fNNNN7f)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. rN!BBTF@ zinvalid opcodezincorrect masking~!Hrz!Q)rr) structunpackr ValueErrorr rr reversedracheck)cls read_exactmaskrrrsrChead1head2rErFrGrHrBexcrl mask_bytesframe extensions r,re 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-sx F-FAF-%F33F-&F%'/F-F'AF-F)F-)F+*AF- F" FF""F-'F-)F-+F-rscUR5 Uc/nUHnURU5nM [R"5nUR(aSOSUR (aSOS-UR (aSOS-UR(aSOS-UR-nU(aSOSn[UR5nUS:a*UR[R"SXVU-55 O[US:a+UR[R"S XVS-U55 O*UR[R"S XVS -U55 U(a'[R"S 5nURU5 U(a[!URW5n O URn URU 5 UR#5$) 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. rvrrwrxryr|ruiz!BBHz!BBQr{r~)rencodeioBytesIOrErFrGrHrBr^rCwriterpacksecrets token_bytesr getvalue) rjrrsroutputrrrlrrCs r, serializeFrame.serializesb$  J#I##D)D$ 88Z!YYzA /!YYzA /"YYzA /kk   # TYY C< LLUE6>B C e^ LLVUCKH I LLVUCKH I  ,,Q/J LL $ dii4D99D T  r+c*UR(d"UR(dUR(a [S5eUR[ ;aA[ UR5S:a [S5eUR(d [S5egg)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 0}zcontrol frame too longzfragmented control frameN) rFrGrHr rBrr^rCrErjs r,r Frame.checkNsh 99 TYY 9: : ;;, &499~##$<==88#$>?? 'r+rreturnrd) rz9Callable[[int], Generator[None, None, bytes | bytearray]]rrDrrz int | Noners%Sequence[extensions.Extension] | NonerzGenerator[None, None, Frame])rrDrsrrr`rNone)rr r!r"r#__annotations__rErFrGrHintosenvirongetrbrp classmethodrerrr*rr+r,rrzs N OCD$D$D$rzz~~&?FGL09d $<@ GMG G  G : G &GGZ=A :!:!: :!  :!x@r+rc`\rSrSr%SrS\S'S\S'S Sjr\SSj5rSS jr SS jr S r g )ri`zk Code and reason for WebSocket close frames. Attributes: code: Close code. reason: Close reason. zCloseCode | intcoderdreasonc"SURs=::aS:aO OSnO=SURs=::aS:aO OSnO [RURS5nURSUS3nUR(aUS UR3nU$) zE Return a human-readable representation of a close code and reason. i registeredz private useunknownz ()rP)rr?rr)rj explanationresults r,rp Close.__str__ns| 499 #t #&K TYY % %'K155diiKKII;b Q/ ;;xq .F r+cT[U[5(a [S5e[U5S:aI[R "SUSS5unUSSR 5nU"X#5nUR5 U$[U5S:XaU"[RS5$[S5e)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 memoryviewrr}NrrLzclose frame too short) isinstance memoryviewAssertionErrorr^rrrarrr3r )rrCrrcloses r,re Close.parses dJ ' ' !QR R t9>mmD$r(3GT!"X__&F%E KKML Y!^y//4 4 78 8r+cUR5 [R"SUR5URR 5-$)z* Serialize the payload of a close frame. r})rrrrrrrs r,rClose.serializes4 {{4+dkk.@.@.BBBr+cvUR[;d%SURs=::aS:d O [S5egg)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_CODESr rs r,r Close.checks6 11TTYY5M5M 56 66N1r+rNr)rCr rr)rr`r) rr r!r"r#rrprrerrr*rr+r,rr`s8  K$992C 7r+rr)? __future__r dataclassesenumrrrrcollections.abcrrtypingr exceptionsrr r speedupsr ImportErrorutils__all__IntEnumr r$r r%rr&rr'rr(rr)rrrrr/r0r1r2r3r4r5r6r7r8r9r:r;r<r=r?rrOK_CLOSE_CODES dataclassrrrLrsrr+r,rsg"  /4"$  )T\\) ++ ++ MM << ++ ++* ')  .d , .  2 =  = 8  2 0 !!#8 . 0 0 = ?+,       !!     "   b@b@b@J J7J7J7\{ "!!"sI I0/I0