Compare commits
17 Commits
06795df3f7
...
v2.2.0
| Author | SHA1 | Date | |
|---|---|---|---|
| 119831481e | |||
| 7246c7afb6 | |||
| 84eaaa1dbd | |||
| c9dda5760c | |||
| 336f1453b9 | |||
| f068e8233e | |||
| d4ef21e243 | |||
| d94c350cde | |||
| 8120cb0489 | |||
| b82cfdb822 | |||
| ea046c929f | |||
| 135acf09b7 | |||
| 136c051c82 | |||
| a0ba8e7ea8 | |||
| 88cafc096f | |||
| b200785e71 | |||
| 8246337ae4 |
@@ -1,10 +1,12 @@
|
||||
[package]
|
||||
name = "gt-tool"
|
||||
version = "1.0.0"
|
||||
version = "2.2.0"
|
||||
edition = "2024"
|
||||
|
||||
[dependencies]
|
||||
clap = { version = "4.0.7", features = ["derive", "env"] }
|
||||
colored = "2.0.0"
|
||||
itertools = "0.10.0"
|
||||
reqwest = { version = "0.11.13", features = ["json", "stream", "multipart"] }
|
||||
serde = { version = "1.0.152", features = ["derive"] }
|
||||
tokio = { version = "1.24.2", features = ["macros", "rt-multi-thread"] }
|
||||
|
||||
11
README.md
11
README.md
@@ -51,14 +51,3 @@ One of these, defaults to `help`:
|
||||
| upload-release | Uploads one-or-more files to an existing release, identified by it's tag name. |
|
||||
| help | prints the help text (the usage summary above). |
|
||||
|
||||
## Unit Testing
|
||||
|
||||
The unit test~~s~~ require a Gitea server to execute against. This information is supplied by environment variables rather than on the command line, but it is otherwise exactly the same usage.
|
||||
|
||||
| Variable | Description |
|
||||
|-|-|
|
||||
| TEST_GITEA_SERVER | Server URL, match `-u`, `--url` |
|
||||
| TEST_GITEA_REPO | Owner + repo name, match `-u` `--repo` |
|
||||
| TEST_GITEA_KEY | API key, match `RELEASE_KEY_GITEA`. The use of a new variable for the API token is to help avoid accidentally touching a production environment during test execution. |
|
||||
| TEST_GITEA_RELEASE_TAG | Git tag used to identify the Release. Same as `upload-release`'s positional argument `<TAG_NAME>`. |
|
||||
|
||||
|
||||
@@ -1,12 +1,9 @@
|
||||
|
||||
use crate::{
|
||||
ApiError, Result,
|
||||
structs::{
|
||||
release::{CreateReleaseOption, Release},
|
||||
},
|
||||
Result,
|
||||
structs::release::{CreateReleaseOption, Release},
|
||||
};
|
||||
|
||||
pub fn get_release(id: u64) -> Result<Release> {
|
||||
pub fn get_release(_id: u64) -> Result<Release> {
|
||||
todo!();
|
||||
}
|
||||
pub fn get_latest_release() -> Result<Release> {
|
||||
@@ -20,7 +17,7 @@ pub async fn list_releases(
|
||||
) -> Result<Vec<Release>> {
|
||||
let request_url = format!("{gitea_url}/api/v1/repos/{repo}/releases/");
|
||||
let req = client.get(request_url).send().await;
|
||||
let response = req.map_err(|reqwest_err| crate::Error::WrappedReqwestErr(reqwest_err))?;
|
||||
let response = req.map_err(crate::Error::WrappedReqwestErr)?;
|
||||
if response.status().is_success() {
|
||||
let release_list = response
|
||||
.json::<Vec<Release>>()
|
||||
@@ -50,22 +47,22 @@ pub async fn create_release(
|
||||
.json(&submission)
|
||||
.send()
|
||||
.await
|
||||
.map_err(|e| crate::Error::from(e))?;
|
||||
.map_err(crate::Error::from)?;
|
||||
if response.status().is_success() {
|
||||
let new_release = response
|
||||
.json::<Release>()
|
||||
.await
|
||||
.map_err(|e| crate::Error::from(e))?;
|
||||
.map_err(crate::Error::from)?;
|
||||
return Ok(new_release);
|
||||
} else if response.status().is_client_error() {
|
||||
let mesg = crate::decode_client_error(response).await?;
|
||||
return Err(crate::Error::ApiErrorMessage(mesg))
|
||||
return Err(crate::Error::ApiErrorMessage(mesg));
|
||||
}
|
||||
panic!("Reached end of create_release without matching a return path");
|
||||
}
|
||||
pub fn edit_release(id: u64) -> Result<Release> {
|
||||
pub fn edit_release(_id: u64) -> Result<Release> {
|
||||
todo!();
|
||||
}
|
||||
pub fn delete_release(id: u64) -> Result<()> {
|
||||
pub fn delete_release(_id: u64) -> Result<()> {
|
||||
todo!();
|
||||
}
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
use std::fs;
|
||||
use std::{fs, path};
|
||||
|
||||
use crate::structs::Attachment;
|
||||
|
||||
@@ -16,13 +16,16 @@ pub async fn create_release_attachment(
|
||||
) -> crate::Result<Attachment> {
|
||||
let request_url = format!("{gitea_url}/api/v1/repos/{repo}/releases/{release_id}/assets");
|
||||
|
||||
match fs::exists(&file) {
|
||||
let path = path::Path::new(&file);
|
||||
match path.try_exists() {
|
||||
Ok(true) => (),
|
||||
Ok(false) => return Err(crate::Error::NoSuchFile),
|
||||
Err(e) => {
|
||||
eprintln!("Uh oh! The file-exists check couldn't be done: {e}");
|
||||
panic!("TODO: Deal with scenario where the file's existence cannot be checked (e.g.: no permission)");
|
||||
},
|
||||
panic!(
|
||||
"TODO: Deal with scenario where the file's existence cannot be checked (e.g.: no permission)"
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
println!("Uploading file {}", &file);
|
||||
@@ -43,7 +46,7 @@ pub async fn create_release_attachment(
|
||||
let attachment_desc = response
|
||||
.json::<Attachment>()
|
||||
.await
|
||||
.map_err(|e| crate::Error::from(e))?;
|
||||
.map_err(crate::Error::from)?;
|
||||
return Ok(attachment_desc);
|
||||
} else if response.status().is_client_error() {
|
||||
let mesg = crate::decode_client_error(response).await?;
|
||||
@@ -53,140 +56,3 @@ pub async fn create_release_attachment(
|
||||
}
|
||||
pub fn edit_release_attachment() {}
|
||||
pub fn delete_release_attachment() {}
|
||||
|
||||
#[cfg(test)]
|
||||
mod tests {
|
||||
use reqwest::header::{self, ACCEPT};
|
||||
|
||||
use crate::structs::release::Release;
|
||||
|
||||
|
||||
#[tokio::test]
|
||||
async fn attach_file_exists() {
|
||||
let conf = TestConfig::new();
|
||||
let release_candidates =
|
||||
crate::api::release::list_releases(
|
||||
&conf.client,
|
||||
&conf.server,
|
||||
&conf.repo
|
||||
)
|
||||
.await
|
||||
.expect("Failed to get releases. Pre-conditions unmet, aborting test!");
|
||||
|
||||
let release = match_release_by_tag(&conf.release_tag, release_candidates)
|
||||
.expect("Failed to select matching release. Pre-conditions unmet, aborting test!");
|
||||
|
||||
let api_result = super::create_release_attachment(
|
||||
&conf.client,
|
||||
&conf.server,
|
||||
&conf.repo,
|
||||
release.id,
|
||||
vec![String::from("Cargo.toml")],
|
||||
)
|
||||
.await;
|
||||
}
|
||||
|
||||
#[tokio::test]
|
||||
async fn attach_file_missing() {
|
||||
let conf = TestConfig::new();
|
||||
let release_candidates =
|
||||
crate::api::release::list_releases(
|
||||
&conf.client,
|
||||
&conf.server,
|
||||
&conf.repo
|
||||
)
|
||||
.await
|
||||
.expect("Failed to get releases. Pre-conditions unmet, aborting test!");
|
||||
|
||||
let release = match_release_by_tag(&conf.release_tag, release_candidates)
|
||||
.expect("Failed to select matching release. Pre-conditions unmet, aborting test!");
|
||||
|
||||
let api_result = super::create_release_attachment(
|
||||
&conf.client,
|
||||
&conf.server,
|
||||
&conf.repo,
|
||||
release.id,
|
||||
vec![String::from("./this-file-doesnt-exist")],
|
||||
)
|
||||
.await;
|
||||
let api_err = api_result.expect_err("Received Ok(()) after uploading non-existent file. That's nonsense, the API Function is wrong.");
|
||||
match api_err {
|
||||
crate::Error::Placeholder=>panic!("Received dummy response from the API function. Finish implementing it, stupid"),
|
||||
crate::Error::WrappedReqwestErr(error)=>panic!("Received a reqwest::Error from the API function: {error}"),
|
||||
crate::Error::MissingAuthToken=>unreachable!("Missing auth token... in a unit test that already panics without the auth token..."),
|
||||
crate::Error::NoSuchFile=>(),
|
||||
crate::Error::ApiErrorMessage(api_error)=>panic!("Received an error message from the API: {api_error:?}"),
|
||||
crate::Error::NoSuchRelease => todo!(),
|
||||
}
|
||||
}
|
||||
|
||||
struct TestConfig {
|
||||
server: String,
|
||||
repo: String,
|
||||
release_tag: String,
|
||||
client: reqwest::Client,
|
||||
}
|
||||
|
||||
impl TestConfig {
|
||||
fn new() -> Self {
|
||||
let server = std::env::var("TEST_GITEA_SERVER")
|
||||
.expect("Must set server address in env var \"TEST_GITEA_SERVER\"");
|
||||
let repo = std::env::var("TEST_GITEA_REPO")
|
||||
.expect("Must set <user>/<repo> name in env var \"TEST_GITEA_REPO\"");
|
||||
let token = format!(
|
||||
"token {}",
|
||||
std::env::var("TEST_GITEA_KEY")
|
||||
.expect("Must set the API token in env var \"TEST_GITEA_KEY\"")
|
||||
);
|
||||
let release_tag = std::env::var("TEST_GITEA_RELEASE_TAG")
|
||||
.expect("Must set the target release tag in env var \"TEST_GITEA_RELEASE_TAG\"");
|
||||
|
||||
let mut headers = reqwest::header::HeaderMap::new();
|
||||
headers.append(ACCEPT, header::HeaderValue::from_static("application/json"));
|
||||
headers.append("Authorization", token.parse().unwrap());
|
||||
|
||||
let client = reqwest::Client::builder()
|
||||
.user_agent(format!(
|
||||
"gt-tools-autotest-agent{}",
|
||||
env!("CARGO_PKG_VERSION")
|
||||
))
|
||||
.default_headers(headers)
|
||||
.build()
|
||||
.expect("Failed to build reqwest::Client.");
|
||||
|
||||
return Self {
|
||||
server,
|
||||
repo,
|
||||
release_tag,
|
||||
client
|
||||
};
|
||||
}
|
||||
}
|
||||
|
||||
// Testing utils
|
||||
fn match_release_by_tag(tag: &String, releases: Vec<Release>) -> Option<Release> {
|
||||
let mut release: Option<Release> = None;
|
||||
for rel in releases {
|
||||
if rel.tag_name == *tag {
|
||||
// Only store the value if one hasn't been stored already
|
||||
if let Some(first_release) = &release {
|
||||
// if there was already a match, begin the error diagnostic creation.
|
||||
let first_id = first_release.id;
|
||||
let second_id = rel.id;
|
||||
assert!(
|
||||
first_id != second_id,
|
||||
"FAILURE: Found the same release ID twice while scanning for duplicate tags. How did we get the same one twice?"
|
||||
);
|
||||
eprintln!("ERROR: Two releases have been found for the tag \"{tag}\".");
|
||||
eprintln!("ERROR: first ID: {first_id}");
|
||||
eprintln!("ERROR: second ID: {second_id}");
|
||||
panic!("ERROR: Nonsense detected, I'm bailing out!");
|
||||
} else {
|
||||
// else, store our first (and hopefully only) match
|
||||
release = Some(rel);
|
||||
}
|
||||
}
|
||||
}
|
||||
return release;
|
||||
}
|
||||
}
|
||||
@@ -10,13 +10,11 @@ pub struct ApiError {
|
||||
url: String,
|
||||
}
|
||||
|
||||
pub (crate) async fn decode_client_error(response: reqwest::Response) -> Result<ApiError> {
|
||||
pub(crate) async fn decode_client_error(response: reqwest::Response) -> Result<ApiError> {
|
||||
response
|
||||
.json::<ApiError>()
|
||||
.await
|
||||
.map_err(|reqwest_err| {
|
||||
crate::Error::WrappedReqwestErr(reqwest_err)
|
||||
})
|
||||
.map_err(crate::Error::WrappedReqwestErr)
|
||||
}
|
||||
|
||||
#[derive(Debug)]
|
||||
|
||||
39
src/main.rs
39
src/main.rs
@@ -1,4 +1,4 @@
|
||||
use std::fs;
|
||||
use std::path;
|
||||
|
||||
use gt_tool::cli::Args;
|
||||
use gt_tool::structs::release::{CreateReleaseOption, Release};
|
||||
@@ -21,10 +21,7 @@ async fn main() -> Result<(), gt_tool::Error> {
|
||||
headers.append("Authorization", token.parse().unwrap());
|
||||
}
|
||||
let client = reqwest::Client::builder()
|
||||
.user_agent(format!(
|
||||
"gt-tools-agent-{}",
|
||||
env!("CARGO_PKG_VERSION")
|
||||
))
|
||||
.user_agent(format!("gt-tools-agent-{}", env!("CARGO_PKG_VERSION")))
|
||||
.default_headers(headers)
|
||||
.build()?;
|
||||
|
||||
@@ -32,9 +29,15 @@ async fn main() -> Result<(), gt_tool::Error> {
|
||||
gt_tool::cli::Commands::ListReleases => {
|
||||
let releases =
|
||||
gt_tool::api::release::list_releases(&client, &args.gitea_url, &args.repo).await?;
|
||||
for release in releases {
|
||||
println!("{:?}", release);
|
||||
}
|
||||
// Print in reverse order so the newest items are closest to the
|
||||
// user's command prompt. Otherwise the newest item scrolls off the
|
||||
// screen and can't be seen.
|
||||
itertools::Itertools::intersperse(
|
||||
releases.iter().rev().map(|release| release.colorized()),
|
||||
String::from(""),
|
||||
)
|
||||
.map(|release| println!("{}", release))
|
||||
.fold((), |_, _| ());
|
||||
}
|
||||
gt_tool::cli::Commands::CreateRelease {
|
||||
name,
|
||||
@@ -51,13 +54,8 @@ async fn main() -> Result<(), gt_tool::Error> {
|
||||
tag_name,
|
||||
target_commitish,
|
||||
};
|
||||
gt_tool::api::release::create_release(
|
||||
&client,
|
||||
&args.gitea_url,
|
||||
&args.repo,
|
||||
submission,
|
||||
)
|
||||
.await?;
|
||||
gt_tool::api::release::create_release(&client, &args.gitea_url, &args.repo, submission)
|
||||
.await?;
|
||||
}
|
||||
gt_tool::cli::Commands::UploadRelease {
|
||||
tag_name,
|
||||
@@ -81,13 +79,16 @@ async fn main() -> Result<(), gt_tool::Error> {
|
||||
|
||||
if let Some(release) = match_release_by_tag(&tag_name, release_candidates) {
|
||||
for file in &files {
|
||||
match fs::exists(file) {
|
||||
let path = path::Path::new(&file);
|
||||
match path.try_exists() {
|
||||
Ok(true) => continue,
|
||||
Ok(false) => return Err(gt_tool::Error::NoSuchFile),
|
||||
Err(e) => {
|
||||
eprintln!("Uh oh! The file-exists check couldn't be done: {e}");
|
||||
panic!("TODO: Deal with scenario where the file's existence cannot be checked (e.g.: no permission)");
|
||||
},
|
||||
panic!(
|
||||
"TODO: Deal with scenario where the file's existence cannot be checked (e.g.: no permission)"
|
||||
);
|
||||
}
|
||||
}
|
||||
}
|
||||
for file in files {
|
||||
@@ -141,5 +142,5 @@ fn match_release_by_tag(tag: &String, releases: Vec<Release>) -> Option<Release>
|
||||
}
|
||||
}
|
||||
}
|
||||
return release;
|
||||
release
|
||||
}
|
||||
|
||||
@@ -9,7 +9,7 @@ pub struct Attachment {
|
||||
name: String,
|
||||
size: i64,
|
||||
download_count: i64,
|
||||
created: String, // TODO: Date-time struct
|
||||
created_at: String, // TODO: Date-time struct
|
||||
uuid: String,
|
||||
download_url: String,
|
||||
browser_download_url: String,
|
||||
}
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
use colored::Colorize;
|
||||
use serde::{Deserialize, Serialize};
|
||||
|
||||
#[derive(Debug, Deserialize, Serialize)]
|
||||
@@ -19,6 +20,36 @@ pub struct Release {
|
||||
author: Author,
|
||||
}
|
||||
|
||||
impl Release {
|
||||
pub fn colorized(&self) -> String {
|
||||
let tag = "Tag:".green().bold();
|
||||
let name = "Name:".green();
|
||||
let published = "Published:".bright_green();
|
||||
let created = "Created:".green().dimmed();
|
||||
let author = "Author:".blue();
|
||||
let body = if !self.body.is_empty() {
|
||||
&self.body.white()
|
||||
} else {
|
||||
&String::from("(empty body)").dimmed()
|
||||
};
|
||||
|
||||
format!(
|
||||
"{tag} {}
|
||||
{name} {}
|
||||
{}
|
||||
{published} {} ({created} {})
|
||||
{author} {} ({})",
|
||||
self.tag_name.bold(),
|
||||
self.name,
|
||||
body,
|
||||
self.published_at,
|
||||
self.created_at.dimmed(),
|
||||
self.author.login,
|
||||
self.author.email,
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
#[derive(Debug, Deserialize, Serialize)]
|
||||
pub struct Author {
|
||||
id: usize,
|
||||
|
||||
Reference in New Issue
Block a user