mirror of
https://github.com/denoland/deno.git
synced 2024-12-23 15:49:44 -05:00
279 lines
7.1 KiB
Rust
279 lines
7.1 KiB
Rust
// Copyright 2018-2022 the Deno authors. All rights reserved. MIT license.
|
|
|
|
use std::cell::RefCell;
|
|
use std::collections::HashMap;
|
|
use std::collections::HashSet;
|
|
use std::path::Path;
|
|
use std::path::PathBuf;
|
|
use std::sync::Arc;
|
|
|
|
use deno_ast::ModuleSpecifier;
|
|
use deno_core::anyhow::anyhow;
|
|
use deno_core::anyhow::bail;
|
|
use deno_core::error::AnyError;
|
|
use deno_core::futures;
|
|
use deno_core::serde_json;
|
|
use deno_graph::source::LoadFuture;
|
|
use deno_graph::source::LoadResponse;
|
|
use deno_graph::source::Loader;
|
|
use deno_graph::ModuleGraph;
|
|
use deno_graph::ModuleKind;
|
|
use import_map::ImportMap;
|
|
|
|
use crate::resolver::ImportMapResolver;
|
|
|
|
use super::build::VendorEnvironment;
|
|
|
|
// Utilities that help `deno vendor` get tested in memory.
|
|
|
|
type RemoteFileText = String;
|
|
type RemoteFileHeaders = Option<HashMap<String, String>>;
|
|
type RemoteFileResult = Result<(RemoteFileText, RemoteFileHeaders), String>;
|
|
|
|
#[derive(Clone, Default)]
|
|
pub struct TestLoader {
|
|
files: HashMap<ModuleSpecifier, RemoteFileResult>,
|
|
redirects: HashMap<ModuleSpecifier, ModuleSpecifier>,
|
|
}
|
|
|
|
impl TestLoader {
|
|
pub fn add(
|
|
&mut self,
|
|
path_or_specifier: impl AsRef<str>,
|
|
text: impl AsRef<str>,
|
|
) -> &mut Self {
|
|
if path_or_specifier
|
|
.as_ref()
|
|
.to_lowercase()
|
|
.starts_with("http")
|
|
{
|
|
self.files.insert(
|
|
ModuleSpecifier::parse(path_or_specifier.as_ref()).unwrap(),
|
|
Ok((text.as_ref().to_string(), None)),
|
|
);
|
|
} else {
|
|
let path = make_path(path_or_specifier.as_ref());
|
|
let specifier = ModuleSpecifier::from_file_path(path).unwrap();
|
|
self
|
|
.files
|
|
.insert(specifier, Ok((text.as_ref().to_string(), None)));
|
|
}
|
|
self
|
|
}
|
|
|
|
pub fn add_with_headers(
|
|
&mut self,
|
|
specifier: impl AsRef<str>,
|
|
text: impl AsRef<str>,
|
|
headers: &[(&str, &str)],
|
|
) -> &mut Self {
|
|
let headers = headers
|
|
.iter()
|
|
.map(|(key, value)| (key.to_string(), value.to_string()))
|
|
.collect();
|
|
self.files.insert(
|
|
ModuleSpecifier::parse(specifier.as_ref()).unwrap(),
|
|
Ok((text.as_ref().to_string(), Some(headers))),
|
|
);
|
|
self
|
|
}
|
|
|
|
pub fn add_redirect(
|
|
&mut self,
|
|
from: impl AsRef<str>,
|
|
to: impl AsRef<str>,
|
|
) -> &mut Self {
|
|
self.redirects.insert(
|
|
ModuleSpecifier::parse(from.as_ref()).unwrap(),
|
|
ModuleSpecifier::parse(to.as_ref()).unwrap(),
|
|
);
|
|
self
|
|
}
|
|
}
|
|
|
|
impl Loader for TestLoader {
|
|
fn load(
|
|
&mut self,
|
|
specifier: &ModuleSpecifier,
|
|
_is_dynamic: bool,
|
|
) -> LoadFuture {
|
|
let specifier = self.redirects.get(specifier).unwrap_or(specifier);
|
|
let result = self.files.get(specifier).map(|result| match result {
|
|
Ok(result) => Ok(LoadResponse::Module {
|
|
specifier: specifier.clone(),
|
|
content: result.0.clone().into(),
|
|
maybe_headers: result.1.clone(),
|
|
}),
|
|
Err(err) => Err(err),
|
|
});
|
|
let result = match result {
|
|
Some(Ok(result)) => Ok(Some(result)),
|
|
Some(Err(err)) => Err(anyhow!("{}", err)),
|
|
None if specifier.scheme() == "data" => {
|
|
deno_graph::source::load_data_url(specifier)
|
|
}
|
|
None => Ok(None),
|
|
};
|
|
Box::pin(futures::future::ready(result))
|
|
}
|
|
}
|
|
|
|
#[derive(Default)]
|
|
struct TestVendorEnvironment {
|
|
directories: RefCell<HashSet<PathBuf>>,
|
|
files: RefCell<HashMap<PathBuf, String>>,
|
|
}
|
|
|
|
impl VendorEnvironment for TestVendorEnvironment {
|
|
fn cwd(&self) -> Result<PathBuf, AnyError> {
|
|
Ok(make_path("/"))
|
|
}
|
|
|
|
fn create_dir_all(&self, dir_path: &Path) -> Result<(), AnyError> {
|
|
let mut directories = self.directories.borrow_mut();
|
|
for path in dir_path.ancestors() {
|
|
if !directories.insert(path.to_path_buf()) {
|
|
break;
|
|
}
|
|
}
|
|
Ok(())
|
|
}
|
|
|
|
fn write_file(&self, file_path: &Path, text: &str) -> Result<(), AnyError> {
|
|
let parent = file_path.parent().unwrap();
|
|
if !self.directories.borrow().contains(parent) {
|
|
bail!("Directory not found: {}", parent.display());
|
|
}
|
|
self
|
|
.files
|
|
.borrow_mut()
|
|
.insert(file_path.to_path_buf(), text.to_string());
|
|
Ok(())
|
|
}
|
|
|
|
fn path_exists(&self, path: &Path) -> bool {
|
|
self.files.borrow().contains_key(&path.to_path_buf())
|
|
}
|
|
}
|
|
|
|
pub struct VendorOutput {
|
|
pub files: Vec<(String, String)>,
|
|
pub import_map: Option<serde_json::Value>,
|
|
}
|
|
|
|
#[derive(Default)]
|
|
pub struct VendorTestBuilder {
|
|
entry_points: Vec<ModuleSpecifier>,
|
|
loader: TestLoader,
|
|
original_import_map: Option<ImportMap>,
|
|
environment: TestVendorEnvironment,
|
|
}
|
|
|
|
impl VendorTestBuilder {
|
|
pub fn with_default_setup() -> Self {
|
|
let mut builder = VendorTestBuilder::default();
|
|
builder.add_entry_point("/mod.ts");
|
|
builder
|
|
}
|
|
|
|
pub fn new_import_map(&self, base_path: &str) -> ImportMap {
|
|
let base = ModuleSpecifier::from_file_path(&make_path(base_path)).unwrap();
|
|
ImportMap::new(base)
|
|
}
|
|
|
|
pub fn set_original_import_map(
|
|
&mut self,
|
|
import_map: ImportMap,
|
|
) -> &mut Self {
|
|
self.original_import_map = Some(import_map);
|
|
self
|
|
}
|
|
|
|
pub fn add_entry_point(&mut self, entry_point: impl AsRef<str>) -> &mut Self {
|
|
let entry_point = make_path(entry_point.as_ref());
|
|
self
|
|
.entry_points
|
|
.push(ModuleSpecifier::from_file_path(entry_point).unwrap());
|
|
self
|
|
}
|
|
|
|
pub async fn build(&mut self) -> Result<VendorOutput, AnyError> {
|
|
let output_dir = make_path("/vendor");
|
|
let roots = self
|
|
.entry_points
|
|
.iter()
|
|
.map(|s| (s.to_owned(), deno_graph::ModuleKind::Esm))
|
|
.collect();
|
|
let loader = self.loader.clone();
|
|
let graph =
|
|
build_test_graph(roots, self.original_import_map.clone(), loader.clone())
|
|
.await;
|
|
super::build::build(
|
|
graph,
|
|
&output_dir,
|
|
self.original_import_map.as_ref(),
|
|
&self.environment,
|
|
)?;
|
|
|
|
let mut files = self.environment.files.borrow_mut();
|
|
let import_map = files.remove(&output_dir.join("import_map.json"));
|
|
let mut files = files
|
|
.iter()
|
|
.map(|(path, text)| (path_to_string(path), text.clone()))
|
|
.collect::<Vec<_>>();
|
|
|
|
files.sort_by(|a, b| a.0.cmp(&b.0));
|
|
|
|
Ok(VendorOutput {
|
|
import_map: import_map.map(|text| serde_json::from_str(&text).unwrap()),
|
|
files,
|
|
})
|
|
}
|
|
|
|
pub fn with_loader(&mut self, action: impl Fn(&mut TestLoader)) -> &mut Self {
|
|
action(&mut self.loader);
|
|
self
|
|
}
|
|
}
|
|
|
|
async fn build_test_graph(
|
|
roots: Vec<(ModuleSpecifier, ModuleKind)>,
|
|
original_import_map: Option<ImportMap>,
|
|
mut loader: TestLoader,
|
|
) -> ModuleGraph {
|
|
let resolver =
|
|
original_import_map.map(|m| ImportMapResolver::new(Arc::new(m)));
|
|
deno_graph::create_graph(
|
|
roots,
|
|
false,
|
|
None,
|
|
&mut loader,
|
|
resolver.as_ref().map(|im| im.as_resolver()),
|
|
None,
|
|
None,
|
|
None,
|
|
)
|
|
.await
|
|
}
|
|
|
|
fn make_path(text: &str) -> PathBuf {
|
|
// This should work all in memory. We're waiting on
|
|
// https://github.com/servo/rust-url/issues/730 to provide
|
|
// a cross platform path here
|
|
assert!(text.starts_with('/'));
|
|
if cfg!(windows) {
|
|
PathBuf::from(format!("C:{}", text.replace('/', "\\")))
|
|
} else {
|
|
PathBuf::from(text)
|
|
}
|
|
}
|
|
|
|
fn path_to_string(path: &Path) -> String {
|
|
// inverse of the function above
|
|
let path = path.to_string_lossy();
|
|
if cfg!(windows) {
|
|
path.replace("C:\\", "\\").replace('\\', "/")
|
|
} else {
|
|
path.to_string()
|
|
}
|
|
}
|