Method run

atomic-cli/src/commands/unrecord.rs:84–132

(&self)

impl Command for Unrecord {
    fn run(&self) -> CliResult<()> {
        let repo_root = find_repository_root()?;
        let repo = Repository::open(&repo_root).map_err(|e| match e {
            atomic_repository::RepositoryError::NotFound { path } => CliError::RepositoryNotFound {
                searched_path: path.into(),
            },
            other => CliError::Repository(other),
        })?;

        let options = if self.dry_run {
            UnrecordOptions::dry_run()
        } else {
            UnrecordOptions::new()
        };

        let outcome = if let Some(ref _prefix) = self.change {
            // TODO: support unrecording a specific change by hash prefix
            // once hash_from_prefix is available on the transaction trait.
            return Err(CliError::InvalidArgument {
                message: "Unrecording a specific change by hash is not yet supported. \
                          Use `atomic unrecord` (no argument) to unrecord the last change."
                    .to_string(),
            });
        } else {
            // Unrecord the most recent change
            repo.unrecord_last(options).map_err(|e| match e {
                atomic_repository::RepositoryError::Unrecord(msg)
                    if msg.contains("empty") || msg.contains("Empty") =>
                {
                    CliError::InvalidArgument {
                        message: "View is empty — nothing to unrecord".to_string(),
                    }
                }
                other => CliError::Repository(other),
            })?
        };

        if outcome.was_dry_run {
            for hash in &outcome.unrecorded {
                print_warning(&format!("Would unrecord: {}", hash.to_base32()));
            }
        } else {
            for hash in &outcome.unrecorded {
                print_success(&format!("Unrecorded: {}", hash.to_base32()));
            }
        }

        Ok(())
    }
}

#[cfg(test)]