use std::{
collections::btree_map::{self, BTreeMap},
env, fmt, fs, io,
path::{Path, PathBuf},
sync::Mutex,
time::SystemTime,
};
use once_cell::sync::Lazy;
use toml_edit::{Document, Item, Table, TomlError};
#[derive(Debug)]
pub enum Error {
NotFound(PathBuf),
CargoManifestDirNotSet,
CouldNotRead { path: PathBuf, source: io::Error },
InvalidToml { source: TomlError },
CrateNotFound { crate_name: String, path: PathBuf },
}
impl std::error::Error for Error {
fn source(&self) -> Option<&(dyn std::error::Error + 'static)> {
match self {
Error::CouldNotRead { source, .. } => Some(source),
Error::InvalidToml { source } => Some(source),
_ => None,
}
}
}
impl fmt::Display for Error {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
match self {
Error::NotFound(path) => write!(
f,
"Could not find `Cargo.toml` in manifest dir: `{}`.",
path.display()
),
Error::CargoManifestDirNotSet => {
f.write_str("`CARGO_MANIFEST_DIR` env variable not set.")
}
Error::CouldNotRead { path, .. } => write!(f, "Could not read `{}`.", path.display()),
Error::InvalidToml { .. } => f.write_str("Invalid toml file."),
Error::CrateNotFound { crate_name, path } => write!(
f,
"Could not find `{}` in `dependencies` or `dev-dependencies` in `{}`!",
crate_name,
path.display(),
),
}
}
}
#[derive(Debug, PartialEq, Clone, Eq)]
pub enum FoundCrate {
Itself,
Name(String),
}
type Cache = BTreeMap<String, CacheEntry>;
struct CacheEntry {
manifest_ts: SystemTime,
crate_names: CrateNames,
}
type CrateNames = BTreeMap<String, FoundCrate>;
pub fn crate_name(orig_name: &str) -> Result<FoundCrate, Error> {
let manifest_dir = env::var("CARGO_MANIFEST_DIR").map_err(|_| Error::CargoManifestDirNotSet)?;
let manifest_path = Path::new(&manifest_dir).join("Cargo.toml");
let manifest_ts = cargo_toml_timestamp(&manifest_path)?;
static CACHE: Lazy<Mutex<Cache>> = Lazy::new(Mutex::default);
let mut cache = CACHE.lock().unwrap();
let crate_names = match cache.entry(manifest_dir) {
btree_map::Entry::Occupied(entry) => {
let cache_entry = entry.into_mut();
if manifest_ts != cache_entry.manifest_ts {
*cache_entry = read_cargo_toml(&manifest_path, manifest_ts)?;
}
&cache_entry.crate_names
}
btree_map::Entry::Vacant(entry) => {
let cache_entry = entry.insert(read_cargo_toml(&manifest_path, manifest_ts)?);
&cache_entry.crate_names
}
};
Ok(crate_names
.get(orig_name)
.ok_or_else(|| Error::CrateNotFound {
crate_name: orig_name.to_owned(),
path: manifest_path,
})?
.clone())
}
fn cargo_toml_timestamp(manifest_path: &Path) -> Result<SystemTime, Error> {
fs::metadata(manifest_path)
.and_then(|meta| meta.modified())
.map_err(|source| {
if source.kind() == io::ErrorKind::NotFound {
Error::NotFound(manifest_path.to_owned())
} else {
Error::CouldNotRead {
path: manifest_path.to_owned(),
source,
}
}
})
}
fn read_cargo_toml(manifest_path: &Path, manifest_ts: SystemTime) -> Result<CacheEntry, Error> {
let manifest = open_cargo_toml(manifest_path)?;
let crate_names = extract_crate_names(&manifest)?;
Ok(CacheEntry {
manifest_ts,
crate_names,
})
}
fn sanitize_crate_name<S: AsRef<str>>(name: S) -> String {
name.as_ref().replace('-', "_")
}
fn open_cargo_toml(path: &Path) -> Result<Document, Error> {
let content = fs::read_to_string(path).map_err(|e| Error::CouldNotRead {
source: e,
path: path.into(),
})?;
content
.parse::<Document>()
.map_err(|e| Error::InvalidToml { source: e })
}
fn extract_crate_names(cargo_toml: &Document) -> Result<CrateNames, Error> {
let package_name = extract_package_name(cargo_toml);
let root_pkg = package_name.as_ref().map(|name| {
let cr = match env::var_os("CARGO_TARGET_TMPDIR") {
None => FoundCrate::Itself,
Some(_) => FoundCrate::Name(sanitize_crate_name(name)),
};
(name.to_string(), cr)
});
let dep_tables = dep_tables(cargo_toml).chain(target_dep_tables(cargo_toml));
let dep_pkgs = dep_tables.flatten().filter_map(move |(dep_name, dep_value)| {
let pkg_name = dep_value
.get("package")
.and_then(|i| i.as_str())
.unwrap_or(dep_name);
if package_name.as_ref().map_or(false, |n| *n == pkg_name) {
return None;
}
let cr = FoundCrate::Name(sanitize_crate_name(dep_name));
Some((pkg_name.to_owned(), cr))
});
Ok(root_pkg.into_iter().chain(dep_pkgs).collect())
}
fn extract_package_name(cargo_toml: &Document) -> Option<&str> {
cargo_toml.get("package")?.get("name")?.as_str()
}
fn target_dep_tables(cargo_toml: &Document) -> impl Iterator<Item = &Table> {
cargo_toml
.get("target")
.into_iter()
.filter_map(Item::as_table)
.flat_map(|t| {
t.iter()
.map(|(_, value)| value)
.filter_map(Item::as_table)
.flat_map(dep_tables)
})
}
fn dep_tables(table: &Table) -> impl Iterator<Item = &Table> {
table
.get("dependencies")
.into_iter()
.chain(table.get("dev-dependencies"))
.filter_map(Item::as_table)
}
#[cfg(test)]
mod tests {
use super::*;
macro_rules! create_test {
(
$name:ident,
$cargo_toml:expr,
$( $result:tt )*
) => {
#[test]
fn $name() {
let cargo_toml = $cargo_toml.parse::<Document>().expect("Parses `Cargo.toml`");
match extract_crate_names(&cargo_toml).map(|mut map| map.remove("my_crate")) {
$( $result )* => (),
o => panic!("Invalid result: {:?}", o),
}
}
};
}
create_test! {
deps_with_crate,
r#"
[dependencies]
my_crate = "0.1"
"#,
Ok(Some(FoundCrate::Name(name))) if name == "my_crate"
}
create_test! {
dev_deps_with_crate,
r#"
[dev-dependencies]
my_crate = "0.1"
"#,
Ok(Some(FoundCrate::Name(name))) if name == "my_crate"
}
create_test! {
deps_with_crate_renamed,
r#"
[dependencies]
cool = { package = "my_crate", version = "0.1" }
"#,
Ok(Some(FoundCrate::Name(name))) if name == "cool"
}
create_test! {
deps_with_crate_renamed_second,
r#"
[dependencies.cool]
package = "my_crate"
version = "0.1"
"#,
Ok(Some(FoundCrate::Name(name))) if name == "cool"
}
create_test! {
deps_empty,
r#"
[dependencies]
"#,
Ok(None)
}
create_test! {
crate_not_found,
r#"
[dependencies]
serde = "1.0"
"#,
Ok(None)
}
create_test! {
target_dependency,
r#"
[target.'cfg(target_os="android")'.dependencies]
my_crate = "0.1"
"#,
Ok(Some(FoundCrate::Name(name))) if name == "my_crate"
}
create_test! {
target_dependency2,
r#"
[target.x86_64-pc-windows-gnu.dependencies]
my_crate = "0.1"
"#,
Ok(Some(FoundCrate::Name(name))) if name == "my_crate"
}
create_test! {
own_crate,
r#"
[package]
name = "my_crate"
"#,
Ok(Some(FoundCrate::Itself))
}
create_test! {
own_crate_and_in_deps,
r#"
[package]
name = "my_crate"
[dev-dependencies]
my_crate = "0.1"
"#,
Ok(Some(FoundCrate::Itself))
}
create_test! {
multiple_times,
r#"
[dependencies]
my_crate = { version = "0.5" }
my-crate-old = { package = "my_crate", version = "0.1" }
"#,
Ok(Some(FoundCrate::Name(name))) if name == "my_crate_old"
}
}