如何在使用Spray反序列化具有型別引數的Trait時對外部呼叫進行分頁？

我有類似結構的物件

case class Countries(countries: Array[Country])
case class Users(users: Array[User])
case class States(states: Array[States]) 

上面提到的類用于從外部 API 呼叫填充資料：

class GenericHttpDataPuller[U:JsonReader, V:JsonReader](val endPoint:String) {
  def getEntity[T:JsonReader](request: HttpRequest): Option[T] = {
      Try(httpClient.singleRequest(httpRequest).entity.parseJson.convertTo[T]) match 
     {
        case scala.util.Success(entityTry) => Some(entityTry)
        case scala.util.Failure(exception) => None
     }
  }

  def get(id:String, options: Map[String, String]): Option[U] = {
     val uri = Uri(s"/$endPoint/$Id").withQuery(Uri.Query(queryMap.getOrElse(Map.empty[String,String])))
     val httpRequest = HttpRequest(HttpMethods.GET,uri = uri,headers = additionalHeaders)
     getEntity[U](httpRequest)
  }

  def getList(options: Map[String, String]): Option[V] = {
     val uri = Uri(s"/$endPoint").withQuery(Uri.Query(queryMap.getOrElse(Map.empty[String,String])))
     val httpRequest = HttpRequest(HttpMethods.GET,uri = uri,headers = additionalHeaders)
     getEntity[V](httpRequest)
  }
}

呼叫者

type HttpUserDataPuller = GenericHttpDataPuller[User, Users]
val users = new HttpUserDataPuller("users"). getList(None)
val user = new HttpUserDataPuller("users").get("someId", None)

上面的代碼作業正常。

我想getList根據options引數對方法進行分頁呼叫。我的更改與上述代碼不兼容，

trait Pagination[V, U] {
  def getSize(): Int
  def getAppend(u: Option[U]): Option[U]
}

case class Users(users: Array[User]) extends Pagination[User, Users] {
   override def getSize(): Int = users.size
   override def getAppend(u: Option[Users]): Option[Users] = { // u is the return value from getEntity()
      val users = u.map(that => that.users    this.users).getOrElse(Array.empty[User])
      Some(Users(users)) }
}

getList方法將如下所示，使用我能想到的getSize和getAppend方法進行下一次呼叫（skip when getSize != current_page_size），基于getEntity[PaginationAppender]我這樣做時的回傳型別，因為我無法trait使用 Spary反序列化帶有型別引數的 a。

  def getList(options: Map[String, String]): Option[PaginationAppender[U, V]] = {
     val limit = Try(queryMap.getOrElse(Map.empty[String, String]).getOrElse("limit", "-1").toInt).getOrElse(-1)
     val uri = Uri(s"/$endPoint").withQuery(Uri.Query(queryMap.getOrElse(Map.empty[String,String])))
     val httpRequest = HttpRequest(HttpMethods.GET,uri = uri,headers = additionalHeaders)
     val returnValue = getEntity[PaginationAppender[U, V]]

     def paginateData(currentPage: Option[PaginationAppender[U, V]]):Option[PaginationAppender[U, V]] = {
         //page size is same as current request return value then go for next page
         if(limit == currentPage.map(_.getSize()).getOrElse(0)) {
             val nextPage = getEntity[PaginationAppender[U, V]](updatedRequsestForNextPage)
             paginateData(currentPage.flatMap(now => now.append(nextPage)))
         } else {
              currentPage
         }
        paginateData(returnValue)
     }
    
  }

在不對現有結構進行太多更改的情況下，是否有更好的解決方法來解決此問題。

干杯！！！

uj5u.com熱心網友回復：

使用了一個特性

trait PaginationAppender {
  type T
  def get(): Array[T]
}

由用戶實作為

case class Users(users:Array[User]) extends PaginationAppender {
  override type T = User
  override def get(): Array[User] = this.users
}

分頁方法

def paginateData[T:ClassTag, V <: PaginationAppender](httpUserDataPuller: GenericHttpDataPuller[T, V],
                                                        userId:String,
                                                        externalQueryMapOpt:Option[Map[String, String]] = None,
                                                        additionalHeaders:Option[Array[HttpHeader]] = None,
                                                        retry: Boolean = true,
                                                        limit: Int = 10,
                                                        offset: Int = 0
                                                       ): ArraySeq[V#T] = {
    val updatedExternalQueryMap = externalQueryMapOpt.getOrElse(Map.empty[String, String])   ("limit" -> limit.toString) // add -OR- update limit to existing options
    @tailrec
    def getData(makeNextCall:Boolean, currentOffset: Int, existingData:  ArraySeq[V#T] = ArraySeq.empty[V#T]): ArraySeq[V#T] = {
      makeNextCall match {
        case true =>
          val currentPage = httpUserDataPuller.list(Some(updatedExternalQueryMap   ("offset" -> currentOffset.toString)), // add -OR- update offset to existing options
            userId,
            additionalHeaders,
            retry).getOrElse(throw new IllegalArgumentException(s"Failed to list from generic pagination")).get()
          getData(currentPage.size == limit, currentOffset   limit, existingData    currentPage)
        case false => existingData
      }
    }
    getData(true, offset) //first time call
  }

呼叫者

paginateData[User, Users](new HttpUserDataPuller("users"), "user")

標籤：斯卡拉 泛型 喷 喷雾-json

上一篇：您如何將_Generic與C中的typedef-ed結構一起使用？

下一篇：打字稿泛型：來自介面子項的只讀值