-
Notifications
You must be signed in to change notification settings - Fork 1.4k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[V2] add inlinecallback to buttoncallback event #4252
base: v2
Are you sure you want to change the base?
Changes from all commits
8948c8c
c2509ad
51c2db9
69e741f
508a0ab
f726d1d
7408a43
8fdc255
fe87031
c0e09e9
5b33b4b
fbf0adb
9db309b
File filter
Filter by extension
Conversations
Jump to
Diff view
Diff view
There are no files selected for viewing
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,9 +1,13 @@ | ||
from __future__ import annotations | ||
|
||
from typing import TYPE_CHECKING, Dict, Optional, Self | ||
import struct | ||
import typing | ||
from typing import TYPE_CHECKING, Dict, Optional, Self, Union | ||
|
||
from .. import errors | ||
from ...session import PackedType | ||
from ...tl import abcs, functions, types | ||
from ..types import Chat, Message | ||
from ..types import Chat, Message, Channel, Group | ||
from .event import Event | ||
from ..types.chat import peer_id | ||
from ..client.messages import CherryPickedList | ||
|
@@ -22,7 +26,7 @@ class ButtonCallback(Event): | |
def __init__( | ||
self, | ||
client: Client, | ||
update: types.UpdateBotCallbackQuery, | ||
update: Union[types.UpdateBotCallbackQuery, types.UpdateInlineBotCallbackQuery], | ||
chat_map: Dict[int, Chat], | ||
): | ||
self._client = client | ||
|
@@ -33,7 +37,13 @@ def __init__( | |
def _try_from_update( | ||
cls, client: Client, update: abcs.Update, chat_map: Dict[int, Chat] | ||
) -> Optional[Self]: | ||
if isinstance(update, types.UpdateBotCallbackQuery) and update.data is not None: | ||
if ( | ||
isinstance( | ||
update, | ||
(types.UpdateBotCallbackQuery, types.UpdateInlineBotCallbackQuery), | ||
) | ||
and update.data is not None | ||
): | ||
return cls._create(client, update, chat_map) | ||
else: | ||
return None | ||
|
@@ -43,6 +53,87 @@ def data(self) -> bytes: | |
assert self._raw.data is not None | ||
return self._raw.data | ||
|
||
@property | ||
def via_inline(self) -> bool: | ||
""" | ||
Whether the button was clicked in an inline message. | ||
|
||
If it was, it might indicate that the bot is not in chat. | ||
If this is the case, both the :meth:`chat` and :meth:`get_message` will return :data:`None`. | ||
""" | ||
return isinstance(self._raw, types.UpdateInlineBotCallbackQuery) | ||
|
||
@property | ||
def message_id(self) -> typing.Union[int, abcs.InputBotInlineMessageId]: | ||
""" | ||
The identifier of the message containing the button that was clicked. | ||
|
||
If the message is inline, :class:`abcs.InputBotInlineMessageId` will be returned. | ||
You can use it in :meth:`~telethon._tl.functions.messages.edit_inline_bot_message` to edit the message. | ||
|
||
Else, usual message ID will be returned. | ||
""" | ||
return self._raw.msg_id | ||
|
||
@property | ||
def chat(self) -> Optional[Chat]: | ||
""" | ||
The :term:`chat` where the button was clicked. | ||
|
||
This may be :data:`None` if :data:`via_inline` is :data:`True`, as the bot might not be part of the chat. | ||
""" | ||
if isinstance(self._raw, types.UpdateInlineBotCallbackQuery): | ||
# for that type of update, the msg_id and owner_id are present, however bot is not guaranteed | ||
# to have "access" to the owner_id. | ||
if isinstance(self._raw.msg_id, types.InputBotInlineMessageId): | ||
# telegram used to pack msg_id and peer_id into InputBotInlineMessageId.id | ||
# I assume this is for the chats with IDs, fitting into 32-bit integer. | ||
_, owner_id = struct.unpack( | ||
"<ii", struct.pack("<q", self._raw.msg_id.id) | ||
) | ||
elif isinstance(self._raw.msg_id, types.InputBotInlineMessageId64): | ||
_ = self._raw.msg_id.id | ||
owner_id = self._raw.msg_id.owner_id | ||
else: | ||
raise RuntimeError(f"unexpected type of msg_id: {type(self._raw.msg_id)}") | ||
|
||
if owner_id is None: | ||
return None | ||
|
||
if owner_id > 0: | ||
# We can't know if it's really a chat with user, or an ID of the user who issued the inline query. | ||
# So it's better to return None, than to return wrong chat. | ||
return None | ||
|
||
owner_id = -owner_id | ||
|
||
if owner := self._chat_map.get(owner_id): | ||
return owner | ||
|
||
packed = self.client._chat_hashes.get(owner_id) | ||
|
||
raw = types.ChannelForbidden( | ||
broadcast=False, | ||
megagroup=False, | ||
id=owner_id, | ||
access_hash=0, | ||
title="", | ||
until_date=None, | ||
) | ||
|
||
if packed: | ||
raw.access_hash = packed.access_hash | ||
|
||
if packed.ty == PackedType.MEGAGROUP or packed.ty == PackedType.GIGAGROUP: | ||
if packed.ty == PackedType.GIGAGROUP: | ||
raw.gigagroup = True | ||
else: | ||
raw.megagroup = True | ||
return Group._from_raw(self.client, raw) | ||
raw.broadcast = True | ||
return Channel._from_raw(raw) | ||
return self._chat_map.get(peer_id(self._raw.peer)) | ||
|
||
async def answer( | ||
self, | ||
text: Optional[str] = None, | ||
|
@@ -75,20 +166,42 @@ async def get_message(self) -> Optional[Message]: | |
""" | ||
Get the :class:`~telethon.types.Message` containing the button that was clicked. | ||
|
||
If the message is too old and is no longer accessible, :data:`None` is returned instead. | ||
If the message is inline, or too old and is no longer accessible, :data:`None` is returned instead. | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. But isn't the purpose of using But we should be able to fetch the message without a chat. So maybe we need to rethink this method's implementation. |
||
""" | ||
|
||
pid = peer_id(self._raw.peer) | ||
chat = self._chat_map.get(pid) | ||
if not chat: | ||
chat = await self._client._resolve_to_packed(pid) | ||
|
||
lst = CherryPickedList(self._client, chat, []) | ||
lst._ids.append(types.InputMessageCallbackQuery(id=self._raw.msg_id, query_id=self._raw.query_id)) | ||
|
||
message = (await lst)[0] | ||
|
||
return message or None | ||
chat = self.chat | ||
|
||
# numeric_id, received in this case, is: | ||
# - a correct message id, if it was sent in a channel (or megagroup, gigagroup) | ||
# - a sender's message id, if it was sent in a private chat. So it's not a correct ID from bot perspective, | ||
# as each account has its own message id counter for private chats (pm, small group chats). | ||
if isinstance(self._raw, types.UpdateInlineBotCallbackQuery): | ||
if isinstance(self._raw.msg_id, types.InputBotInlineMessageId): | ||
numeric_id, _ = struct.unpack("<ii", struct.pack("<q", self._raw.msg_id.id)) | ||
elif isinstance(self._raw.msg_id, types.InputBotInlineMessageId64): | ||
numeric_id = self._raw.msg_id.id | ||
else: | ||
raise RuntimeError(f"unexpected type of msg_id: {type(self._raw.msg_id)}") | ||
else: | ||
numeric_id = self._raw.msg_id | ||
|
||
if chat: | ||
lst = CherryPickedList(self._client, chat, [numeric_id]) | ||
try: | ||
res = await lst | ||
if res: | ||
return res[0] or None | ||
except errors.RpcError as e: | ||
if e.name != "CHANNEL_INVALID" and e.name != "MESSAGE_IDS_EMPTY": | ||
raise | ||
|
||
# I didn't notice a single case, when this request returns a message. | ||
# However, theoretically, self._raw.msg_id is a valid type of InputMessageID, so it may be possible. | ||
res = await self._client( | ||
functions.messages.get_messages( | ||
id=[self._raw.msg_id], | ||
) | ||
) | ||
return res.messages[0] if res.messages else None | ||
|
||
|
||
class InlineQuery(Event): | ||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Should never return
abcs
to the user. They're in a private package.