38 lines
1.2 KiB
Python
38 lines
1.2 KiB
Python
import requests as _rqsts
|
|
import syms as _bot_syms
|
|
|
|
|
|
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:
|
|
chat_id= user[0]
|
|
thread_id= user[1]
|
|
_wb_telegram_send_alert(msg, chat_id, thread_id)
|