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)