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
|
use serde_derive::*;
pub use simple_cache::Error;
use simple_cache::TempCache;
use std::path::Path;
pub struct DocsRsClient {
cache: TempCache<Option<Vec<BuildStatus>>>,
}
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct BuildStatus {
build_status: bool, //true,
build_time: String, //"2018-03-26T08:57:46+02:00",
rustc_version: String,
}
impl DocsRsClient {
pub fn new(cache_path: impl AsRef<Path>) -> Result<Self, Error> {
Ok(Self {
cache: TempCache::new(cache_path.as_ref())?,
})
}
pub async fn builds(&self, crate_name: &str, version: &str) -> Result<bool, Error> {
let res = self.build_status(crate_name, version).await?;
Ok(res.and_then(|s| s.get(0).map(|st| st.build_status)).unwrap_or(false))
}
pub async fn build_status(&self, crate_name: &str, version: &str) -> Result<Option<Vec<BuildStatus>>, Error> {
let key = format!("{}-{}", crate_name, version);
if let Some(cached) = self.cache.get(&key)? {
return Ok(cached);
}
let url = format!("https://docs.rs/crate/{}/{}/builds.json", crate_name, version);
Ok(self.cache.get_json(&key, url, |t| t).await?.and_then(|f| f))
}
}
#[tokio::test]
async fn test_docsrsclient() {
let client = DocsRsClient::new("../data/docsrs.db").expect("new");
assert!(client.builds("libc", "0.2.40").await.expect("libc"));
client.build_status("libc", "0.2.40").await.expect("libc");
}
|
