mecha10_deploy/services/

binary_manager.rs

//! Binary Manager service for downloading and caching node binaries via `mecha10-api`
//!
//! This service implements the Node Binary Distribution architecture, providing:
//! - Downloading pre-built node binaries via the public `mecha10-api` downloads proxy
//!   (`GET /api/downloads/node/{name}`), never the private Minio instance directly
//! - Caching binaries to `~/.mecha10/bin/`
//! - Platform detection and target triple resolution
//! - Fallback to cargo install for unsupported platforms
//!
//! # Design
//!
//! - Binaries are downloaded from `{mecha10_api}/downloads/node/{node}?os=..&arch=..&version=..`
//! - Binary naming: `{node}-{version}-{target}.tar.gz`
//! - Cached to: `~/.mecha10/bin/{node}-{version}-{target}`
//! - Symlink created: `~/.mecha10/bin/{node}` -> latest version
//!
//! # Usage
//!
//! ```no_run
//! use mecha10_deploy::services::BinaryManager;
//!
//! # async fn example() -> anyhow::Result<()> {
//! let manager = BinaryManager::new()?;
//!
//! // Resolve binary path (downloads if needed)
//! let path = manager.resolve("speaker").await?;
//!
//! // Execute the binary
//! std::process::Command::new(&path).spawn()?;
//! # Ok(())
//! # }
//! ```

#![allow(dead_code)]

use crate::paths;
use anyhow::{Context, Result};
use indicatif::{ProgressBar, ProgressStyle};
use mecha10_cli_core::utils::build_client;
use std::path::PathBuf;

/// Framework version (should match workspace Cargo.toml)
const FRAMEWORK_VERSION: &str = env!("CARGO_PKG_VERSION");

/// Service for managing node binary downloads and caching
///
/// `find_cached`, `find_cached_version`, `binary_name(_with_version)`,
/// `tarball_name(_with_version)`, and `download` are structurally similar to
/// `mecha10-node-resolver::NodeResolver`'s equivalents (LAB-2762). Re-reviewed under LAB-2803
/// with a shared-trait/module extraction specifically in mind: that's intentionally still not
/// addressed by merging the two. Each is already a thin delegate to the shared
/// `mecha10-binary-naming` crate (the actual single source of truth for naming/caching logic),
/// and unifying the two *callers* further would require `node-resolver` to depend on this crate
/// or `mecha10-cli-core`, which violates its documented zero-dependency-on-mecha10-cli-core
/// design goal (minimal binary size for embedding in robot binaries - see `NodeResolver`'s doc
/// comment). This service also does more than `NodeResolver` ever should (progress-bar
/// rendering, a `cargo install` fallback for unsupported platforms, Windows symlink support),
/// so a shared trait would either dilute `NodeResolver`'s minimal surface or force it to grow
/// the dependency footprint it's designed to avoid. cargo-dupes no longer flags this pair at all
/// under the workspace's tuned thresholds (dupes.toml) - only the unavoidable thin per-crate
/// wrapper methods remain. See `.dupes-ignore.toml` for the per-fingerprint reasoning on other
/// groups.
pub struct BinaryManager {
    /// Binary cache directory (~/.mecha10/bin)
    cache_dir: PathBuf,
    /// Framework version for binary resolution
    version: String,
    /// Current platform target triple
    target: String,
}

impl BinaryManager {
    /// Create a new binary manager
    pub fn new() -> Result<Self> {
        let cache_dir = paths::user::bin_dir();
        let version = FRAMEWORK_VERSION.to_string();
        let target = mecha10_binary_naming::detect_target()?;

        Ok(Self {
            cache_dir,
            version,
            target,
        })
    }

    /// Create a binary manager with a specific version
    #[allow(dead_code)]
    pub fn with_version(version: String) -> Result<Self> {
        let cache_dir = paths::user::bin_dir();
        let target = mecha10_binary_naming::detect_target()?;

        Ok(Self {
            cache_dir,
            version,
            target,
        })
    }

