api: Update API schema to Layer 160 and adapt senders

Co-Authored-By: Moshe <62907797+moshe-coh@users.noreply.github.com>

Author: 2 people

compiler/api/source/main_api.tl

@@ -19,8 +19,7 @@
 from typing import Union
 
 import pyrogram
-from pyrogram import raw
-from pyrogram import types
+from pyrogram import raw, utils, types
 
 
 class SendGame:
@@ -30,6 +29,7 @@ async def send_game(
         game_short_name: str,
         disable_notification: bool = None,
         reply_to_message_id: int = None,
+        message_thread_id: int = None,
         protect_content: bool = None,
         reply_markup: Union[
             "types.InlineKeyboardMarkup",
@@ -58,6 +58,9 @@ async def send_game(
             reply_to_message_id (``int``, *optional*):
                 If the message is a reply, ID of the original message.
 
+            message_thread_id (``int``, *optional*):
+                If the message is in a thread, ID of the original message.
+
             protect_content (``bool``, *optional*):
                 Protects the contents of the sent message from forwarding and saving.
 
@@ -73,6 +76,9 @@ async def send_game(
 
                 await app.send_game(chat_id, "gamename")
         """
+
+        reply_to = utils.get_reply_head_fm(message_thread_id, reply_to_message_id)
+
         r = await self.invoke(
             raw.functions.messages.SendMedia(
                 peer=await self.resolve_peer(chat_id),
@@ -84,7 +90,7 @@ async def send_game(
                 ),
                 message="",
                 silent=disable_notification or None,
-                reply_to_msg_id=reply_to_message_id,
+                reply_to=reply_to,
                 random_id=self.rnd_id(),
                 noforwards=protect_content,
                 reply_markup=await reply_markup.write(self) if reply_markup else None

pyrogram/methods/bots/send_game.py

@@ -19,7 +19,7 @@
 from typing import Union
 
 import pyrogram
-from pyrogram import raw
+from pyrogram import raw, utils
 
 
 class SendInlineBotResult:
@@ -29,7 +29,8 @@ async def send_inline_bot_result(
         query_id: int,
         result_id: str,
         disable_notification: bool = None,
-        reply_to_message_id: int = None
+        reply_to_message_id: int = None,
+        message_thread_id: int = None
     ) -> "raw.base.Updates":
         """Send an inline bot result.
         Bot results can be retrieved using :meth:`~pyrogram.Client.get_inline_bot_results`
@@ -52,9 +53,12 @@ async def send_inline_bot_result(
                 Sends the message silently.
                 Users will receive a notification with no sound.
 
-            reply_to_message_id (``bool``, *optional*):
+            reply_to_message_id (``int``, *optional*):
                 If the message is a reply, ID of the original message.
 
+            message_thread_id (``int``, *optional*):
+                If the message is in a thread, ID of the original message.
+
         Returns:
             :obj:`~pyrogram.raw.base.Updates`: Currently, on success, a raw result is returned.
 
@@ -63,13 +67,16 @@ async def send_inline_bot_result(
 
                 await app.send_inline_bot_result(chat_id, query_id, result_id)
         """
+
+        reply_to = utils.get_reply_head_fm(message_thread_id, reply_to_message_id)
+
         return await self.invoke(
             raw.functions.messages.SendInlineBotResult(
                 peer=await self.resolve_peer(chat_id),
                 query_id=query_id,
                 id=result_id,
                 random_id=self.rnd_id(),
                 silent=disable_notification or None,
-                reply_to_msg_id=reply_to_message_id
+                reply_to=reply_to
             )
         )

pyrogram/methods/bots/send_inline_bot_result.py

@@ -32,6 +32,7 @@ async def copy_media_group(
         captions: Union[List[str], str] = None,
         disable_notification: bool = None,
         reply_to_message_id: int = None,
+        message_thread_id: int = None,
         schedule_date: datetime = None,
     ) -> List["types.Message"]:
         """Copy a media group by providing one of the message ids.
@@ -68,6 +69,9 @@ async def copy_media_group(
             reply_to_message_id (``int``, *optional*):
                 If the message is a reply, ID of the original message.
 
+            message_thread_id (``int``, *optional*):
+                If the message is in a thread, ID of the original message.
+
             schedule_date (:py:obj:`~datetime.datetime`, *optional*):
                 Date when the message will be automatically sent.
 
@@ -114,12 +118,14 @@ async def copy_media_group(
                 )
             )
 
+        reply_to = utils.get_reply_head_fm(message_thread_id, reply_to_message_id)
+
         r = await self.invoke(
             raw.functions.messages.SendMultiMedia(
                 peer=await self.resolve_peer(chat_id),
                 multi_media=multi_media,
                 silent=disable_notification or None,
-                reply_to_msg_id=reply_to_message_id,
+                reply_to=reply_to,
                 schedule_date=utils.datetime_to_timestamp(schedule_date)
             ),
             sleep_threshold=60

pyrogram/methods/messages/copy_media_group.py

@@ -47,6 +47,7 @@ async def send_animation(
         file_name: str = None,
         disable_notification: bool = None,
         reply_to_message_id: int = None,
+        message_thread_id: int = None,
         schedule_date: datetime = None,
         protect_content: bool = None,
         reply_markup: Union[
@@ -118,6 +119,9 @@ async def send_animation(
             reply_to_message_id (``int``, *optional*):
                 If the message is a reply, ID of the original message.
 
+            message_thread_id (``int``, *optional*):
+                If the message is in a thread, ID of the original message.
+
             schedule_date (:py:obj:`~datetime.datetime`, *optional*):
                 Date when the message will be automatically sent.
 
@@ -223,14 +227,16 @@ async def progress(current, total):
                     ]
                 )
 
+            reply_to = utils.get_reply_head_fm(message_thread_id, reply_to_message_id)
+
             while True:
                 try:
                     r = await self.invoke(
                         raw.functions.messages.SendMedia(
                             peer=await self.resolve_peer(chat_id),
                             media=media,
                             silent=disable_notification or None,
-                            reply_to_msg_id=reply_to_message_id,
+                            reply_to=reply_to,
                             random_id=self.rnd_id(),
                             schedule_date=utils.datetime_to_timestamp(schedule_date),
                             noforwards=protect_content,

pyrogram/methods/messages/send_animation.py

@@ -45,6 +45,7 @@ async def send_audio(
         file_name: str = None,
         disable_notification: bool = None,
         reply_to_message_id: int = None,
+        message_thread_id: int = None,
         schedule_date: datetime = None,
         protect_content: bool = None,
         reply_markup: Union[
@@ -111,6 +112,9 @@ async def send_audio(
             reply_to_message_id (``int``, *optional*):
                 If the message is a reply, ID of the original message.
 
+            message_thread_id (``int``, *optional*):
+                If the message is in a thread, ID of the original message.
+
             schedule_date (:py:obj:`~datetime.datetime`, *optional*):
                 Date when the message will be automatically sent.
 
@@ -210,14 +214,16 @@ async def progress(current, total):
                     ]
                 )
 
+            reply_to = utils.get_reply_head_fm(message_thread_id, reply_to_message_id)
+
             while True:
                 try:
                     r = await self.invoke(
                         raw.functions.messages.SendMedia(
                             peer=await self.resolve_peer(chat_id),
                             media=media,
                             silent=disable_notification or None,
-                            reply_to_msg_id=reply_to_message_id,
+                            reply_to=reply_to,
                             random_id=self.rnd_id(),
                             schedule_date=utils.datetime_to_timestamp(schedule_date),
                             noforwards=protect_content,

pyrogram/methods/messages/send_audio.py

@@ -35,6 +35,7 @@ async def send_cached_media(
         caption_entities: List["types.MessageEntity"] = None,
         disable_notification: bool = None,
         reply_to_message_id: int = None,
+        message_thread_id: int = None,
         schedule_date: datetime = None,
         protect_content: bool = None,
         reply_markup: Union[
@@ -79,6 +80,9 @@ async def send_cached_media(
             reply_to_message_id (``int``, *optional*):
                 If the message is a reply, ID of the original message.
 
+            message_thread_id (``int``, *optional*):
+                If the message is in a thread, ID of the original message.
+
             schedule_date (:py:obj:`~datetime.datetime`, *optional*):
                 Date when the message will be automatically sent.
             
@@ -98,12 +102,14 @@ async def send_cached_media(
                 await app.send_cached_media("me", file_id)
         """
 
+        reply_to = utils.get_reply_head_fm(message_thread_id, reply_to_message_id)
+
         r = await self.invoke(
             raw.functions.messages.SendMedia(
                 peer=await self.resolve_peer(chat_id),
                 media=utils.get_input_media_from_file_id(file_id),
                 silent=disable_notification or None,
-                reply_to_msg_id=reply_to_message_id,
+                reply_to=reply_to,
                 random_id=self.rnd_id(),
                 schedule_date=utils.datetime_to_timestamp(schedule_date),
                 noforwards=protect_content,

pyrogram/methods/messages/send_cached_media.py

@@ -34,6 +34,7 @@ async def send_contact(
         vcard: str = None,
         disable_notification: bool = None,
         reply_to_message_id: int = None,
+        message_thread_id: int = None,
         schedule_date: datetime = None,
         protect_content: bool = None,
         reply_markup: Union[
@@ -72,6 +73,9 @@ async def send_contact(
             reply_to_message_id (``int``, *optional*):
                 If the message is a reply, ID of the original message.
 
+            message_thread_id (``int``, *optional*):
+                If the message is in a thread, ID of the original message.
+
             schedule_date (:py:obj:`~datetime.datetime`, *optional*):
                 Date when the message will be automatically sent.
 
@@ -90,6 +94,9 @@ async def send_contact(
 
                 await app.send_contact("me", "+1-123-456-7890", "Name")
         """
+
+        reply_to = utils.get_reply_head_fm(message_thread_id, reply_to_message_id)
+
         r = await self.invoke(
             raw.functions.messages.SendMedia(
                 peer=await self.resolve_peer(chat_id),
@@ -101,7 +108,7 @@ async def send_contact(
                 ),
                 message="",
                 silent=disable_notification or None,
-                reply_to_msg_id=reply_to_message_id,
+                reply_to=reply_to,
                 random_id=self.rnd_id(),
                 schedule_date=utils.datetime_to_timestamp(schedule_date),
                 noforwards=protect_content,

pyrogram/methods/messages/send_contact.py

@@ -31,6 +31,7 @@ async def send_dice(
         emoji: str = "🎲",
         disable_notification: bool = None,
         reply_to_message_id: int = None,
+        message_thread_id: int = None,
         schedule_date: datetime = None,
         protect_content: bool = None,
         reply_markup: Union[
@@ -64,6 +65,9 @@ async def send_dice(
             reply_to_message_id (``int``, *optional*):
                 If the message is a reply, ID of the original message.
 
+            message_thread_id (``int``, *optional*):
+                If the message is in a thread, ID of the original message.
+
             schedule_date (:py:obj:`~datetime.datetime`, *optional*):
                 Date when the message will be automatically sent.
 
@@ -90,12 +94,14 @@ async def send_dice(
                 await app.send_dice(chat_id, "🏀")
         """
 
+        reply_to = utils.get_reply_head_fm(message_thread_id, reply_to_message_id)
+
         r = await self.invoke(
             raw.functions.messages.SendMedia(
                 peer=await self.resolve_peer(chat_id),
                 media=raw.types.InputMediaDice(emoticon=emoji),
                 silent=disable_notification or None,
-                reply_to_msg_id=reply_to_message_id,
+                reply_to=reply_to,
                 random_id=self.rnd_id(),
                 schedule_date=utils.datetime_to_timestamp(schedule_date),
                 noforwards=protect_content,

pyrogram/methods/messages/send_dice.py

@@ -43,6 +43,7 @@ async def send_document(
         force_document: bool = None,
         disable_notification: bool = None,
         reply_to_message_id: int = None,
+        message_thread_id: int = None,
         schedule_date: datetime = None,
         protect_content: bool = None,
         reply_markup: Union[
@@ -103,6 +104,9 @@ async def send_document(
             reply_to_message_id (``int``, *optional*):
                 If the message is a reply, ID of the original message.
 
+            message_thread_id (``int``, *optional*):
+                If the message is in a thread, ID of the original message.
+
             schedule_date (:py:obj:`~datetime.datetime`, *optional*):
                 Date when the message will be automatically sent.
 
@@ -188,14 +192,16 @@ async def progress(current, total):
                     ]
                 )
 
+            reply_to = utils.get_reply_head_fm(message_thread_id, reply_to_message_id)
+
             while True:
                 try:
                     r = await self.invoke(
                         raw.functions.messages.SendMedia(
                             peer=await self.resolve_peer(chat_id),
                             media=media,
                             silent=disable_notification or None,
-                            reply_to_msg_id=reply_to_message_id,
+                            reply_to=reply_to,
                             random_id=self.rnd_id(),
                             schedule_date=utils.datetime_to_timestamp(schedule_date),
                             noforwards=protect_content,