alerts.py

import requests
import os
import time
from datetime import datetime
from dotenv import load_dotenv

load_dotenv()

TELEGRAM_TOKEN = os.getenv("TELEGRAM_TOKEN")
TELEGRAM_CHAT_ID = os.getenv("TELEGRAM_CHAT_ID")

# Track last time a message was sent
_last_message_time = 0


def send_message(message):
    global _last_message_time

    if not TELEGRAM_TOKEN or not TELEGRAM_CHAT_ID:
        print("Missing TELEGRAM_TOKEN or TELEGRAM_CHAT_ID")
        return

    # Wait at least 1 second since last message
    now = time.time()
    if now - _last_message_time < 1:
        time.sleep(1 - (now - _last_message_time))

    url = f"https://api.telegram.org/bot{TELEGRAM_TOKEN}/sendMessage"
    payload = {"chat_id": TELEGRAM_CHAT_ID, "text": message}

    # Retry with backoff
    for attempt in range(3):
        try:
            response = requests.post(url, data=payload, timeout=3)
            response.raise_for_status()
            _last_message_time = time.time()
            print(f"[{datetime.now()}] ✅ Sent: {message}")
            break
        except Exception as e:
            print(f"[{datetime.now()}] ⚠️ Attempt {attempt + 1} failed: {e}")
            time.sleep(1.5 * (attempt + 1))  # exponential backoff