Update telegram_bot.py

telegram_bot.py

@@ -1,15 +1,32 @@
 import os
 import requests
+from agent_zero import AgentZero
 from command_router import process_command
 
-BOT = os.getenv("BOT_TELEGRAM")
-CHANNEL = os.getenv("CHANNEL_TELEGRAM")
+BOT_TOKEN = os.getenv("BOT_TELEGRAM")
+CHANNEL_ID = os.getenv("CHANNEL_TELEGRAM")
 
-def send(msg):
-    url = f"https://api.telegram.org/bot{BOT}/sendMessage"
-    data = {"chat_id": CHANNEL, "text": msg}
+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 handle_update(message):
-    reply = process_command(message)
-    send(reply)
+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)