    /// Check if pre-built binaries are available for current platform
    pub fn is_prebuilt_available(&self) -> bool {
        mecha10_binary_naming::is_prebuilt_available(&self.target)
    }

    /// Get the binary cache directory
    #[allow(dead_code)]
    pub fn cache_dir(&self) -> &PathBuf {
        &self.cache_dir
    }

    /// Get the current version
    #[allow(dead_code)]
    pub fn version(&self) -> &str {
        &self.version
    }

    /// Get the current target
    #[allow(dead_code)]
    pub fn target(&self) -> &str {
        &self.target
    }

    /// Resolve binary path for a node, downloading if needed
    ///
    /// Resolution strategy:
    /// 1. Check if cached binary exists for current version/target
    /// 2. If not, try to download from GitHub releases
    /// 3. If download fails and platform unsupported, fall back to cargo install
    ///
    /// # Arguments
    ///
    /// * `node_name` - Name of the node (e.g., "speaker", "motor")
    ///
    /// # Returns
    ///
    /// Path to the executable binary
    pub async fn resolve(&self, node_name: &str) -> Result<PathBuf> {
        self.resolve_with_version(node_name, None).await
    }

    /// Resolve binary path for a node with a specific version
    ///
    /// # Arguments
    ///
    /// * `node_name` - Name of the node (e.g., "speaker", "motor")
    /// * `version` - Optional specific version to download (e.g., "0.1.48").
    ///   If None, downloads the latest available version.
    ///
    /// # Returns
    ///
    /// Path to the executable binary
    pub async fn resolve_with_version(&self, node_name: &str, version: Option<&str>) -> Result<PathBuf> {
        if let Some(v) = version {
            if let Some(path) = self.find_cached_version(node_name, v) {
                tracing::debug!("Using cached binary: {}", path.display());
                return Ok(path);
            }
        } else if let Some(cached) = self.find_cached(node_name) {
            tracing::debug!("Using cached binary: {}", cached.display());
            return Ok(cached);
        }

        if self.is_prebuilt_available() {
            let result = if let Some(v) = version {
                self.download_version(node_name, v).await
            } else {
                self.download(node_name).await
            };

            match result {
                Ok(path) => {
                    tracing::info!("Downloaded binary for {}: {}", node_name, path.display());
                    return Ok(path);
                }
                Err(e) => {
                    tracing::warn!("Failed to download binary for {}: {}", node_name, e);
                    if self.target.ends_with("-apple-darwin") {
                        println!("⚠️  macOS binaries for '{}' v{} not found.", node_name, self.version);
                        println!("   Compiling from source instead (this may take a few minutes)...");
                    }
                }
            }
        } else {
            tracing::info!("Pre-built binary not available for {} on {}", node_name, self.target);
        }

        self.cargo_install(node_name).await
    }

    /// Check for cached binary with specific version
    fn find_cached_version(&self, node_name: &str, version: &str) -> Option<PathBuf> {
        mecha10_binary_naming::find_cached_version(&self.cache_dir, node_name, version, &self.target)
    }

    /// Check for cached binary (any version)
    ///
    /// Looks for any cached version of the binary, preferring the symlink which
    /// points to the most recently downloaded version.
    fn find_cached(&self, node_name: &str) -> Option<PathBuf> {
        mecha10_binary_naming::find_cached(&self.cache_dir, node_name, &self.target)
    }

    /// Build the binary name for a node with a specific version
    fn binary_name_with_version(&self, node_name: &str, version: &str) -> String {
        mecha10_binary_naming::binary_name(node_name, version, &self.target)
    }

    /// Build the binary name for a node (uses current version)
    fn binary_name(&self, node_name: &str) -> String {
        self.binary_name_with_version(node_name, &self.version)
    }

    /// Build the tarball name for a node with a specific version
    fn tarball_name_with_version(&self, node_name: &str, version: &str) -> String {
        mecha10_binary_naming::tarball_name(node_name, version, &self.target)
    }

