gor-cli 0.2.0

//! Implementation of the `gor codespace` subcommand.
//!
//! Provides codespace listing and creation.

#![allow(clippy::print_stdout, clippy::option_if_let_else)]

use crate::cli::CodespaceCommand;
use crate::client::Client;
use crate::output::print_json;
use anyhow::Context;

/// Run the `gor codespace` subcommand.
///
/// # Errors
///
/// Returns an error if the command execution fails.
pub fn run(cmd: CodespaceCommand) -> anyhow::Result<()> {
    match cmd {
        CodespaceCommand::List {
            repo,
            json,
            hostname,
        } => list(repo.as_deref(), json, hostname.as_deref()),
        CodespaceCommand::Create {
            repo,
            branch,
            machine,
            hostname,
        } => create(
            &repo,
            branch.as_deref(),
            machine.as_deref(),
            hostname.as_deref(),
        ),
        CodespaceCommand::Delete {
            name,
            repo,
            yes,
            hostname,
        } => delete(&name, repo.as_deref(), yes, hostname.as_deref()),
        CodespaceCommand::Logs {
            name,
            repo,
            json,
            follow,
            hostname,
        } => logs(&name, repo.as_deref(), json, follow, hostname.as_deref()),
        CodespaceCommand::Ssh {
            name,
            repo,
            profile,
            config,
            hostname,
        } => ssh(
            &name,
            repo.as_deref(),
            profile.as_deref(),
            config,
            hostname.as_deref(),
        ),
        CodespaceCommand::Stop {
            name,
            repo,
            all,
            hostname,
        } => stop(name.as_deref(), repo.as_deref(), all, hostname.as_deref()),
        CodespaceCommand::Cp {
            name,
            paths,
            recursive,
            hostname,
        } => cp(&name, &paths, recursive, hostname.as_deref()),
        CodespaceCommand::Ports {
            name,
            json,
            hostname,
        } => ports(&name, json, hostname.as_deref()),
        CodespaceCommand::Rebuild {
            name,
            yes,
            hostname,
        } => rebuild(&name, yes, hostname.as_deref()),
    }
}

fn list(
    repo: Option<&str>,
    json: Option<Vec<String>>,
    hostname: Option<&str>,
) -> anyhow::Result<()> {
    let host = hostname.unwrap_or("github.com");
    let client = Client::new(host).context("failed to create HTTP client")?;

    let path = if let Some(r) = repo {
        format!("/user/codespaces?repository_id={r}")
    } else {
        "/user/codespaces".to_string()
    };

    let response = client.get(&path).context("failed to fetch codespaces")?;
    let status = response.status();
    if !status.is_success() {
        anyhow::bail!("failed to list codespaces: HTTP {status}");
    }

    let result: serde_json::Value = response.json().context("failed to parse response")?;
    let spaces: Vec<serde_json::Value> = result["codespaces"]
        .as_array()
        .map_or_else(Vec::new, Clone::clone);

    if let Some(fields) = json {
        let fields_ref: Option<&[String]> = if fields.is_empty() {
            None
        } else {
            Some(&fields)
        };
        print_json(&spaces, fields_ref);
        return Ok(());
    }

    if spaces.is_empty() {
        println!("No codespaces found.");
        return Ok(());
    }

    println!(
        "{:<24}  {:<20}  {:<15}  BRANCH",
        "NAME", "REPOSITORY", "STATE"
    );
    for s in &spaces {
        let name = s["name"].as_str().unwrap_or("—");
        let repo_name = s["repository"]["full_name"].as_str().unwrap_or("—");
        let state = s["state"].as_str().unwrap_or("—");
        let branch = s["git_status"]["branch"].as_str().unwrap_or("—");
        let name_truncated = crate::cmd::util::truncate(name, 24);
        let repo_truncated = crate::cmd::util::truncate(repo_name, 20);
        println!("{name_truncated:<24}  {repo_truncated:<20}  {state:<15}  {branch}");
    }

    Ok(())
}

