blob: 51b86731854125f70178f0c2134d7bb27a9fba23 (
plain)
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
|
//! ref: composer/src/Composer/Repository/RepositoryUtils.php
use crate::package::Link;
use crate::package::PackageInterface;
use crate::repository::CompositeRepository;
use crate::repository::FilterRepository;
use crate::repository::RepositoryInterface;
use indexmap::IndexMap;
use std::any::Any;
pub struct RepositoryUtils;
impl RepositoryUtils {
pub fn filter_required_packages(
packages: &[crate::package::BasePackageHandle],
requirer: &dyn PackageInterface,
include_require_dev: bool,
mut bucket: Vec<crate::package::BasePackageHandle>,
) -> Vec<crate::package::BasePackageHandle> {
let mut requires: IndexMap<String, Link> = requirer.get_requires();
if include_require_dev {
requires.extend(requirer.get_dev_requires());
}
for candidate in packages {
for name in candidate.get_names(true) {
if requires.contains_key(&name) {
let already_in_bucket = bucket.iter().any(|b| b.ptr_eq(candidate));
if !already_in_bucket {
bucket.push(candidate.clone());
// TODO(phase-b): recursion requires &dyn PackageInterface; cast pending.
let _ = (requires.contains_key("dummy"),);
}
break;
}
}
}
bucket
}
pub fn flatten_repositories(
repo: Box<dyn RepositoryInterface>,
unwrap_filter_repos: bool,
) -> Vec<Box<dyn RepositoryInterface>> {
let repo: Box<dyn RepositoryInterface> = if unwrap_filter_repos {
if let Some(filter_repo) = repo.as_any().downcast_ref::<FilterRepository>() {
filter_repo.get_repository().clone_box()
} else {
repo
}
} else {
repo
};
if let Some(composite_repo) = repo.as_any().downcast_ref::<CompositeRepository>() {
let mut repos = Vec::new();
for r in composite_repo.get_repositories() {
for r2 in Self::flatten_repositories(r.clone_box(), unwrap_filter_repos) {
repos.push(r2);
}
}
repos
} else {
vec![repo]
}
}
}
|
