Function ensure_packages_installed

ci/util/pio_package_client.py:220–508

Ensure PlatformIO packages are installed via daemon. Enhanced with banner-style logging and typed message protocol. Args: project_dir: PlatformIO project directory environment: PlatformIO environment name (or None for all) timeout: Maximum wait time in seconds (defa

(
    project_dir: Path,
    environment: str | None,
    timeout: int = 1800,
)

def ensure_packages_installed(
    project_dir: Path,
    environment: str | None,
    timeout: int = 1800,
) -> bool:
    """Ensure PlatformIO packages are installed via daemon.

    Enhanced with banner-style logging and typed message protocol.

    Args:
        project_dir: PlatformIO project directory
        environment: PlatformIO environment name (or None for all)
        timeout: Maximum wait time in seconds (default: 30 minutes)

    Returns:
        True if packages installed successfully, False otherwise
    """
    # Detect default environment if None (for package validation)
    default_env = environment
    if default_env is None:
        from ci.util.pio_package_daemon import get_default_environment

        default_env = get_default_environment(str(project_dir))
        if default_env:
            environment = default_env  # Use detected default for display

    # ═══════════════════════════════════════════════════════════
    # PHASE BANNER
    # ═══════════════════════════════════════════════════════════
    print_phase_banner(
        "PHASE 0: PACKAGE INSTALLATION",
        details={
            "Project": str(project_dir),
            "Environment": environment or "default",
            "Caller PID": str(os.getpid()),
        },
    )

    # ───────────────────────────────────────────────────────────
    # PRE-FLIGHT CHECK
    # ───────────────────────────────────────────────────────────
    # Quick check: are packages already installed?
    if packages_already_installed(project_dir, environment):
        # Additional validation check for corrupted packages
        if default_env:
            is_valid, errors = check_all_packages(project_dir, default_env)
            if not is_valid:
                print_tree_status(
                    "🔍 Checking packages...",
                    [
                        ("", "Validating integrity...", None),
                        ("", f"❌ Corrupted: {errors[0]}", "error"),
                        ("", "📦 Reinstallation required", None),
                    ],
                )
                # Fall through to daemon installation
            else:
                print_tree_status(