fn delete(name: &str, repo: Option<&str>, yes: bool, hostname: Option<&str>) -> anyhow::Result<()> {
    let host = hostname.unwrap_or("github.com");
    let client = Client::new(host).context("failed to create HTTP client")?;

    if !yes {
        use std::io::Write;
        let prompt = if let Some(r) = repo {
            format!("Are you sure you want to delete codespace '{name}' in repo '{r}'?")
        } else {
            format!("Are you sure you want to delete codespace '{name}'?")
        };
        print!("{prompt} [y/N] ");
        std::io::stdout().flush().ok();

        let mut input = String::new();
        std::io::stdin()
            .read_line(&mut input)
            .context("failed to read input")?;
        let input = input.trim().to_lowercase();
        if input != "y" && input != "yes" {
            println!("Cancelled.");
            return Ok(());
        }
    }

    let path = format!("/user/codespaces/{name}");

    let response = client
        .request("DELETE", &path, &[], None)
        .context("failed to delete codespace")?;

    let status = response.status();
    if !status.is_success() {
        anyhow::bail!("failed to delete codespace '{name}': HTTP {status}");
    }

    println!("Codespace '{name}' deleted.");
    Ok(())
}

fn create(
    repo: &str,
    branch: Option<&str>,
    machine: Option<&str>,
    hostname: Option<&str>,
) -> anyhow::Result<()> {
    let host = hostname.unwrap_or("github.com");
    let client = Client::new(host).context("failed to create HTTP client")?;

    let mut body_map = serde_json::Map::new();
    body_map.insert(
        "repository_id".to_string(),
        serde_json::Value::String(repo.to_string()),
    );

    if let Some(b) = branch {
        body_map.insert("git_status".to_string(), serde_json::json!({"branch": b}));
    }

    if let Some(m) = machine {
        body_map.insert(
            "machine".to_string(),
            serde_json::Value::String(m.to_string()),
        );
    }

    let body_value = serde_json::Value::Object(body_map);
    let body_bytes = serde_json::to_vec(&body_value).context("failed to serialize body")?;

    let response = client
        .request("POST", "/user/codespaces", &[], Some(body_bytes))
        .context("failed to create codespace")?;

    let status = response.status();
    if !status.is_success() {
        let err_body: serde_json::Value = response.json().unwrap_or_default();
        let msg = err_body["message"].as_str().unwrap_or("create failed");
        anyhow::bail!("failed to create codespace: {msg}");
    }

    let result: serde_json::Value = response.json().context("failed to parse response")?;
    let name = result["name"].as_str().unwrap_or("—");
    println!("Codespace '{name}' created.");
    Ok(())
}

fn logs(
    name: &str,
    _repo: Option<&str>,
    json: Option<Vec<String>>,
    follow: bool,
    hostname: Option<&str>,
) -> anyhow::Result<()> {
    let host = hostname.unwrap_or("github.com");
    let client = Client::new(host).context("failed to create HTTP client")?;

    let path = format!("/user/codespaces/{name}/logs");

    let response = client
        .get(&path)
        .context("failed to fetch codespace logs")?;
    let status = response.status();
    if !status.is_success() {
        anyhow::bail!("failed to fetch logs for '{name}': HTTP {status}");
    }

    let body = response.text().context("failed to read response")?;

    if let Some(fields) = json {
        let parsed: serde_json::Value = serde_json::from_str(&body).unwrap_or_default();
        let fields_ref: Option<&[String]> = if fields.is_empty() {
            None
        } else {
            Some(&fields)
        };
        print_json(&parsed, fields_ref);
        return Ok(());
    }

    if follow {
        println!("Logs for codespace '{name}':");
    }
    println!("{body}");

    if follow {
        tracing::warn!("log following is not yet implemented");
    }

    Ok(())
}

