use std::collections::BTreeSet;
use chrono::{DateTime, NaiveDate, Utc};
use derive_builder::Builder;
use itertools::Itertools;
use crate::api::common::NameOrId;
use crate::api::endpoint_prelude::*;
#[derive(Debug, Builder)]
#[builder(setter(strip_option))]
pub struct CreateIssue<'a> {
#[builder(setter(into))]
project: NameOrId<'a>,
#[builder(setter(into))]
title: Cow<'a, str>,
#[builder(default)]
iid: Option<u64>,
#[builder(setter(into), default)]
description: Option<Cow<'a, str>>,
#[builder(default)]
confidential: Option<bool>,
#[builder(setter(name = "_assignee_ids"), default, private)]
assignee_ids: BTreeSet<u64>,
#[builder(default)]
milestone_id: Option<u64>,
#[builder(setter(name = "_labels"), default, private)]
labels: BTreeSet<Cow<'a, str>>,
#[builder(default)]
created_at: Option<DateTime<Utc>>,
#[builder(default)]
due_date: Option<NaiveDate>,
#[builder(default)]
merge_request_to_resolve_discussions_of: Option<u64>,
#[builder(setter(into), default)]
discussion_to_resolve: Option<Cow<'a, str>>,
#[builder(default)]
weight: Option<u64>,
#[builder(default)]
epic_id: Option<u64>,
#[deprecated(note = "use `epic_id` instead")]
#[builder(default)]
epic_iid: Option<u64>,
}
impl<'a> CreateIssue<'a> {
pub fn builder() -> CreateIssueBuilder<'a> {
CreateIssueBuilder::default()
}
}
impl<'a> CreateIssueBuilder<'a> {
pub fn assignee_id(&mut self, assignee: u64) -> &mut Self {
self.assignee_ids
.get_or_insert_with(BTreeSet::new)
.insert(assignee);
self
}
pub fn assignee_ids<I>(&mut self, iter: I) -> &mut Self
where
I: Iterator<Item = u64>,
{
self.assignee_ids
.get_or_insert_with(BTreeSet::new)
.extend(iter);
self
}
pub fn label<L>(&mut self, label: L) -> &mut Self
where
L: Into<Cow<'a, str>>,
{
self.labels
.get_or_insert_with(BTreeSet::new)
.insert(label.into());
self
}
pub fn labels<I, L>(&mut self, iter: I) -> &mut Self
where
I: IntoIterator<Item = L>,
L: Into<Cow<'a, str>>,
{
self.labels
.get_or_insert_with(BTreeSet::new)
.extend(iter.into_iter().map(Into::into));
self
}
}
impl<'a> Endpoint for CreateIssue<'a> {
fn method(&self) -> Method {
Method::POST
}
fn endpoint(&self) -> Cow<'static, str> {
format!("projects/{}/issues", self.project).into()
}
fn body(&self) -> Result<Option<(&'static str, Vec<u8>)>, BodyError> {
let mut params = FormParams::default();
if !self.title.is_empty() || self.merge_request_to_resolve_discussions_of.is_none() {
params.push("title", &self.title);
}
params
.push_opt("iid", self.iid)
.push_opt("description", self.description.as_ref())
.push_opt("confidential", self.confidential)
.extend(
self.assignee_ids
.iter()
.map(|&value| ("assignee_ids[]", value)),
)
.push_opt("milestone_id", self.milestone_id)
.push_opt("created_at", self.created_at)
.push_opt("due_date", self.due_date)
.push_opt(
"merge_request_to_resolve_discussions_of",
self.merge_request_to_resolve_discussions_of,
)
.push_opt("discussion_to_resolve", self.discussion_to_resolve.as_ref())
.push_opt("weight", self.weight)
.push_opt("epic_id", self.epic_id);
if !self.labels.is_empty() {
params.push("labels", format!("{}", self.labels.iter().format(",")));
}
#[allow(deprecated)]
{
params.push_opt("epic_iid", self.epic_iid);
}
params.into_body()
}
}
#[cfg(test)]
mod tests {
use chrono::{NaiveDate, TimeZone, Utc};
use http::Method;
use crate::api::projects::issues::CreateIssue;
use crate::api::{self, Query};
use crate::test::client::{ExpectedUrl, SingleTestClient};
#[test]
fn project_and_title_are_necessary() {
let err = CreateIssue::builder().build().unwrap_err();
assert_eq!(err, "`project` must be initialized");
}
#[test]
fn project_is_necessary() {
let err = CreateIssue::builder().title("title").build().unwrap_err();
assert_eq!(err, "`project` must be initialized");
}
#[test]
fn title_is_necessary() {
let err = CreateIssue::builder().project(1).build().unwrap_err();
assert_eq!(err, "`title` must be initialized");
}
#[test]
fn project_and_title_are_sufficient() {
CreateIssue::builder()
.project(1)
.title("title")
.build()
.unwrap();
}
#[test]
fn endpoint() {
let endpoint = ExpectedUrl::builder()
.method(Method::POST)
.endpoint("projects/simple%2Fproject/issues")
.content_type("application/x-www-form-urlencoded")
.body_str("title=title+of+issue")
.build()
.unwrap();
let client = SingleTestClient::new_raw(endpoint, "");
let endpoint = CreateIssue::builder()
.project("simple/project")
.title("title of issue")
.build()
.unwrap();
api::ignore(endpoint).query(&client).unwrap();
}
#[test]
fn endpoint_iid() {
let endpoint = ExpectedUrl::builder()
.method(Method::POST)
.endpoint("projects/simple%2Fproject/issues")
.content_type("application/x-www-form-urlencoded")
.body_str(concat!("title=title", "&iid=1"))
.build()
.unwrap();
let client = SingleTestClient::new_raw(endpoint, "");
let endpoint = CreateIssue::builder()
.project("simple/project")
.title("title")
.iid(1)
.build()
.unwrap();
api::ignore(endpoint).query(&client).unwrap();
}
#[test]
fn endpoint_description() {
let endpoint = ExpectedUrl::builder()
.method(Method::POST)
.endpoint("projects/simple%2Fproject/issues")
.content_type("application/x-www-form-urlencoded")
.body_str(concat!("title=title", "&description=description"))
.build()
.unwrap();
let client = SingleTestClient::new_raw(endpoint, "");
let endpoint = CreateIssue::builder()
.project("simple/project")
.title("title")
.description("description")
.build()
.unwrap();
api::ignore(endpoint).query(&client).unwrap();
}
#[test]
fn endpoint_confidential() {
let endpoint = ExpectedUrl::builder()
.method(Method::POST)
.endpoint("projects/simple%2Fproject/issues")
.content_type("application/x-www-form-urlencoded")
.body_str(concat!("title=title", "&confidential=true"))
.build()
.unwrap();
let client = SingleTestClient::new_raw(endpoint, "");
let endpoint = CreateIssue::builder()
.project("simple/project")
.title("title")
.confidential(true)
.build()
.unwrap();
api::ignore(endpoint).query(&client).unwrap();
}
#[test]
fn endpoint_assignee_ids() {
let endpoint = ExpectedUrl::builder()
.method(Method::POST)
.endpoint("projects/simple%2Fproject/issues")
.content_type("application/x-www-form-urlencoded")
.body_str(concat!(
"title=title",
"&assignee_ids%5B%5D=1",
"&assignee_ids%5B%5D=2",
))
.build()
.unwrap();
let client = SingleTestClient::new_raw(endpoint, "");
let endpoint = CreateIssue::builder()
.project("simple/project")
.title("title")
.assignee_id(1)
.assignee_ids([1, 2].iter().copied())
.build()
.unwrap();
api::ignore(endpoint).query(&client).unwrap();
}
#[test]
fn endpoint_milestone_id() {
let endpoint = ExpectedUrl::builder()
.method(Method::POST)
.endpoint("projects/simple%2Fproject/issues")
.content_type("application/x-www-form-urlencoded")
.body_str(concat!("title=title", "&milestone_id=1"))
.build()
.unwrap();
let client = SingleTestClient::new_raw(endpoint, "");
let endpoint = CreateIssue::builder()
.project("simple/project")
.title("title")
.milestone_id(1)
.build()
.unwrap();
api::ignore(endpoint).query(&client).unwrap();
}
#[test]
fn endpoint_labels() {
let endpoint = ExpectedUrl::builder()
.method(Method::POST)
.endpoint("projects/simple%2Fproject/issues")
.content_type("application/x-www-form-urlencoded")
.body_str(concat!("title=title", "&labels=label"))
.build()
.unwrap();
let client = SingleTestClient::new_raw(endpoint, "");
let endpoint = CreateIssue::builder()
.project("simple/project")
.title("title")
.label("label")
.build()
.unwrap();
api::ignore(endpoint).query(&client).unwrap();
}
#[test]
fn endpoint_labels_multiple() {
let endpoint = ExpectedUrl::builder()
.method(Method::POST)
.endpoint("projects/simple%2Fproject/issues")
.content_type("application/x-www-form-urlencoded")
.body_str(concat!("title=title", "&labels=label1%2Clabel2"))
.build()
.unwrap();
let client = SingleTestClient::new_raw(endpoint, "");
let endpoint = CreateIssue::builder()
.project("simple/project")
.title("title")
.labels(["label1", "label2"].iter().copied())
.build()
.unwrap();
api::ignore(endpoint).query(&client).unwrap();
}
#[test]
fn endpoint_created_at() {
let endpoint = ExpectedUrl::builder()
.method(Method::POST)
.endpoint("projects/simple%2Fproject/issues")
.content_type("application/x-www-form-urlencoded")
.body_str(concat!(
"title=title",
"&created_at=2020-01-01T00%3A00%3A00Z",
))
.build()
.unwrap();
let client = SingleTestClient::new_raw(endpoint, "");
let endpoint = CreateIssue::builder()
.project("simple/project")
.title("title")
.created_at(Utc.ymd(2020, 1, 1).and_hms_milli(0, 0, 0, 0))
.build()
.unwrap();
api::ignore(endpoint).query(&client).unwrap();
}
#[test]
fn endpoint_due_date() {
let endpoint = ExpectedUrl::builder()
.method(Method::POST)
.endpoint("projects/simple%2Fproject/issues")
.content_type("application/x-www-form-urlencoded")
.body_str(concat!("title=title", "&due_date=2020-01-01"))
.build()
.unwrap();
let client = SingleTestClient::new_raw(endpoint, "");
let endpoint = CreateIssue::builder()
.project("simple/project")
.title("title")
.due_date(NaiveDate::from_ymd(2020, 1, 1))
.build()
.unwrap();
api::ignore(endpoint).query(&client).unwrap();
}
#[test]
fn endpoint_merge_request_to_resolve_discussions_of() {
let endpoint = ExpectedUrl::builder()
.method(Method::POST)
.endpoint("projects/simple%2Fproject/issues")
.content_type("application/x-www-form-urlencoded")
.body_str(concat!(
"title=title",
"&merge_request_to_resolve_discussions_of=1",
))
.build()
.unwrap();
let client = SingleTestClient::new_raw(endpoint, "");
let endpoint = CreateIssue::builder()
.project("simple/project")
.title("title")
.merge_request_to_resolve_discussions_of(1)
.build()
.unwrap();
api::ignore(endpoint).query(&client).unwrap();
}
#[test]
fn endpoint_merge_request_to_resolve_discussions_of_no_title() {
let endpoint = ExpectedUrl::builder()
.method(Method::POST)
.endpoint("projects/simple%2Fproject/issues")
.content_type("application/x-www-form-urlencoded")
.body_str("merge_request_to_resolve_discussions_of=1")
.build()
.unwrap();
let client = SingleTestClient::new_raw(endpoint, "");
let endpoint = CreateIssue::builder()
.project("simple/project")
.title("")
.merge_request_to_resolve_discussions_of(1)
.build()
.unwrap();
api::ignore(endpoint).query(&client).unwrap();
}
#[test]
fn endpoint_discussion_to_resolve() {
let endpoint = ExpectedUrl::builder()
.method(Method::POST)
.endpoint("projects/simple%2Fproject/issues")
.content_type("application/x-www-form-urlencoded")
.body_str(concat!("title=title", "&discussion_to_resolve=deadbeef"))
.build()
.unwrap();
let client = SingleTestClient::new_raw(endpoint, "");
let endpoint = CreateIssue::builder()
.project("simple/project")
.title("title")
.discussion_to_resolve("deadbeef")
.build()
.unwrap();
api::ignore(endpoint).query(&client).unwrap();
}
#[test]
fn endpoint_weight() {
let endpoint = ExpectedUrl::builder()
.method(Method::POST)
.endpoint("projects/simple%2Fproject/issues")
.content_type("application/x-www-form-urlencoded")
.body_str(concat!("title=title", "&weight=1"))
.build()
.unwrap();
let client = SingleTestClient::new_raw(endpoint, "");
let endpoint = CreateIssue::builder()
.project("simple/project")
.title("title")
.weight(1)
.build()
.unwrap();
api::ignore(endpoint).query(&client).unwrap();
}
#[test]
fn endpoint_epic_id() {
let endpoint = ExpectedUrl::builder()
.method(Method::POST)
.endpoint("projects/simple%2Fproject/issues")
.content_type("application/x-www-form-urlencoded")
.body_str(concat!("title=title", "&epic_id=1"))
.build()
.unwrap();
let client = SingleTestClient::new_raw(endpoint, "");
let endpoint = CreateIssue::builder()
.project("simple/project")
.title("title")
.epic_id(1)
.build()
.unwrap();
api::ignore(endpoint).query(&client).unwrap();
}
#[test]
#[allow(deprecated)]
fn endpoint_epic_iid() {
let endpoint = ExpectedUrl::builder()
.method(Method::POST)
.endpoint("projects/simple%2Fproject/issues")
.content_type("application/x-www-form-urlencoded")
.body_str(concat!("title=title", "&epic_iid=1"))
.build()
.unwrap();
let client = SingleTestClient::new_raw(endpoint, "");
let endpoint = CreateIssue::builder()
.project("simple/project")
.title("title")
.epic_iid(1)
.build()
.unwrap();
api::ignore(endpoint).query(&client).unwrap();
}
}