o Xzj@sVddlZddlZddlZddlZddlmZddlmZddlm Z GdddZ dS)N) TLRequest)MessageContainer) TLMessagec@s0eZdZdZddZddZddZdd Zd S) 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. cCs(||_t|_t|_|t|_dSN) _state collectionsdeque_dequeasyncioEvent_ready__name___log)selfstateloggersr\/var/www/kodo/tsheker/venv/lib/python3.10/site-packages/telethon/extensions/messagepacker.py__init__s  zMessagePacker.__init__cC|j||jdSr)r appendrset)rrrrrr zMessagePacker.appendcCrr)r extendrr)rstatesrrrr#rzMessagePacker.extendcsv|js|j|jIdHt}g}d}|jrt|tjkr|j }|t|j t j 7}|tj krd|jj||j t|jt|jrI|jjndd|_|||jd|j|jjjt|jq|rm|j|n|jd|jjjt|j |jtdd}q|sdSt|dkrt !d tj"t||#}t}|jj||d d }|D]}||_$q|#}||fS) 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)NNzs