LonamiWebs/Telethon
1
1
Fork 0
mirror of https://github.com/LonamiWebs/Telethon.git synced 2025-01-27 01:34:29 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fix awaits on input_chat property

Browse Source
This commit is contained in:
Lonami Exo 2018-06-22 10:05:29 +02:00
parent f733f8e565
commit 8d98c04932
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
telethon/tl/custom/message.py
View File

@ -146,7 +146,7 @@ class Message:
along with their input versions. along with their input versions.
""" """
try: try:
chat = await self.input_chat if self.is_channel else None chat = await self.get_input_chat() if self.is_channel else None
msg = await self._client.get_messages( msg = await self._client.get_messages(
chat, ids=self.original_message.id) chat, ids=self.original_message.id)
except ValueError: except ValueError:
@ -488,7 +488,7 @@ class Message:
if not self.original_message.reply_to_msg_id: if not self.original_message.reply_to_msg_id:
return None return None
self._reply_message = await self._client.get_messages( self._reply_message = await self._client.get_messages(
await self.input_chat if self.is_channel else None, await self.get_input_chat() if self.is_channel else None,
ids=self.original_message.reply_to_msg_id ids=self.original_message.reply_to_msg_id
) )
@ -517,7 +517,7 @@ class Message:
``entity`` already set. ``entity`` already set.
""" """
return await self._client.send_message( return await self._client.send_message(
await self.input_chat, *args, **kwargs) await self.get_input_chat(), *args, **kwargs)
async def reply(self, *args, **kwargs): async def reply(self, *args, **kwargs):
""" """
@ -527,7 +527,7 @@ class Message:
""" """
kwargs['reply_to'] = self.original_message.id kwargs['reply_to'] = self.original_message.id
return await self._client.send_message( return await self._client.send_message(
await self.input_chat, *args, **kwargs) await self.get_input_chat(), *args, **kwargs)
async def forward_to(self, *args, **kwargs): async def forward_to(self, *args, **kwargs):
""" """
@ -540,7 +540,7 @@ class Message:
`telethon.telegram_client.TelegramClient` instance directly. `telethon.telegram_client.TelegramClient` instance directly.
""" """
kwargs['messages'] = self.original_message.id kwargs['messages'] = self.original_message.id
kwargs['from_peer'] = await self.input_chat kwargs['from_peer'] = await self.get_input_chat()
return await self._client.forward_messages(*args, **kwargs) return await self._client.forward_messages(*args, **kwargs)
async def edit(self, *args, **kwargs): async def edit(self, *args, **kwargs):
@ -562,7 +562,9 @@ class Message:
return None return None
return await self._client.edit_message( return await self._client.edit_message(
await self.input_chat, self.original_message, *args, **kwargs) await self.get_input_chat(), self.original_message,
*args, **kwargs
)
async def delete(self, *args, **kwargs): async def delete(self, *args, **kwargs):
""" """
@ -577,7 +579,9 @@ class Message:
`telethon.telegram_client.TelegramClient` instance directly. `telethon.telegram_client.TelegramClient` instance directly.
""" """
return await self._client.delete_messages( return await self._client.delete_messages(
await self.input_chat, [self.original_message], *args, **kwargs) await self.get_input_chat(), [self.original_message],
*args, **kwargs
)
async def download_media(self, *args, **kwargs): async def download_media(self, *args, **kwargs):
""" """