    /// Build the tarball name for a node (uses current version)
    #[allow(dead_code)]
    fn tarball_name(&self, node_name: &str) -> String {
        self.tarball_name_with_version(node_name, &self.version)
    }

    /// Download binary at the current framework version via mecha10-api
    async fn download(&self, node_name: &str) -> Result<PathBuf> {
        self.download_version(node_name, &self.version.clone()).await
    }

    /// Download a specific version of a node binary via `mecha10-api`
    async fn download_version(&self, node_name: &str, version: &str) -> Result<PathBuf> {
        let tarball = self.tarball_name_with_version(node_name, version);
        let (os, arch) = mecha10_binary_naming::os_arch_query(&self.target)?;
        let url = format!(
            "{}/downloads/node/{}?os={}&arch={}&version={}",
            paths::urls::mecha10_api_base_url(),
            node_name,
            os,
            arch,
            version
        );

        println!("📦 Downloading {} v{}...", node_name, version);
        tracing::info!("Downloading binary from mecha10-api: {}", url);

        let client = build_client()?;
        let response = client
            .get(&url)
            .send()
            .await
            .context(format!("Failed to connect to mecha10-api for binary '{}'", node_name))?;

        if !response.status().is_success() {
            return Err(anyhow::anyhow!(
                "Binary '{}' not found: HTTP {}\n\
                 URL: {}\n\
                 Falling back to cargo install...",
                tarball,
                response.status(),
                url
            ));
        }

        let size = response.content_length().unwrap_or(0);
        self.download_and_extract_versioned(node_name, version, response, size)
            .await
    }

    /// Download and extract a binary tarball with a specific version
    async fn download_and_extract_versioned(
        &self,
        node_name: &str,
        version: &str,
        response: reqwest::Response,
        size: u64,
    ) -> Result<PathBuf> {
        let pb = ProgressBar::new(size);
        pb.set_style(
            ProgressStyle::default_bar()
                .template("{spinner:.green} [{bar:40.cyan/blue}] {bytes}/{total_bytes} ({eta})")
                .unwrap()
                .progress_chars("#>-"),
        );

        let temp_dir = tempfile::tempdir()?;
        let temp_file = temp_dir.path().join("binary.tar.gz");

        let mut file = tokio::fs::File::create(&temp_file).await?;
        let mut stream = response.bytes_stream();

        use futures_util::StreamExt;
        use tokio::io::AsyncWriteExt;

        while let Some(chunk) = stream.next().await {
            let chunk = chunk.context("Error downloading chunk")?;
            file.write_all(&chunk).await?;
            pb.inc(chunk.len() as u64);
        }

        file.flush().await?;
        pb.finish_with_message("Download complete");

        tokio::fs::create_dir_all(&self.cache_dir).await?;

        let tar_gz = std::fs::File::open(&temp_file)?;
        let tar = flate2::read::GzDecoder::new(tar_gz);
        let mut archive = tar::Archive::new(tar);

        let extract_dir = temp_dir.path().join("extract");
        std::fs::create_dir_all(&extract_dir)?;
        archive.unpack(&extract_dir)?;

        let extracted_binary = extract_dir.join(node_name);
        if !extracted_binary.exists() {
            return Err(anyhow::anyhow!("Binary '{}' not found in tarball", node_name));
        }

        let binary_name = self.binary_name_with_version(node_name, version);
        let dest_path = self.cache_dir.join(&binary_name);

        tokio::fs::copy(&extracted_binary, &dest_path).await?;

        #[cfg(unix)]
        {
            use std::os::unix::fs::PermissionsExt;
            let mut perms = tokio::fs::metadata(&dest_path).await?.permissions();
            perms.set_mode(0o755);
            tokio::fs::set_permissions(&dest_path, perms).await?;
        }

        let symlink_path = self.cache_dir.join(node_name);
        if symlink_path.exists() || symlink_path.is_symlink() {
            tokio::fs::remove_file(&symlink_path).await.ok();
        }

        #[cfg(unix)]
        {
            std::os::unix::fs::symlink(&binary_name, &symlink_path)?;
        }

        #[cfg(windows)]
        {
            std::os::windows::fs::symlink_file(&dest_path, &symlink_path)?;
        }

        println!("✅ Installed {} v{} to {}", node_name, version, dest_path.display());

        Ok(dest_path)
    }

