fix(pyrogram.utils.get_reply_to): function parameters

This commit is contained in:
n/a 2025-01-29 04:40:09 +07:00
parent 0f65486aba
commit 4a50a9183d
4 changed files with 31 additions and 22 deletions

View file

@ -102,6 +102,17 @@ class SendInlineBotResult:
""" """
quote_text, quote_entities = (await utils.parse_text_entities(self, quote_text, parse_mode, quote_entities)).values() quote_text, quote_entities = (await utils.parse_text_entities(self, quote_text, parse_mode, quote_entities)).values()
reply_to = await utils.get_reply_to(
client=self,
reply_to_message_id=reply_to_message_id,
reply_to_chat_id=reply_to_chat_id,
reply_to_story_id=reply_to_story_id,
message_thread_id=message_thread_id,
quote_text=quote_text,
quote_entities=quote_entities,
quote_offset=quote_offset,
parse_mode=parse_mode,
)
r = await self.invoke( r = await self.invoke(
raw.functions.messages.SendInlineBotResult( raw.functions.messages.SendInlineBotResult(
peer=await self.resolve_peer(chat_id), peer=await self.resolve_peer(chat_id),
@ -109,15 +120,7 @@ class SendInlineBotResult:
id=result_id, id=result_id,
random_id=self.rnd_id(), random_id=self.rnd_id(),
silent=disable_notification or None, silent=disable_notification or None,
reply_to=utils.get_reply_to( reply_to=reply_to,
reply_to_message_id=reply_to_message_id,
reply_to_peer=await self.resolve_peer(reply_to_chat_id) if reply_to_chat_id else None,
reply_to_story_id=reply_to_story_id,
message_thread_id=message_thread_id,
quote_text=quote_text,
quote_entities=quote_entities,
quote_offset=quote_offset,
),
schedule_date=utils.datetime_to_timestamp(schedule_date), schedule_date=utils.datetime_to_timestamp(schedule_date),
) )
) )

View file

@ -169,20 +169,21 @@ class CopyMediaGroup:
) )
) )
reply_to = await utils.get_reply_to(
reply_to_message_id=reply_to_message_id,
message_thread_id=message_thread_id,
reply_to_chat_id=reply_to_chat_id,
reply_to_story_id=reply_to_story_id,
quote_text=quote_text,
quote_entities=quote_entities,
quote_offset=quote_offset,
)
r = await self.invoke( r = await self.invoke(
raw.functions.messages.SendMultiMedia( raw.functions.messages.SendMultiMedia(
peer=await self.resolve_peer(chat_id), peer=await self.resolve_peer(chat_id),
multi_media=multi_media, multi_media=multi_media,
silent=disable_notification or None, silent=disable_notification or None,
reply_to=utils.get_reply_to( reply_to=reply_to,
reply_to_message_id=reply_to_message_id,
message_thread_id=message_thread_id,
reply_to_peer=await self.resolve_peer(reply_to_chat_id) if reply_to_chat_id else None,
reply_to_story_id=reply_to_story_id,
quote_text=quote_text,
quote_entities=quote_entities,
quote_offset=quote_offset,
),
schedule_date=utils.datetime_to_timestamp(schedule_date), schedule_date=utils.datetime_to_timestamp(schedule_date),
noforwards=protect_content, noforwards=protect_content,
invert_media=invert_media invert_media=invert_media

View file

@ -55,7 +55,8 @@ class InputReplyToMessage(Object):
"raw.types.InputPeerUser" "raw.types.InputPeerUser"
] = None, ] = None,
quote_text: str = None, quote_text: str = None,
quote_entities: List["raw.base.MessageEntity"] = None quote_entities: List["raw.base.MessageEntity"] = None,
quote_offset: int = None,
): ):
super().__init__() super().__init__()
@ -64,6 +65,7 @@ class InputReplyToMessage(Object):
self.reply_to_chat = reply_to_chat self.reply_to_chat = reply_to_chat
self.quote_text = quote_text self.quote_text = quote_text
self.quote_entities = quote_entities self.quote_entities = quote_entities
self.quote_offset = quote_offset
def write(self): def write(self):
reply_to_msg_id = None reply_to_msg_id = None
@ -82,6 +84,7 @@ class InputReplyToMessage(Object):
top_msg_id=top_msg_id, top_msg_id=top_msg_id,
reply_to_peer_id=self.reply_to_chat, reply_to_peer_id=self.reply_to_chat,
quote_text=self.quote_text, quote_text=self.quote_text,
quote_entities=self.quote_entities quote_entities=self.quote_entities,
quote_offset=self.quote_offset,
).write() ).write()
return None return None

View file

@ -502,7 +502,8 @@ async def get_reply_to(
reply_to_chat_id: Union[int,str] = None, reply_to_chat_id: Union[int,str] = None,
quote_text: str = None, quote_text: str = None,
quote_entities: List["types.MessageEntity"] = None, quote_entities: List["types.MessageEntity"] = None,
parse_mode: "enums.ParseMode" = None quote_offset: int = None,
parse_mode: "enums.ParseMode" = None,
): ):
reply_to = None reply_to = None
reply_to_chat = None reply_to_chat = None
@ -515,7 +516,8 @@ async def get_reply_to(
message_thread_id=message_thread_id, message_thread_id=message_thread_id,
reply_to_chat=reply_to_chat, reply_to_chat=reply_to_chat,
quote_text=text, quote_text=text,
quote_entities=entities quote_entities=entities,
quote_offset=quote_offset,
) )
if reply_to_story_id: if reply_to_story_id:
peer = await client.resolve_peer(chat_id) peer = await client.resolve_peer(chat_id)