From 59f8634207991d8ce4708da82017b985ee1c0778 Mon Sep 17 00:00:00 2001
From: Teddy Wing
Date: Sun, 30 May 2021 19:14:50 +0200
Subject: github::fetch_repos(): Fetch all repos from all pages

Also switch from `reqwest::blocking` to async because I was getting this
error, probably because I call `fetch_repos()` in the async 'tokio'
function `main()`:

    thread 'main' panicked at 'Cannot drop a runtime in a context where
    blocking is not allowed. This happens when a runtime is dropped from
    within an asynchronous context.',
    $HOME/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.6.1/src/runtime/blocking/shutdown.rs:51:21
---
 src/github.rs | 35 ++++++++++++++++++++++++-----------
 1 file changed, 24 insertions(+), 11 deletions(-)

(limited to 'src/github.rs')

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)
 }
-- 
cgit v1.2.3