    /// Fallback: install via cargo
    async fn cargo_install(&self, node_name: &str) -> Result<PathBuf> {
        println!(
            "⚠️  Pre-built binary not available for {} on {}",
            node_name, self.target
        );
        println!("🔨 Compiling via cargo install...");

        let crate_name = format!("mecha10-nodes-{}", node_name);

        let output = tokio::process::Command::new("cargo")
            .args([
                "install",
                &crate_name,
                "--version",
                &self.version,
                "--root",
                &self.cache_dir.to_string_lossy(),
            ])
            .output()
            .await
            .context("Failed to run cargo install")?;

        if !output.status.success() {
            let stderr = String::from_utf8_lossy(&output.stderr);
            return Err(anyhow::anyhow!("cargo install failed for {}: {}", crate_name, stderr));
        }

        let binary_path = self.cache_dir.join("bin").join(node_name);
        if !binary_path.exists() {
            return Err(anyhow::anyhow!(
                "Binary not found after cargo install: {}",
                binary_path.display()
            ));
        }

        println!("✅ Compiled {} via cargo install", node_name);

        Ok(binary_path)
    }

    /// Remove a cached binary
    pub async fn remove(&self, node_name: &str) -> Result<()> {
        let binary_name = self.binary_name(node_name);
        let binary_path = self.cache_dir.join(&binary_name);
        let symlink_path = self.cache_dir.join(node_name);

        if binary_path.exists() {
            tokio::fs::remove_file(&binary_path).await?;
            println!("Removed {}", binary_path.display());
        }

        if symlink_path.exists() || symlink_path.is_symlink() {
            tokio::fs::remove_file(&symlink_path).await?;
            println!("Removed symlink {}", symlink_path.display());
        }

        Ok(())
    }

    /// Clear all cached binaries
    pub async fn clear_cache(&self) -> Result<()> {
        if self.cache_dir.exists() {
            tokio::fs::remove_dir_all(&self.cache_dir).await?;
            println!("Cleared binary cache at {}", self.cache_dir.display());
        }
        Ok(())
    }
}

impl Default for BinaryManager {
    fn default() -> Self {
        Self::new().expect("Failed to create BinaryManager")
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_binary_name() {
        let manager = BinaryManager {
            cache_dir: PathBuf::from("/tmp"),
            version: "0.1.44".to_string(),
            target: "aarch64-apple-darwin".to_string(),
        };

        assert_eq!(manager.binary_name("speaker"), "speaker-0.1.44-aarch64-apple-darwin");
    }

    #[test]
    fn test_tarball_name() {
        let manager = BinaryManager {
            cache_dir: PathBuf::from("/tmp"),
            version: "0.1.44".to_string(),
            target: "x86_64-apple-darwin".to_string(),
        };

        assert_eq!(manager.tarball_name("motor"), "motor-0.1.44-x86_64-apple-darwin.tar.gz");
    }

    #[test]
    fn test_prebuilt_available() {
        let manager = BinaryManager {
            cache_dir: PathBuf::from("/tmp"),
            version: "0.1.44".to_string(),
            target: "aarch64-apple-darwin".to_string(),
        };
        assert!(manager.is_prebuilt_available());

        let manager_arm_linux = BinaryManager {
            cache_dir: PathBuf::from("/tmp"),
            version: "0.1.44".to_string(),
            target: "aarch64-unknown-linux-gnu".to_string(),
        };
        assert!(manager_arm_linux.is_prebuilt_available());

        let manager_unsupported = BinaryManager {
            cache_dir: PathBuf::from("/tmp"),
            version: "0.1.44".to_string(),
            target: "aarch64-unknown-linux-musl".to_string(),
        };
        assert!(!manager_unsupported.is_prebuilt_available());
    }
}