|
18 | 18 |
|
19 | 19 | import struct |
20 | 20 | from base64 import b64decode, b64encode |
21 | | -from typing import Union |
| 21 | +from typing import Union, List |
22 | 22 |
|
| 23 | +import pyrogram |
23 | 24 | from . import BaseClient |
24 | 25 | from ...api import types |
25 | 26 |
|
@@ -135,3 +136,58 @@ def get_input_media_from_file_id( |
135 | 136 | ) |
136 | 137 |
|
137 | 138 | raise ValueError("Unknown media type: {}".format(file_id_str)) |
| 139 | + |
| 140 | + |
| 141 | +def parse_messages(client, messages: types.messages.Messages, replies: int = 1) -> List["pyrogram.Message"]: |
| 142 | + users = {i.id: i for i in messages.users} |
| 143 | + chats = {i.id: i for i in messages.chats} |
| 144 | + |
| 145 | + if not messages.messages: |
| 146 | + return pyrogram.List() |
| 147 | + |
| 148 | + parsed_messages = [ |
| 149 | + pyrogram.Message._parse(client, message, users, chats, replies=0) |
| 150 | + for message in messages.messages |
| 151 | + ] |
| 152 | + |
| 153 | + if replies: |
| 154 | + messages_with_replies = {i.id: getattr(i, "reply_to_msg_id", None) for i in messages.messages} |
| 155 | + reply_message_ids = [i[0] for i in filter(lambda x: x[1] is not None, messages_with_replies.items())] |
| 156 | + |
| 157 | + if reply_message_ids: |
| 158 | + reply_messages = client.get_messages( |
| 159 | + parsed_messages[0].chat.id, |
| 160 | + reply_to_message_ids=reply_message_ids, |
| 161 | + replies=replies - 1 |
| 162 | + ) |
| 163 | + |
| 164 | + for message in parsed_messages: |
| 165 | + reply_id = messages_with_replies[message.message_id] |
| 166 | + |
| 167 | + for reply in reply_messages: |
| 168 | + if reply.message_id == reply_id: |
| 169 | + message.reply_to_message = reply |
| 170 | + |
| 171 | + return pyrogram.List(parsed_messages) |
| 172 | + |
| 173 | + |
| 174 | +def parse_deleted_messages(client, update) -> List["pyrogram.Message"]: |
| 175 | + messages = update.messages |
| 176 | + channel_id = getattr(update, "channel_id", None) |
| 177 | + |
| 178 | + parsed_messages = [] |
| 179 | + |
| 180 | + for message in messages: |
| 181 | + parsed_messages.append( |
| 182 | + pyrogram.Message( |
| 183 | + message_id=message, |
| 184 | + chat=pyrogram.Chat( |
| 185 | + id=int("-100" + str(channel_id)), |
| 186 | + type="channel", |
| 187 | + client=client |
| 188 | + ) if channel_id is not None else None, |
| 189 | + client=client |
| 190 | + ) |
| 191 | + ) |
| 192 | + |
| 193 | + return pyrogram.List(parsed_messages) |
0 commit comments