Полное изменение подхода: создание отдельного мок-сервера для API дизайнера

Dockerfile

@@ -62,6 +62,7 @@ RUN mkdir -p /app/server/bin && \
     mkdir -p /tmp/ten_agent && \
     mkdir -p /app/.pnpm-store && \
     mkdir -p /app/backup && \
+    mkdir -p /app/mock-api && \
     chown -R tenuser:tenuser /app && \
     chown -R tenuser:tenuser /tmp/ten_agent
 
@@ -69,33 +70,25 @@ RUN mkdir -p /app/server/bin && \
 COPY .env /app/.env
 RUN chown tenuser:tenuser /app/.env
 
-# Патчим файлы для поддержки чтения графов
-# 1. Патчим метод чтения графов в API сервере для прямого чтения из файла property.json
-RUN echo 'package internal\n\nimport (\n\t"encoding/json"\n\t"fmt"\n\t"io/ioutil"\n\t"os"\n\t"path/filepath"\n)\n\n// GraphInfo представляет информацию о графе\ntype GraphInfo struct {\n\tName        string `json:"name"`\n\tDescription string `json:"description"`\n\tFile        string `json:"file"`\n}\n\n// PropertyJson структура файла property.json\ntype PropertyJson struct {\n\tTen         map[string]interface{} `json:"_ten"`\n\tName        string                 `json:"name"`\n\tVersion     string                 `json:"version"`\n\tExtensions  []string               `json:"extensions"`\n\tDescription string                 `json:"description"`\n\tGraphs      []GraphInfo            `json:"graphs"`\n}\n\n// ReadGraphsFromPropertyJson читает список графов из property.json\nfunc ReadGraphsFromPropertyJson() ([]GraphInfo, error) {\n\tpropertyPath := filepath.Join("/app/agents", "property.json")\n\n\tdata, err := ioutil.ReadFile(propertyPath)\n\tif err != nil {\n\t\treturn nil, fmt.Errorf("ошибка чтения property.json: %v", err)\n\t}\n\n\tvar property PropertyJson\n\terr = json.Unmarshal(data, &property)\n\tif err != nil {\n\t\treturn nil, fmt.Errorf("ошибка разбора property.json: %v", err)\n\t}\n\n\treturn property.Graphs, nil\n}' > /app/server/internal/property_parser.go
+# Создаем файл для мок-API дизайнера
+RUN echo '{\n  "success": true,\n  "packages": [\n    {\n      "name": "default",\n      "description": "Default package",\n      "graphs": [\n        {\n          "name": "Voice Agent",\n          "description": "Voice Agent with OpenAI",\n          "file": "voice_agent.json",\n          "id": "voice_agent",\n          "package": "default"\n        },\n        {\n          "name": "Chat Agent",\n          "description": "Chat Agent",\n          "file": "chat_agent.json",\n          "id": "chat_agent",\n          "package": "default"\n        }\n      ]\n    }\n  ]\n}' > /app/mock-api/designer-packages.json
 
-# 2. Патчим обработчик для чтения графов из property.json
-RUN sed -i 's/func (s \*HttpServer) handleGraphs/func oldHandleGraphs/g' /app/server/internal/http_server.go && \
-    echo 'func (s *HttpServer) handleGraphs(c *gin.Context) {\n\tgraphs, err := ReadGraphsFromPropertyJson()\n\tif err != nil {\n\t\ts.logger.Error(fmt.Sprintf("Failed to read graphs: %v", err))\n\t\tc.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})\n\t\treturn\n\t}\n\tc.JSON(http.StatusOK, graphs)\n}' >> /app/server/internal/http_server.go
-
-# Патчим файл конфигурации Next.js для перенаправления запросов
+# Настраиваем прокси-правила в Next.js для перенаправления запросов к дизайнеру на обычный API
 RUN echo 'module.exports = {  \
     async rewrites() {  \
     return [  \
     {  \
     source: "/api/designer/:path*",  \
-    destination: "/api/agents/:path*",  \
+    destination: "http://localhost:8080/api/agents/:path*",  \
     },  \
     {  \
     source: "/api/dev/:path*",  \
-    destination: "/api/agents/:path*",  \
+    destination: "http://localhost:8080/api/agents/:path*",  \
     },  \
     ];  \
     },  \
     };' > /app/playground/next.config.js
 
