Update server.py

server.py

@@ -7,91 +7,108 @@ ALLOWED_USER = os.environ.get("TELEGRAM_ALLOWED_USERS", "").strip()
 CF_URL = os.environ.get("CF_WORKER_URL", "").rstrip('/')
 
 def log(msg):
-    """Мгновенный вывод в логи Hugging Face"""
     print(msg, flush=True)
     sys.stdout.flush()
 
 def send_tg(chat_id, text):
-    """Отправка в Telegram через Cloudflare с маскировкой под браузер"""
-    if not CF_URL or not TOKEN: 
-        log("❌ Ошибка: Не задан CF_WORKER_URL или TELEGRAM_BOT_TOKEN")
-        return
-        
+    """Отправка в Telegram через Cloudflare"""
+    if not CF_URL or not TOKEN: return
     url = f"{CF_URL}/bot{TOKEN}/sendMessage"
     data = json.dumps({"chat_id": chat_id, "text": str(text)}).encode('utf-8')
+    headers = {"Content-Type": "application/json", "User-Agent": "Mozilla/5.0"}
+    req = urllib.request.Request(url, data=data, headers=headers)
+    try: urllib.request.urlopen(req, timeout=15)
+    except: pass
+
+def check_api():
+    """ПРЯМОЙ РЕНТГЕН ТВОЕГО ПРОВАЙДЕРА API"""
+    base = os.environ.get("OPENAI_API_BASE", "").strip().rstrip('/')
+    key = os.environ.get("OPENAI_API_KEY", "").strip()
+    
+    if not base or not key:
+        return False, "❌ В секретах Hugging Face не найдены OPENAI_API_BASE или OPENAI_API_KEY!"
+    
+    if not base.endswith("/v1"): 
+        base += "/v1"
+        
+    url = f"{base}/chat/completions"
+    
+    # Отправляем тестовый запрос напрямую в агрегатор
+    data = json.dumps({
+        "model": "z-ai/glm-5.1", 
+        "messages": [{"role": "user", "content": "Привет"}],
+        "max_tokens": 10
+    }).encode('utf-8')
     
-    # 🎭 Маскируемся под Google Chrome, чтобы Cloudflare не выдавал 403
     headers = {
-        "Content-Type": "application/json",
-        "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Safari/537.36"
+        "Authorization": f"Bearer {key}", 
+        "Content-Type": "application/json"
     }
     req = urllib.request.Request(url, data=data, headers=headers)
     
-    try: 
-        urllib.request.urlopen(req, timeout=15)
-        log(f"✈️ Сообщение успешно отправлено в чат {chat_id}")
+    try:
+        resp = urllib.request.urlopen(req, timeout=10)
+        res_data = json.loads(resp.read().decode('utf-8'))
+        return True, "✅ API работает отлично!"
     except urllib.error.HTTPError as e:
-        # Если Cloudflare все равно ругается, мы выведем точную причину
-        error_body = e.read().decode('utf-8', errors='ignore')
-        log(f"❌ Ошибка 403/HTTP от Cloudflare: {error_body[:250]}")
-    except Exception as e: 
-        log(f"❌ Ошибка сети: {e}")
+        # ВОТ ЗДЕСЬ МЫ ПОЙМАЕМ РЕАЛЬНУЮ ОШИБКУ ПРОВАЙДЕРА
+        err_msg = e.read().decode('utf-8', errors='ignore')
+        return False, f"❌ Провайдер API отклонил запрос (Код {e.code}):\n{err_msg}"
+    except Exception as e:
+        return False, f"❌ Ошибка соединения с провайдером API: {e}"
 
 class WebhookHandler(BaseHTTPRequestHandler):
     def do_POST(self):
         length = int(self.headers.get('Content-Length', 0))
         data = json.loads(self.rfile.read(length))
-        
         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"]
-            
             log(f"📥 Получено: {text}")
 
             if ALLOWED_USER and chat_id != ALLOWED_USER:
-                log("⛔ Блокировка: чужой ID.")
                 send_tg(chat_id, "⛔ Доступ закрыт.")
                 return
 
-            send_tg(chat_id, "🤖 Принято! Запускаю Гермеса...")
+            send_tg(chat_id, "🔍 Сканирую провайдера API...")
+            
+            # --- ЗАПУСК ДИАГНОСТИКИ ---
+            api_ok, api_msg = check_api()
+            
+            if not api_ok:
+                log(f"⚠️ ОШИБКА API: {api_msg}")
+                # Отправляем реальную ошибку провайдера прямо тебе в бота!
+                send_tg(chat_id, api_msg[:4000])
+                return
+            
+            # Если API ответило нормально, запускаем Гермеса
+            send_tg(chat_id, "🤖 API в норме! Запускаю Гермеса...")
             
             try:
-                log("🧠 Выполняю команду hermes...")
                 my_env = os.environ.copy()
-                
-                cmd = [
-                    "hermes", 
-                    "-m", "openai/z-ai/glm-5.1", 
-                    "-z", text, 
-                    "chat", 
-                    "--cli"
-                ]
-                log(f"⚙️ Полная команда: {' '.join(cmd)}")
-                
+                api_base = my_env.get("OPENAI_API_BASE", "")
+                if api_base and not api_base.endswith("/v1"):
+                    my_env["OPENAI_API_BASE"] = api_base.rstrip('/') + "/v1"
+                    my_env["OPENAI_BASE_URL"] = my_env["OPENAI_API_BASE"]
+
+                cmd = ["hermes", "-m", "openai/z-ai/glm-5.1", "-z", text, "chat", "--cli"]
                 result = subprocess.run(cmd, capture_output=True, text=True, env=my_env)
                 
                 reply = result.stdout.strip()
                 err_reply = result.stderr.strip()
                 
-                if err_reply:
-                    log(f"⚠️ Лог Гермеса (stderr): {err_reply}")
-                
                 if not reply:
                     reply = err_reply
                 
                 if reply:
-                    log(f"📤 Ответ получен: {len(reply)} симв.")
                     send_tg(chat_id, reply[-4000:])
                 else:
-                    log("❓ Гермес вернул пустоту.")
                     send_tg(chat_id, "✅ Пустой ответ от Гермеса.")
                     
             except Exception as e:
-                error_trace = traceback.format_exc()
-                log(f"❌ ОШИБКА:\n{error_trace}")
                 send_tg(chat_id, f"❌ Системная ошибка: {e}")
 
     def do_GET(self):