diff options
| -rw-r--r-- | Cargo.toml | 2 | ||||
| -rw-r--r-- | src/github.rs | 35 | ||||
| -rw-r--r-- | src/main.rs | 6 |
3 files changed, 28 insertions, 15 deletions
@@ -6,7 +6,7 @@ edition = "2018" [dependencies] anyhow = "1.0.40" git2 = "0.13.20" -reqwest = { version = "0.11.3", features = ["blocking", "json"] } +reqwest = { version = "0.11.3", features = ["json"] } serde = { version = "1.0.126", features = ["derive"] } thiserror = "1.0.25" tokio = { version = "1.6.1", features = ["macros", "rt"] } diff --git a/src/github.rs b/src/github.rs index b937f9b..f5598ba 100644 --- a/src/github.rs +++ b/src/github.rs @@ -1,4 +1,4 @@ -use reqwest::blocking::ClientBuilder; +use reqwest::ClientBuilder; use serde::Deserialize; use thiserror; @@ -41,7 +41,7 @@ impl Repo { } -pub fn fetch_repos() -> Result<Vec<Repo>, Error> { +pub async fn fetch_repos() -> Result<Vec<Repo>, Error> { let mut headers = reqwest::header::HeaderMap::new(); headers.insert("Accept", "application/vnd.github.v3+json".parse()?); @@ -50,15 +50,28 @@ pub fn fetch_repos() -> Result<Vec<Repo>, Error> { .default_headers(headers) .build()?; - let repos = client.request( - reqwest::Method::GET, - format!( - "https://api.github.com/users/{}/repos", - "teddywing", - ), - ) - .send()? - .json::<Vec<Repo>>()?; + 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", + "teddywing", + i, + ), + ) + .send() + .await? + .json::<Vec<Repo>>() + .await?; + + if repo_page.is_empty() { + break; + } + + repos.extend(repo_page); + } Ok(repos) } diff --git a/src/main.rs b/src/main.rs index 13b2b07..77083cf 100644 --- a/src/main.rs +++ b/src/main.rs @@ -10,9 +10,9 @@ use std::path::{Path, PathBuf}; #[tokio::main] async fn main() { - // let repos = github::fetch_repos().unwrap(); - // - // dbg!(&repos); + let repos = github::fetch_repos().await.unwrap(); + + dbg!(&repos); // git::mirror( // "https://github.com/teddywing/google-calendar-rsvp.git", |