Function ensure_postgres_service

start_webui.py:134–181

(
    service_name: str,
    timeout_seconds: int,
    dry_run: bool,
    database_endpoint: tuple[str, int] | None = None,
)

def ensure_postgres_service(
    service_name: str,
    timeout_seconds: int,
    dry_run: bool,
    database_endpoint: tuple[str, int] | None = None,
) -> None:
    if dry_run:
        log(f"[dry-run] 将执行: docker compose up -d {service_name}")
        log(f"[dry-run] 将等待服务 {service_name} 进入 healthy/running")
        return

    try:
        run_command(["docker", "compose", "up", "-d", service_name], capture_output=True)
    except LaunchError as exc:
        if (
            database_endpoint
            and "port is already allocated" in str(exc)
            and can_connect_tcp(database_endpoint[0], database_endpoint[1])
        ):
            log(
                f"检测到数据库端口已被占用，但目标数据库已经可直连，沿用现有实例继续启动: {database_endpoint[0]}:{database_endpoint[1]}",
                "WARN",
            )
            return
        raise

    container_id = run_command(["docker", "compose", "ps", "-q", service_name], capture_output=True).stdout.strip()
    if not container_id:
        raise LaunchError(f"未找到服务 {service_name} 对应的容器，请检查 docker-compose.yml。")

    deadline = time.time() + timeout_seconds
    while time.time() < deadline:
        status = run_command(
            [
                "docker",
                "inspect",
                "--format",
                "{{if .State.Health}}{{.State.Health.Status}}{{else}}{{.State.Status}}{{end}}",
                container_id,
            ],
            capture_output=True,
        ).stdout.strip()
        if status in {"healthy", "running"}:
            log(f"数据库容器已就绪: {service_name} ({status})")
            return
        time.sleep(2)

    raise LaunchError(f"等待数据库容器 {service_name} 就绪超时。")


def get_display_host(host: str) -> str: