Исправления для fallback.py: добавление файла .env и настройка директорий логов

fallback.py

@@ -70,7 +70,56 @@ def create_directory_structure():
     AGENTS_DIR.mkdir(exist_ok=True)
     RAG_DIR.mkdir(exist_ok=True)
     LOG_DIR.mkdir(exist_ok=True)
+    
+    # Создаем папки, которые ожидает API сервер
+    server_log_dir = Path("/tmp/ten_agent/logs")
+    server_log_dir.parent.mkdir(exist_ok=True)
+    server_log_dir.mkdir(exist_ok=True)
+    
     logger.info(f"Created log directory at {LOG_DIR}")
+    logger.info(f"Created server log directory at {server_log_dir}")
+
+def create_env_file():
+    """Создание файла .env для API сервера"""
+    logger.info("Creating .env file...")
+    
+    # Создаем .env файл в директории сервера
+    env_path = Path("/app/.env")
+    tmp_env_path = Path("/tmp/ten_agent/.env")
+    
+    # Базовое содержимое .env
+    env_content = """
+LOG_LEVEL=debug
+LOG_DIR=/tmp/ten_agent/logs
+AGENT_SERVER_DIRECTORY=/tmp/ten_user/agents
+AGENT_SERVER_HOST=0.0.0.0
+AGENT_SERVER_PORT=8080
+PUBLIC_URL=http://localhost:7860
+DISABLE_CAMERA=true
+"""
+    
+    # Записываем файл во временную директорию
+    with open(tmp_env_path, 'w') as f:
+        f.write(env_content)
+    
+    # Пытаемся скопировать в основную директорию (может не сработать из-за прав доступа)
+    try:
+        with open(env_path, 'w') as f:
+            f.write(env_content)
+        logger.info(f"Created .env file at {env_path}")
+    except Exception as e:
+        logger.warning(f"Could not create .env in /app, using temporary one: {e}")
+    
+    logger.info(f"Created .env file at {tmp_env_path}")
+    
+    # Также устанавливаем переменные окружения напрямую
+    os.environ["LOG_LEVEL"] = "debug"
+    os.environ["LOG_DIR"] = "/tmp/ten_agent/logs"
+    os.environ["AGENT_SERVER_DIRECTORY"] = str(AGENTS_DIR)
+    os.environ["AGENT_SERVER_HOST"] = "0.0.0.0"
+    os.environ["AGENT_SERVER_PORT"] = "8080"
+    os.environ["PUBLIC_URL"] = "http://localhost:7860"
+    os.environ["DISABLE_CAMERA"] = "true"
 
 def create_basic_config():
     """Создание базовых конфигурационных файлов"""
@@ -255,9 +304,6 @@ def create_basic_config():
 
 def run_api_server():
     """Запуск API сервера"""
-    # Конфигурирование переменных среды
-    os.environ["AGENT_SERVER_DIRECTORY"] = str(AGENTS_DIR)
-    
     logger.info(f"Starting API server with agents directory: {AGENTS_DIR}")
     
     # Запуск API сервера напрямую из директории server
@@ -266,12 +312,22 @@ def run_api_server():
         logger.error(f"API binary not found at {api_binary}")
         raise FileNotFoundError(f"API binary not found at {api_binary}")
     
+    # Настраиваем рабочую директорию и окружение
+    work_dir = Path("/app/server")
+    env = os.environ.copy()
+    env["AGENT_SERVER_DIRECTORY"] = str(AGENTS_DIR)
+    env["LOG_DIR"] = "/tmp/ten_agent/logs"
+    
     cmd = [str(api_binary)]
     logger.info(f"Running command: {' '.join(cmd)}")
+    logger.info(f"With AGENT_SERVER_DIRECTORY={env['AGENT_SERVER_DIRECTORY']}")
+    logger.info(f"With LOG_DIR={env['LOG_DIR']}")
     
     # Запуск процесса сервера
     api_process = subprocess.Popen(
         cmd,
+        cwd=str(work_dir),
+        env=env,
         stdout=subprocess.PIPE,
         stderr=subprocess.PIPE,
         text=True,
@@ -290,7 +346,44 @@ def run_api_server():
     time.sleep(2)
     if api_process.poll() is not None:
         logger.error(f"API server failed to start with exit code {api_process.returncode}")
-        raise RuntimeError(f"API server failed to start with exit code {api_process.returncode}")
+        # Если процесс упал, логируем его вывод
+        stdout, stderr = api_process.communicate()
+        logger.error(f"API stdout: {stdout}")
+        logger.error(f"API stderr: {stderr}")
+        
+        # Пробуем запустить с другими аргументами, если первая попытка не удалась
+        logger.info("Trying alternative API server launch method...")
+        try:
+            # Пробуем запустить с помощью wrapper скрипта
+            wrapper_script = Path("/app/api_wrapper.py")
+            if wrapper_script.exists():
+                logger.info("Using api_wrapper.py as fallback")
+                env["AGENT_DIR"] = str(AGENTS_DIR)
+                wrapper_process = subprocess.Popen(
+                    ["python3", str(wrapper_script)],
+                    env=env,
+                    stdout=subprocess.PIPE,
+                    stderr=subprocess.PIPE,
+                    text=True,
+                    bufsize=1,
+                )
+                
+                threading.Thread(target=log_output, args=(wrapper_process.stdout, "WRAPPER"), daemon=True).start()
+                threading.Thread(target=log_output, args=(wrapper_process.stderr, "WRAPPER ERROR"), daemon=True).start()
+                
+                time.sleep(2)
+                if wrapper_process.poll() is not None:
+                    logger.error(f"Wrapper script failed with code {wrapper_process.returncode}")
+                    stdout, stderr = wrapper_process.communicate()
+                    logger.error(f"Wrapper stdout: {stdout}")
+                    logger.error(f"Wrapper stderr: {stderr}")
+                    raise RuntimeError("All API server launch methods failed")
+                
+                logger.info("API server started through wrapper script")
+                return wrapper_process
+        except Exception as e:
+            logger.error(f"Alternative launch method also failed: {e}")
+            raise RuntimeError(f"API server failed to start with exit code {api_process.returncode}")
     
     logger.info("API server started successfully")
     return api_process
@@ -521,6 +614,9 @@ def main():
         # Создание структуры директорий
         create_directory_structure()
         
+        # Создаем .env файл
+        create_env_file()
+        
         # Создание базовых конфигурационных файлов
         create_basic_config()