use thiserror::Error;
#[derive(Error, Debug)]
pub enum BundlerError {
#[error("Failed to parse Gemfile: {message}")]
ParseError { message: String },
#[error("Invalid version specifier '{specifier}': {message}")]
InvalidVersionSpecifier { specifier: String, message: String },
#[error("Gem '{package}' not found on rubygems.org")]
PackageNotFound { package: String },
#[error("rubygems.org request failed for '{package}': {source}")]
RegistryError {
package: String,
#[source]
source: Box<dyn std::error::Error + Send + Sync>,
},
#[error("Failed to parse rubygems API response for '{package}': {source}")]
ApiResponseError {
package: String,
#[source]
source: serde_json::Error,
},
#[error("Invalid Gemfile structure: {message}")]
InvalidStructure { message: String },
#[error("Invalid file URI: {uri}")]
InvalidUri { uri: String },
#[error("Cache error: {0}")]
CacheError(String),
#[error("I/O error: {0}")]
Io(#[from] std::io::Error),
#[error(transparent)]
Other(#[from] Box<dyn std::error::Error + Send + Sync>),
}
pub type Result<T> = std::result::Result<T, BundlerError>;
impl BundlerError {
pub fn registry_error(
package: impl Into<String>,
error: impl std::error::Error + Send + Sync + 'static,
) -> Self {
Self::RegistryError {
package: package.into(),
source: Box::new(error),
}
}
pub fn api_response_error(package: impl Into<String>, error: serde_json::Error) -> Self {
Self::ApiResponseError {
package: package.into(),
source: error,
}
}
pub fn invalid_structure(message: impl Into<String>) -> Self {
Self::InvalidStructure {
message: message.into(),
}
}
pub fn invalid_version_specifier(
specifier: impl Into<String>,
message: impl Into<String>,
) -> Self {
Self::InvalidVersionSpecifier {
specifier: specifier.into(),
message: message.into(),
}
}
pub fn invalid_uri(uri: impl Into<String>) -> Self {
Self::InvalidUri { uri: uri.into() }
}
}
impl From<deps_core::DepsError> for BundlerError {
fn from(err: deps_core::DepsError) -> Self {
match err {
deps_core::DepsError::ParseError { source, .. } => Self::CacheError(source.to_string()),
deps_core::DepsError::CacheError(msg) => Self::CacheError(msg),
deps_core::DepsError::InvalidVersionReq(msg) => Self::InvalidVersionSpecifier {
specifier: String::new(),
message: msg,
},
deps_core::DepsError::Io(e) => Self::Io(e),
deps_core::DepsError::Json(e) => Self::ApiResponseError {
package: String::new(),
source: e,
},
other => Self::CacheError(other.to_string()),
}
}
}
impl From<BundlerError> for deps_core::DepsError {
fn from(err: BundlerError) -> Self {
match err {
BundlerError::ParseError { message } => Self::ParseError {
file_type: "Gemfile".into(),
source: Box::new(std::io::Error::other(message)),
},
BundlerError::InvalidVersionSpecifier { message, .. } => {
Self::InvalidVersionReq(message)
}
BundlerError::PackageNotFound { package } => {
Self::CacheError(format!("Gem '{package}' not found"))
}
BundlerError::RegistryError { package, source } => Self::ParseError {
file_type: format!("rubygems.org for {package}"),
source,
},
BundlerError::ApiResponseError { source, .. } => Self::Json(source),
BundlerError::InvalidStructure { message } => Self::CacheError(message),
BundlerError::InvalidUri { uri } => Self::CacheError(format!("Invalid URI: {uri}")),
BundlerError::CacheError(msg) => Self::CacheError(msg),
BundlerError::Io(e) => Self::Io(e),
BundlerError::Other(e) => Self::CacheError(e.to_string()),
}
}
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn test_error_display() {
let err = BundlerError::PackageNotFound {
package: "nonexistent".into(),
};
assert_eq!(
err.to_string(),
"Gem 'nonexistent' not found on rubygems.org"
);
let err = BundlerError::invalid_structure("missing source");
assert_eq!(err.to_string(), "Invalid Gemfile structure: missing source");
}
#[test]
fn test_error_construction() {
let err = BundlerError::registry_error(
"rails",
std::io::Error::from(std::io::ErrorKind::NotFound),
);
assert!(matches!(err, BundlerError::RegistryError { .. }));
let json_err = serde_json::from_str::<serde_json::Value>("invalid").unwrap_err();
let err = BundlerError::api_response_error("rails", json_err);
assert!(matches!(err, BundlerError::ApiResponseError { .. }));
}
#[test]
fn test_invalid_version_specifier() {
let err = BundlerError::invalid_version_specifier("invalid", "not a valid version");
assert!(err.to_string().contains("invalid"));
assert!(err.to_string().contains("not a valid version"));
}
#[test]
fn test_invalid_uri() {
let err = BundlerError::invalid_uri("not-a-valid-uri");
assert!(err.to_string().contains("not-a-valid-uri"));
}
#[test]
fn test_conversion_to_deps_error() {
let bundler_err = BundlerError::PackageNotFound {
package: "test".into(),
};
let deps_err: deps_core::DepsError = bundler_err.into();
assert!(deps_err.to_string().contains("not found"));
}
#[test]
fn test_parse_error_display() {
let err = BundlerError::ParseError {
message: "unexpected token".into(),
};
assert_eq!(err.to_string(), "Failed to parse Gemfile: unexpected token");
}
#[test]
fn test_parse_error_to_deps_error() {
let err = BundlerError::ParseError {
message: "syntax error".into(),
};
let deps_err: deps_core::DepsError = err.into();
assert!(matches!(deps_err, deps_core::DepsError::ParseError { .. }));
}
#[test]
fn test_invalid_version_specifier_to_deps_error() {
let err = BundlerError::InvalidVersionSpecifier {
specifier: "~>".into(),
message: "incomplete specifier".into(),
};
let deps_err: deps_core::DepsError = err.into();
assert!(matches!(
deps_err,
deps_core::DepsError::InvalidVersionReq(_)
));
}
#[test]
fn test_registry_error_to_deps_error() {
let io_err = std::io::Error::other("connection refused");
let err = BundlerError::RegistryError {
package: "nokogiri".into(),
source: Box::new(io_err),
};
let deps_err: deps_core::DepsError = err.into();
assert!(matches!(deps_err, deps_core::DepsError::ParseError { .. }));
}
#[test]
fn test_api_response_error_to_deps_error() {
let json_err = serde_json::from_str::<serde_json::Value>("{invalid}").unwrap_err();
let err = BundlerError::ApiResponseError {
package: "test".into(),
source: json_err,
};
let deps_err: deps_core::DepsError = err.into();
assert!(matches!(deps_err, deps_core::DepsError::Json(_)));
}
#[test]
fn test_invalid_structure_to_deps_error() {
let err = BundlerError::InvalidStructure {
message: "missing gem declaration".into(),
};
let deps_err: deps_core::DepsError = err.into();
assert!(matches!(deps_err, deps_core::DepsError::CacheError(_)));
}
#[test]
fn test_invalid_uri_to_deps_error() {
let err = BundlerError::InvalidUri {
uri: "invalid://uri".into(),
};
let deps_err: deps_core::DepsError = err.into();
assert!(matches!(deps_err, deps_core::DepsError::CacheError(_)));
assert!(deps_err.to_string().contains("Invalid URI"));
}
#[test]
fn test_cache_error_to_deps_error() {
let err = BundlerError::CacheError("cache miss".into());
let deps_err: deps_core::DepsError = err.into();
assert!(matches!(deps_err, deps_core::DepsError::CacheError(_)));
}
#[test]
fn test_io_error_to_deps_error() {
let io_err = std::io::Error::from(std::io::ErrorKind::NotFound);
let err = BundlerError::Io(io_err);
let deps_err: deps_core::DepsError = err.into();
assert!(matches!(deps_err, deps_core::DepsError::Io(_)));
}
#[test]
fn test_other_error_to_deps_error() {
let other_err: Box<dyn std::error::Error + Send + Sync> =
Box::new(std::io::Error::other("unknown error"));
let err = BundlerError::Other(other_err);
let deps_err: deps_core::DepsError = err.into();
assert!(matches!(deps_err, deps_core::DepsError::CacheError(_)));
}
#[test]
fn test_deps_error_to_bundler_error_parse() {
let deps_err = deps_core::DepsError::ParseError {
file_type: "test".into(),
source: Box::new(std::io::Error::other("parse failed")),
};
let bundler_err: BundlerError = deps_err.into();
assert!(matches!(bundler_err, BundlerError::CacheError(_)));
}
#[test]
fn test_deps_error_to_bundler_error_cache() {
let deps_err = deps_core::DepsError::CacheError("cache failure".into());
let bundler_err: BundlerError = deps_err.into();
assert!(matches!(bundler_err, BundlerError::CacheError(_)));
}
#[test]
fn test_deps_error_to_bundler_error_invalid_version() {
let deps_err = deps_core::DepsError::InvalidVersionReq("bad version".into());
let bundler_err: BundlerError = deps_err.into();
assert!(matches!(
bundler_err,
BundlerError::InvalidVersionSpecifier { .. }
));
}
#[test]
fn test_deps_error_to_bundler_error_io() {
let io_err = std::io::Error::from(std::io::ErrorKind::PermissionDenied);
let deps_err = deps_core::DepsError::Io(io_err);
let bundler_err: BundlerError = deps_err.into();
assert!(matches!(bundler_err, BundlerError::Io(_)));
}
#[test]
fn test_deps_error_to_bundler_error_json() {
let json_err = serde_json::from_str::<serde_json::Value>("not json").unwrap_err();
let deps_err = deps_core::DepsError::Json(json_err);
let bundler_err: BundlerError = deps_err.into();
assert!(matches!(bundler_err, BundlerError::ApiResponseError { .. }));
}
#[test]
fn test_io_error_from_impl() {
let io_err = std::io::Error::from(std::io::ErrorKind::NotFound);
let bundler_err: BundlerError = io_err.into();
assert!(matches!(bundler_err, BundlerError::Io(_)));
}
#[test]
fn test_error_display_api_response_error() {
let json_err = serde_json::from_str::<serde_json::Value>("[invalid").unwrap_err();
let err = BundlerError::ApiResponseError {
package: "rails".into(),
source: json_err,
};
let display = err.to_string();
assert!(display.contains("rails"));
assert!(display.contains("rubygems API response"));
}
#[test]
fn test_error_display_registry_error() {
let io_err = std::io::Error::other("timeout");
let err = BundlerError::RegistryError {
package: "nokogiri".into(),
source: Box::new(io_err),
};
let display = err.to_string();
assert!(display.contains("nokogiri"));
assert!(display.contains("rubygems.org"));
}
#[test]
fn test_error_debug() {
let err = BundlerError::PackageNotFound {
package: "test".into(),
};
let debug = format!("{:?}", err);
assert!(debug.contains("PackageNotFound"));
assert!(debug.contains("test"));
}
}