summaryrefslogtreecommitdiff
path: root/src/http/github.rs
diff options
context:
space:
mode:
authorseth <[email protected]>2024-05-27 04:55:45 -0400
committerseth <[email protected]>2024-05-27 04:56:48 -0400
commitc69eea2f4823da476628742fbbec600ee95ac049 (patch)
tree7cf3d87f5f202e6049ba44a06ac6fe9d3558826b /src/http/github.rs
initial commit
Diffstat (limited to 'src/http/github.rs')
-rw-r--r--src/http/github.rs68
1 files changed, 68 insertions, 0 deletions
diff --git a/src/http/github.rs b/src/http/github.rs
new file mode 100644
index 0000000..bdb363e
--- /dev/null
+++ b/src/http/github.rs
@@ -0,0 +1,68 @@
+use super::{Error, HttpClientExt};
+
+use serde::Deserialize;
+
+const GITHUB_API: &str = "https://api.github.com";
+
+/// Bad version of `/repos/{owner}/{repo}/{compare}/{ref}...{ref}`
+#[derive(Deserialize)]
+struct Compare {
+ status: String,
+ ahead_by: i32,
+}
+
+/// Bad version of `/repos/{owner}/{repo}/pulls/{pull_number}`
+#[derive(Deserialize)]
+struct PullRequest {
+ merge_commit_sha: String,
+}
+
+pub trait GithubClientExt {
+ /// Get the commit that merged [`pr`] in [`repo_owner`]/[`repo_name`]
+ async fn merge_commit_for(
+ &self,
+ repo_owner: &str,
+ repo_name: &str,
+ pr: u64,
+ ) -> Result<String, Error>;
+
+ /// Check if [`commit`] is in [`branch`] of [`repo_owner`]/[`repo_name`]
+ async fn is_commit_in_branch(
+ &self,
+ repo_owner: &str,
+ repo_name: &str,
+ branch_name: &str,
+ commit: &str,
+ ) -> Result<bool, Error>;
+}
+
+impl GithubClientExt for super::Client {
+ async fn merge_commit_for(
+ &self,
+ repo_owner: &str,
+ repo_name: &str,
+ pr: u64,
+ ) -> Result<String, Error> {
+ let url = format!("{GITHUB_API}/repos/{repo_owner}/{repo_name}/pulls/{pr}");
+ let resp: PullRequest = self.get_json(&url).await?;
+ let merge_commit = resp.merge_commit_sha;
+
+ Ok(merge_commit)
+ }
+
+ async fn is_commit_in_branch(
+ &self,
+ repo_owner: &str,
+ repo_name: &str,
+ branch: &str,
+ commit: &str,
+ ) -> Result<bool, Error> {
+ let url = format!(
+ "https://api.github.com/repos/{repo_owner}/{repo_name}/compare/{branch}...{commit}"
+ );
+ let resp: Compare = self.get_json(&url).await?;
+ let in_branch = resp.status != "diverged" && resp.ahead_by >= 0;
+
+ Ok(in_branch)
+ }
+}