;Si\ddlZddlZddlZddlZddlmZddlmZddlm Z GddZ y)N) TLRequest)MessageContainer) TLMessagec(eZdZdZdZdZdZdZy) MessagePackeraN This class packs `RequestState` as outgoing `TLMessages`. The purpose of this class is to support putting N `RequestState` into a queue, and then awaiting for "packed" `TLMessage` in the other end. The simplest case would be ``State -> TLMessage`` (1-to-1 relationship) but for efficiency purposes it's ``States -> Container`` (N-to-1). This addresses several needs: outgoing messages will be smaller, so the encryption and network overhead also is smaller. It's also a central point where outgoing requests are put, and where ready-messages are get. c||_tj|_t j |_|t|_yN) _state collectionsdeque_dequeasyncioEvent_ready__name___log)selfstateloggerss f/var/www/OnlineNewsSite/project/venv/lib/python3.12/site-packages/telethon/extensions/messagepacker.py__init__zMessagePacker.__init__s2 !'') mmo H% cn|jj||jjyr )rappendrset)rrs rrzMessagePacker.appends" 5! rcn|jj||jjyr )rextendrr)rstatess rrzMessagePacker.extend#s" 6" rcK|js<|jj|jjd{t j }g}d}|jrt |tjkr|jj}|t |jtjzz }|tjkr|jj||jt!|j"t$|j&r|j&j(nd|_|j+||j,j/d|j(|j"j0j2t5|j"T|r|jj7|nv|j,j9d|j"j0j2t |j|j:j=t?dd}|syt |dkDrtAjBd tjDt ||jGz}t j }|jj||d }|D] }||_$ |jG}||fS7w) z Returns (batch, data) if one or more items could be retrieved. If the cancellation occurs or only invalid items were in the queue, (None, None) will be returned instead. Nr)after_idzAssigned msg_id = %d to %s (%x)z:Message payload for %s is too long (%d) and cannot be sentzRequest payload is too big)NNz;;'66E !"DZZ\F;;<<e=L .!- . d{ %sAK2K/J)K2N)r __module__ __qualname____doc__rrrrDrrrr s & Hrr) rr r&r;tlrtl.core.messagecontainerrtl.core.tlmessagerrrHrrrLs& 7)ddr