Fix permissions issue for config files by using direct /tmp path

api_wrapper.py

@@ -22,8 +22,9 @@ USE_WRAPPER = os.environ.get("USE_WRAPPER", "false").lower() in ("true", "1", "y
 
 # Путь к директории с агентами
 if IS_HF_SPACE or USE_WRAPPER:
-    TMP_DIR = os.environ.get("TMP_DIR", "/tmp/ten_user")
-    AGENT_DIR = os.environ.get("TEN_AGENT_DIR", f"{TMP_DIR}/agents")
+    # В HuggingFace используем корневую директорию /tmp
+    TMP_DIR = os.environ.get("TMP_DIR", "/tmp")
+    AGENT_DIR = os.environ.get("TEN_AGENT_DIR", TMP_DIR)
 else:
     AGENT_DIR = os.environ.get("TEN_AGENT_DIR", "/tmp/ten_user/agents")
 
@@ -31,6 +32,16 @@ logger.info(f"Using agent directory: {AGENT_DIR}")
 logger.info(f"Running in HuggingFace Space: {IS_HF_SPACE}")
 logger.info(f"Using Wrapper: {USE_WRAPPER}")
 
+# Проверяем наличие файлов конфигурации
+agent_dir_path = Path(AGENT_DIR)
+if agent_dir_path.exists():
+    logger.info(f"Checking files in agent directory {AGENT_DIR}:")
+    for file in agent_dir_path.iterdir():
+        if file.name.endswith('.json'):
+            logger.info(f"  - {file.name} ({os.path.getsize(file)}b)")
+else:
+    logger.warning(f"Agent directory {AGENT_DIR} does not exist!")
+
 class TENAgentHandler(http.server.BaseHTTPRequestHandler):
     def log_message(self, format, *args):
         """Переопределение логирования для вывода в stdout"""
@@ -78,15 +89,38 @@ class TENAgentHandler(http.server.BaseHTTPRequestHandler):
         """Обработка запроса на получение списка графов"""
         try:
             property_file = Path(AGENT_DIR) / "property.json"
+            logger.info(f"Looking for property file at {property_file}")
+            
             if not property_file.exists():
                 logger.error(f"Property file not found at {property_file}")
-                self.send_error(404, "Property file not found")
-                return
+                
+                # Проверяем, возможно файл находится в другой директории
+                alt_property_file = Path("/tmp/property.json")
+                if alt_property_file.exists():
+                    logger.info(f"Found property file at alternative location: {alt_property_file}")
+                    property_file = alt_property_file
+                else:
+                    self.send_error(404, "Property file not found")
+                    return
             
             with open(property_file, "r") as f:
                 property_data = json.load(f)
             
             graphs = property_data.get("graphs", [])
+            
+            # Для каждого графа проверяем наличие файла
+            for graph in graphs:
+                file_name = graph.get("file", "")
+                file_path = Path(AGENT_DIR) / file_name
+                alt_file_path = Path("/tmp") / file_name
+                
+                if file_path.exists():
+                    logger.info(f"Graph file exists: {file_path}")
+                elif alt_file_path.exists():
+                    logger.info(f"Graph file exists at alternative location: {alt_file_path}")
+                else:
+                    logger.warning(f"Graph file not found: {file_name}")
+            
             self._set_headers()
             self.wfile.write(json.dumps(graphs).encode())
             logger.info(f"Returned {len(graphs)} graphs")
@@ -101,7 +135,8 @@ class TENAgentHandler(http.server.BaseHTTPRequestHandler):
             "status": "ok", 
             "time": time.time(), 
             "is_hf_space": IS_HF_SPACE,
-            "using_wrapper": True
+            "using_wrapper": True,
+            "agent_dir": AGENT_DIR
         }).encode())
     
     def _handle_list(self):
@@ -125,9 +160,14 @@ class TENAgentHandler(http.server.BaseHTTPRequestHandler):
         try:
             property_file = Path(AGENT_DIR) / "property.json"
             if not property_file.exists():
-                logger.error(f"Property file not found at {property_file}")
-                self.send_error(404, "Property file not found")
-                return
+                # Проверяем альтернативную директорию
+                alt_property_file = Path("/tmp/property.json")
+                if alt_property_file.exists():
+                    property_file = alt_property_file
+                else:
+                    logger.error(f"Property file not found at {property_file}")
+                    self.send_error(404, "Property file not found")
+                    return
             
             with open(property_file, "r") as f:
                 property_data = json.load(f)
@@ -183,7 +223,8 @@ class TENAgentHandler(http.server.BaseHTTPRequestHandler):
             "status": "ok", 
             "timestamp": time.time(),
             "server": "ten-agent-api-wrapper",
-            "in_hf_space": IS_HF_SPACE
+            "in_hf_space": IS_HF_SPACE,
+            "agent_dir": AGENT_DIR
         }).encode())
     
     def _handle_token_generate(self, request_data):
@@ -200,16 +241,30 @@ class TENAgentHandler(http.server.BaseHTTPRequestHandler):
     
     def _handle_start(self, request_data):
         """Обработка запроса на запуск сессии"""
