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
use tracing::instrument;
use url::Url;
use crate::error::Error;
use crate::error::Result;
use crate::version::Version;
#[instrument(level = "debug")]
async fn get_json(url: &Url) -> Result<serde_json::Value> {
let response = reqwest::get(url.as_str()).await?;
if !response.status().is_success() {
return Err(Error::HttpError(url.clone(), response.status()));
}
Ok(response.json::<serde_json::Value>().await?)
}
#[instrument(level = "debug")]
fn parse_versions(data: serde_json::Value) -> Result<Vec<Version>> {
data.as_object()
.ok_or_else(|| Error::JsonParsing("invalid type for top object".into()))?
.get("results")
.ok_or_else(|| Error::JsonParsing("could not find \"results\" member".into()))?
.as_array()
.ok_or_else(|| Error::JsonParsing("invalid type for \"results\" list".into()))?
.iter()
.map(|result| {
result
.as_object()
.ok_or_else(|| Error::JsonParsing("invalid type for \"result\" object".into()))?
.get("name")
.ok_or_else(|| {
Error::JsonParsing("\"name\" field not found in \"result\" object".into())
})
.map(|version_value| {
let version_str = version_value.as_str().ok_or_else(|| {
Error::JsonParsing(
"invalid type for \"name\" field in \"result\" object".into(),
)
})?;
Version::new(version_str)
.ok_or_else(|| Error::VersionParsing(version_str.into()))
})?
})
.collect::<Result<Vec<Version>>>()
}
#[instrument(level = "debug")]
pub async fn get_versions(url: &Url) -> Result<Vec<Version>> {
let data = get_json(url).await?;
let versions = parse_versions(data)?;
Ok(versions)
}
#[test]
fn test_docker_parse_versions() -> Result<()> {
let json_str = r#"{"results":[{"name": "latest"}, {"name": "0.2"}, {"name": "0.3"}, {"name": "0.4"}, {"name": "0.6"}, {"name": "0.7"}, {"name": "0.8.0"}, {"name": "0.9.0"}]}"#;
let json_value: serde_json::Value = serde_json::from_str(json_str)?;
let versions = parse_versions(json_value)?
.into_iter()
.map(|v| format!("{}", v))
.collect::<Vec<_>>();
assert_eq!(
versions,
["latest", "0.2", "0.3", "0.4", "0.6", "0.7", "0.8.0", "0.9.0"]
);
Ok(())
}