Полное перестроение контейнера с исправлением проблем прав доступа и добавлением прямого чтения property.json из API

Dockerfile

@@ -38,6 +38,9 @@ RUN curl -fsSL https://deb.nodesource.com/setup_20.x | bash - && \
     apt-get install -y nodejs && \
     npm install -g pnpm
 
+# Создаем пользователя tenuser с правильными правами
+RUN useradd -m -u 1000 -s /bin/bash tenuser
+
 # Устанавливаем рабочую директорию
 WORKDIR /app
 
@@ -54,12 +57,24 @@ RUN go install github.com/go-task/task/v3/cmd/task@latest
 RUN mkdir -p /app/server/bin && \
     mkdir -p /app/agents && \
     mkdir -p /tmp/ten_agent && \
-    mkdir -p /app/.pnpm-store
+    mkdir -p /app/.pnpm-store && \
+    mkdir -p /app/backup && \
+    chown -R tenuser:tenuser /app && \
+    chown -R tenuser:tenuser /tmp/ten_agent
 
 # Копируем .env файл
 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
 
-# Патчим файл конфигурации Next.js, чтобы перенаправлять запросы к дизайнеру на наш API
+# 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 для перенаправления запросов
 RUN echo 'module.exports = {  \
     async rewrites() {  \
     return [  \
@@ -158,11 +173,20 @@ RUN echo '{\n\
     }' > /app/agents/chat_agent.json
 
 # Устанавливаем правильные права доступа для всех файлов
-RUN chmod -R 777 /app
+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
 
 # Настраиваем стартовый скрипт
 COPY app.py /app/app.py
-RUN chmod +x /app/app.py
+RUN chmod +x /app/app.py && \
+    chown tenuser:tenuser /app/app.py
+
+# Переключаемся на пользователя tenuser
+USER tenuser
 
 # Открываем порты
 EXPOSE 7860 8080 3000

app.py

@@ -9,6 +9,9 @@ import signal
 import threading
 import shutil
 import logging
