mirror of
https://github.com/LonamiWebs/Telethon.git
synced 2025-08-03 11:40:11 +03:00
Add even more missing await keywords
This commit is contained in:
parent
d980e947cf
commit
aae6a26654
|
@ -164,7 +164,7 @@ class ChatAction(EventBuilder):
|
|||
Responds to the chat action message (not as a reply).
|
||||
Shorthand for ``client.send_message(event.chat, ...)``.
|
||||
"""
|
||||
return await self._client.send_message(self.input_chat, *args, **kwargs)
|
||||
return await self._client.send_message(await self.input_chat, *args, **kwargs)
|
||||
|
||||
async def reply(self, *args, **kwargs):
|
||||
"""
|
||||
|
@ -177,7 +177,7 @@ class ChatAction(EventBuilder):
|
|||
return self.respond(*args, **kwargs)
|
||||
|
||||
kwargs['reply_to'] = self.action_message.id
|
||||
return await self._client.send_message(self.input_chat, *args, **kwargs)
|
||||
return await self._client.send_message(await self.input_chat, *args, **kwargs)
|
||||
|
||||
async def delete(self, *args, **kwargs):
|
||||
"""
|
||||
|
@ -189,7 +189,7 @@ class ChatAction(EventBuilder):
|
|||
Does nothing if no message action triggered this event.
|
||||
"""
|
||||
if self.action_message:
|
||||
return await self._client.delete_messages(self.input_chat,
|
||||
return await self._client.delete_messages(await self.input_chat,
|
||||
[self.action_message],
|
||||
*args, **kwargs)
|
||||
|
||||
|
@ -202,7 +202,7 @@ class ChatAction(EventBuilder):
|
|||
if self._pinned_message == 0:
|
||||
return None
|
||||
|
||||
if isinstance(self._pinned_message, int) and self.input_chat:
|
||||
if isinstance(self._pinned_message, int) and await self.input_chat:
|
||||
r = await self._client(functions.channels.GetMessagesRequest(
|
||||
self._input_chat, [
|
||||
types.InputMessageID(self._pinned_message)
|
||||
|
|
|
@ -97,7 +97,7 @@ class MessageRead(EventBuilder):
|
|||
was read instead checking if it's in here.
|
||||
"""
|
||||
if self._messages is None:
|
||||
chat = self.input_chat
|
||||
chat = await self.input_chat
|
||||
if not chat:
|
||||
self._messages = []
|
||||
elif isinstance(chat, types.InputPeerChannel):
|
||||
|
|
|
@ -158,7 +158,7 @@ class NewMessage(EventBuilder):
|
|||
Responds to the message (not as a reply). This is a shorthand for
|
||||
``client.send_message(event.chat, ...)``.
|
||||
"""
|
||||
return await self._client.send_message(self.input_chat, *args, **kwargs)
|
||||
return await self._client.send_message(await self.input_chat, *args, **kwargs)
|
||||
|
||||
async def reply(self, *args, **kwargs):
|
||||
"""
|
||||
|
@ -166,7 +166,7 @@ class NewMessage(EventBuilder):
|
|||
``client.send_message(event.chat, ..., reply_to=event.message.id)``.
|
||||
"""
|
||||
kwargs['reply_to'] = self.message.id
|
||||
return await self._client.send_message(self.input_chat, *args, **kwargs)
|
||||
return await self._client.send_message(await self.input_chat, *args, **kwargs)
|
||||
|
||||
async def forward_to(self, *args, **kwargs):
|
||||
"""
|
||||
|
@ -174,7 +174,7 @@ class NewMessage(EventBuilder):
|
|||
``client.forward_messages(entity, event.message, event.chat)``.
|
||||
"""
|
||||
kwargs['messages'] = self.message.id
|
||||
kwargs['from_peer'] = self.input_chat
|
||||
kwargs['from_peer'] = await self.input_chat
|
||||
return await self._client.forward_messages(*args, **kwargs)
|
||||
|
||||
async def edit(self, *args, **kwargs):
|
||||
|
@ -194,7 +194,7 @@ class NewMessage(EventBuilder):
|
|||
if self.message.to_id.user_id != me.user_id:
|
||||
return None
|
||||
|
||||
return await self._client.edit_message(self.input_chat,
|
||||
return await self._client.edit_message(await self.input_chat,
|
||||
self.message,
|
||||
*args, **kwargs)
|
||||
|
||||
|
@ -205,7 +205,7 @@ class NewMessage(EventBuilder):
|
|||
This is a shorthand for
|
||||
``client.delete_messages(event.chat, event.message, ...)``.
|
||||
"""
|
||||
return await self._client.delete_messages(self.input_chat,
|
||||
return await self._client.delete_messages(await self.input_chat,
|
||||
[self.message],
|
||||
*args, **kwargs)
|
||||
|
||||
|
@ -232,7 +232,7 @@ class NewMessage(EventBuilder):
|
|||
self._sender, self._input_sender = await self._get_entity(
|
||||
self.message.id,
|
||||
self.message.from_id,
|
||||
chat=self.input_chat
|
||||
chat=await self.input_chat
|
||||
)
|
||||
|
||||
return self._input_sender
|
||||
|
@ -295,9 +295,9 @@ class NewMessage(EventBuilder):
|
|||
return None
|
||||
|
||||
if self._reply_message is None:
|
||||
if isinstance(self.input_chat, types.InputPeerChannel):
|
||||
if isinstance(await self.input_chat, types.InputPeerChannel):
|
||||
r = await self._client(functions.channels.GetMessagesRequest(
|
||||
self.input_chat, [
|
||||
await self.input_chat, [
|
||||
types.InputMessageID(self.message.reply_to_msg_id)
|
||||
]
|
||||
))
|
||||
|
|
Loading…
Reference in New Issue
Block a user