mirror of
https://github.com/pyrogram/pyrogram
synced 2025-08-29 05:18:10 +00:00
Allow bots to message old chats even if they don't exist in the session
This commit is contained in:
parent
6e964b51b1
commit
00e4e385aa
@ -1104,35 +1104,58 @@ class Client(Methods, BaseClient):
|
|||||||
:class:`Error <pyrogram.Error>` in case of a Telegram RPC error.
|
:class:`Error <pyrogram.Error>` in case of a Telegram RPC error.
|
||||||
``KeyError`` in case the peer doesn't exist in the internal database.
|
``KeyError`` in case the peer doesn't exist in the internal database.
|
||||||
"""
|
"""
|
||||||
if type(peer_id) is str:
|
try:
|
||||||
if peer_id in ("self", "me"):
|
|
||||||
return types.InputPeerSelf()
|
|
||||||
|
|
||||||
peer_id = re.sub(r"[@+\s]", "", peer_id.lower())
|
|
||||||
|
|
||||||
try:
|
|
||||||
int(peer_id)
|
|
||||||
except ValueError:
|
|
||||||
if peer_id not in self.peers_by_username:
|
|
||||||
self.send(functions.contacts.ResolveUsername(peer_id))
|
|
||||||
|
|
||||||
return self.peers_by_username[peer_id]
|
|
||||||
else:
|
|
||||||
try:
|
|
||||||
return self.peers_by_phone[peer_id]
|
|
||||||
except KeyError:
|
|
||||||
raise PeerIdInvalid
|
|
||||||
|
|
||||||
try: # User
|
|
||||||
return self.peers_by_id[peer_id]
|
return self.peers_by_id[peer_id]
|
||||||
except KeyError:
|
except KeyError:
|
||||||
try: # Chat
|
if type(peer_id) is str:
|
||||||
return self.peers_by_id[-peer_id]
|
if peer_id in ("self", "me"):
|
||||||
|
return types.InputPeerSelf()
|
||||||
|
|
||||||
|
peer_id = re.sub(r"[@+\s]", "", peer_id.lower())
|
||||||
|
|
||||||
|
try:
|
||||||
|
int(peer_id)
|
||||||
|
except ValueError:
|
||||||
|
if peer_id not in self.peers_by_username:
|
||||||
|
self.send(
|
||||||
|
functions.contacts.ResolveUsername(
|
||||||
|
username=peer_id
|
||||||
|
)
|
||||||
|
)
|
||||||
|
|
||||||
|
return self.peers_by_username[peer_id]
|
||||||
|
else:
|
||||||
|
try:
|
||||||
|
return self.peers_by_phone[peer_id]
|
||||||
|
except KeyError:
|
||||||
|
raise PeerIdInvalid
|
||||||
|
|
||||||
|
if peer_id > 0:
|
||||||
|
self.fetch_peers(
|
||||||
|
self.send(
|
||||||
|
functions.users.GetUsers(
|
||||||
|
id=[types.InputUser(peer_id, 0)]
|
||||||
|
)
|
||||||
|
)
|
||||||
|
)
|
||||||
|
else:
|
||||||
|
if str(peer_id).startswith("-100"):
|
||||||
|
self.send(
|
||||||
|
functions.channels.GetChannels(
|
||||||
|
id=[types.InputChannel(int(str(peer_id)[4:]), 0)]
|
||||||
|
)
|
||||||
|
)
|
||||||
|
else:
|
||||||
|
self.send(
|
||||||
|
functions.messages.GetChats(
|
||||||
|
id=[-peer_id]
|
||||||
|
)
|
||||||
|
)
|
||||||
|
|
||||||
|
try:
|
||||||
|
return self.peers_by_id[peer_id]
|
||||||
except KeyError:
|
except KeyError:
|
||||||
try: # Channel
|
raise PeerIdInvalid
|
||||||
return self.peers_by_id[int("-100" + str(peer_id))]
|
|
||||||
except (KeyError, ValueError):
|
|
||||||
raise PeerIdInvalid
|
|
||||||
|
|
||||||
def save_file(self,
|
def save_file(self,
|
||||||
path: str,
|
path: str,
|
||||||
|
Loading…
x
Reference in New Issue
Block a user