LonamiWebs/Telethon
1
1
Fork 0
mirror of https://github.com/LonamiWebs/Telethon.git synced 2025-09-19 02:12:40 +03:00
Code Issues Packages Projects Releases Wiki Activity

Corrected the offset

Browse Source
This commit is contained in:
Kacnep89 2023-04-04 22:37:57 +05:00
parent 8238e99623
commit 1b6f4d26a5
1 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
telethon/client/updates.py
View File

@ -450,22 +450,22 @@ class UpdateMethods:
types.UpdateReadChannelOutbox,
)):
if is_min and update.pts:
get_diff = functions.updates.GetChannelDifferenceRequest(
force=False,
channel=await self.get_input_entity(update.message.peer_id),
filter=types.ChannelMessagesFilter(
ranges=[types.MessageRange(
min_id=update.message.id,
max_id=update.message.id
)]
),
pts=update.pts - update.pts_count,
limit=update.pts
)
diff = await self(get_diff)
if not isinstance(diff, types.updates.ChannelDifferenceEmpty):
chats.update({utils.get_peer_id(x): x for x in diff.chats})
users.update({utils.get_peer_id(x): x for x in diff.users})
get_diff = functions.updates.GetChannelDifferenceRequest(
force=False,
channel=await self.get_input_entity(update.message.peer_id),
filter=types.ChannelMessagesFilter(
ranges=[types.MessageRange(
min_id=update.message.id,
max_id=update.message.id
)]
),
pts=update.pts - update.pts_count,
limit=update.pts
)
diff = await self(get_diff)
if not isinstance(diff, types.updates.ChannelDifferenceEmpty):
chats.update({utils.get_peer_id(x): x for x in diff.chats})
users.update({utils.get_peer_id(x): x for x in diff.users})
self._mb_entity_cache.extend(list(users.values()), list(chats.values()))
entities = users | chats