1 files changed, 26 insertions, 3 deletions
diff --git a/src/main/scala/xyz/driver/pdsuidomain/formats/json/sprayformats/ListResponse.scala b/src/main/scala/xyz/driver/pdsuidomain/formats/json/sprayformats/ListResponse.scala
index 2a670c4..4afe0ee 100644
--- a/src/main/scala/xyz/driver/pdsuidomain/formats/json/sprayformats/ListResponse.scala
+++ b/src/main/scala/xyz/driver/pdsuidomain/formats/json/sprayformats/ListResponse.scala
@@ -2,13 +2,14 @@ package xyz.driver.pdsuidomain.formats.json.sprayformats
 
 import java.time.LocalDateTime
 
-import spray.json.{RootJsonFormat, _}
+import spray.json._
+import spray.json.DefaultJsonProtocol._
 import xyz.driver.pdsuicommon.db.Pagination
 import xyz.driver.pdsuidomain.formats.json.sprayformats.common._
 
 final case class ListResponse[+T](items: Seq[T], meta: ListResponse.Meta)
 
-object ListResponse extends DefaultJsonProtocol {
+object ListResponse {
   private val itemsField = "items"
   private val metaField  = "meta"
 
@@ -27,7 +28,7 @@ object ListResponse extends DefaultJsonProtocol {
 
   implicit val listResponseMetaFormat: RootJsonFormat[Meta] = jsonFormat4(Meta.apply)
 
-  implicit def listResponseMetaWriter[T: JsonWriter]: RootJsonWriter[ListResponse[T]] =
+  implicit def listResponseWriter[T: JsonWriter]: RootJsonWriter[ListResponse[T]] =
     new RootJsonWriter[ListResponse[T]] {
       override def write(listResponse: ListResponse[T]): JsValue = {
         JsObject(
@@ -36,4 +37,26 @@ object ListResponse extends DefaultJsonProtocol {
         )
       }
     }
+
+  implicit def listResponseReader[T: JsonReader]: RootJsonReader[ListResponse[T]] =
+    new RootJsonReader[ListResponse[T]] {
+      override def read(json: JsValue): ListResponse[T] = json match {
+        case JsObject(fields) =>
+          val items = fields
+            .get(itemsField)
+            .map {
+              case JsArray(elements) => elements.map(_.convertTo[T])(collection.breakOut)
+              case x                 => deserializationError(s"Expected Array as JsArray, but got $x")
+            }
+            .getOrElse(deserializationError(s"ListResponse json object does not contain `$itemsField` field: $json"))
+
+          val meta = fields
+            .get(metaField)
+            .map(_.convertTo[Meta])
+            .getOrElse(deserializationError(s"ListResponse json object does not contain `$metaField` field: $json"))
+
+          ListResponse(items, meta)
+        case _ => deserializationError(s"Expected ListResponse json object, but got $json")
+      }
+    }
 }