blob: 44e50da220d1cea84a779e5545c4de33dc14295f (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
package xyz.driver.pdsuidomain.services
import xyz.driver.core.rest.AuthorizedServiceRequestContext
import xyz.driver.entities.users.AuthUserInfo
import xyz.driver.pdsuicommon.db._
import xyz.driver.pdsuicommon.domain.LongId
import xyz.driver.pdsuicommon.error.DomainError
import xyz.driver.pdsuicommon.logging._
import xyz.driver.pdsuidomain.entities.SlotArm
import scala.concurrent.Future
object SlotArmService {
trait DefaultAccessDeniedError {
def userMessage: String = "Access denied"
}
trait DefaultNotFoundError {
def userMessage: String = "SlotArm not found"
}
sealed trait GetByIdReply
object GetByIdReply {
final case class Entity(x: SlotArm) extends GetByIdReply
type Error = GetByIdReply with DomainError
case object NotFoundError extends GetByIdReply with DefaultNotFoundError with DomainError.NotFoundError
case object AuthorizationError
extends GetByIdReply with DomainError.AuthorizationError with DefaultAccessDeniedError
final case class CommonError(userMessage: String)(
implicit requestContext: AuthorizedServiceRequestContext[AuthUserInfo])
extends GetByIdReply with DomainError
}
sealed trait GetListReply
object GetListReply {
type Error = GetListReply with DomainError
final case class EntityList(xs: Seq[SlotArm], totalFound: Int) extends GetListReply
case object AuthorizationError
extends GetListReply with DomainError.AuthorizationError with DefaultAccessDeniedError
}
sealed trait UpdateReply
object UpdateReply {
final case class Updated(updated: SlotArm) extends UpdateReply
type Error = UpdateReply with DomainError
case object NotFoundError extends UpdateReply with DefaultNotFoundError with DomainError.NotFoundError
case object AuthorizationError
extends UpdateReply with DefaultAccessDeniedError with DomainError.AuthorizationError
final case class CommonError(userMessage: String) extends UpdateReply with DomainError
final case class AlreadyExistsError(x: SlotArm) extends UpdateReply with DomainError {
val userMessage = s"The arm with such name of trial already exists."
}
implicit def toPhiString(reply: UpdateReply): PhiString = reply match {
case Updated(x) => phi"Updated($x)"
case x: Error => DomainError.toPhiString(x)
}
}
sealed trait CreateReply
object CreateReply {
final case class Created(x: SlotArm) extends CreateReply
type Error = CreateReply with DomainError
case object AuthorizationError
extends CreateReply with DefaultAccessDeniedError with DomainError.AuthorizationError
final case class CommonError(userMessage: String) extends CreateReply with DomainError
final case class AlreadyExistsError(x: SlotArm) extends CreateReply with DomainError {
val userMessage = s"The arm with this name of trial already exists."
}
implicit def toPhiString(reply: CreateReply): PhiString = reply match {
case Created(x) => phi"Created($x)"
case x: Error => DomainError.toPhiString(x)
}
}
sealed trait DeleteReply
object DeleteReply {
case object Deleted extends DeleteReply
type Error = DeleteReply with DomainError
case object NotFoundError extends DeleteReply with DefaultNotFoundError with DomainError.NotFoundError
case object AuthorizationError
extends DeleteReply with DefaultAccessDeniedError with DomainError.AuthorizationError
final case class CommonError(userMessage: String) extends DeleteReply with DomainError
}
}
trait SlotArmService {
import SlotArmService._
def getAll(filter: SearchFilterExpr = SearchFilterExpr.Empty,
sorting: Option[Sorting] = None,
pagination: Option[Pagination] = None)(
implicit requestContext: AuthorizedServiceRequestContext[AuthUserInfo]): Future[GetListReply]
def getById(armId: LongId[SlotArm])(
implicit requestContext: AuthorizedServiceRequestContext[AuthUserInfo]): Future[GetByIdReply]
def create(draftSlotArm: SlotArm)(
implicit requestContext: AuthorizedServiceRequestContext[AuthUserInfo]): Future[CreateReply]
def update(origSlotArm: SlotArm, draftSlotArm: SlotArm)(
implicit requestContext: AuthorizedServiceRequestContext[AuthUserInfo]): Future[UpdateReply]
def delete(id: LongId[SlotArm])(
implicit requestContext: AuthorizedServiceRequestContext[AuthUserInfo]): Future[DeleteReply]
}
|
