use derive_builder::Builder;
use reqwest::Method;
use std::borrow::Cow;
use crate::api::projects::ProjectEssentials;
use crate::api::users::UserEssentials;
use crate::api::{Endpoint, Pageable, ReturnsJsonResponse};
#[derive(Debug, Clone, PartialEq, Eq, serde::Serialize, serde::Deserialize)]
pub struct News {
pub id: u64,
pub project: ProjectEssentials,
pub author: UserEssentials,
pub title: String,
pub summary: String,
pub description: String,
#[serde(
serialize_with = "crate::api::serialize_rfc3339",
deserialize_with = "crate::api::deserialize_rfc3339"
)]
pub created_on: time::OffsetDateTime,
}
#[derive(Debug, Clone, Builder)]
#[builder(setter(strip_option))]
pub struct ListNews {}
impl ReturnsJsonResponse for ListNews {}
impl Pageable for ListNews {
fn response_wrapper_key(&self) -> String {
"news".to_string()
}
}
impl ListNews {
#[must_use]
pub fn builder() -> ListNewsBuilder {
ListNewsBuilder::default()
}
}
impl Endpoint for ListNews {
fn method(&self) -> Method {
Method::GET
}
fn endpoint(&self) -> Cow<'static, str> {
"news.json".into()
}
}
#[derive(Debug, Clone, Builder)]
#[builder(setter(strip_option))]
pub struct ListProjectNews<'a> {
#[builder(setter(into))]
project_id_or_name: Cow<'a, str>,
}
impl ReturnsJsonResponse for ListProjectNews<'_> {}
impl Pageable for ListProjectNews<'_> {
fn response_wrapper_key(&self) -> String {
"news".to_string()
}
}
impl<'a> ListProjectNews<'a> {
#[must_use]
pub fn builder() -> ListProjectNewsBuilder<'a> {
ListProjectNewsBuilder::default()
}
}
impl Endpoint for ListProjectNews<'_> {
fn method(&self) -> Method {
Method::GET
}
fn endpoint(&self) -> Cow<'static, str> {
format!("projects/{}/news.json", self.project_id_or_name).into()
}
}
#[derive(Debug, Clone, Builder)]
#[builder(setter(strip_option))]
pub struct GetNews {
id: u64,
}
impl ReturnsJsonResponse for GetNews {}
impl crate::api::NoPagination for GetNews {}
impl GetNews {
#[must_use]
pub fn builder() -> GetNewsBuilder {
GetNewsBuilder::default()
}
}
impl Endpoint for GetNews {
fn method(&self) -> Method {
Method::GET
}
fn endpoint(&self) -> Cow<'static, str> {
format!("news/{}.json", self.id).into()
}
}
#[derive(Debug, Clone, Builder, serde::Serialize)]
#[builder(setter(strip_option))]
pub struct CreateNews<'a> {
#[builder(setter(into))]
#[serde(skip_serializing)]
project_id_or_name: Cow<'a, str>,
#[builder(setter(into))]
title: Cow<'a, str>,
#[builder(setter(into), default)]
summary: Option<Cow<'a, str>>,
#[builder(setter(into))]
description: Cow<'a, str>,
}
impl<'a> CreateNews<'a> {
#[must_use]
pub fn builder() -> CreateNewsBuilder<'a> {
CreateNewsBuilder::default()
}
}
impl crate::api::NoPagination for CreateNews<'_> {}
impl Endpoint for CreateNews<'_> {
fn method(&self) -> Method {
Method::POST
}
fn endpoint(&self) -> Cow<'static, str> {
format!("projects/{}/news.json", self.project_id_or_name).into()
}
fn body(&self) -> Result<Option<(&'static str, Vec<u8>)>, crate::Error> {
Ok(Some((
"application/json",
serde_json::to_vec(&SingleNewsWrapper::<CreateNews> {
news: (*self).to_owned(),
})?,
)))
}
}
#[derive(Debug, Clone, Builder, serde::Serialize)]
#[builder(setter(strip_option))]
pub struct UpdateNews<'a> {
#[serde(skip_serializing)]
id: u64,
#[builder(setter(into), default)]
#[serde(skip_serializing_if = "Option::is_none")]
title: Option<Cow<'a, str>>,
#[builder(setter(into), default)]
#[serde(skip_serializing_if = "Option::is_none")]
summary: Option<Cow<'a, str>>,
#[builder(setter(into), default)]
#[serde(skip_serializing_if = "Option::is_none")]
description: Option<Cow<'a, str>>,
}
impl<'a> UpdateNews<'a> {
#[must_use]
pub fn builder() -> UpdateNewsBuilder<'a> {
UpdateNewsBuilder::default()
}
}
impl Endpoint for UpdateNews<'_> {
fn method(&self) -> Method {
Method::PUT
}
fn endpoint(&self) -> Cow<'static, str> {
format!("news/{}.json", self.id).into()
}
fn body(&self) -> Result<Option<(&'static str, Vec<u8>)>, crate::Error> {
Ok(Some((
"application/json",
serde_json::to_vec(&SingleNewsWrapper::<UpdateNews> {
news: (*self).to_owned(),
})?,
)))
}
}
#[derive(Debug, Clone, Builder)]
#[builder(setter(strip_option))]
pub struct DeleteNews {
id: u64,
}
impl DeleteNews {
#[must_use]
pub fn builder() -> DeleteNewsBuilder {
DeleteNewsBuilder::default()
}
}
impl Endpoint for DeleteNews {
fn method(&self) -> Method {
Method::DELETE
}
fn endpoint(&self) -> Cow<'static, str> {
format!("news/{}.json", self.id).into()
}
}
#[derive(Debug, Clone, PartialEq, Eq, serde::Serialize, serde::Deserialize)]
pub struct NewsWrapper<T> {
pub news: Vec<T>,
}
#[derive(Debug, Clone, PartialEq, Eq, serde::Serialize, serde::Deserialize)]
pub struct SingleNewsWrapper<T> {
pub news: T,
}
#[cfg(test)]
mod test {
use super::*;
use pretty_assertions::assert_eq;
use std::error::Error;
use tracing_test::traced_test;
#[traced_test]
#[test]
fn test_list_news_first_page() -> Result<(), Box<dyn Error>> {
dotenvy::dotenv()?;
let redmine = crate::api::Redmine::from_env(
reqwest::blocking::Client::builder()
.tls_backend_rustls()
.build()?,
)?;
let endpoint = ListNews::builder().build()?;
redmine.json_response_body_page::<_, News>(&endpoint, 0, 25)?;
Ok(())
}
#[traced_test]
#[test]
fn test_list_news_all_pages() -> Result<(), Box<dyn Error>> {
dotenvy::dotenv()?;
let redmine = crate::api::Redmine::from_env(
reqwest::blocking::Client::builder()
.tls_backend_rustls()
.build()?,
)?;
let endpoint = ListNews::builder().build()?;
redmine.json_response_body_all_pages::<_, News>(&endpoint)?;
Ok(())
}
#[traced_test]
#[test]
fn test_get_update_delete_news() -> Result<(), Box<dyn Error>> {
crate::api::test_helpers::with_project("test_get_update_delete_news", |redmine, _, name| {
let create_endpoint = CreateNews::builder()
.project_id_or_name(name)
.title("Test News")
.summary("Test Summary")
.description("Test Description")
.build()?;
redmine.ignore_response_body(&create_endpoint)?;
let list_endpoint = ListProjectNews::builder()
.project_id_or_name(name)
.build()?;
let news: Vec<News> = redmine.json_response_body_all_pages(&list_endpoint)?;
let created_news = news
.into_iter()
.find(|n| n.title == "Test News")
.ok_or("Could not find created news")?;
let get_endpoint = GetNews::builder().id(created_news.id).build()?;
let fetched_news: SingleNewsWrapper<News> =
redmine.json_response_body(&get_endpoint)?;
assert_eq!(created_news, fetched_news.news);
let update_endpoint = UpdateNews::builder()
.id(created_news.id)
.title("New Test News")
.build()?;
redmine.ignore_response_body(&update_endpoint)?;
let delete_endpoint = DeleteNews::builder().id(created_news.id).build()?;
redmine.ignore_response_body(&delete_endpoint)?;
Ok(())
})
}
#[traced_test]
#[test]
fn test_completeness_news_type() -> Result<(), Box<dyn Error>> {
dotenvy::dotenv()?;
let redmine = crate::api::Redmine::from_env(
reqwest::blocking::Client::builder()
.tls_backend_rustls()
.build()?,
)?;
let endpoint = ListNews::builder().build()?;
let values: Vec<serde_json::Value> = redmine.json_response_body_all_pages(&endpoint)?;
for value in values {
let o: News = serde_json::from_value(value.clone())?;
let reserialized = serde_json::to_value(o)?;
assert_eq!(value, reserialized);
}
Ok(())
}
}