telegram_bot.py

import os
import requests
from agent_zero import AgentZero
from command_router import process_command

BOT_TOKEN = os.getenv("BOT_TELEGRAM")
CHANNEL_ID = os.getenv("CHANNEL_TELEGRAM")

agent = AgentZero()

def send_telegram(message):
    url = f"https://api.telegram.org/bot{BOT_TOKEN}/sendMessage"
    data = {"chat_id": CHANNEL_ID, "text": message}
    requests.post(url, data=data)

def get_updates(offset=None):
    url = f"https://api.telegram.org/bot{BOT_TOKEN}/getUpdates"
    params = {"timeout": 100, "offset": offset}
    r = requests.get(url, params=params)
    return r.json().get("result", [])

def run_telegram_loop():
    last_update_id = None
    send_telegram("🤖 Agent Zéro activé. Je suis prêt maître.")
    while True:
        updates = get_updates(last_update_id + 1 if last_update_id else None)
        for u in updates:
            last_update_id = u["update_id"]
            if "message" in u and "text" in u["message"]:
                msg = u["message"]["text"]
                reply = process_command(msg, agent)
                send_telegram(reply)