fn ssh(
    name: &str,
    _repo: Option<&str>,
    _profile: Option<&str>,
    config: bool,
    hostname: Option<&str>,
) -> anyhow::Result<()> {
    let host = hostname.unwrap_or("github.com");
    let client = Client::new(host).context("failed to create HTTP client")?;

    let path = format!("/user/codespaces/{name}");

    let response = client
        .get(&path)
        .context("failed to fetch codespace details")?;
    let status = response.status();
    if !status.is_success() {
        anyhow::bail!("failed to fetch codespace '{name}': HTTP {status}");
    }

    let cs: serde_json::Value = response.json().context("failed to parse response")?;
    let state = cs["state"].as_str().unwrap_or("unknown");

    if state != "Available" {
        anyhow::bail!("codespace '{name}' is not available (state: {state})");
    }

    // Fetch SSH connection details
    let ssh_path = format!("/user/codespaces/{name}");
    let ssh_response = client
        .get(&ssh_path)
        .context("failed to fetch SSH details")?;
    let ssh_details: serde_json::Value =
        ssh_response.json().context("failed to parse SSH details")?;

    if config {
        let connection = ssh_details.get("connection").and_then(|c| c.as_object());
        if let Some(conn) = connection {
            println!("Host {name}");
            if let Some(hostname) = conn.get("host").and_then(|v| v.as_str()) {
                println!("  HostName {hostname}");
            }
            if let Some(port) = conn.get("port") {
                println!("  Port {port}");
            }
            if let Some(user) = conn.get("user").and_then(|v| v.as_str()) {
                println!("  User {user}");
            }
        } else {
            println!("# No SSH connection details available for '{name}'");
        }
        return Ok(());
    }

    anyhow::bail!("SSH connection is not yet implemented; use --config to view connection details");
}

