d5939db
use db::conn::sea_orm::*;
use db::issue::milestone as milestone_entity;
use time::OffsetDateTime;
use time::format_description::well_known::Rfc3339;
use uuid::Uuid;
use crate::error::{IssueError, IssueResult};
use crate::features::IssueService;
use super::super::super::issue::usecase::load_issue_collection;
use super::super::{CreateMilestoneOption, MilestoneView};
use super::helpers::require_authenticated;
pub async fn create_milestone(
svc: &IssueService,
actor: Uuid,
channel_id: Uuid,
input: CreateMilestoneOption,
) -> IssueResult<MilestoneView> {
require_authenticated(actor)?;
let name = input.name.trim().to_string();
if name.is_empty() || name.len() > svc.config.max_milestone_title_len {
return Err(IssueError::BadRequest(format!(
"milestone name length must be in 1..={}",
svc.config.max_milestone_title_len
)));
}
if let Some(ref d) = input.description
&& d.len() > svc.config.max_milestone_description_len
{
return Err(IssueError::BadRequest("milestone description too long".into()));
}
let due_at = match input.due_at.as_deref() {
Some(s) => Some(
OffsetDateTime::parse(s, &Rfc3339)
.map_err(|e| IssueError::BadRequest(format!("invalid due_at: {e}")))?,
),
None => None,
};
let collection = load_issue_collection(svc, channel_id).await?;
let db = svc.db.writer();
let now = OffsetDateTime::now_utc();
let id = Uuid::new_v4();
let active: milestone_entity::ActiveModel = milestone_entity::ActiveModel::builder()
.set_id(id)
.set_collection_id(collection.id)
.set_name(name)
.set_description(input.description)
.set_is_closed(false)
.set_due_at(due_at)
.set_num_issues(0)
.set_num_closed_issues(0)
.set_created_at(now)
.set_updated_at(None)
.into();
let saved = active.insert(&db).await?;
Ok(MilestoneView::from(saved))
}