web3cyberservices commited on
Commit
86ece9a
·
unverified ·
1 Parent(s): aee9d74

Add files via upload

Browse files
Files changed (1) hide show
  1. api/user_client.py +23 -0
api/user_client.py ADDED
@@ -0,0 +1,23 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ import os
2
+ from telethon import TelegramClient
3
+
4
+ # Инициализируем клиент один раз при запуске
5
+ # Используем переменные окружения для безопасности
6
+ api_id = int(os.environ.get("API_ID"))
7
+ api_hash = os.environ.get("API_HASH")
8
+
9
+ client = TelegramClient('user_session', api_id, api_hash)
10
+
11
+ async def search_in_group(group_username, query):
12
+ """Поиск сообщения в конкретной группе/канале"""
13
+ await client.start()
14
+ results = []
15
+ async for message in client.iter_messages(group_username, search=query, limit=10):
16
+ results.append(f"[{message.date}] {message.sender_id}: {message.text}")
17
+ return "\n".join(results) if results else "Ничего не найдено."
18
+
19
+ async def send_private_message(username, text):
20
+ """Отправка сообщения пользователю"""
21
+ await client.start()
22
+ await client.send_message(username, text)
23
+ return f"Сообщение отправлено пользователю {username}"