Update server.py

server.py

@@ -1,4 +1,4 @@
-import os, json, urllib.request, subprocess, traceback
+import os, json, urllib.request, subprocess, traceback, sys
 from http.server import BaseHTTPRequestHandler, HTTPServer
 
 PORT = 7860
@@ -6,26 +6,30 @@ TOKEN = os.environ.get("TELEGRAM_BOT_TOKEN", "")
 ALLOWED_USER = os.environ.get("TELEGRAM_ALLOWED_USERS", "")
 CF_URL = os.environ.get("CF_WORKER_URL", "").rstrip('/')
 
+def log(msg):
+    """Специальный print, который мгновенно пробивает буфер Hugging Face"""
+    print(msg, flush=True)
+    sys.stdout.flush()
+
 def send_tg(chat_id, text):
-    """Отправка сообщений в Telegram ЧЕРЕЗ Cloudflare"""
     if not CF_URL or not TOKEN: 
-        print("❌ Ошибка отправки: Не задан CF_WORKER_URL или TELEGRAM_BOT_TOKEN")
+        log("❌ Ошибка: Не задан 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}")
+        log(f"✈️ Сообщение успешно отправлено в чат {chat_id}")
     except Exception as e: 
-        print(f"❌ Ошибка отправки в Telegram: {e}")
+        log(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()
 
@@ -33,22 +37,21 @@ class WebhookHandler(BaseHTTPRequestHandler):
             chat_id = str(data["message"]["chat"]["id"])
             text = data["message"]["text"]
             
-            print(f"📥 Получено сообщение от chat_id {chat_id}: {text}")
+            log(f"📥 Получено: {text}")
 
             if ALLOWED_USER and chat_id != ALLOWED_USER:
-                print(f"⛔ Блокировка: chat_id {chat_id} не совпадает с ALLOWED_USER {ALLOWED_USER}")
+                log("⛔ Блокировка: чужой ID.")
                 send_tg(chat_id, "⛔ Доступ закрыт.")
                 return
 
-            # Отправляем первое проверочное сообщение
-            send_tg(chat_id, "🤖 Задача принята! Гермес приступил к выполнению цикла...")
+            send_tg(chat_id, "🤖 Принято! Думаю...")
             
-            # Запускаем локального агента Гермеса
             try:
-                print("🧠 Запускаю команду hermes...")
-                # Передаем API ключ Nvidia прямо в окружение команды на всякий случай
+                log("🧠 Запускаю команду hermes...")
                 my_env = os.environ.copy()
-                cmd = ["hermes", "chat", "--cli", "-m", "nvidia/glm-5.1", "-z", text]
+                
+                # Используем префикс openai/ для кастомных прокси и имя модели из твоего скрина
+                cmd = ["hermes", "chat", "--cli", "-m", "openai/z-ai/glm-5.1", "-z", text]
                 
                 result = subprocess.run(cmd, capture_output=True, text=True, env=my_env)
                 
@@ -56,22 +59,22 @@ class WebhookHandler(BaseHTTPRequestHandler):
                 err_reply = result.stderr.strip()
                 
                 if err_reply:
-                    print(f"⚠️ Лог Гермеса (stderr): {err_reply}")
+                    log(f"⚠️ Лог Гермеса (stderr): {err_reply}")
                 
                 if not reply:
                     reply = err_reply
                 
                 if reply:
-                    print(f"📤 Ответ от Гермеса получен, длина: {len(reply)} симв.")
+                    log(f"📤 Ответ получен: {len(reply)} симв.")
                     send_tg(chat_id, reply[-4000:])
                 else:
-                    print("❓ Гермес вернул абсолютно пустой ответ.")
-                    send_tg(chat_id, "✅ Цикл завершен, но Гермес ничего не вывел.")
+                    log("❓ Гермес вернул пустоту.")
+                    send_tg(chat_id, "✅ Пустой ответ от Гермеса.")
                     
             except Exception as e:
                 error_trace = traceback.format_exc()
-                print(f"❌ КРИТИЧЕСКАЯ ОШИБКА В СИСТЕМЕ:\n{error_trace}")
-                send_tg(chat_id, f"❌ Ошибка системы: {e}")
+                log(f"❌ ОШИБКА:\n{error_trace}")
+                send_tg(chat_id, f"❌ Ошибка: {e}")
 
     def do_GET(self):
         self.send_response(200)
@@ -79,6 +82,6 @@ class WebhookHandler(BaseHTTPRequestHandler):
         self.wfile.write(b"Server Online")
 
 if __name__ == "__main__":
-    print(f"Starting Hermes Webhook Bridge on port {PORT}")
+    log(f"Starting Hermes Webhook Bridge on port {PORT}")
     HTTPServer(('0.0.0.0', PORT), WebhookHandler).serve_forever()