Create testsuite for GithubClient

README.md

@@ -115,6 +115,21 @@ You need to sign up for a free account, and also deal with configuring the GitHu
       * Secret: Enter a shared secret (some longish random text)
       * Events: "Send me everything"
 
+## Tests
+
+When possible, writing unittests is very helpful and one of the easiest ways to test.
+For more advanced testing, there is an integration test called `testsuite` which provides a testing environment for testing triagebot.
+At this time, there is one part to it:
+
+* [`github_client`](tests/github_client/mod.rs) — Tests specifically targeting `GithubClient`.
+  This sets up an HTTP server that mimics api.github.com and verifies the client's behavior.
+
+Other parts may be added in the future, such as testing the database or the triagebot server itself.
+
+The real GitHub API responses are recorded in JSON files that the tests can later replay to verify the behavior of triagebot.
+These recordings are enabled with the `TRIAGEBOT_TEST_RECORD_DIR` environment variable.
+See the documentation in `github_client` for the steps for setting up recording to write a test.
+
 ## License
 
 Triagebot is distributed under the terms of both the MIT license and the

src/github.rs

@@ -1,3 +1,4 @@
+use crate::test_record;
 use anyhow::{anyhow, Context};
 use async_trait::async_trait;
 use bytes::Bytes;
@@ -30,15 +31,18 @@ impl GithubClient {
             .build()
             .with_context(|| format!("building reqwest {}", req_dbg))?;
 
+        let test_capture_info = test_record::capture_request(&req);
         let mut resp = self.client.execute(req.try_clone().unwrap()).await?;
         if let Some(sleep) = Self::needs_retry(&resp).await {
             resp = self.retry(req, sleep, MAX_ATTEMPTS).await?;
         }
+        let status = resp.status();
         let maybe_err = resp.error_for_status_ref().err();
         let body = resp
             .bytes()
             .await
             .with_context(|| format!("failed to read response body {req_dbg}"))?;
+        test_record::record_request(test_capture_info, status, &body);
         if let Some(e) = maybe_err {
             return Err(anyhow::Error::new(e))
                 .with_context(|| format!("response: {}", String::from_utf8_lossy(&body)));
@@ -248,7 +252,7 @@ pub struct Issue {
     pub number: u64,
     #[serde(deserialize_with = "opt_string")]
     pub body: String,
-    created_at: chrono::DateTime<Utc>,
+    pub created_at: chrono::DateTime<Utc>,
     pub updated_at: chrono::DateTime<Utc>,
     /// The SHA for a merge commit.
     ///
@@ -264,6 +268,7 @@ pub struct Issue {
     pub html_url: String,
     pub user: User,
     pub labels: Vec<Label>,
+    pub milestone: Option<Milestone>,
     pub assignees: Vec<User>,
     /// Indicator if this is a pull request.
     ///
@@ -330,6 +335,7 @@ impl ZulipGitHubReference {
 
 #[derive(Debug, serde::Deserialize)]
 pub struct Comment {
+    pub id: i64,
     #[serde(deserialize_with = "opt_string")]
     pub body: String,
     pub html_url: String,
@@ -476,12 +482,22 @@ impl Issue {
         self.state == IssueState::Open
     }
 
-    pub async fn get_comment(&self, client: &GithubClient, id: usize) -> anyhow::Result<Comment> {
+    pub async fn get_comment(&self, client: &GithubClient, id: u64) -> anyhow::Result<Comment> {
         let comment_url = format!("{}/issues/comments/{}", self.repository().url(client), id);
         let comment = client.json(client.get(&comment_url)).await?;
         Ok(comment)
     }
 
+    pub async fn get_comments(&self, client: &GithubClient) -> anyhow::Result<Vec<Comment>> {
+        let comment_url = format!(
+            "{}/issues/{}/comments",
+            self.repository().url(client),
+            self.number
+        );
+        let comments = client.json(client.get(&comment_url)).await?;
+        Ok(comments)
+    }
+
     pub async fn edit_body(&self, client: &GithubClient, body: &str) -> anyhow::Result<()> {
         let edit_url = format!("{}/issues/{}", self.repository().url(client), self.number);
         #[derive(serde::Serialize)]
@@ -855,8 +871,8 @@ struct MilestoneCreateBody<'a> {
 
 #[derive(Debug, serde::Deserialize)]
 pub struct Milestone {
-    number: u64,
-    title: String,
+    pub number: u64,
+    pub title: String,
 }
 
 #[derive(Debug, serde::Deserialize)]
@@ -1066,6 +1082,15 @@ impl Repository {
             || filters.iter().any(|&(key, _)| key == "no")
             || is_pr && !include_labels.is_empty();
 
+        let set_is_pr = |issues: &mut [Issue]| {
+            if !is_pr {
+                return;
+            }
+            for issue in issues {
+                issue.pull_request = Some(PullRequestDetails {});
+            }
+        };
+
         // If there are more than `per_page` of issues, we need to paginate
         let mut issues = vec![];
         loop {
@@ -1085,10 +1110,11 @@ impl Repository {
 
             let result = client.get(&url);
             if use_search_api {
-                let result = client
+                let mut result = client
                     .json::<IssueSearchResult>(result)
                     .await
                     .with_context(|| format!("failed to list issues from {}", url))?;
+                set_is_pr(&mut result.items);
                 issues.extend(result.items);
                 if issues.len() < result.total_count {
                     ordering.page += 1;
@@ -1099,7 +1125,8 @@ impl Repository {
                 issues = client
                     .json(result)
                     .await
-                    .with_context(|| format!("failed to list issues from {}", url))?
+                    .with_context(|| format!("failed to list issues from {}", url))?;
+                set_is_pr(&mut issues);
             }
 
             break;
@@ -1562,6 +1589,16 @@ impl Repository {
             })?;
         Ok(())
     }
+
+    pub async fn get_pr(&self, client: &GithubClient, number: u64) -> anyhow::Result<Issue> {
+        let url = format!("{}/pulls/{number}", self.url(client));
+        let mut pr: Issue = client
+            .json(client.get(&url))
+            .await
+            .with_context(|| format!("{} failed to get pr {number}", self.full_name))?;
+        pr.pull_request = Some(PullRequestDetails {});
+        Ok(pr)
+    }
 }
 
 pub struct Query<'a> {
@@ -1863,12 +1900,14 @@ impl GithubClient {
         let req = req
             .build()
             .with_context(|| format!("failed to build request {:?}", req_dbg))?;
+        let test_capture_info = test_record::capture_request(&req);
         let resp = self.client.execute(req).await.context(req_dbg.clone())?;
         let status = resp.status();
         let body = resp
             .bytes()
             .await
             .with_context(|| format!("failed to read response body {req_dbg}"))?;
+        test_record::record_request(test_capture_info, status, &body);
         match status {
             StatusCode::OK => Ok(Some(body)),
             StatusCode::NOT_FOUND => Ok(None),
@@ -2021,6 +2060,7 @@ pub struct GitTreeEntry {
     pub sha: String,
 }
 
+#[derive(Debug)]
 pub struct RecentCommit {
     pub title: String,
     pub pr_num: Option<i32>,

src/lib.rs

@@ -26,6 +26,7 @@ pub mod payload;
 pub mod rfcbot;
 pub mod team;
 mod team_data;
+pub mod test_record;
 pub mod triage;
 pub mod zulip;