;i-ddlmZddlZddlZddlZddlmZmZmZm Z ddl m Z ddl m Z mZmZmZddlmZdd lmZd gZej*d ZGd d Zy) ) annotationsN)AnyCallableIterableIterator)ConcurrencyError) OP_BINARYOP_CONTOP_TEXTFrame)Data)Deadline Assemblerzutf-8c~eZdZdZddddf ddZdddZddZdddZddd Zdd Z dd Z dd Z dd Z y)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. NcyNr^/var/www/python/tenders/Scrapper/venv/lib/python3.12/site-packages/websockets/sync/messages.pyzAssembler.&rcyrrrrrrzAssembler.'rrc8tj|_tj|_|||dz}|||dz}|"| |dkr t d||kr t d||c|_|_||_ ||_ d|_ d|_ d|_ y)Nrz%low must be positive or equal to zeroz)high must be greater than or equal to lowF) threadingLockmutexqueue SimpleQueueframes ValueErrorhighlowpauseresumepausedget_in_progressclosed)selfr$r%r&r's r__init__zAssembler.__init__"s^^% 8=7H7H7J   !)C ?;;   ' & '  ' & ' ' ' 's'B%->AB%AAB%%B.c|j5|jr tdd|_ddd t|}|j |j d}|j5|j ddd|jtus|jtusJ||jtu}|g}|jsy |j |j d}|j5|j ddd|jtusJ|j||jsyd|_djd|D}|r|j!S|S#1swYQxYw#1swY xYw#t$r|j|wxYw#1swYxYw#d|_wxYw)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_elapsedrc34K|]}|jywr)data).0r7s r z Assembler.get..s7u 7s)rr)r rr8r1 maybe_resumeopcoder r finr6r=r r:joindecode)r+r1rIdeadliner7r"rBs rr3z Assembler.getqs4ZZ (##&'OPP#'D  ( )(H''(8(8%(8(PQE $!!# $<<7*elli.G GG~0WFii // ((%(@EZZ(%%'(||w... e$ii $)D xx777 ;;= KW ( ( $ $$$$V,  (( $)D s_E;8G-F>AG!F1 G=F49G;FF GF11G4F=9G G c#fK|j5|jr tdd|_ddd|j}|j5|j ddd|j t us|j tusJ||j t u}|r3t}|j|j|jn|j|js|j}|j5|j ddd|j tusJ|r)j|j|jn|j|jsd|_y#1swY_xYw#1swY7xYw#1swYxYww)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. r?TNF) rr)r r8rErFr r UTF8DecoderrIrBrGr )r+rIr7decoders rget_iterzAssembler.get_iters`2ZZ (##&'OPP#'D  (##% ZZ     ||w&%,,)*CCC >\\W,F !mG..UYY7 7** ))'')E $!!# $<<7* **nnUZZ;;jj )) %G ( (   $ $sS F1F $F1F#B-F1F%!A!F1F1 FF1F"F1%F.*F1c|j5|jr td|jj ||j dddy#1swYyxYw)z Add ``frame`` to the next message. Raises: EOFError: If the stream of frames has ended. r0N)rr*r5r"r; maybe_pause)r+r7s rr;z Assembler.putsOZZ {{788 KKOOE "        s AAA"c|jy|jjsJ|jj |jkDr%|j sd|_|j yyy)z7Pause the writer if queue is above the high water mark.NT)r$rlockedr"qsizer(r&r+s rrPzAssembler.maybe_pauses` 99  zz  """ ;;    *4;;DK JJL4? *rc|jy|jjsJ|jj |jkr%|j rd|_|j yyy)z7Resume the writer if queue is below the low water mark.NF)r%rrRr"rSr(r'rTs rrEzAssembler.maybe_resumes` 88  zz  """ ;;   $(( *t{{DK KKM0; *rc|j5|jr dddyd|_|jr|jj d|j rd|_|j dddy#1swYyxYw)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)rr*r)r"r;r(r'rTs rclosezAssembler.close)smZZ {{  DK## %{{#     sA>AA>>B) r$ int | Noner%rXr&Callable[[], Any]r'rYreturnNoner)r1 float | NonerZr )r"zIterable[Frame]rZr[)NN)r1r\rI bool | NonerZr)rIr]rZzIterator[Data])r7r rZr[)rZr[) __name__ __module__ __qualname____doc__r,r8r=r3rNr;rPrErWrrrrrsv   #/$0 $$$! $ " $  $L,'&EN<%| 2  r) __future__rcodecsr rtypingrrrr exceptionsr r"r r r r rutilsr__all__getincrementaldecoderrLrrrrrisM" 44)77 -*f**73 kkr