aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/xyz/driver/pdsuidomain/formats/json/criterion.scala
diff options
context:
space:
mode:
authorKseniya Tomskikh <ktomskih@datamonsters.co>2017-10-20 16:25:04 +0700
committerKseniya Tomskikh <ktomskih@datamonsters.co>2017-10-20 16:25:04 +0700
commit54b15dae509212f6661dc1f1bc4ca248cb487443 (patch)
tree85b1ceafd9a56da511513797bd263977f52b556c /src/main/scala/xyz/driver/pdsuidomain/formats/json/criterion.scala
parent6d6e732368e97e319653f00e498189afceeb4671 (diff)
downloadrest-query-54b15dae509212f6661dc1f1bc4ca248cb487443.tar.gz
rest-query-54b15dae509212f6661dc1f1bc4ca248cb487443.tar.bz2
rest-query-54b15dae509212f6661dc1f1bc4ca248cb487443.zip
PDSUI-2336 Deleted api classes of play format, userhistory and message services
Diffstat (limited to 'src/main/scala/xyz/driver/pdsuidomain/formats/json/criterion.scala')
-rw-r--r--src/main/scala/xyz/driver/pdsuidomain/formats/json/criterion.scala171
1 files changed, 171 insertions, 0 deletions
diff --git a/src/main/scala/xyz/driver/pdsuidomain/formats/json/criterion.scala b/src/main/scala/xyz/driver/pdsuidomain/formats/json/criterion.scala
new file mode 100644
index 0000000..d7acfd4
--- /dev/null
+++ b/src/main/scala/xyz/driver/pdsuidomain/formats/json/criterion.scala
@@ -0,0 +1,171 @@
+package xyz.driver.pdsuidomain.formats.json
+
+import spray.json._
+import xyz.driver.entities.labels.{Label, LabelCategory}
+import xyz.driver.pdsuicommon.domain.{LongId, StringId}
+import xyz.driver.pdsuidomain.entities._
+import xyz.driver.pdsuidomain.services.CriterionService.RichCriterion
+
+object criterion {
+ import DefaultJsonProtocol._
+ import common._
+
+ implicit val criterionLabelWriter: RootJsonWriter[CriterionLabel] = new RootJsonWriter[CriterionLabel] {
+ override def write(obj: CriterionLabel) = JsObject(
+ "labelId" -> obj.labelId.toJson,
+ "categoryId" -> obj.categoryId.toJson,
+ "value" -> obj.value.map {
+ case true => "Yes"
+ case false => "No"
+ }.toJson,
+ "isDefining" -> obj.isDefining.toJson
+ )
+ }
+
+ def jsValueToCriterionLabel(json: JsValue, criterionId: LongId[Criterion]): CriterionLabel = json match {
+ case JsObject(fields) =>
+ val labelId = fields
+ .get("labelId")
+ .flatMap(_.convertTo[Option[LongId[Label]]])
+
+ val categoryId = fields
+ .get("categoryId")
+ .flatMap(_.convertTo[Option[LongId[LabelCategory]]])
+
+ val value = fields
+ .get("value")
+ .flatMap(_.convertTo[Option[String]])
+ .map {
+ case "Yes" => true
+ case "No" => false
+ case other =>
+ deserializationError(s"Unknown `value` of CriterionLabel object: expected `yes` or `no`, but got $other")
+ }
+
+ val isDefining = fields
+ .get("isDefining")
+ .map(_.convertTo[Boolean])
+ .getOrElse(deserializationError(s"CriterionLabel json object does not contain `isDefining` field: $json"))
+
+ CriterionLabel(
+ id = LongId(0L),
+ labelId = labelId,
+ criterionId = criterionId,
+ categoryId = categoryId,
+ value = value,
+ isDefining = isDefining
+ )
+
+ case _ => deserializationError(s"Expected Json Object as CriterionLabel, but got $json")
+ }
+
+ def applyUpdateToCriterion(json: JsValue, orig: RichCriterion): RichCriterion = json match {
+ case JsObject(fields) =>
+ val text = fields
+ .get("text")
+ .map(_.convertTo[String])
+
+ val isCompound = fields
+ .get("isCompound")
+ .exists(_.convertTo[Boolean])
+
+ val meta = fields
+ .get("meta")
+ .map(_.convertTo[Option[String]].getOrElse("{}"))
+ .getOrElse(orig.criterion.meta)
+
+ val inclusion = fields
+ .get("inclusion")
+ .map(_.convertTo[Option[Boolean]])
+ .getOrElse(orig.criterion.inclusion)
+
+ val arms = fields
+ .get("arms")
+ .map(_.convertTo[Option[List[LongId[EligibilityArm]]]].getOrElse(List.empty[LongId[EligibilityArm]]))
+ .getOrElse(orig.armIds)
+
+ val labels = fields
+ .get("labels")
+ .map(_.convertTo[Option[List[JsValue]]].getOrElse(List.empty[JsValue]))
+ .map(_.map(l => jsValueToCriterionLabel(l, orig.criterion.id)))
+ .getOrElse(orig.labels)
+
+ orig.copy(
+ criterion = orig.criterion.copy(
+ meta = meta,
+ text = text,
+ isCompound = isCompound,
+ inclusion = inclusion
+ ),
+ armIds = arms,
+ labels = labels
+ )
+
+ case _ => deserializationError(s"Expected Json Object as partial Criterion, but got $json")
+ }
+
+ implicit val richCriterionFormat: RootJsonFormat[RichCriterion] = new RootJsonFormat[RichCriterion] {
+ override def write(obj: RichCriterion): JsValue =
+ JsObject(
+ "id" -> obj.criterion.id.toJson,
+ "meta" -> Option(obj.criterion.meta).toJson,
+ "arms" -> obj.armIds.toJson,
+ "text" -> obj.criterion.text.toJson,
+ "isCompound" -> obj.criterion.isCompound.toJson,
+ "labels" -> obj.labels.map(_.toJson).toJson,
+ "trialId" -> obj.criterion.trialId.toJson,
+ "inclusion" -> obj.criterion.inclusion.toJson
+ )
+
+ override def read(json: JsValue): RichCriterion = json match {
+ case JsObject(fields) =>
+ val trialId = fields
+ .get("trialId")
+ .map(_.convertTo[StringId[Trial]])
+ .getOrElse(deserializationError(s"Criterion json object does not contain `trialId` field: $json"))
+
+ val text = fields
+ .get("text")
+ .flatMap(_.convertTo[Option[String]])
+
+ val isCompound = fields
+ .get("isCompound")
+ .exists(_.convertTo[Boolean])
+
+ val meta = fields
+ .get("meta")
+ .flatMap(_.convertTo[Option[String]])
+
+ val inclusion = fields
+ .get("inclusion")
+ .flatMap(_.convertTo[Option[Boolean]])
+
+ val arms = fields
+ .get("arms")
+ .map(_.convertTo[Seq[LongId[EligibilityArm]]])
+ .getOrElse(Seq.empty[LongId[EligibilityArm]])
+
+ val labels = fields
+ .get("labels")
+ .map(_.convertTo[Seq[JsValue]])
+ .map(_.map(l => jsValueToCriterionLabel(l, LongId(0))))
+ .getOrElse(Seq.empty[CriterionLabel])
+
+ RichCriterion(
+ criterion = Criterion(
+ id = LongId(0),
+ trialId = trialId,
+ text = text,
+ isCompound = isCompound,
+ meta = meta.getOrElse(""),
+ inclusion = inclusion
+ ),
+ armIds = arms,
+ labels = labels
+ )
+
+ case _ => deserializationError(s"Expected Json Object as Criterion, but got $json")
+ }
+ }
+
+}