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
use storage::CachedBackend;
use super::{LalResult, Manifest, CliError};
pub fn update<T: CachedBackend + ?Sized>(
manifest: &Manifest,
backend: &T,
components: Vec<String>,
save: bool,
savedev: bool,
env: &str,
) -> LalResult<()> {
debug!("Update specific deps: {:?}", components);
let mut error = None;
let mut updated = Vec::with_capacity(components.len());
for comp in &components {
info!("Fetch {} {}", env, comp);
if comp.contains('=') {
let pair: Vec<&str> = comp.split('=').collect();
if let Ok(n) = pair[1].parse::<u32>() {
if pair[0].to_lowercase() != pair[0] {
return Err(CliError::InvalidComponentName(pair[0].into()));
}
match backend.unpack_published_component(pair[0], Some(n), env) {
Ok(c) => updated.push(c),
Err(e) => {
warn!("Failed to update {} ({})", pair[0], e);
error = Some(e);
}
}
} else {
let _ = backend.unpack_stashed_component(pair[0], pair[1]).map_err(|e| {
warn!("Failed to update {} from stash ({})", pair[0], e);
error = Some(e);
});
}
} else {
if &comp.to_lowercase() != comp {
return Err(CliError::InvalidComponentName(comp.clone()));
}
let ver = backend
.get_latest_supported_versions(comp, manifest.supportedEnvironments.clone())?
.into_iter()
.max()
.ok_or(CliError::NoIntersectedVersion(comp.clone()))?;
info!("Fetch {} {}={}", env, comp, ver);
match backend.unpack_published_component(comp, Some(ver), env) {
Ok(c) => updated.push(c),
Err(e) => {
warn!("Failed to update {} ({})", &comp, e);
error = Some(e);
}
}
}
}
if let Some(e) = error {
return Err(e);
}
if save || savedev {
let mut mf = manifest.clone();
let mut hmap = if save { mf.dependencies.clone() } else { mf.devDependencies.clone() };
for c in &updated {
debug!("Successfully updated {} at version {}", &c.name, c.version);
if hmap.contains_key(&c.name) {
let val = hmap.get_mut(&c.name).unwrap();
if c.version < *val {
warn!("Downgrading {} from {} to {}", c.name, *val, c.version);
} else if c.version > *val {
info!("Upgrading {} from {} to {}", c.name, *val, c.version);
} else {
info!("Maintaining {} at version {}", c.name, c.version);
}
*val = c.version;
} else {
hmap.insert(c.name.clone(), c.version);
}
}
if save {
mf.dependencies = hmap;
} else {
mf.devDependencies = hmap;
}
mf.write()?;
}
Ok(())
}
pub fn update_all<T: CachedBackend + ?Sized>(
manifest: &Manifest,
backend: &T,
save: bool,
dev: bool,
env: &str,
) -> LalResult<()> {
let deps: Vec<String> = if dev {
manifest.devDependencies.keys().cloned().collect()
} else {
manifest.dependencies.keys().cloned().collect()
};
update(manifest, backend, deps, save && !dev, save && dev, env)
}