use std::{
collections::btree_map::{self, BTreeMap},
env,
fs::{self, File},
io::{self, Read},
path::{Path, PathBuf},
sync::Mutex,
time::SystemTime,
};
use once_cell::sync::Lazy;
use toml::{self, value::Table};
#[derive(Debug, thiserror::Error)]
pub enum Error {
#[error("Could not find `Cargo.toml` in manifest dir: `{0}`.")]
NotFound(PathBuf),
#[error("`CARGO_MANIFEST_DIR` env variable not set.")]
CargoManifestDirNotSet,
#[error("Could not read `{path}`.")]
CouldNotRead { path: PathBuf, source: io::Error },
#[error("Invalid toml file.")]
InvalidToml { source: toml::de::Error },
#[error("Could not find `{crate_name}` in `dependencies` or `dev-dependencies` in `{path}`!")]
CrateNotFound { crate_name: String, path: PathBuf },
}
#[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<Table, Error> {
let mut content = String::new();
File::open(path)
.map_err(|e| Error::CouldNotRead {
source: e,
path: path.into(),
})?
.read_to_string(&mut content)
.map_err(|e| Error::CouldNotRead {
source: e,
path: path.into(),
})?;
toml::from_str(&content).map_err(|e| Error::InvalidToml { source: e })
}
fn extract_crate_names(cargo_toml: &Table) -> Result<CrateNames, Error> {
let package_name = extract_package_name(cargo_toml);
let root_pkg = package_name.map(|name| {
let cr = match env::var_os("CARGO_TARGET_TMPDIR") {
None => FoundCrate::Itself,
Some(_) => FoundCrate::Name(sanitize_crate_name(name)),
};
(name.to_owned(), cr)
});
let dep_tables = dep_tables(cargo_toml).chain(target_dep_tables(cargo_toml));
let dep_pkgs = dep_tables.flatten().map(|(dep_name, dep_value)| {
let pkg_name = dep_value
.as_table()
.and_then(|t| t.get("package")?.as_str())
.unwrap_or(dep_name);
let cr = FoundCrate::Name(sanitize_crate_name(dep_name));
(pkg_name.to_owned(), cr)
});
Ok(root_pkg.into_iter().chain(dep_pkgs).collect())
}
fn extract_package_name(cargo_toml: &Table) -> Option<&str> {
cargo_toml.get("package")?.as_table()?.get("name")?.as_str()
}
fn target_dep_tables(cargo_toml: &Table) -> impl Iterator<Item = &Table> {
cargo_toml
.get("target")
.into_iter()
.filter_map(toml::Value::as_table)
.flat_map(|t| {
t.values()
.filter_map(toml::Value::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(toml::Value::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 = toml::from_str($cargo_toml).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))
}
}