mirror of
https://github.com/LonamiWebs/Telethon.git
synced 2024-09-21 11:18:50 +03:00
393e1966c7
This issue would likely be triggered when automatically merging multiple requests into a single one while having their size exceed 1044456 bytes like SaveFilePartRequest. This commit avoids such issue by keeping track of the current size, and if it exceeds the limit, avoid merge.
48 lines
1.5 KiB
Python
48 lines
1.5 KiB
Python
import logging
|
|
import struct
|
|
|
|
from .tlmessage import TLMessage
|
|
from ..tlobject import TLObject
|
|
|
|
__log__ = logging.getLogger(__name__)
|
|
|
|
|
|
class MessageContainer(TLObject):
|
|
CONSTRUCTOR_ID = 0x73f1f8dc
|
|
|
|
# Maximum size in bytes for the inner payload of the container.
|
|
# Telegram will close the connection if the payload is bigger.
|
|
# The overhead of the container itself is subtracted.
|
|
MAXIMUM_SIZE = 1044456 - 8
|
|
|
|
def __init__(self, messages):
|
|
self.messages = messages
|
|
|
|
def to_dict(self):
|
|
return {
|
|
'_': 'MessageContainer',
|
|
'messages':
|
|
[] if self.messages is None else [
|
|
None if x is None else x.to_dict() for x in self.messages
|
|
],
|
|
}
|
|
|
|
def __bytes__(self):
|
|
return struct.pack(
|
|
'<Ii', MessageContainer.CONSTRUCTOR_ID, len(self.messages)
|
|
) + b''.join(bytes(m) for m in self.messages)
|
|
|
|
@classmethod
|
|
def from_reader(cls, reader):
|
|
# This assumes that .read_* calls are done in the order they appear
|
|
messages = []
|
|
for _ in range(reader.read_int()):
|
|
msg_id = reader.read_long()
|
|
seq_no = reader.read_int()
|
|
length = reader.read_int()
|
|
before = reader.tell_position()
|
|
obj = reader.tgread_object() # May over-read e.g. RpcResult
|
|
reader.set_position(before + length)
|
|
messages.append(TLMessage(msg_id, seq_no, obj))
|
|
return MessageContainer(messages)
|