|
17 | 17 | # along with Pyrogram. If not, see <http://www.gnu.org/licenses/>. |
18 | 18 |
|
19 | 19 | import logging |
20 | | -import time |
21 | 20 | from base64 import b64decode, b64encode |
22 | 21 | from struct import pack |
23 | 22 | from weakref import proxy |
24 | 23 |
|
25 | | -from pyrogram.api.errors import FloodWait |
26 | 24 | from pyrogram.client import types as pyrogram_types |
27 | 25 | from ...api import types, functions |
28 | 26 | from ...api.errors import StickersetInvalid |
@@ -635,19 +633,11 @@ def parse_messages( |
635 | 633 | m.caption.init(m._client, m.caption_entities or []) |
636 | 634 |
|
637 | 635 | if message.reply_to_msg_id and replies: |
638 | | - while True: |
639 | | - try: |
640 | | - m.reply_to_message = client.get_messages( |
641 | | - m.chat.id, |
642 | | - reply_to_message_ids=message.id, |
643 | | - replies=replies - 1 |
644 | | - ) |
645 | | - except FloodWait as e: |
646 | | - log.warning("get_messages flood: waiting {} seconds".format(e.x)) |
647 | | - time.sleep(e.x) |
648 | | - continue |
649 | | - else: |
650 | | - break |
| 636 | + m.reply_to_message = client.get_messages( |
| 637 | + m.chat.id, |
| 638 | + reply_to_message_ids=message.id, |
| 639 | + replies=replies - 1 |
| 640 | + ) |
651 | 641 | elif isinstance(message, types.MessageService): |
652 | 642 | action = message.action |
653 | 643 |
|
@@ -748,19 +738,11 @@ def parse_messages( |
748 | 738 | ) |
749 | 739 |
|
750 | 740 | if isinstance(action, types.MessageActionPinMessage): |
751 | | - while True: |
752 | | - try: |
753 | | - m.pinned_message = client.get_messages( |
754 | | - m.chat.id, |
755 | | - reply_to_message_ids=message.id, |
756 | | - replies=0 |
757 | | - ) |
758 | | - except FloodWait as e: |
759 | | - log.warning("get_messages flood: waiting {} seconds".format(e.x)) |
760 | | - time.sleep(e.x) |
761 | | - continue |
762 | | - else: |
763 | | - break |
| 741 | + m.pinned_message = client.get_messages( |
| 742 | + m.chat.id, |
| 743 | + reply_to_message_ids=message.id, |
| 744 | + replies=0 |
| 745 | + ) |
764 | 746 | else: |
765 | 747 | m = pyrogram_types.Message(message_id=message.id, client=proxy(client)) |
766 | 748 |
|
|
0 commit comments