Create server.py

server.py

@@ -0,0 +1,61 @@
+import os, json, urllib.request, subprocess
+from http.server import BaseHTTPRequestHandler, HTTPServer
+
+PORT = 7860
+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 send_tg(chat_id, text):
+    """Отправка сообщений в 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')
+    req = urllib.request.Request(url, data=data, headers={"Content-Type": "application/json"})
+    try: 
+        urllib.request.urlopen(req)
+    except Exception as e: 
+        print(f"Ошибка отправки: {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 Телеграму
+        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"]
+
+            if ALLOWED_USER and chat_id != ALLOWED_USER:
+                send_tg(chat_id, "⛔ Доступ закрыт.")
+                return
+
+            send_tg(chat_id, "🤖 Задача принята! Гермес приступил к выполнению цикла...")
+            
+            # Запускаем локального агента Гермеса для выполнения ТЗ
+            try:
+                cmd = ["hermes", "chat", "--cli", "-m", "nvidia/glm-5.1", "-z", text]
+                result = subprocess.run(cmd, capture_output=True, text=True)
+                
+                # Собираем лог (берем последние 4000 символов, чтобы влезло в лимит ТГ)
+                reply = result.stdout.strip()
+                if not reply:
+                    reply = result.stderr.strip()
+                
+                send_tg(chat_id, reply[-4000:] if reply else "✅ Цикл завершен (вывод пуст).")
+            except Exception as e:
+                send_tg(chat_id, f"❌ Ошибка системы: {e}")
+
+    def do_GET(self):
+        self.send_response(200)
+        self.end_headers()
+        self.wfile.write(b"Server Online")
+
+if __name__ == "__main__":
+    print(f"Starting Hermes Webhook Bridge on port {PORT}")
+    HTTPServer(('0.0.0.0', PORT), WebhookHandler).serve_forever()
+