From 6f5f95dc23d11109c0923ca10fbc6f3165472e63 Mon Sep 17 00:00:00 2001 From: Cyborus Date: Fri, 17 Nov 2023 13:31:36 -0500 Subject: [PATCH] add release functionality --- src/issue.rs | 5 ++ src/lib.rs | 10 ++++ src/repository.rs | 120 ++++++++++++++++++++++++++++++++++++++++++++++ 3 files changed, 135 insertions(+) diff --git a/src/issue.rs b/src/issue.rs index 98903bf..4d4b8d2 100644 --- a/src/issue.rs +++ b/src/issue.rs @@ -103,6 +103,11 @@ pub struct Attachment { pub uuid: String, } +#[derive(serde::Serialize, Debug, PartialEq, Default)] +pub struct EditAttachmentOption { + pub name: Option, +} + #[derive(serde::Serialize, serde::Deserialize, Debug, PartialEq, Clone, Copy)] pub enum State { Open, diff --git a/src/lib.rs b/src/lib.rs index de92123..39abdaa 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -95,6 +95,16 @@ impl Forgejo { self.execute(request).await } + async fn post_form( + &self, + path: &str, + body: &T, + ) -> Result { + let url = self.url.join("api/v1/").unwrap().join(path).unwrap(); + let request = self.client.post(url).form(body).build()?; + self.execute(request).await + } + async fn delete(&self, path: &str) -> Result<(), ForgejoError> { let url = self.url.join("api/v1/").unwrap().join(path).unwrap(); let request = self.client.delete(url).build()?; diff --git a/src/repository.rs b/src/repository.rs index f85080d..627c040 100644 --- a/src/repository.rs +++ b/src/repository.rs @@ -31,6 +31,58 @@ impl Forgejo { pub async fn cancel_merge(&self, owner: &str, repo: &str, pr: u64) -> Result<(), ForgejoError> { self.delete(&format!("repos/{owner}/{repo}/pulls/{pr}/merge")).await } + + pub async fn get_releases(&self, owner: &str, repo: &str, query: ReleaseQuery) -> Result, ForgejoError> { + self.get(&query.to_string(owner, repo)).await + } + + pub async fn get_release(&self, owner: &str, repo: &str, id: u64) -> Result, ForgejoError> { + self.get_opt(&format!("repos/{owner}/{repo}/releases/{id}")).await + } + + pub async fn get_release_by_tag(&self, owner: &str, repo: &str, tag: &str) -> Result, ForgejoError> { + self.get_opt(&format!("repos/{owner}/{repo}/releases/tags/{tag}")).await + } + + pub async fn delete_release(&self, owner: &str, repo: &str, id: u64) -> Result<(), ForgejoError> { + self.delete(&format!("repos/{owner}/{repo}/releases/{id}")).await + } + + pub async fn delete_release_by_tag(&self, owner: &str, repo: &str, tag: &str) -> Result<(), ForgejoError> { + self.delete(&format!("repos/{owner}/{repo}/releases/tags/{tag}")).await + } + + pub async fn edit_release(&self, owner: &str, repo: &str, id: u64, opts: EditReleaseOption) -> Result { + self.patch(&format!("repos/{owner}/{repo}/releases/{id}"), &opts).await + } + + pub async fn get_release_attachments(&self, owner: &str, repo: &str, id: u64) -> Result, ForgejoError> { + self.get(&format!("repos/{owner}/{repo}/releases/{id}/assets")).await + } + + pub async fn get_release_attachment(&self, owner: &str, repo: &str, release_id: u64, attachment_id: u64) -> Result { + self.get(&format!("repos/{owner}/{repo}/releases/{release_id}/assets/{attachment_id}")).await + } + + pub async fn create_release_attachment(&self, owner: &str, repo: &str, id: u64, name: &str, file: &[u8]) -> Result { + self.post_form(&format!("repos/{owner}/{repo}/releases/{id}/assets?name={name}"), &file).await + } + + pub async fn delete_release_attachment(&self, owner: &str, repo: &str, release_id: u64, attachment_id: u64) -> Result<(), ForgejoError> { + self.delete(&format!("repos/{owner}/{repo}/releases/{release_id}/assets/{attachment_id}")).await + } + + pub async fn edit_release_attachment(&self, owner: &str, repo: &str, release_id: u64, attachment_id: u64, opts: EditAttachmentOption) -> Result { + self.patch(&format!("repos/{owner}/{repo}/releases/{release_id}/assets/{attachment_id}"), &opts).await + } + + pub async fn create_release(&self, owner: &str, repo: &str, opts: CreateReleaseOption) -> Result { + self.post(&format!("repos/{owner}/{repo}/releases"), &opts).await + } + + pub async fn latest_release(&self, owner: &str, repo: &str) -> Result, ForgejoError> { + self.get_opt(&format!("repos/{owner}/{repo}/releases/latest")).await + } } #[derive(serde::Deserialize, Debug, PartialEq)] @@ -277,3 +329,71 @@ pub enum MergePrAction { ManuallyMerged, } +#[derive(serde::Deserialize, Debug, PartialEq)] +pub struct Release { + pub assets: Vec, + pub author: User, + pub body: String, + #[serde(with = "time::serde::rfc3339")] + pub created_at: time::OffsetDateTime, + pub draft: bool, + pub html_url: Url, + pub id: u64, + pub name: String, + pub prerelease: bool, + #[serde(with = "time::serde::rfc3339")] + pub published_at: time::OffsetDateTime, + pub tag_name: String, + pub tarball_url: Url, + pub target_commitish: String, + pub url: Url, + pub zipball_url: Url, +} + +#[derive(serde::Serialize, Debug, PartialEq, Default)] +pub struct CreateReleaseOption { + pub body: String, + pub draft: bool, + pub name: String, + pub prerelease: bool, + pub tag_name: String, + pub target_commitish: Option, +} + +#[derive(serde::Serialize, Debug, PartialEq, Default)] +pub struct EditReleaseOption { + pub body: Option, + pub draft: Option, + pub name: Option, + pub prerelease: Option, + pub tag_name: Option, + pub target_commitish: Option, +} + +#[derive(Default, Debug)] +pub struct ReleaseQuery { + pub draft: Option, + pub prerelease: Option, + pub page: Option, + pub limit: Option, +} + +impl ReleaseQuery { + fn to_string(&self, owner: &str, repo: &str) -> String { + format!("repos/{owner}/{repo}/releases?draft={}&pre-release={}&page={}&limit={}", + opt_bool_s(self.draft), + opt_bool_s(self.prerelease), + self.page.map(|page| page.to_string()).unwrap_or_default(), + self.limit.map(|page| page.to_string()).unwrap_or_default(), + ) + } +} + +fn opt_bool_s(b: Option) -> &'static str { + match b { + Some(true) => "true", + Some(false) => "false", + None => "", + } +} +