libuptest 0.1.4

Core Substrate runtime upgrade Library for UpTest
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

use reqwest::header::USER_AGENT;
use serde::{Deserialize, Serialize};
use tokio::fs::File;
use tokio::io::AsyncWriteExt; // for write_all()
use crate::error::Error;

/// crates.io crates.crate.links field
#[derive(Deserialize, Serialize, Debug)]
pub struct Lankar {
    pub owner_team: String,
    pub owner_user: String,
    pub owners: String,
    pub reverse_dependencies: String,
    pub version_downloads: String,
    pub versions: String,
}

/// crates.io crates.crate json field
#[derive(Deserialize, Serialize, Debug)]
pub struct Crate {
    pub badges: Vec<String>,
    pub categories: Option<Vec<String>>,
    pub created_at: String,
    pub description: Option<String>,
    pub documentation: Option<String>,
    pub downloads: u32,
    pub exact_match: bool,
    pub homepage: Option<String>,
    pub id: String,
    pub keywords: Option<String>,
    pub links: Lankar,
    pub max_stable_version: String,
    pub max_version: String,
    pub name: String,
    #[serde(rename = "newest_version")]
    pub version: String,
    pub recent_downloads: u32,
    #[serde(rename = "repository")]
    pub repository_url: Option<String>,
    pub updated_at: Option<String>,
    pub versions: Option<String>,
}

/// crates.io meta key field
#[derive(Deserialize, Serialize, Debug)]
pub struct Metastruct {
    pub next_page: Option<String>,
    pub prev_page: Option<String>,
    pub total: u32,
}

/// Wrapper used by crates.io API.
/// crates.io search returns a json blob with crates and meta field
#[derive(Deserialize, Serialize, Debug)]
pub struct Crates {
    #[serde(rename = "crates")]
    pub crates: Vec<Crate>,
    pub meta: Metastruct,
}

/// download tarball/gzip of crate from crates.io, unstable version atm, does not handle errors properly
/// return file name if all is good
pub async fn download_crate_from_crates_io(
    crate_version: String,
    crate_name: String,
) -> Result<String, Error> {
    let file_name = format!("{crate_name:}-{crate_version:}.gzip");
    //https://crates.io/api/v1/crates/serde/1.0.0/download
    let url = format!(
        "https://crates.io/api/v1/crates/{}/{}/download",
        crate_name, crate_version
    );
    let client = reqwest::Client::new();
    println!("Downloading crate: {crate_name:?} version: {crate_version:?}");
    let tanka = client
        .get(url)
        .header(USER_AGENT, "Uptest cli client")
        .send()
        .await?;
    println!("crate downloaded ok");
    let mut filen = File::create(file_name.clone()).await?;
    filen
        .write_all(&tanka.bytes().await.unwrap())
        .await
        ?;
    println!("crate saved as {file_name:}");

    Ok(file_name)
}

/// search crates.io
pub async fn search_crates_io(query: &str) -> Result<Crates, reqwest::Error> {
    let client = reqwest::Client::new();
    let url = format!(
        "https://crates.io/api/v1/crates?page=1&per_page=100&q={}",
        query
    ); // https://crates.io/api/v1/crates?page=1&per_page=100&q=pallet-balan
    let resp = client
        .get(url)
        .header(USER_AGENT, "Uptest cli client")
        .send()
        .await?
        .json::<Crates>()
        .await;
    resp
}