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
129
130
131
132
133
134
|
//! ref: composer/tests/Composer/Test/Downloader/XzDownloaderTest.php
use std::cell::RefCell;
use std::rc::Rc;
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 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)
}
fn set_up() -> TempDir {
if Platform::is_windows() {
// markTestSkipped('Skip test on Windows')
todo!()
}
if std::mem::size_of::<usize>() == 4 {
// markTestSkipped('Skip test on 32bit')
todo!()
}
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
}
#[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()));
}
|