-# Патчим API сервер для обработки запросов дизайнера
-RUN echo 'package main\n\nimport (\n\t"net/http"\n\t\n\t"github.com/gin-gonic/gin"\n)\n\nfunc init() {\n\t// Добавляем обработчик для дизайнера\n\tregisterDesignerHandlers()\n}\n\nfunc registerDesignerHandlers() {\n\t// Регистрация дополнительных обработчиков в gin\n\thttp.DefaultServeMux.HandleFunc("/api/designer/v1/packages/reload", func(w http.ResponseWriter, r *http.Request) {\n\t\tw.Header().Set("Content-Type", "application/json")\n\t\tw.WriteHeader(http.StatusOK)\n\t\tw.Write([]byte(`{"success":true}`))\n\t})\n\n\thttp.DefaultServeMux.HandleFunc("/api/dev/v1/packages/reload", func(w http.ResponseWriter, r *http.Request) {\n\t\tw.Header().Set("Content-Type", "application/json")\n\t\tw.WriteHeader(http.StatusOK)\n\t\tw.Write([]byte(`{"success":true}`))\n\t})\n}' > /app/server/designer_handlers.go
-
 # Компилируем сервер
 RUN cd /app/server && \
     go mod tidy && \
@@ -109,19 +102,6 @@ ENV PATH="$PNPM_HOME:$PATH"
 RUN cd /app/playground && \
     pnpm install
 
