Commit message

Ref: https://t.me/c/1220993104/1382620/1384317

Co-authored-by: anonymousx97 <[email protected]>

Author: SpEcHiDe

pyrogram/methods/business/get_user_gifts.py

@@ -16,6 +16,7 @@
 #  You should have received a copy of the GNU Lesser General Public License
 #  along with Pyrogram.  If not, see <http://www.gnu.org/licenses/>.
 
+from asyncio import sleep
 from typing import Union, Optional, AsyncGenerator
 
 import pyrogram
@@ -83,6 +84,7 @@ async def get_user_gifts(
                 return
 
             for user_gift in user_gifts:
+                await sleep(0)
                 yield user_gift
 
                 current += 1

pyrogram/methods/chat_topics/get_forum_topics.py

@@ -16,6 +16,7 @@
 #  You should have received a copy of the GNU Lesser General Public License
 #  along with Pyrogram.  If not, see <http://www.gnu.org/licenses/>.
 
+from asyncio import sleep
 from datetime import datetime
 from typing import Union, AsyncGenerator
 
@@ -125,6 +126,7 @@ async def get_forum_topics(
             offset_message_thread_id = last.message_thread_id
 
             for topic in topics:
+                await sleep(0)
                 yield topic
 
                 current += 1

pyrogram/methods/chats/get_chat_event_log.py

@@ -16,6 +16,7 @@
 #  You should have received a copy of the GNU Lesser General Public License
 #  along with Pyrogram.  If not, see <http://www.gnu.org/licenses/>.
 
+from asyncio import sleep
 from typing import Union, AsyncGenerator, Optional
 
 import pyrogram
@@ -101,6 +102,7 @@ async def get_chat_event_log(
             offset_id = last.id
 
             for event in r.events:
+                await sleep(0)
                 yield await types.ChatEvent._parse(self, event, r.users, r.chats)
 
                 current += 1

pyrogram/methods/chats/get_chat_members.py

@@ -17,6 +17,7 @@
 #  along with Pyrogram.  If not, see <http://www.gnu.org/licenses/>.
 
 import logging
+from asyncio import sleep
 from typing import Union, Optional, AsyncGenerator
 
 import pyrogram
@@ -125,6 +126,7 @@ async def get_chat_members(
             users = {i.id: i for i in r.users}
 
             for member in members:
+                await sleep(0)
                 yield types.ChatMember._parse(self, member, users, {})
 
             return
@@ -150,6 +152,7 @@ async def get_chat_members(
             offset += len(members)
 
             for member in members:
+                await sleep(0)
                 yield member
 
                 current += 1

pyrogram/methods/chats/get_dialogs.py

@@ -16,6 +16,7 @@
 #  You should have received a copy of the GNU Lesser General Public License
 #  along with Pyrogram.  If not, see <http://www.gnu.org/licenses/>.
 
+from asyncio import sleep
 from typing import AsyncGenerator, Optional
 
 import pyrogram
@@ -113,6 +114,7 @@ async def get_dialogs(
             offset_peer = await self.resolve_peer(last.chat.id)
 
             for dialog in dialogs:
+                await sleep(0)
                 yield dialog
 
                 current += 1

pyrogram/methods/invite_links/get_chat_admin_invite_links.py

@@ -16,6 +16,7 @@
 #  You should have received a copy of the GNU Lesser General Public License
 #  along with Pyrogram.  If not, see <http://www.gnu.org/licenses/>.
 
+from asyncio import sleep
 from typing import Union, Optional, AsyncGenerator
 
 import pyrogram
@@ -92,6 +93,7 @@ async def get_chat_admin_invite_links(
             offset_link = r.invites[-1].link
 
             for i in r.invites:
+                await sleep(0)
                 yield types.ChatInviteLink._parse(self, i, users)
 
                 current += 1

pyrogram/methods/invite_links/get_chat_invite_link_joiners.py

@@ -16,6 +16,7 @@
 #  You should have received a copy of the GNU Lesser General Public License
 #  along with Pyrogram.  If not, see <http://www.gnu.org/licenses/>.
 
+from asyncio import sleep
 from typing import Union, Optional, AsyncGenerator
 
 import pyrogram
@@ -79,6 +80,7 @@ async def get_chat_invite_link_joiners(
             offset_user = await self.resolve_peer(r.importers[-1].user_id)
 
             for i in r.importers:
+                await sleep(0)
                 yield types.ChatJoiner._parse(self, i, users)
 
                 current += 1

pyrogram/methods/invite_links/get_chat_join_requests.py

@@ -16,6 +16,7 @@
 #  You should have received a copy of the GNU Lesser General Public License
 #  along with Pyrogram.  If not, see <http://www.gnu.org/licenses/>.
 
+from asyncio import sleep
 from typing import Union, Optional, AsyncGenerator
 
 import pyrogram
@@ -80,6 +81,7 @@ async def get_chat_join_requests(
             offset_user = await self.resolve_peer(r.importers[-1].user_id)
 
             for i in r.importers:
+                await sleep(0)
                 yield types.ChatJoiner._parse(self, i, users)
 
                 current += 1

pyrogram/methods/messages/get_chat_history.py

@@ -16,6 +16,7 @@
 #  You should have received a copy of the GNU Lesser General Public License
 #  along with Pyrogram.  If not, see <http://www.gnu.org/licenses/>.
 
+from asyncio import sleep
 from datetime import datetime
 from typing import Union, Optional, AsyncGenerator
 
@@ -68,7 +69,7 @@ async def get_chunk(
             ),
             sleep_threshold=60
         )
-        messages =await utils.parse_messages(
+        messages = await utils.parse_messages(
             client,
             messages,
             is_scheduled=False,
@@ -165,6 +166,7 @@ async def get_chat_history(
             offset_id = messages[-1].id + (1 if reverse else 0)
 
             for message in messages:
+                await sleep(0)
                 yield message
 
                 current += 1

pyrogram/methods/messages/get_discussion_replies.py

@@ -16,6 +16,7 @@
 #  You should have received a copy of the GNU Lesser General Public License
 #  along with Pyrogram.  If not, see <http://www.gnu.org/licenses/>.
 
+from asyncio import sleep
 from typing import Union, Optional, AsyncGenerator
 
 import pyrogram
@@ -72,12 +73,13 @@ async def get_discussion_replies(
 
             users = {u.id: u for u in r.users}
             chats = {c.id: c for c in r.chats}
-            messages = r.messages
+            messages = r.messages  # TODO
 
             if not messages:
                 return
 
             for message in messages:
+                await sleep(0)
                 yield await types.Message._parse(
                     self,
                     message,