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
131
132
|
package xyz.driver.pdsuidomain.services
import java.time.LocalDateTime
import xyz.driver.core.rest.AuthorizedServiceRequestContext
import xyz.driver.entities.labels.{Label, LabelValue}
import xyz.driver.entities.users.AuthUserInfo
import xyz.driver.pdsuicommon.db._
import xyz.driver.pdsuicommon.domain._
import xyz.driver.pdsuicommon.error.DomainError
import xyz.driver.pdsuicommon.logging._
import xyz.driver.pdsuidomain.entities._
import scala.concurrent.Future
object PatientCriterionService {
final case class DraftPatientCriterion(id: LongId[PatientCriterion],
eligibilityStatus: Option[LabelValue],
isVerified: Option[Boolean]) {
def applyTo(orig: PatientCriterion) = {
orig.copy(
eligibilityStatus = eligibilityStatus.getOrElse(orig.eligibilityStatus),
isVerified = isVerified.getOrElse(orig.isVerified)
)
}
}
object DraftPatientCriterion {
implicit def toPhiString(x: DraftPatientCriterion): PhiString = {
phi"DraftPatientCriterion(id=${x.id}, eligibilityStatus=${Unsafe(x.eligibilityStatus)}, isVerified=${x.isVerified})"
}
}
trait DefaultPatientNotFoundError {
def userMessage: String = "Patient not found"
}
trait DefaultNotFoundError {
def userMessage: String = "Patient criterion not found"
}
trait DefaultAccessDeniedError {
def userMessage: String = "Access denied"
}
final case class RichPatientCriterion(patientCriterion: PatientCriterion,
labelId: LongId[Label],
armList: List[PatientCriterionArm])
object RichPatientCriterion {
implicit def toPhiString(x: RichPatientCriterion): PhiString = {
phi"RichPatientCriterion(patientCriterion=${x.patientCriterion}, labelId=${x.labelId}, arms=${x.armList})"
}
}
sealed trait GetListReply
object GetListReply {
type Error = GetListReply with DomainError
final case class EntityList(xs: Seq[RichPatientCriterion], totalFound: Int, lastUpdate: Option[LocalDateTime])
extends GetListReply
case object AuthorizationError
extends GetListReply with DomainError.AuthorizationError with DefaultAccessDeniedError
case object PatientNotFoundError
extends GetListReply with DomainError.NotFoundError with DefaultPatientNotFoundError
final case class CommonError(userMessage: String) extends GetListReply with DomainError
}
sealed trait GetByIdReply
object GetByIdReply {
type Error = GetByIdReply with DomainError
final case class Entity(x: RichPatientCriterion) extends GetByIdReply
case object AuthorizationError
extends GetByIdReply with DomainError.AuthorizationError with DefaultAccessDeniedError
case object NotFoundError extends GetByIdReply with DomainError.NotFoundError with DefaultNotFoundError
case object PatientNotFoundError
extends GetByIdReply with DomainError.NotFoundError with DefaultPatientNotFoundError
final case class CommonError(userMessage: String) extends GetByIdReply with DomainError
implicit def toPhiString(reply: GetByIdReply): PhiString = reply match {
case x: DomainError => phi"GetByIdReply.Error($x)"
case Entity(x) => phi"GetByIdReply.Entity($x)"
}
}
sealed trait UpdateReply
object UpdateReply {
type Error = UpdateReply with DomainError
final case class Updated(x: RichPatientCriterion) extends UpdateReply
case object UpdatedList extends UpdateReply
case object AuthorizationError
extends UpdateReply with DomainError.AuthorizationError with DefaultAccessDeniedError
case object PatientNotFoundError
extends UpdateReply with DomainError.NotFoundError with DefaultPatientNotFoundError
final case class CommonError(userMessage: String) extends UpdateReply with DomainError
}
}
trait PatientCriterionService {
import PatientCriterionService._
def getAll(patientId: UuidId[Patient],
origFilter: SearchFilterExpr = SearchFilterExpr.Empty,
sorting: Option[Sorting] = None,
pagination: Option[Pagination] = None)(
implicit requestContext: AuthorizedServiceRequestContext[AuthUserInfo]): Future[GetListReply]
def getById(patientId: UuidId[Patient], id: LongId[PatientCriterion])(
implicit requestContext: AuthorizedServiceRequestContext[AuthUserInfo]): Future[GetByIdReply]
def updateList(patientId: UuidId[Patient], draftEntities: List[DraftPatientCriterion])(
implicit requestContext: AuthorizedServiceRequestContext[AuthUserInfo]): Future[UpdateReply]
def update(origEntity: PatientCriterion, draftEntity: PatientCriterion, patientId: UuidId[Patient])(
implicit requestContext: AuthorizedServiceRequestContext[AuthUserInfo]): Future[UpdateReply]
}
|
