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
|
use reqwest::ClientBuilder;
use serde::Deserialize;
use thiserror;
const USER_AGENT: &'static str = concat!(
env!("CARGO_PKG_NAME"),
"/",
env!("CARGO_PKG_VERSION"),
);
#[derive(Debug, thiserror::Error)]
pub enum Error {
#[error("request error")]
Http(#[from] reqwest::Error),
#[error("request header error")]
Header(#[from] reqwest::header::InvalidHeaderValue),
}
#[derive(Debug, Deserialize)]
pub struct Repo {
pub id: i64,
pub name: String,
pub description: Option<String>,
pub fork: bool,
pub git_url: String,
pub default_branch: String,
pub size: u64,
pub updated_at: String,
}
impl Repo {
/// Get the repository description or an empty string if `None`.
pub fn description(&self) -> &str {
self.description
.as_deref()
.unwrap_or("")
}
}
/// Fetch all GitHub repositories for the given user.
pub async fn fetch_repos(github_username: &str) -> Result<Vec<Repo>, Error> {
let mut headers = reqwest::header::HeaderMap::new();
headers.insert("Accept", "application/vnd.github.v3+json".parse()?);
let client = ClientBuilder::new()
.user_agent(USER_AGENT)
.default_headers(headers)
.build()?;
let mut repos = Vec::new();
for i in 1.. {
let repo_page = client.request(
reqwest::Method::GET,
format!(
"https://api.github.com/users/{}/repos?page={}&per_page=100&sort=updated",
github_username,
i,
),
)
.send()
.await?
.json::<Vec<Repo>>()
.await?;
if repo_page.is_empty() {
break;
}
repos.extend(repo_page);
}
Ok(repos)
}
|
