mirror of
https://github.com/LonamiWebs/Telethon.git
synced 2024-09-21 11:18:50 +03:00
115 lines
3.7 KiB
Python
115 lines
3.7 KiB
Python
import abc
|
|
|
|
from ... import errors, utils
|
|
from ...tl import types
|
|
|
|
|
|
class ChatGetter(abc.ABC):
|
|
"""
|
|
Helper base class that introduces the `chat`, `input_chat`
|
|
and `chat_id` properties and `get_chat` and `get_input_chat`
|
|
methods.
|
|
|
|
Subclasses **must** have the following private members: `_chat`,
|
|
`_input_chat`, `_chat_peer`, `_broadcast` and `_client`. As an end
|
|
user, you should not worry about this.
|
|
"""
|
|
@property
|
|
def chat(self):
|
|
"""
|
|
Returns the :tl:`User`, :tl:`Chat` or :tl:`Channel` where this object
|
|
belongs to. It may be ``None`` if Telegram didn't send the chat.
|
|
|
|
If you're using `telethon.events`, use `get_chat` instead.
|
|
"""
|
|
return self._chat
|
|
|
|
async def get_chat(self):
|
|
"""
|
|
Returns `chat`, but will make an API call to find the
|
|
chat unless it's already cached.
|
|
"""
|
|
if self._chat is None and await self.get_input_chat():
|
|
try:
|
|
self._chat =\
|
|
await self._client.get_entity(self._input_chat)
|
|
except ValueError:
|
|
await self._refetch_chat()
|
|
return self._chat
|
|
|
|
@property
|
|
def input_chat(self):
|
|
"""
|
|
This :tl:`InputPeer` is the input version of the chat where the
|
|
message was sent. Similarly to `input_sender`, this doesn't have
|
|
things like username or similar, but still useful in some cases.
|
|
|
|
Note that this might not be available if the library doesn't
|
|
have enough information available.
|
|
"""
|
|
if self._input_chat is None and self._chat_peer:
|
|
try:
|
|
self._input_chat =\
|
|
self._client.session.get_input_entity(self._chat_peer)
|
|
except ValueError:
|
|
pass
|
|
|
|
return self._input_chat
|
|
|
|
async def get_input_chat(self):
|
|
"""
|
|
Returns `input_chat`, but will make an API call to find the
|
|
input chat unless it's already cached.
|
|
"""
|
|
if self.input_chat is None and self.chat_id:
|
|
try:
|
|
# The chat may be recent, look in dialogs
|
|
target = self.chat_id
|
|
async for d in self._client.iter_dialogs(100):
|
|
if d.id == target:
|
|
self._chat = d.entity
|
|
self._input_chat = d.input_entity
|
|
break
|
|
except errors.RPCError:
|
|
pass
|
|
|
|
return self._input_chat
|
|
|
|
@property
|
|
def chat_id(self):
|
|
"""
|
|
Returns the marked chat integer ID. Note that this value **will
|
|
be different** from `to_id` for incoming private messages, since
|
|
the chat *to* which the messages go is to your own person, but
|
|
the *chat* itself is with the one who sent the message.
|
|
|
|
TL;DR; this gets the ID that you expect.
|
|
"""
|
|
return utils.get_peer_id(self._chat_peer) if self._chat_peer else None
|
|
|
|
@property
|
|
def is_private(self):
|
|
"""True if the message was sent as a private message."""
|
|
return isinstance(self._chat_peer, types.PeerUser)
|
|
|
|
@property
|
|
def is_group(self):
|
|
"""True if the message was sent on a group or megagroup."""
|
|
if self._broadcast is None and self.chat:
|
|
self._broadcast = getattr(self.chat, 'broadcast', None)
|
|
|
|
return (
|
|
isinstance(self._chat_peer, (types.PeerChat, types.PeerChannel))
|
|
and not self._broadcast
|
|
)
|
|
|
|
@property
|
|
def is_channel(self):
|
|
"""True if the message was sent on a megagroup or channel."""
|
|
return isinstance(self._chat_peer, types.PeerChannel)
|
|
|
|
async def _refetch_chat(self):
|
|
"""
|
|
Re-fetches chat information through other means.
|
|
"""
|