Update server.py

server.py

@@ -1,4 +1,4 @@
-import os, json, urllib.request, subprocess
+import os, json, urllib.request, subprocess, traceback
 from http.server import BaseHTTPRequestHandler, HTTPServer
 
 PORT = 7860
@@ -8,46 +8,69 @@ CF_URL = os.environ.get("CF_WORKER_URL", "").rstrip('/')
 
 def send_tg(chat_id, text):
     """Отправка сообщений в Telegram ЧЕРЕЗ Cloudflare"""
-    if not CF_URL or not TOKEN: return
+    if not CF_URL or not TOKEN: 
+        print("❌ Ошибка отправки: Не задан CF_WORKER_URL или TELEGRAM_BOT_TOKEN")
+        return
     url = f"{CF_URL}/bot{TOKEN}/sendMessage"
     data = json.dumps({"chat_id": chat_id, "text": str(text)}).encode('utf-8')
     req = urllib.request.Request(url, data=data, headers={"Content-Type": "application/json"})
     try: 
         urllib.request.urlopen(req)
+        print(f"✈️ Сообщение успешно отправлено в чат {chat_id}")
     except Exception as e: 
-        print(f"Ошибка отправки: {e}")
+        print(f"❌ Ошибка отправки в Telegram: {e}")
 
 class WebhookHandler(BaseHTTPRequestHandler):
     def do_POST(self):
         length = int(self.headers.get('Content-Length', 0))
         data = json.loads(self.rfile.read(length))
         
-        # Обязательно отдаем 200 OK Телеграму
+        # Сразу отдаем 200 OK
         self.send_response(200)
         self.end_headers()
 
         if "message" in data and "text" in data["message"]:
             chat_id = str(data["message"]["chat"]["id"])
             text = data["message"]["text"]
+            
+            print(f"📥 Получено сообщение от chat_id {chat_id}: {text}")
 
             if ALLOWED_USER and chat_id != ALLOWED_USER:
+                print(f"⛔ Блокировка: chat_id {chat_id} не совпадает с ALLOWED_USER {ALLOWED_USER}")
                 send_tg(chat_id, "⛔ Доступ закрыт.")
                 return
 
+            # Отправляем первое проверочное сообщение
             send_tg(chat_id, "🤖 Задача принята! Гермес приступил к выполнению цикла...")
             
-            # Запускаем локального агента Гермеса для выполнения ТЗ
+            # Запускаем локального агента Гермеса
             try:
+                print("🧠 Запускаю команду hermes...")
+                # Передаем API ключ Nvidia прямо в окружение команды на всякий случай
+                my_env = os.environ.copy()
                 cmd = ["hermes", "chat", "--cli", "-m", "nvidia/glm-5.1", "-z", text]
-                result = subprocess.run(cmd, capture_output=True, text=True)
                 
-                # Собираем лог (берем последние 4000 символов, чтобы влезло в лимит ТГ)
+                result = subprocess.run(cmd, capture_output=True, text=True, env=my_env)
+                
                 reply = result.stdout.strip()
+                err_reply = result.stderr.strip()
+                
+                if err_reply:
+                    print(f"⚠️ Лог Гермеса (stderr): {err_reply}")
+                
                 if not reply:
-                    reply = result.stderr.strip()
+                    reply = err_reply
                 
-                send_tg(chat_id, reply[-4000:] if reply else "✅ Цикл завершен (вывод пуст).")
+                if reply:
+                    print(f"📤 Ответ от Гермеса получен, длина: {len(reply)} симв.")
+                    send_tg(chat_id, reply[-4000:])
+                else:
+                    print("❓ Гермес вернул абсолютно пустой ответ.")
+                    send_tg(chat_id, "✅ Цикл завершен, но Гермес ничего не вывел.")
+                    
             except Exception as e:
+                error_trace = traceback.format_exc()
+                print(f"❌ КРИТИЧЕСКАЯ ОШИБКА В СИСТЕМЕ:\n{error_trace}")
                 send_tg(chat_id, f"❌ Ошибка системы: {e}")
 
     def do_GET(self):