1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
//! ref: composer/tests/Composer/Test/Downloader/XzDownloaderTest.php
use indexmap::IndexMap;
use shirabe::config::Config;
use shirabe::downloader::DownloaderInterface;
use shirabe::downloader::xz_downloader::XzDownloader;
use shirabe::io::IOInterface;
use shirabe::io::null_io::NullIO;
use shirabe::package::handle::{CompletePackageHandle, PackageInterfaceHandle};
use shirabe::util::HttpDownloader;
use shirabe::util::Platform;
use shirabe::util::ProcessExecutor;
use shirabe::util::filesystem::Filesystem;
use shirabe::util::r#loop::Loop;
use shirabe_php_shim::PhpMixed;
use shirabe_semver::VersionParser;
use std::cell::RefCell;
use std::rc::Rc;
use tempfile::TempDir;
/// ref: TestCase::getPackage (default class CompletePackage)
fn get_package(name: &str, version: &str) -> PackageInterfaceHandle {
let norm_version = VersionParser.normalize(version, None).unwrap();
CompletePackageHandle::new(name.to_string(), norm_version, version.to_string()).into()
}
fn run<F: std::future::Future>(future: F) -> F::Output {
tokio::runtime::Builder::new_current_thread()
.build()
.unwrap()
.block_on(future)
}
/// ref: setUp markTestSkipped on Windows / 32bit, expressed as a compile-time
/// cfg gate on the test function below.
fn set_up() -> TempDir {
TempDir::new().unwrap()
}
fn tear_down(test_dir: &std::path::Path) {
if Platform::is_windows() {
return;
}
let mut fs = Filesystem::new(None);
fs.remove_directory(test_dir).unwrap();
}
struct TearDown {
test_dir: std::path::PathBuf,
}
impl TearDown {
fn new(test_dir: std::path::PathBuf) -> Self {
TearDown { test_dir }
}
}
impl Drop for TearDown {
fn drop(&mut self) {
tear_down(&self.test_dir);
}
}
/// ref: TestCase::getConfig
fn get_config(config_options: IndexMap<String, PhpMixed>, use_environment: bool) -> Config {
let mut config = Config::new(use_environment, None);
let mut merged: IndexMap<String, PhpMixed> = IndexMap::new();
merged.insert("config".to_string(), PhpMixed::Array(config_options));
config.merge(&merged, "test");
config
}
#[cfg(all(not(windows), target_pointer_width = "64"))]
#[ignore]
#[test]
fn test_error_messages() {
let test_dir = set_up();
let _tear_down = TearDown::new(test_dir.path().to_path_buf());
let test_dir = test_dir.path().to_path_buf();
let package = get_package("dummy/pkg", "1.0.0");
let dist_url = format!("file://{}", file!());
package.set_dist_url(Some(dist_url));
let io: Rc<RefCell<dyn IOInterface>> = Rc::new(RefCell::new(NullIO::new()));
let mut config_options: IndexMap<String, PhpMixed> = IndexMap::new();
config_options.insert(
"vendor-dir".to_string(),
PhpMixed::String(test_dir.to_string_lossy().into_owned()),
);
let config = Rc::new(RefCell::new(get_config(config_options, false)));
let http_downloader = Rc::new(RefCell::new(HttpDownloader::new(
io.clone(),
config.clone(),
IndexMap::new(),
false,
)));
let filesystem = Rc::new(RefCell::new(Filesystem::new(None)));
let process = Rc::new(RefCell::new(ProcessExecutor::new(Some(io.clone()))));
let mut downloader = XzDownloader::new(
io,
config,
http_downloader.clone(),
None,
None,
filesystem,
process,
);
let install_path = test_dir.join("install-path");
let install_path = install_path.to_string_lossy().into_owned();
let mut loop_ = Loop::new(http_downloader, None);
let promise = Box::pin(async {
downloader
.download3(package.clone(), &install_path, None)
.await
.map(|_| ())
});
run(loop_.wait(vec![promise], None)).unwrap();
let result = run(downloader.install2(package, &install_path));
// Download of invalid tarball should throw an exception.
let e = result.expect_err("Download of invalid tarball should throw an exception");
let re =
regex::Regex::new("(?i)(File format not recognized|Unrecognized archive format)").unwrap();
assert!(re.is_match(&e.to_string()));
}
|
