use std::{
fmt, io, ops,
path::PathBuf,
process::{ExitCode, ExitStatus, Termination},
};
use binstalk_downloader::{download::DownloadError, remote::Error as RemoteError};
use binstalk_fetchers::FetchError;
use binstalk_types::cargo_toml_binstall::TargetTripleParseError;
use compact_str::CompactString;
use itertools::Itertools;
use miette::{Diagnostic, Report};
use thiserror::Error;
use tokio::task;
use tracing::{error, warn};
use crate::{
bins,
helpers::{
cargo_toml::Error as CargoTomlError,
cargo_toml_workspace::Error as LoadManifestFromWSError, gh_api_client::GhApiError,
},
registry::{InvalidRegistryError, RegistryError},
};
#[derive(Debug, Error)]
#[error("version string '{v}' is not semver: {err}")]
pub struct VersionParseError {
pub v: CompactString,
#[source]
pub err: semver::Error,
}
#[derive(Debug, Diagnostic, Error)]
#[error("For crate {crate_name}: {err}")]
pub struct CrateContextError {
crate_name: CompactString,
#[source]
#[diagnostic(transparent)]
err: BinstallError,
}
#[derive(Debug)]
pub struct CrateErrors(Box<[Box<CrateContextError>]>);
impl CrateErrors {
fn iter(&self) -> impl Iterator<Item = &CrateContextError> + Clone {
self.0.iter().map(ops::Deref::deref)
}
fn get_iter_for<'a, T: 'a>(
&'a self,
f: fn(&'a CrateContextError) -> Option<T>,
) -> Option<impl Iterator<Item = T> + 'a> {
let iter = self.iter().filter_map(f);
if iter.clone().next().is_none() {
None
} else {
Some(iter)
}
}
}
impl fmt::Display for CrateErrors {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
fmt::Display::fmt(&self.0.iter().format(", "), f)
}
}
impl std::error::Error for CrateErrors {
fn source(&self) -> Option<&(dyn std::error::Error + 'static)> {
self.0.first().map(|e| e as _)
}
}
impl miette::Diagnostic for CrateErrors {
fn code<'a>(&'a self) -> Option<Box<dyn fmt::Display + 'a>> {
Some(Box::new("binstall::many_failure"))
}
fn severity(&self) -> Option<miette::Severity> {
self.iter().filter_map(miette::Diagnostic::severity).max()
}
fn help<'a>(&'a self) -> Option<Box<dyn fmt::Display + 'a>> {
Some(Box::new(
self.get_iter_for(miette::Diagnostic::help)?.format("\n"),
))
}
fn url<'a>(&'a self) -> Option<Box<dyn fmt::Display + 'a>> {
Some(Box::new(
self.get_iter_for(miette::Diagnostic::url)?.format("\n"),
))
}
fn source_code(&self) -> Option<&dyn miette::SourceCode> {
self.iter().find_map(miette::Diagnostic::source_code)
}
fn labels(&self) -> Option<Box<dyn Iterator<Item = miette::LabeledSpan> + '_>> {
let get_iter = || self.iter().filter_map(miette::Diagnostic::labels).flatten();
if get_iter().next().is_none() {
None
} else {
Some(Box::new(get_iter()))
}
}
fn related<'a>(&'a self) -> Option<Box<dyn Iterator<Item = &'a dyn miette::Diagnostic> + 'a>> {
Some(Box::new(
self.iter().map(|e| e as _).chain(
self.iter()
.filter_map(miette::Diagnostic::related)
.flatten(),
),
))
}
fn diagnostic_source(&self) -> Option<&dyn miette::Diagnostic> {
self.0.first().map(|err| &**err as _)
}
}
#[derive(Debug, Error)]
#[error("Invalid pkg-url {pkg_url} for {crate_name}@{version} on {target}: {reason}")]
pub struct InvalidPkgFmtError {
pub crate_name: CompactString,
pub version: CompactString,
pub target: String,
pub pkg_url: String,
pub reason: &'static str,
}
#[derive(Error, Diagnostic, Debug)]
#[non_exhaustive]
pub enum BinstallError {
#[error(transparent)]
#[diagnostic(severity(error), code(binstall::internal::task_join))]
TaskJoinError(#[from] task::JoinError),
#[error("installation cancelled by user")]
#[diagnostic(severity(info), code(binstall::user_abort))]
UserAbort,
#[error("Crate {crate_name} is signed and package {package_name} failed verification")]
#[diagnostic(severity(error), code(binstall::signature::invalid))]
InvalidSignature {
crate_name: CompactString,
package_name: CompactString,
},
#[error("Crate {0} does not have signing information")]
#[diagnostic(severity(error), code(binstall::signature::missing))]
MissingSignature(CompactString),
#[error("Failed to parse url: {0}")]
#[diagnostic(severity(error), code(binstall::url_parse))]
UrlParse(#[from] url::ParseError),
#[error(transparent)]
#[diagnostic(severity(error), code(binstall::template))]
#[source_code(transparent)]
#[label(transparent)]
TemplateParseError(
#[from]
#[diagnostic_source]
leon::ParseError,
),
#[error(transparent)]
#[diagnostic(severity(error), code(binstall::fetch))]
#[source_code(transparent)]
#[label(transparent)]
FetchError(Box<FetchError>),
#[error(transparent)]
#[diagnostic(severity(error), code(binstall::download))]
Download(#[from] DownloadError),
#[error("subprocess {command} errored with {status}")]
#[diagnostic(severity(error), code(binstall::subprocess))]
SubProcess {
command: Box<str>,
status: ExitStatus,
},
#[error("I/O Error: {0}")]
#[diagnostic(severity(error), code(binstall::io))]
Io(io::Error),
#[error("Unknown registry name {0}, env `CARGO_REGISTRIES_{0}_INDEX` nor is it in .cargo/config.toml")]
#[diagnostic(severity(error), code(binstall::cargo_registry))]
UnknownRegistryName(CompactString),
#[error(transparent)]
#[diagnostic(transparent)]
RegistryError(#[from] Box<RegistryError>),
#[error("the --manifest-path is invalid or cannot be resolved")]
#[diagnostic(severity(error), code(binstall::cargo_manifest_path))]
CargoManifestPath,
#[error("Failed to parse cargo manifest: {0}")]
#[diagnostic(
severity(error),
code(binstall::cargo_manifest),
help("If you used --manifest-path, check the Cargo.toml syntax.")
)]
CargoManifest(Box<CargoTomlError>),
#[error(transparent)]
#[diagnostic(severity(error), code(binstall::cargo_registry))]
RegistryParseError(#[from] Box<InvalidRegistryError>),
#[error(transparent)]
#[diagnostic(severity(error), code(binstall::version::parse))]
VersionParse(#[from] Box<VersionParseError>),
#[error("superfluous version specification")]
#[diagnostic(
severity(error),
code(binstall::conflict::version),
help("You cannot use both crate@version and the --version option. Remove one.")
)]
SuperfluousVersionOption,
#[error("no binaries specified nor inferred")]
#[diagnostic(
severity(error),
code(binstall::resolve::binaries),
help("This crate doesn't specify any binaries, so there's nothing to install.")
)]
UnspecifiedBinaries,
#[error("failed to discovered a viable target from the host")]
#[diagnostic(
severity(error),
code(binstall::targets::none_host),
help("Try to specify --target")
)]
NoViableTargets,
#[error("failed to find or install binaries: {0}")]
#[diagnostic(
severity(error),
code(binstall::targets::none_host),
help("Try to specify --target")
)]
BinFile(#[from] bins::Error),
#[error("Cargo.toml of crate {0} does not have section \"Package\"")]
#[diagnostic(severity(error), code(binstall::cargo_manifest))]
CargoTomlMissingPackage(CompactString),
#[error("bin-dir configuration provided generates duplicate source path: {path}")]
#[diagnostic(severity(error), code(binstall::SourceFilePath))]
DuplicateSourceFilePath { path: PathBuf },
#[error("Fallback to cargo-install is disabled")]
#[diagnostic(severity(error), code(binstall::no_fallback_to_cargo_install))]
NoFallbackToCargoInstall,
#[error(transparent)]
#[diagnostic(severity(error), code(binstall::invalid_pkg_fmt))]
InvalidPkgFmt(Box<InvalidPkgFmtError>),
#[error("Request to GitHub API failed: {0}")]
#[diagnostic(severity(error), code(binstall::gh_api_failure))]
GhApiErr(#[source] Box<GhApiError>),
#[error("Failed to parse target triple: {0}")]
#[diagnostic(severity(error), code(binstall::target_triple_parse_error))]
TargetTripleParseError(#[source] Box<TargetTripleParseError>),
#[cfg(feature = "git")]
#[error("Failed to shallow clone git repository: {0}")]
#[diagnostic(severity(error), code(binstall::git))]
GitError(#[from] crate::helpers::git::GitError),
#[error(transparent)]
#[diagnostic(severity(error), code(binstall::load_manifest_from_workspace))]
LoadManifestFromWSError(#[from] Box<LoadManifestFromWSError>),
#[error("cargo-install does not support `--install-path`")]
#[diagnostic(
severity(error),
code(binatall::cargo_install_does_not_support_install_path)
)]
CargoInstallDoesNotSupportInstallPath,
#[error(transparent)]
#[diagnostic(transparent)]
CrateContext(Box<CrateContextError>),
#[error(transparent)]
#[diagnostic(transparent)]
Errors(CrateErrors),
}
impl BinstallError {
fn exit_number(&self) -> u8 {
use BinstallError::*;
let code: u8 = match self {
TaskJoinError(_) => 17,
UserAbort => 32,
InvalidSignature { .. } => 40,
MissingSignature(_) => 41,
UrlParse(_) => 65,
TemplateParseError(..) => 67,
FetchError(..) => 68,
Download(_) => 68,
SubProcess { .. } => 70,
Io(_) => 74,
UnknownRegistryName(_) => 75,
RegistryError { .. } => 76,
CargoManifestPath => 77,
CargoManifest { .. } => 78,
RegistryParseError(..) => 79,
VersionParse { .. } => 80,
SuperfluousVersionOption => 84,
UnspecifiedBinaries => 86,
NoViableTargets => 87,
BinFile(_) => 88,
CargoTomlMissingPackage(_) => 89,
DuplicateSourceFilePath { .. } => 90,
NoFallbackToCargoInstall => 94,
InvalidPkgFmt(..) => 95,
GhApiErr(..) => 96,
TargetTripleParseError(..) => 97,
#[cfg(feature = "git")]
GitError(_) => 98,
LoadManifestFromWSError(_) => 99,
CargoInstallDoesNotSupportInstallPath => 100,
CrateContext(context) => context.err.exit_number(),
Errors(errors) => (errors.0)[0].err.exit_number(),
};
debug_assert!(code != 64 && code != 16 && code != 1 && code != 2 && code != 0);
code
}
pub fn exit_code(&self) -> ExitCode {
self.exit_number().into()
}
pub fn crate_context(self, crate_name: impl Into<CompactString>) -> Self {
self.crate_context_inner(crate_name.into())
}
fn crate_context_inner(self, crate_name: CompactString) -> Self {
match self {
Self::CrateContext(mut crate_context_error) => {
crate_context_error.crate_name = crate_name;
Self::CrateContext(crate_context_error)
}
err => Self::CrateContext(Box::new(CrateContextError { err, crate_name })),
}
}
pub fn crate_errors(mut errors: Vec<Box<CrateContextError>>) -> Option<Self> {
if errors.is_empty() {
None
} else if errors.len() == 1 {
Some(Self::CrateContext(errors.pop().unwrap()))
} else {
Some(Self::Errors(CrateErrors(errors.into_boxed_slice())))
}
}
}
impl Termination for BinstallError {
fn report(self) -> ExitCode {
let code = self.exit_code();
if let BinstallError::UserAbort = self {
warn!("Installation cancelled");
} else {
error!("Fatal error:\n{:?}", Report::new(self));
}
code
}
}
impl From<io::Error> for BinstallError {
fn from(err: io::Error) -> Self {
err.downcast::<BinstallError>()
.unwrap_or_else(BinstallError::Io)
}
}
impl From<BinstallError> for io::Error {
fn from(e: BinstallError) -> io::Error {
match e {
BinstallError::Io(io_error) => io_error,
e => io::Error::other(e),
}
}
}
impl From<RemoteError> for BinstallError {
fn from(e: RemoteError) -> Self {
DownloadError::from(e).into()
}
}
impl From<CargoTomlError> for BinstallError {
fn from(e: CargoTomlError) -> Self {
BinstallError::CargoManifest(Box::new(e))
}
}
impl From<InvalidPkgFmtError> for BinstallError {
fn from(e: InvalidPkgFmtError) -> Self {
BinstallError::InvalidPkgFmt(Box::new(e))
}
}
impl From<GhApiError> for BinstallError {
fn from(e: GhApiError) -> Self {
BinstallError::GhApiErr(Box::new(e))
}
}
impl From<TargetTripleParseError> for BinstallError {
fn from(e: TargetTripleParseError) -> Self {
BinstallError::TargetTripleParseError(Box::new(e))
}
}
impl From<RegistryError> for BinstallError {
fn from(e: RegistryError) -> Self {
BinstallError::RegistryError(Box::new(e))
}
}
impl From<InvalidRegistryError> for BinstallError {
fn from(e: InvalidRegistryError) -> Self {
BinstallError::RegistryParseError(Box::new(e))
}
}
impl From<LoadManifestFromWSError> for BinstallError {
fn from(e: LoadManifestFromWSError) -> Self {
BinstallError::LoadManifestFromWSError(Box::new(e))
}
}
impl From<FetchError> for BinstallError {
fn from(e: FetchError) -> Self {
BinstallError::FetchError(Box::new(e))
}
}