get chat_id and thread_id from caller

This commit is contained in:
Crystal
2025-12-01 16:11:23 +01:00
parent 8f240f0d56
commit 3be2ba7688

View File

@@ -2,32 +2,36 @@ import requests as _rqsts
import syms as _bot_syms
def _wb_telegram_send_alert(message: str):
def _wb_telegram_send_alert(message, chat_id, thread_id= None):
print(f"wb_alert_bot _wb_telegram_send_alert: sending message to {chat_id}, {thread_id}...")
payload = {
'chat_id': chat_id,
'text': message,
'parse_mode': 'Markdown',
}
if thread_id: payload['message_thread_id']= thread_id
try:
res = _rqsts.post(_bot_syms.TELEGRAM_API_URL, data=payload, timeout=3)
res.raise_for_status()
jres = res.json()
if jres.get('ok'):
print(f"wb_alert_bot _wb_telegram_send_alert: message sent to {chat_id}, {thread_id}!")
else:
print(f"wb_alert_bot _wb_telegram_send_alert: Message not sent to {chat_id}, {thread_id}: {jres}")
except _rqsts.exceptions.RequestException as e:
print(f"wb_alert_bot _wb_telegram_send_alert: Connection error {chat_id}, {thread_id}: {e}")
def wb_telegram_send_alert(msg, chat_id, thread_id= None):
_wb_telegram_send_alert(msg, chat_id, thread_id)
def wb_telegram_send_alert_debug(msg):
users= _bot_syms.USERS
for user in users:
u= user[0]
chat_id= user[0]
thread_id= user[1]
print(f"wb_alert_bot _wb_telegram_send_alert: sending message to {user}...")
payload = {
'chat_id': u,
'text': message,
'parse_mode': 'Markdown',
}
if thread_id: payload['message_thread_id']= thread_id
try:
res = _rqsts.post(_bot_syms.TELEGRAM_API_URL, data=payload, timeout=3)
res.raise_for_status()
jres = res.json()
if jres.get('ok'):
print(f"wb_alert_bot _wb_telegram_send_alert: message sent to {user}!")
else:
print(f"wb_alert_bot _wb_telegram_send_alert: Message not sent to {user}: {jres}")
except _rqsts.exceptions.RequestException as e:
print(f"wb_alert_bot _wb_telegram_send_alert: Connection error: {e}")
def wb_telegram_send_alert(msg):
_wb_telegram_send_alert(msg)
_wb_telegram_send_alert(msg, chat_id, thread_id)