/// Copy files between a local machine and a codespace.
///
/// The last path in `paths` is the destination, all others are sources.
/// Use the `remote:` prefix for codespace paths.
///
/// # Errors
///
/// Returns an error if the codespace is not running, the paths are invalid,
/// or the transfer fails.
fn cp(name: &str, paths: &[String], recursive: bool, hostname: Option<&str>) -> anyhow::Result<()> {
    let host = hostname.unwrap_or("github.com");
    let client = Client::new(host).context("failed to create HTTP client")?;

    if paths.len() < 2 {
        anyhow::bail!("at least two paths are required: source and destination");
    }

    let dest = paths
        .last()
        .ok_or_else(|| anyhow::anyhow!("paths is empty"))?;
    let sources = &paths[..paths.len() - 1];

    let dest_is_remote = dest.starts_with("remote:");
    let any_source_remote = sources.iter().any(|p| p.starts_with("remote:"));

    if dest_is_remote && any_source_remote {
        anyhow::bail!("copying between two remote paths is not supported");
    }

    // Fetch codespace details to verify it's running and get connection info.
    let cs_path = format!("/user/codespaces/{name}");
    let response = client
        .get(&cs_path)
        .context("failed to fetch codespace details")?;
    let status = response.status();
    if !status.is_success() {
        anyhow::bail!("failed to fetch codespace '{name}': HTTP {status}");
    }

    let cs: serde_json::Value = response
        .json()
        .context("failed to parse codespace response")?;
    let state = cs["state"].as_str().unwrap_or("unknown");

    if state != "Available" {
        anyhow::bail!(
            "codespace '{name}' is not available (state: {state}). Start the codespace first."
        );
    }

    if dest_is_remote {
        // Upload: local → remote via SCP
        let connection = cs["connection"]
            .as_object()
            .ok_or_else(|| anyhow::anyhow!("no SSH connection details available for '{name}'"))?;

        let ssh_host = connection["host"]
            .as_str()
            .ok_or_else(|| anyhow::anyhow!("missing SSH host"))?;
        let ssh_port = connection["port"]
            .as_u64()
            .ok_or_else(|| anyhow::anyhow!("missing SSH port"))?;
        let ssh_user = connection["user"]
            .as_str()
            .ok_or_else(|| anyhow::anyhow!("missing SSH user"))?;

        let remote_path = dest
            .strip_prefix("remote:")
            .ok_or_else(|| anyhow::anyhow!("invalid remote path"))?;

        for source in sources {
            if source.starts_with("remote:") {
                anyhow::bail!("cannot mix remote sources with remote destination");
            }

            tracing::info!("Uploading {source} to {name}:{remote_path}...");

            let mut cmd = std::process::Command::new("scp");
            cmd.arg("-P")
                .arg(ssh_port.to_string())
                .arg("-o")
                .arg("LogLevel=ERROR");
            if recursive {
                cmd.arg("-r");
            }
            cmd.arg(source);
            cmd.arg(format!("{ssh_user}@{ssh_host}:{remote_path}"));

            let output = cmd
                .output()
                .context("failed to run scp; is it installed?")?;

            if !output.status.success() {
                let stderr = String::from_utf8_lossy(&output.stderr);
                anyhow::bail!("scp failed for '{source}': {stderr}");
            }

            tracing::info!("✓ Uploaded {source}");
        }
    } else if any_source_remote {
        // Download: remote → local via export API
        for source in sources {
            let remote_path = source
                .strip_prefix("remote:")
                .ok_or_else(|| anyhow::anyhow!("invalid remote path: {source}"))?;

            tracing::info!("Downloading {remote_path} from {name}...");

            // Start an export operation
            let export_body = serde_json::json!({"path": remote_path});
            let export_response = client
                .post(&format!("/user/codespaces/{name}/exports"), &export_body)
                .context("failed to start export")?;

            if !export_response.status().is_success() {
                let err_body: serde_json::Value = export_response.json().unwrap_or_default();
                let msg = err_body["message"].as_str().unwrap_or("export failed");
                anyhow::bail!("failed to export '{remote_path}': {msg}");
            }

            let export_result: serde_json::Value = export_response
                .json()
                .context("failed to parse export response")?;

            // The export API returns a download URL in the `url` field
            let download_url = export_result["url"]
                .as_str()
                .ok_or_else(|| anyhow::anyhow!("no download URL in export response"))?;

            // Download the file
            let file_response = client
                .get_absolute(download_url)
                .context("failed to download exported file")?;

            if !file_response.status().is_success() {
                anyhow::bail!("failed to download file: HTTP {}", file_response.status());
            }

            let bytes = file_response
                .bytes()
                .context("failed to read downloaded file")?;

            // Determine local path: if dest is a directory, use the filename
            let local_path = if dest.ends_with('/') || dest.ends_with(std::path::MAIN_SEPARATOR_STR)
            {
                let filename = std::path::Path::new(remote_path)
                    .file_name()
                    .and_then(|n| n.to_str())
                    .unwrap_or("file");
                std::path::Path::new(dest).join(filename)
            } else {
                std::path::PathBuf::from(dest)
            };

            if let Some(parent) = local_path.parent() {
                std::fs::create_dir_all(parent).context("failed to create parent directory")?;
            }

            std::fs::write(&local_path, &bytes).context("failed to write file")?;

            tracing::info!("✓ Downloaded to {}", local_path.display());
        }
    } else {
        // Local to local copy — not supported by this command
        anyhow::bail!(
            "at least one path must use the 'remote:' prefix to specify a codespace path"
        );
    }

    Ok(())
}

