ޠjA%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"55r<S%S&S#jjr=SS$K>J?r? g!\a SSKJr GN#Frame._data_repr..s B64:6sz...)rCrSrTrBrstrrparser UnicodeDecodeErrorrV MAX_LOG_SIZEbytesis_utf8_fragmentr rEreprdecoderW)rZ data_startdata_endr]r\rCrNcuts r,rUFrame._data_reprsMyy--11$++>> > ;;( " 5;;tyy12D88 tyy>A 1 11 1tyy)E1t/@/@+@A+EFGJTYYrD,=,='='B'DEFH&!%!7##xx  *"7!?!?y!?!QR #D&!%!7#xxG  I!>? YYF6{T..!33((A-1a76)AG#4k6$%="QR B6 BBI y>D-- -##q(1,C!)AG,u4y7GGI!!e"#56  s )II+*I+N)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!Qre)r~) structunpackr ValueErrorr rr reversedrycheck)cls read_exactmaskr~rrChead1head2rErFrGrHrBexcr_ mask_bytesframe extensions r,rs 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-rcUR5 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. rrrrrrriz!BBHz!BBQrre)rencodeioBytesIOrErFrGrHrBrVrCwriterpacksecrets token_bytesr getvalue) rZrrroutputrrr_rrCs r, serializeFrame.serializeCsb$  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 rBrrVrCrErZs r,r Frame.checksh 99 TYY 9: : ;;, &499~##$<==88#$>?? 'r+rreturnrr)rztuple[str, bool | None]) rz9Callable[[int], Generator[None, None, bytes | bytearray]]rrDr~z int | Noner%Sequence[extensions.Extension] | NonerzGenerator[None, None, Frame])rrDrrrrvrNone)rr r!r"r#__annotations__rErFrGrHintosenvironrTrurrrrSrbrU classmethodrsrrr*rr+r,rrzs N OCD$D$D$rzz~~&?FGLi$GO>2F"P $<@ GMG G  G : G &GGZ=A :!:!: :!  :!x@r+rc`\rSrSr%SrS\S'S\S'S Sjr\SSj5rSS jr SS jr S r g )rizk Code and reason for WebSocket close frames. Attributes: code: Close code. reason: Close reason. zCloseCode | intcoderrreasonc"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 ()rQ)rr?rTr)rZ explanationresults r,rb Close.__str__s| 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 memoryviewrrNrrLzclose frame too short) isinstance memoryviewAssertionErrorrVrrryrrr3r )rrCrrcloses r,rs 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)rrvr) rr r!r"r#rrbrrsrrr*rr+r,rrs8  K$992C 7r+rcS[U5pCU(d/[S[U55nX5:aXnUS-S:XaUS- nMU(dUS-n[[U5S- U5nXG:adXnUS-S:XaUS-nMUS-S:XaSnO&US-S:XaSnOUS -S:XaSnOUS -S :XaSnOSnU[U5U- ::a [U5nXUR5n S [ U 5;$![ a g f=f) z*Guess if data is a fragment of UTF-8 text.rrfrrrerz\xF)rVminmaxryrxrt) rCrhristartend max_startromin_endseq_lenrMs r,rwrws=CI3 3t9% ;Dj J.    qc$i!mU+n9Dj J.qj J. "j0 "j0 "j0#d)c/)$i '#%%' DJ&& sC11 C>=C>r)FF)rCrvrhrDrirDrrD)@ __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 dataclassrrrwrLrrr+r,rs"  /4"$  )T\\) ++ ++ MM << ++ ++* ')  .d , .  2 =  = 8  2 0 !!#8 . 0 0 = ?+,       !!     "   S@S@S@l J7J7J7^# E' E'E'E' E'Rm"!!"sI00 J?J