mirror of
https://github.com/gitbucket/gitbucket.git
synced 2025-11-12 08:25:50 +01:00
121b6ee641
This is temporary fix to decrease compilation time in development. Therefore this fix will be reverted in the future to add multiple database support capability.
57 lines
2.4 KiB
Scala
57 lines
2.4 KiB
Scala
package service
|
|
|
|
import model._
|
|
import profile.simple._
|
|
// TODO [Slick 2.0]NOT import directly?
|
|
import model.dateColumnType
|
|
|
|
trait MilestonesService {
|
|
|
|
def createMilestone(owner: String, repository: String, title: String, description: Option[String],
|
|
dueDate: Option[java.util.Date])(implicit s: Session): Unit =
|
|
Milestones insert Milestone(
|
|
userName = owner,
|
|
repositoryName = repository,
|
|
title = title,
|
|
description = description,
|
|
dueDate = dueDate,
|
|
closedDate = None
|
|
)
|
|
|
|
def updateMilestone(milestone: Milestone)(implicit s: Session): Unit =
|
|
Milestones
|
|
.filter (t => t.byPrimaryKey(milestone.userName, milestone.repositoryName, milestone.milestoneId))
|
|
.map (t => (t.title, t.description.?, t.dueDate.?, t.closedDate.?))
|
|
.update (milestone.title, milestone.description, milestone.dueDate, milestone.closedDate)
|
|
|
|
def openMilestone(milestone: Milestone)(implicit s: Session): Unit =
|
|
updateMilestone(milestone.copy(closedDate = None))
|
|
|
|
def closeMilestone(milestone: Milestone)(implicit s: Session): Unit =
|
|
updateMilestone(milestone.copy(closedDate = Some(currentDate)))
|
|
|
|
def deleteMilestone(owner: String, repository: String, milestoneId: Int)(implicit s: Session): Unit = {
|
|
Issues.filter(_.byMilestone(owner, repository, milestoneId)).map(_.milestoneId.?).update(None)
|
|
Milestones.filter(_.byPrimaryKey(owner, repository, milestoneId)).delete
|
|
}
|
|
|
|
def getMilestone(owner: String, repository: String, milestoneId: Int)(implicit s: Session): Option[Milestone] =
|
|
Milestones.filter(_.byPrimaryKey(owner, repository, milestoneId)).firstOption
|
|
|
|
def getMilestonesWithIssueCount(owner: String, repository: String)(implicit s: Session): List[(Milestone, Int, Int)] = {
|
|
val counts = Issues
|
|
.filter { t => (t.byRepository(owner, repository)) && (t.milestoneId isNotNull) }
|
|
.groupBy { t => t.milestoneId -> t.closed }
|
|
.map { case (t1, t2) => t1._1 -> t1._2 -> t2.length }
|
|
.toMap
|
|
|
|
getMilestones(owner, repository).map { milestone =>
|
|
(milestone, counts.getOrElse((milestone.milestoneId, false), 0), counts.getOrElse((milestone.milestoneId, true), 0))
|
|
}
|
|
}
|
|
|
|
def getMilestones(owner: String, repository: String)(implicit s: Session): List[Milestone] =
|
|
Milestones.filter(_.byRepository(owner, repository)).sortBy(_.milestoneId asc).list
|
|
|
|
}
|