+import urllib.request
+import urllib.error
+import tempfile
 
 # Настройка логирования
 logging.basicConfig(level=logging.INFO, 
@@ -17,12 +20,47 @@ logging.basicConfig(level=logging.INFO,
 
 logger = logging.getLogger('ten-agent')
 
+# Глобальные пути
+AGENTS_DIR = Path("/app/agents")
+PROPERTY_JSON = AGENTS_DIR / "property.json"
+MANIFEST_JSON = AGENTS_DIR / "manifest.json"
+VOICE_AGENT_JSON = AGENTS_DIR / "voice_agent.json" 
+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")
+
+def ensure_directory_permissions(directory_path):
+    """Обеспечиваем правильные разрешения для директории"""
+    directory = Path(directory_path)
+    if not directory.exists():
+        logger.info(f"Создание директории {directory}")
+        directory.mkdir(parents=True, exist_ok=True)
+    
+    # Устанавливаем полные права
+    subprocess.run(["chmod", "-R", "777", str(directory)])
+    logger.info(f"Права доступа для {directory} установлены")
+
+def backup_file(filepath):
+    """Создает резервную копию файла"""
+    src_path = Path(filepath)
+    if not src_path.exists():
+        logger.warning(f"Невозможно создать резервную копию: {filepath} не существует")
+        return
+    
+    BACKUP_DIR.mkdir(parents=True, exist_ok=True)
+    dest_path = BACKUP_DIR / f"{src_path.name}.bak"
+    
+    try:
+        shutil.copy2(src_path, dest_path)
+        logger.info(f"Резервная копия создана: {dest_path}")
+    except Exception as e:
+        logger.error(f"Ошибка при создании резервной копии {filepath}: {e}")
+
 def check_and_create_property_json():
     """Проверяет наличие property.json и создает его при необходимости"""
-    property_path = Path("/app/agents/property.json")
-    
-    if not property_path.exists():
-        logger.warning(f"{property_path} не найден, создаем файл...")
+    if not PROPERTY_JSON.exists():
+        logger.warning(f"{PROPERTY_JSON} не найден, создаем файл...")
         
         property_data = {
             "_ten": {},  # Важное поле для TEN формата
@@ -45,22 +83,85 @@ def check_and_create_property_json():
         }
         
         # Проверяем и создаем директории
-        property_path.parent.mkdir(parents=True, exist_ok=True)
+        PROPERTY_JSON.parent.mkdir(parents=True, exist_ok=True)
         
-        # Записываем файл
-        with open(property_path, 'w') as f:
-            json.dump(property_data, f, indent=2)
-            
-        logger.info(f"Файл {property_path} создан успешно")
+        # Создаем временный файл и затем перемещаем его
+        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-
+            logger.info(f"Файл {PROPERTY_JSON} создан успешно")
+        except Exception as e:
+            logger.error(f"Ошибка при создании {PROPERTY_JSON}: {e}")
+        finally:
+            os.unlink(temp_path)  # Удаляем временный файл
+
+def check_and_create_agent_files():
+    """Проверяет наличие всех необходимых файлов агентов и создает их при необходимости"""
+    
+    # Создаем manifest.json если он не существует
+    if not MANIFEST_JSON.exists():
+        manifest_data = {
+            "name": "default",
+            "agents": [
+                {
+                    "name": "voice_agent",
+                    "description": "A simple voice agent"
+                },
+                {
+                    "name": "chat_agent",
+                    "description": "A text chat agent"
+                }
+            ]
+        }
+        
+        with open(MANIFEST_JSON, 'w') as f:
+            json.dump(manifest_data, f, indent=2)
+        os.chmod(MANIFEST_JSON, 0o666)
+        logger.info(f"Файл {MANIFEST_JSON} создан")
+    
+    # Создаем voice_agent.json если он не существует
+    if not VOICE_AGENT_JSON.exists():
+        voice_agent_data = {
+            "nodes": [],
+            "edges": [],
+            "groups": [],
+            "templates": [],
+            "root": None
+        }
+        
+        with open(VOICE_AGENT_JSON, 'w') as f:
+            json.dump(voice_agent_data, f, indent=2)
+        os.chmod(VOICE_AGENT_JSON, 0o666)
+        logger.info(f"Файл {VOICE_AGENT_JSON} создан")
+    
+    # Создаем chat_agent.json если он не существует
+    if not CHAT_AGENT_JSON.exists():
+        chat_agent_data = {
+            "nodes": [],
+            "edges": [],
+            "groups": [],
+            "templates": [],
+            "root": None
+        }
+        
+        with open(CHAT_AGENT_JSON, 'w') as f:
+            json.dump(chat_agent_data, f, indent=2)
+        os.chmod(CHAT_AGENT_JSON, 0o666)
+        logger.info(f"Файл {CHAT_AGENT_JSON} создан")
 
 def check_files():
     """Проверяет и выводит информацию о важных файлах"""
     files_to_check = [
-        "/app/agents/property.json",
-        "/app/agents/manifest.json",
-        "/app/agents/voice_agent.json",
-        "/app/agents/chat_agent.json",
-        "/app/server/bin/api"
+        PROPERTY_JSON,
+        MANIFEST_JSON,
+        VOICE_AGENT_JSON,
+        CHAT_AGENT_JSON,
+        API_BINARY
     ]
     
     logger.info("=== Проверка критических файлов ===")
@@ -72,7 +173,7 @@ def check_files():
                 logger.info(f"✅ {file_path} (размер: {size} байт)")
                 
                 # Если это JSON файл, выводим его содержимое
-                if file_path.endswith('.json'):
+                if str(file_path).endswith('.json'):
                     try:
                         with open(file_path, 'r') as f:
                             content = json.load(f)
@@ -85,43 +186,15 @@ def check_files():
             logger.error(f"❌ {file_path} (файл не найден)")
     
     logger.info("=== Проверка структуры директорий ===")
-    logger.info("Содержимое /app/agents:")
-    subprocess.run(["ls", "-la", "/app/agents"])
+    logger.info(f"Содержимое {AGENTS_DIR}:")
+    subprocess.run(["ls", "-la", str(AGENTS_DIR)])
     
     logger.info("Проверка прав доступа:")
-    subprocess.run(["stat", "/app/agents"])
-    subprocess.run(["stat", "/app/agents/property.json"])
-
-def setup_mock_designer():
-    """Настраивает мок-эндпоинты для дизайнера"""
-    # Создаем файл с мок-ответом для запросов
-    mock_dir = Path("/app/mock_responses")
-    mock_dir.mkdir(exist_ok=True)
-    
-    reload_response = {
-        "success": True,
-        "packages": [
-            {
-                "name": "default",
-                "description": "Default package",
-                "graphs": [
-                    {"name": "Voice Agent", "description": "Voice Agent with OpenAI", "file": "voice_agent.json"},
-                    {"name": "Chat Agent", "description": "Simple Chat Agent", "file": "chat_agent.json"}
-                ]
-            }
-        ]
-    }
-    
-    with open(mock_dir / "reload_response.json", "w") as f:
-        json.dump(reload_response, f, indent=2)
-    
-    logger.info("Мок-файлы для дизайнера созданы")
+    subprocess.run(["stat", str(AGENTS_DIR)])
+    subprocess.run(["stat", str(PROPERTY_JSON)])
 
 def test_api():
     """Делает запрос к API для получения списка графов"""
-    import urllib.request
-    import urllib.error
-    
     logger.info("=== Тестирование API ===")
     try:
         # Даем серверу время запуститься
@@ -135,6 +208,18 @@ def test_api():
                 json_data = json.loads(data)
                 if isinstance(json_data, list) and len(json_data) > 0:
                     logger.info(f"API вернул {len(json_data)} графов")
+                    # Если API вернул пустой список, исправляем это
+                    if len(json_data) == 0:
+                        logger.warning("API вернул пустой список графов, исправляем property.json")
+                        backup_file(PROPERTY_JSON)
+                        check_and_create_property_json()
+                        check_and_create_agent_files()
+                        ensure_directory_permissions(AGENTS_DIR)
+                        # Перезапускаем API сервер
+                        logger.info("Перезапускаем API сервер...")
+                        subprocess.run(["pkill", "-f", str(API_BINARY)])
+                        time.sleep(1)
+                        subprocess.Popen([str(API_BINARY)])
                 else:
                     logger.warning("API вернул пустой список графов")
             except json.JSONDecodeError:
@@ -147,31 +232,31 @@ def test_api():
 def main():
     processes = []
     try:
-        # Пути к исполняемым файлам
-        api_binary = Path("/app/server/bin/api")
-        playground_dir = Path("/app/playground")
-        
         # Проверяем существование файлов
-        if not api_binary.exists():
-            logger.error(f"API binary не найден: {api_binary}")
+        if not API_BINARY.exists():
+            logger.error(f"API binary не найден: {API_BINARY}")
             return 1
         
-        if not playground_dir.exists():
-            logger.error(f"Playground директория не найдена: {playground_dir}")
+        if not PLAYGROUND_DIR.exists():
+            logger.error(f"Playground директория не найдена: {PLAYGROUND_DIR}")
             return 1
         
+        # Создаем директории и устанавливаем права
+        ensure_directory_permissions(AGENTS_DIR)
+        ensure_directory_permissions(BACKUP_DIR)
+        
         # Проверяем и создаем property.json
         check_and_create_property_json()
         
-        # Создаем мок-файлы для дизайнера
-        setup_mock_designer()
+        # Проверяем и создаем файлы агентов
+        check_and_create_agent_files()
         
         # Проверка файлов перед запуском
         check_files()
         
         # Запускаем API сервер
         logger.info("Запуск TEN-Agent API сервера на порту 8080...")
-        api_process = subprocess.Popen([str(api_binary)])
+        api_process = subprocess.Popen([str(API_BINARY)])
         processes.append(api_process)
         
         # Тестируем API
@@ -191,9 +276,10 @@ def main():
         os.environ["NEXT_PUBLIC_API_BASE_URL"] = "/api/agents"
         os.environ["NEXT_PUBLIC_DESIGNER_API_URL"] = "http://localhost:8080"
         
+        # Запускаем Playground UI
         playground_process = subprocess.Popen(
             ["pnpm", "dev"],
-            cwd=str(playground_dir),
+            cwd=str(PLAYGROUND_DIR),
             env=os.environ
         )
         processes.append(playground_process)