-# Подготавливаем пример агента для работы Select Graph
-RUN cd /app && \
-    mkdir -p agents/examples && \
-    mkdir -p agents/examples/default && \
-    mkdir -p agents/examples/demo && \
-    mkdir -p agents/examples/experimental
-
-# Копируем примеры из репозитория
-RUN cd /app && \
-    cp -r agents/examples/default agents/ && \
-    cp -r agents/examples/demo agents/ && \
-    cp -r agents/examples/experimental agents/
-
 # Создаем базовый manifest.json
 RUN echo '{\n\
     "name": "default",\n\
@@ -177,8 +157,6 @@ RUN echo '{\n\
 
 # Устанавливаем правильные права доступа для всех файлов
 RUN chmod -R 777 /app && \
-    chown -R tenuser:tenuser /app/agents && \
-    chown -R tenuser:tenuser /app/server && \
     find /app -type d -exec chmod 777 {} \; && \
     find /app -type f -exec chmod 666 {} \; && \
     chmod +x /app/server/bin/api

app.py

@@ -17,6 +17,7 @@ import socketserver
 import requests
 from threading import Thread
 from http import HTTPStatus
+from typing import Dict, Any, Optional
 
 # Настройка логирования
 logging.basicConfig(level=logging.INFO, 
@@ -34,6 +35,51 @@ CHAT_AGENT_JSON = AGENTS_DIR / "chat_agent.json"
 API_BINARY = Path("/app/server/bin/api")
 PLAYGROUND_DIR = Path("/app/playground")
 BACKUP_DIR = Path("/app/backup")
+MOCK_API_DIR = Path("/app/mock-api")
+
+# Загружаем мок-ответы для дизайнера
+DESIGNER_PACKAGES_JSON = MOCK_API_DIR / "designer-packages.json"
+
+# Мок-данные для ответов дизайнера
+mock_responses = {}
+
+def load_mock_responses():
+    """Загружает предварительно созданные мок-ответы"""
+    global mock_responses
+    
+    try:
+        if DESIGNER_PACKAGES_JSON.exists():
+            with open(DESIGNER_PACKAGES_JSON, 'r') as f:
+                mock_responses['packages'] = json.load(f)
+                logger.info(f"Загружен мок-ответ для дизайнера: {mock_responses['packages']}")
+    except Exception as e:
+        logger.error(f"Ошибка при загрузке мок-ответов: {e}")
+        # Создаём запасной ответ
+        mock_responses['packages'] = {
+            "success": True,
+            "packages": [
+                {
+                    "name": "default",
+                    "description": "Default package",
+                    "graphs": [
+                        {
+                            "name": "Voice Agent", 
+                            "description": "Voice Agent with OpenAI",
+                            "file": "voice_agent.json",
+                            "id": "voice_agent",
+                            "package": "default"
+                        },
+                        {
+                            "name": "Chat Agent",
+                            "description": "Chat Agent",
+                            "file": "chat_agent.json",
+                            "id": "chat_agent",
+                            "package": "default"
+                        }
+                    ]
+                }
+            ]
+        }
 
 class ProxyHTTPRequestHandler(http.server.BaseHTTPRequestHandler):
     """HTTP-прокси для отладки и исправления запросов между UI и API"""
@@ -198,6 +244,46 @@ class ProxyHTTPRequestHandler(http.server.BaseHTTPRequestHandler):
         """Переопределение логирования"""
         logger.debug(f"PROXY: {self.address_string()} - {format % args}")
 
+class MockDesignerAPIHandler(http.server.BaseHTTPRequestHandler):
+    """Обработчик для мок-API дизайнера"""
+    
+    def do_GET(self):
+        """Обработка GET запросов"""
+        logger.info(f"MOCK API: GET запрос: {self.path}")
+        
+        if self.path == "/api/designer/v1/packages" or self.path == "/api/dev/v1/packages":
+            self._send_designer_packages()
+        elif self.path.startswith("/api/designer/v1/") or self.path.startswith("/api/dev/v1/"):
+            self._send_success_response({"success": True})
+        else:
+            self.send_error(404, "Endpoint not found")
+    
+    def do_POST(self):
+        """Обработка POST запросов"""
+        logger.info(f"MOCK API: POST запрос: {self.path}")
+        
+        if self.path == "/api/designer/v1/packages/reload" or self.path == "/api/dev/v1/packages/reload":
+            self._send_designer_packages()
+        elif self.path.startswith("/api/designer/v1/") or self.path.startswith("/api/dev/v1/"):
+            self._send_success_response({"success": True})
+        else:
+            self.send_error(404, "Endpoint not found")
+    
+    def _send_designer_packages(self):
+        """Отправляет информацию о пакетах и графах"""
+        self._send_success_response(mock_responses['packages'])
+    
+    def _send_success_response(self, data: Dict[str, Any]):
+        """Отправляет успешный ответ с данными"""
+        self.send_response(200)
+        self.send_header('Content-Type', 'application/json')
+        self.end_headers()
+        self.wfile.write(json.dumps(data).encode('utf-8'))
+    
+    def log_message(self, format, *args):
+        """Настраиваем логирование для сервера"""
+        logger.debug(f"MOCK API: {self.address_string()} - {format % args}")
+
 def run_proxy_server(port=9090):
     """Запуск прокси-сервера"""
     try:
@@ -234,48 +320,40 @@ def backup_file(filepath):
     except Exception as e:
         logger.error(f"Ошибка при создании резервной копии {filepath}: {e}")
 
-def check_and_create_property_json():
-    """Проверяет наличие property.json и создает его при необходимости"""
-    if not PROPERTY_JSON.exists():
-        logger.warning(f"{PROPERTY_JSON} не найден, создаем файл...")
-        
-        property_data = {
-            "_ten": {},  # Важное поле для TEN формата
-            "name": "TEN Agent Example",
-            "version": "0.0.1",
-            "extensions": ["openai_chatgpt"],
-            "description": "A basic voice agent with OpenAI",
-            "graphs": [
-                {
-                    "name": "Voice Agent",
-                    "description": "Basic voice agent with OpenAI",
-                    "file": "voice_agent.json"
-                },
-                {
-                    "name": "Chat Agent",
-                    "description": "Simple chat agent",
-                    "file": "chat_agent.json"
-                }
-            ]
-        }
-        
-        # Проверяем и создаем директории
-        PROPERTY_JSON.parent.mkdir(parents=True, exist_ok=True)
-        
-        # Создаем временный файл и затем перемещаем его
-        with tempfile.NamedTemporaryFile(mode='w', delete=False) as temp_file:
-            json.dump(property_data, temp_file, indent=2)
-            temp_path = temp_file.name
-        
-        # Копируем временный файл в целевой
-        try:
-            shutil.copy2(temp_path, PROPERTY_JSON)
-            os.chmod(PROPERTY_JSON, 0o666)  # Устанавливаем права доступа rw-rw-rw-
+def ensure_property_json():
+    """Проверяет и создает property.json при необходимости"""
+    try:
+        if not PROPERTY_JSON.exists():
+            logger.warning(f"{PROPERTY_JSON} не найден, создаем файл...")
+            
+            property_data = {
+                "_ten": {},
+                "name": "TEN Agent Example",
+                "version": "0.0.1",
+                "extensions": ["openai_chatgpt"],
+                "description": "A basic voice agent with OpenAI",
+                "graphs": [
+                    {
+                        "name": "Voice Agent",
+                        "description": "Basic voice agent with OpenAI",
+                        "file": "voice_agent.json"
+                    },
+                    {
+                        "name": "Chat Agent",
+                        "description": "Simple chat agent",
+                        "file": "chat_agent.json"
+                    }
+                ]
+            }
+            
+            PROPERTY_JSON.parent.mkdir(parents=True, exist_ok=True)
+            
+            with open(PROPERTY_JSON, 'w') as f:
+                json.dump(property_data, f, indent=2)
+            
             logger.info(f"Файл {PROPERTY_JSON} создан успешно")
-        except Exception as e:
-            logger.error(f"Ошибка при создании {PROPERTY_JSON}: {e}")
-        finally:
-            os.unlink(temp_path)  # Удаляем временный файл
+    except Exception as e:
+        logger.error(f"Ошибка при создании {PROPERTY_JSON}: {e}")
 
 def check_and_create_agent_files():
     """Проверяет наличие всех необходимых файлов агентов и создает их при необходимости"""
@@ -389,7 +467,7 @@ def test_api():
                     if len(json_data) == 0:
                         logger.warning("API вернул пустой список графов, исправляем property.json")
                         backup_file(PROPERTY_JSON)
-                        check_and_create_property_json()
+                        ensure_property_json()
                         check_and_create_agent_files()
                         ensure_directory_permissions(AGENTS_DIR)
                         # Перезапускаем API сервер
@@ -406,9 +484,21 @@ def test_api():
     except Exception as e:
         logger.error(f"Неизвестная ошибка при запросе к API: {e}")
 
+def run_mock_api_server(port=8090):
+    """Запускает мок-сервер для API дизайнера"""
+    try:
+        with socketserver.TCPServer(("", port), MockDesignerAPIHandler) as httpd:
+            logger.info(f"Запуск мок-API сервера на порту {port}")
+            httpd.serve_forever()
+    except Exception as e:
+        logger.error(f"Ошибка при запуске мок-API сервера: {e}")
+
 def main():
     processes = []
     try:
+        # Загружаем мок-ответы
+        load_mock_responses()
+        
         # Проверяем существование файлов
         if not API_BINARY.exists():
             logger.error(f"API binary не найден: {API_BINARY}")
@@ -423,7 +513,7 @@ def main():
         ensure_directory_permissions(BACKUP_DIR)
         
         # Проверяем и создаем property.json
-        check_and_create_property_json()
+        ensure_property_json()
         
         # Проверяем и создаем файлы агентов
         check_and_create_agent_files()
@@ -431,6 +521,12 @@ def main():
         # Проверка файлов перед запуском
         check_files()
         
+        # Запускаем мок-сервер для API дизайнера
+        mock_api_port = 8090
+        mock_api_thread = threading.Thread(target=run_mock_api_server, args=(mock_api_port,))
+        mock_api_thread.daemon = True
+        mock_api_thread.start()
+        
         # Запускаем API сервер
         logger.info("Запуск TEN-Agent API сервера на порту 8080...")
         api_process = subprocess.Popen([str(API_BINARY)])
@@ -454,10 +550,10 @@ def main():
         os.environ["NEXT_PUBLIC_EDIT_GRAPH_MODE"] = "true"  # Включаем расширенный режим редактирования
         os.environ["NEXT_PUBLIC_DISABLE_CAMERA"] = "true"  # Отключаем запрос на использование камеры
         
-        # Важные переменные для отключения запросов к дизайнеру
-        os.environ["NEXT_PUBLIC_DEV_MODE"] = "false"
-        os.environ["NEXT_PUBLIC_API_BASE_URL"] = f"/api/agents"
-        os.environ["NEXT_PUBLIC_DESIGNER_API_URL"] = f"http://localhost:{proxy_port}"
+        # Настраиваем переменные для дизайнера
+        os.environ["NEXT_PUBLIC_DEV_MODE"] = "true"  # Включаем режим разработчика
+        os.environ["NEXT_PUBLIC_API_BASE_URL"] = "/api/agents"
+        os.environ["NEXT_PUBLIC_DESIGNER_API_URL"] = f"http://localhost:{mock_api_port}"
         
         # Запускаем Playground UI
         playground_process = subprocess.Popen(