import requests
import json
from configparser import ConfigParser
import logging

logging.basicConfig(filename='/var/www/html/logs/kafka_monitor.log',
                    filemode='a',
                    format='%(asctime)s %(name)s %(levelname)s %(message)s',
                    level=logging.INFO)

#Read config.ini file
config_object = ConfigParser()
config_object.read("tg_config.ini")

#Get ids
botinfo = config_object["botinfo"]
telegram_id = botinfo["telegram_id"]
telegram_chat_id = botinfo["telegram_chat_id"]

def send_telegram_message(message):
    """Sends alert via Telegram"""
    url = "https://api.telegram.org/" + telegram_id + "/sendMessage"
    data = {
        "chat_id": telegram_chat_id,
        "text": message
    }
    try:
        response = requests.request(
            "POST",
            url,
            params=data
        )
        logging.info(response.text)
        telegram_data = json.loads(response.text)
        return telegram_data["ok"]
    except Exception as e:
        logging.info(f"failed with error {e}")
        return False