+        graph_file = request_data.get("graph_file", "")
+        logger.info(f"Starting session with graph file: {graph_file}")
+        
+        # Проверяем наличие файла графа
+        graph_path = Path(AGENT_DIR) / graph_file
+        alt_graph_path = Path("/tmp") / graph_file
+        
+        if graph_path.exists():
+            logger.info(f"Found graph file at: {graph_path}")
+        elif alt_graph_path.exists():
+            logger.info(f"Found graph file at alternative location: {alt_graph_path}")
+        else:
+            logger.warning(f"Graph file not found: {graph_file}")
+        
         self._set_headers()
         # Возвращаем успешный статус и ID сессии
         response = {
             "status": "ok",
             "session_id": f"dummy_session_{int(time.time())}",
             "message": "Session started successfully",
-            "graph_file": request_data.get("graph_file", "unknown")
+            "graph_file": graph_file
         }
         self.wfile.write(json.dumps(response).encode())
-        logger.info(f"Started session with graph: {request_data.get('graph_file', '')}")
+        logger.info(f"Started session with graph: {graph_file}")
     
     def _handle_stop(self, request_data):
         """Обработка запроса на остановку сессии"""

app.py

@@ -71,6 +71,12 @@ def create_config_files():
     """Создает базовые файлы конфигурации"""
     print("Создание конфигурационных файлов...")
     
+    # Используем директорию в /tmp напрямую, без вложенных директорий
+    config_dir = Path("/tmp")
+    property_file_path = config_dir / "property.json"
+    voice_agent_path = config_dir / "voice_agent.json"
+    chat_agent_path = config_dir / "chat_agent.json"
+    
     # Создаем property.json с графами
     property_data = {
         "name": "TEN Agent Demo",
@@ -91,8 +97,13 @@ def create_config_files():
         ]
     }
     
-    with open(AGENTS_DIR / "property.json", "w") as f:
-        json.dump(property_data, f, indent=2)
+    try:
+        with open(property_file_path, "w") as f:
+            json.dump(property_data, f, indent=2)
+        print(f"Файл {property_file_path} создан успешно")
+    except Exception as e:
+        print(f"Ошибка при создании {property_file_path}: {e}")
+        return False
     
     # Создаем voice_agent.json
     voice_agent = {
@@ -155,8 +166,13 @@ def create_config_files():
         "root": "start"
     }
     
-    with open(AGENTS_DIR / "voice_agent.json", "w") as f:
-        json.dump(voice_agent, f, indent=2)
+    try:
+        with open(voice_agent_path, "w") as f:
+            json.dump(voice_agent, f, indent=2)
+        print(f"Файл {voice_agent_path} создан успешно")
+    except Exception as e:
+        print(f"Ошибка при создании {voice_agent_path}: {e}")
+        return False
     
     # Создаем chat_agent.json (упрощенная версия)
     chat_agent = {
@@ -195,10 +211,19 @@ def create_config_files():
         "root": "start"
     }
     
-    with open(AGENTS_DIR / "chat_agent.json", "w") as f:
-        json.dump(chat_agent, f, indent=2)
-    
-    print("Конфигурационные файлы созданы успешно")
+    try:
+        with open(chat_agent_path, "w") as f:
+            json.dump(chat_agent, f, indent=2)
+        print(f"Файл {chat_agent_path} создан успешно")
+    except Exception as e:
+        print(f"Ошибка при создании {chat_agent_path}: {e}")
+        return False
+    
+    # Обновляем глобальную переменную AGENTS_DIR для использования нового пути
+    global AGENTS_DIR
+    AGENTS_DIR = config_dir
+    print(f"Конфигурационные файлы созданы успешно в директории {config_dir}")
+    return True
 
 def start_api_server():
     """Запускает API сервер"""
@@ -209,6 +234,14 @@ def start_api_server():
     api_env["TEN_AGENT_DIR"] = str(AGENTS_DIR)
     api_env["API_PORT"] = str(API_PORT)
     
+    # Выводим информацию о директории с агентами для отладки
+    print(f"Директория с агентами: {AGENTS_DIR}")
+    print(f"Файлы в директории агентов:")
+    if AGENTS_DIR.exists():
+        for file in AGENTS_DIR.iterdir():
+            if file.name.endswith('.json'):
+                print(f"  - {file.name} ({os.path.getsize(file)}b)")
+    
     # В HuggingFace Space нужны дополнительные настройки
     if IS_HF_SPACE:
         print("Configuring API server for HuggingFace Space environment...")
@@ -217,7 +250,7 @@ def start_api_server():
         # Отключаем логирование в файл
         api_env["TEN_LOG_DISABLE_FILE"] = "true"
         # Указываем путь для временных файлов
-        api_env["TMP_DIR"] = str(TMP_DIR)
+        api_env["TMP_DIR"] = "/tmp"
     
     # Запускаем Python API wrapper
     api_cmd = ["python", "api_wrapper.py"]
@@ -638,13 +671,17 @@ def start_simple_ui():
 def main():
     # Создаем директории и файлы конфигурации
     create_directories()
-    create_config_files()
+    
+    # Пытаемся создать конфигурационные файлы
+    if not create_config_files():
+        print("ОШИБКА: Не удалось создать конфигурационные файлы!")
+        return 1
     
     # Запускаем API сервер
     api_process = start_api_server()
     if not api_process:
         print("Не удалось запустить API сервер")
-        return
+        return 1
     
     # Пробуем запустить Playground UI через Next.js
     ui_process = start_playground()
@@ -683,6 +720,8 @@ def main():
         api_process.terminate()
         if ui_process:
             ui_process.terminate()
+    
+    return 0
 
 if __name__ == "__main__":
     # Корректная обработка сигналов