/// List forwarded ports for a codespace.
///
/// # Errors
///
/// Returns an error if the codespace is not running or the API request fails.
fn ports(name: &str, json: Option<Vec<String>>, hostname: Option<&str>) -> anyhow::Result<()> {
    let host = hostname.unwrap_or("github.com");
    let client = Client::new(host).context("failed to create HTTP client")?;

    let path = format!("/user/codespaces/{name}/ports");
    let response = client
        .get(&path)
        .context("failed to fetch codespace ports")?;
    let status = response.status();
    if !status.is_success() {
        anyhow::bail!("failed to fetch ports for '{name}': HTTP {status}");
    }

    let ports: Vec<serde_json::Value> =
        response.json().context("failed to parse ports response")?;

    if let Some(fields) = json {
        let fields_ref: Option<&[String]> = if fields.is_empty() {
            None
        } else {
            Some(&fields)
        };
        print_json(&ports, fields_ref);
        return Ok(());
    }

    if ports.is_empty() {
        println!("No forwarded ports for codespace '{name}'.");
        return Ok(());
    }

    println!("{:<24}  {:<12}  {:<12}", "LABEL", "PORT", "VISIBILITY");
    for p in &ports {
        let label = p["label"].as_str().unwrap_or("—");
        let source_port = p["source_port"]
            .as_u64()
            .map_or_else(|| "—".to_string(), |v| v.to_string());
        let visibility = p["visibility"].as_str().unwrap_or("—");
        let label_truncated = crate::cmd::util::truncate(label, 24);
        println!("{label_truncated:<24}  {source_port:<12}  {visibility:<12}");
    }

    Ok(())
}

/// Rebuild a codespace from its devcontainer configuration.
///
/// # Errors
///
/// Returns an error if the codespace is not running, the user cancels,
/// or the API request fails.
fn rebuild(name: &str, yes: bool, hostname: Option<&str>) -> anyhow::Result<()> {
    let host = hostname.unwrap_or("github.com");
    let client = Client::new(host).context("failed to create HTTP client")?;

    if !yes {
        use std::io::Write;
        print!("Are you sure you want to rebuild codespace '{name}'? [y/N] ");
        std::io::stdout().flush().ok();

        let mut input = String::new();
        std::io::stdin()
            .read_line(&mut input)
            .context("failed to read input")?;
        let input = input.trim().to_lowercase();
        if input != "y" && input != "yes" {
            println!("Cancelled.");
            return Ok(());
        }
    }

    let path = format!("/user/codespaces/{name}/rebuild");
    let response = client
        .request("POST", &path, &[], None)
        .context("failed to trigger rebuild")?;

    let status = response.status();
    if !status.is_success() {
        let err_body: serde_json::Value = response.json().unwrap_or_default();
        let msg = err_body["message"].as_str().unwrap_or("rebuild failed");
        anyhow::bail!("failed to rebuild codespace '{name}': {msg}");
    }

    println!("Codespace '{name}' rebuild started.");
    Ok(())
}

fn stop(
    name: Option<&str>,
    _repo: Option<&str>,
    all: bool,
    hostname: Option<&str>,
) -> anyhow::Result<()> {
    let host = hostname.unwrap_or("github.com");
    let client = Client::new(host).context("failed to create HTTP client")?;

    if all {
        // List all codespaces and stop each one
        let response = client
            .get("/user/codespaces")
            .context("failed to list codespaces")?;
        let result: serde_json::Value = response.json().context("failed to parse response")?;
        let spaces: Vec<serde_json::Value> = result["codespaces"]
            .as_array()
            .map_or_else(Vec::new, Clone::clone);

        let mut stopped = 0u32;
        for s in &spaces {
            let cs_name = s["name"].as_str().unwrap_or("");
            let cs_state = s["state"].as_str().unwrap_or("");
            if cs_state == "Shutdown" || cs_state == "Deleted" {
                continue;
            }
            let stop_path = format!("/user/codespaces/{cs_name}/stop");
            let resp = client
                .request("POST", &stop_path, &[], None)
                .context("failed to stop codespace")?;
            if resp.status().is_success() {
                stopped += 1;
            }
        }
        println!("Stopped {stopped} codespace(s).");
        return Ok(());
    }

    let cs_name = name.ok_or_else(|| anyhow::anyhow!("codespace name is required"))?;
    let path = format!("/user/codespaces/{cs_name}/stop");

    let response = client
        .request("POST", &path, &[], None)
        .context("failed to stop codespace")?;

    let status = response.status();
    if !status.is_success() {
        anyhow::bail!("failed to stop codespace '{cs_name}': HTTP {status}");
    }

    println!("Codespace '{cs_name}' stopped.");
    Ok(())
}