vKg1%SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKJ r J r SSK J r J r SSKJrJr SSKJr /SQr"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\:\;\<4r=\R|"SS55r?\R|"S S!55r@SS"KAJBrB g!\a SSKJr GN1f=f)#) annotationsN) GeneratorSequence)CallableUnion) PayloadTooBig ProtocolError) apply_mask) OpcodeOP_CONTOP_TEXT OP_BINARYOP_CLOSEOP_PINGOP_PONG DATA_OPCODES CTRL_OPCODESFrameClosec0\rSrSrSrSurrrSurr r Sr g)r $z#Opcode values for WebSocket frames.)rr) N) __name__ __module__ __qualname____firstlineno____doc__CONTTEXTBINARYCLOSEPINGPONG__static_attributes__rQ/var/www/highfloat_scraper/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) CloseCode6z-Close code values for WebSocket close frames.iiiiiiiiiiiiiiirN)rrr 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+r-r-6sT7NJNNLONOOKMr*r-OKz 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)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 opcodez#Union[bytes, bytearray, memoryview]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 r r 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) rz-Callable[[int], Generator[None, None, bytes]]rrDrrz int | Noners%Sequence[extensions.Extension] | NonerzGenerator[None, None, Frame])rrDrsrrr`rNone)rrr r!r"__annotations__rErFrGrHintosenvirongetrbrp classmethodrerrr)rr*r+rr{s N --CD$D$D$rzz~~&?FGL09d $<@ GAG G  G : G &GGZ=A 9!9!: 9!  9!v@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. rcoderdreasonc"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*c[U5S:aI[R"SUSS5unUSSR5nU"X#5nUR 5 U$[U5S:XaU"[ R S5$[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. rr}NrrLzclose frame too short)r^rrrarr-r3r )rrCrrcloses r+re Close.parses{ 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) rrr r!r"rrprrerrr)rr*r+rr`s7 I K$99.C 7r*rr)C __future__r dataclassesenumrrrrcollections.abcrrtypingrr exceptionsr r speedupsr ImportErrorutils__all__IntEnumr r#r r$rr%rr&rr'rr(rrrr-r/r0r1r2r3r4r5r6r7r8r9r:r;r<r=r?rrOK_CLOSE_CODESr` bytearray memoryview BytesLike dataclassrrrLrsrr*r+rsr"  /"4"$ )T\\) ++ ++ MM << ++ ++* ')  .d , .  2 =  = 8  2 0 !!#8 . 0 0 = ?+,       !!     "   9j (  a@a@a@H H7H7H7Xy "!!"sI!! I10I1