U h@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)selfstateloggersrE/tmp/pip-unpacked-wheel-c81u5j2r/telethon/extensions/messagepacker.py__init__s  zMessagePacker.__init__cCs|j||jdSr)r appendrset)rrrrrrs zMessagePacker.appendcCs|j||jdSr)r extendrr)rZstatesrrrr#s zMessagePacker.extendcs|js |j|jIdHt}g}d}|jrt|tjkr|j }|t|j t j 7}|tj kr|jj||j t|jt|jr|jjndd|_|||jd|j|jjjt|jq0|r|j|q|jd|jjjt|j |jtdd}q0q0|sdSt|dkrrt !d tj"t||#}t}|jj||d d }|D] }||_$qd|#}||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)Zafter_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