Jtj?1ddlmZddlZddlZddlZddlmZmZmZm Z m Z m Z ddl m Z ddlmZmZmZmZddlmZdd lmZd gZejd ZGd d ZdS) ) annotationsN)AnyCallableIterableIteratorLiteraloverload)ConcurrencyError) OP_BINARYOP_CONTOP_TEXTFrame)Data)Deadline Assemblerzutf-8c6eZdZdZddddfd.d Zd/d0dZd1dZed2dZed3dZed/d2dZed/d3dZed4d5d Zd4d5d!Zed6d#Z ed7d%Z ed/d8d'Z d/d8d(Z d9d*Z d:d+Z d:d,Z d:d-Z dS);ra Assemble messages from frames. :class:`Assembler` expects only data frames. The stream of frames must respect the protocol; if it doesn't, the behavior is undefined. Args: pause: Called when the buffer of frames goes above the high water mark; should pause reading from the network. resume: Called when the buffer of frames goes below the low water mark; should resume reading from the network. NcdSNrV/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/websockets/sync/messages.pyzAssembler.&s4rcdSrrrrrrzAssembler.'sDrhigh int | NonelowpauseCallable[[], Any]resumereturnNonecJtj|_tj|_|||dz}|||dz}|,|*|dkrt d||krt d||c|_|_||_ ||_ d|_ d|_ d|_ dS)Nrz%low must be positive or equal to zeroz)high must be greater than or equal to lowF) threadingLockmutexqueue SimpleQueueframes ValueErrorrrrr!pausedget_in_progressclosed)selfrrrr!s r__init__zAssembler.__init__"s^%% 8=7H7J7J   !)C ">???@;     ' ' &&&& ' ' &&&& ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' 's-B0<A B AABB!$B!decode Literal[True]strcdSrrr0r2rEs rr9z Assembler.gettsHKrLiteral[False]bytescdSrrrIs rr9z Assembler.getwsKN3rcdSrrrIs rr9z Assembler.getzsRURUrcdSrrrIs rr9z Assembler.get}UXUXr bool | NonercdSrrrIs rr9z Assembler.getrOrc|j5|jrtdd|_dddn #1swxYwY t|}||d}|j5|dddn #1swxYwY|jtus|jtusJ||jtu}|g}|j s ||d}n$#t$r| |wxYw|j5|dddn #1swxYwY|jtusJ|||j d|_n #d|_wxYwdd|D}|r|S|S)a? Read the next message. :meth:`get` returns a single :class:`str` or :class:`bytes`. If the message is fragmented, :meth:`get` waits until the last frame is received, then it reassembles the message and returns it. To receive messages frame by frame, use :meth:`get_iter` instead. Args: timeout: If a timeout is provided and elapses before a complete message is received, :meth:`get` raises :exc:`TimeoutError`. decode: :obj:`False` disables UTF-8 decoding of text frames and returns :class:`bytes`. :obj:`True` forces UTF-8 decoding of binary frames and returns :class:`str`. Raises: EOFError: If the stream of frames has ended. UnicodeDecodeError: If a text frame contains invalid UTF-8. ConcurrencyError: If two coroutines run :meth:`get` or :meth:`get_iter` concurrently. TimeoutError: If a timeout is provided and elapses before a complete message is received. &get() or get_iter() is already runningTNF)raise_if_elapsedrc3$K|] }|jV dSr)data).0r=s r z Assembler.get..s$77u 777777r)r(r.r rr>r2 maybe_resumeopcoderr finr<rDr rAjoinrE)r0r2rEdeadliner=r+rVs rr9z Assembler.gets4Z ( (# Q&'OPPP#'D  ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( )((H''(8(8%(8(P(PQQE $ $!!### $ $ $ $ $ $ $ $ $ $ $ $ $ $ $<7**eli.G.G.GG~0WFi % // ((%(@@EE$$$V,,,  Z((%%'''(((((((((((((((|w.... e$$$i % $)D 5D ( ( ( (xx7777777  ;;== Ksw266?F=B FB""F%B"&;F")D F !D-- F7E FEFE /F F  Iterator[str]cdSrrr0rEs rget_iterzAssembler.get_iters@CrIterator[bytes]cdSrrr`s rrazAssembler.get_itersCF3rIterator[Data]cdSrrr`s rrazAssembler.get_itersFIcrc#K|j5|jrtdd|_dddn #1swxYwY|}|j5|dddn #1swxYwY|jt us|jtusJ||jt u}|r1t}| |j |j Vn |j V|j s|}|j5|dddn #1swxYwY|jtusJ|r#| |j |j Vn |j V|j d|_dS)a Stream the next message. Iterating the return value of :meth:`get_iter` yields a :class:`str` or :class:`bytes` for each frame in the message. The iterator must be fully consumed before calling :meth:`get_iter` or :meth:`get` again. Else, :exc:`ConcurrencyError` is raised. This method only makes sense for fragmented messages. If messages aren't fragmented, use :meth:`get` instead. Args: decode: :obj:`False` disables UTF-8 decoding of text frames and returns :class:`bytes`. :obj:`True` forces UTF-8 decoding of binary frames and returns :class:`str`. Raises: EOFError: If the stream of frames has ended. UnicodeDecodeError: If a text frame contains invalid UTF-8. ConcurrencyError: If two coroutines run :meth:`get` or :meth:`get_iter` concurrently. rSTNF) r(r.r r>rYrZrr UTF8DecoderrErVr[r )r0rEr=decoders rrazAssembler.get_itersl2Z ( (# Q&'OPPP#'D  ( ( ( ( ( ( ( ( ( ( ( ( ( ( (##%% Z                      |w&&%,)*C*C*CC >\W,F  !mmG..UY77 7 7 7 7*   ) !''))E $ $!!### $ $ $ $ $ $ $ $ $ $ $ $ $ $ $<7**** !nnUZ;;;;;;j   ) ! %s0488A;;A?A?D33D7:D7r=c|j5|jrtd|j||ddddS#1swxYwYdS)z Add ``frame`` to the next message. Raises: EOFError: If the stream of frames has ended. r7N)r(r/r;r+rB maybe_pause)r0r=s rrBz Assembler.putsZ  { 97888 KOOE " " "                         sAAA!Ac|jdS|jsJ|j|jkr$|jsd|_|dSdSdS)z7Pause the writer if queue is above the high water mark.NT)rr(lockedr+qsizer-rr0s rrjzAssembler.maybe_pause*su 9  Fz  """"" ;     * *4; *DK JJLLLLL + * * *rc|jdS|jsJ|j|jkr$|jrd|_|dSdSdS)z7Resume the writer if queue is below the low water mark.NF)rr(rlr+rmr-r!rns rrYzAssembler.maybe_resume7su 8  Fz  """"" ;    $( * *t{ *DK KKMMMMM + * * *rc|j5|jr ddddSd|_|jr|jd|jrd|_|ddddS#1swxYwYdS)z End the stream of frames. Calling :meth:`close` concurrently with :meth:`get`, :meth:`get_iter`, or :meth:`put` is safe. They will raise :exc:`EOFError`. NTF)r(r/r.r+rBr-r!rns rclosezAssembler.closeDsZ  {         DK# & %%%{ #                    s A5A A55A9<A9) rrrrrr r!r r"r#r)r2r3r"r)r+r?r"r#)r2r3rErFr"rG)r2r3rErJr"rK)NN)r2r3rErPr"r)rErFr"r^)rErJr"rb)rErPr"rd)r=rr"r#)r"r#)__name__ __module__ __qualname____doc__r1r>rDr r9rarBrjrYrqrrrrrs    #/<$0L $$$$$L,'''',KKKXK NNNXN UUUUXU XXXXXX XXXXXXEEEEENCCCXC FFFXF IIIIXI<%<%<%<%<%|    2        r) __future__rcodecsr)r&typingrrrrrr exceptionsr r+r r rrrutilsr__all__getincrementaldecoderrgrrrrr}s"""""" GGGGGGGGGGGGGGGG))))))777777777777 -*f*733 FFFFFFFFFFr