pijul 1.0.0-alpha.9

use std::path::PathBuf;

use clap::Clap;
use libpijul::{MutTxnT, MutTxnTExt};
use log::debug;
use tempfile::TempDir;

use crate::repository::*;

#[derive(Clap, Debug)]
pub struct Clone {
    /// Only download changes with alive contents
    #[clap(long = "lazy")]
    lazy: bool,
    /// Set the remote channel
    #[clap(long = "channel", default_value = crate::DEFAULT_CHANNEL)]
    channel: String,
    /// Clone this change and its dependencies
    #[clap(long = "change", conflicts_with = "state")]
    change: Option<String>,
    /// clone this state
    #[clap(long = "state", conflicts_with = "change")]
    state: Option<String>,
    /// Clone this path only
    #[clap(long = "path", multiple(true))]
    partial_paths: Vec<String>,
    /// Do not check certificates (HTTPS remotes only, this option might be dangerous)
    #[clap(short = 'k')]
    no_cert_check: bool,
    /// Clone this remote
    remote: String,
    /// Path where to clone the repository
    /// If not given, the name of the remote repsoitory is given
    path: Option<PathBuf>,
}

impl Clone {
    pub async fn run(self) -> Result<(), anyhow::Error> {
        let mut remote =
            crate::remote::unknown_remote(None, &self.remote, &self.channel, self.no_cert_check)
                .await?;

        let path = if let Some(path) = self.path {
            if path.is_relative() {
                let mut p = std::env::current_dir()?;
                p.push(path);
                p
            } else {
                path
            }
        } else if let Some(path) = remote.repo_name() {
            let mut p = std::env::current_dir()?;
            p.push(path);
            p
        } else {
            return Err((crate::Error::CouldNotInferRepositoryName { repo: self.remote }).into());
        };
        debug!("path = {:?}", path);
        let parent = std::fs::canonicalize(path.parent().unwrap())?;
        let temp = TempDir::new_in(&parent)?;
        debug!("temp = {:?}", temp.path());
        let mut repo = Repository::init(Some(temp.path().to_path_buf()))?;
        let mut txn = repo.pristine.mut_txn_begin();
        let mut channel = txn.open_or_create_channel(&self.channel)?;
        if let Some(ref change) = self.change {
            let h = change.parse()?;
            remote
                .clone_tag(&mut repo, &mut txn, &mut channel, &[h])
                .await?
        } else if let Some(ref state) = self.state {
            let h = state.parse()?;
            remote
                .clone_state(&mut repo, &mut txn, &mut channel, h, self.lazy)
                .await?
        } else {
            remote
                .clone_channel(
                    &mut repo,
                    &mut txn,
                    &mut channel,
                    self.lazy,
                    &self.partial_paths,
                )
                .await?;
        }
        txn.output_repository_no_pending(
            &mut repo.working_copy,
            &repo.changes,
            &mut channel,
            "",
            true,
        )?;
        remote.finish().await?;
        txn.commit()?;
        repo.config.current_channel = Some(self.channel);
        repo.save_config()?;
        std::mem::drop(repo);
        std::fs::rename(&temp.into_path(), &path)?;
        Ok(())
    }
}