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
|
package xyz.driver.core.rest
import akka.http.scaladsl.model.{HttpRequest, HttpResponse, ResponseEntity}
import akka.http.scaladsl.unmarshalling.Unmarshal
import akka.stream.Materializer
import scala.concurrent.Future
trait Service
object Service
trait HttpClient {
def makeRequest(request: HttpRequest): Future[HttpResponse]
}
trait ServiceTransport {
def sendRequestGetResponse(context: ServiceRequestContext)(requestStub: HttpRequest): Future[HttpResponse]
def sendRequest(context: ServiceRequestContext)(requestStub: HttpRequest)(
implicit mat: Materializer): Future[Unmarshal[ResponseEntity]]
}
sealed trait SortingOrder
object SortingOrder {
case object Asc extends SortingOrder
case object Desc extends SortingOrder
}
final case class SortingField(name: String, sortingOrder: SortingOrder)
final case class Sorting(sortingFields: Seq[SortingField])
final case class Pagination(pageSize: Int, pageNumber: Int) {
require(pageSize > 0, "Page size must be greater than zero")
require(pageNumber > 0, "Page number must be greater than zero")
def offset: Int = pageSize * (pageNumber - 1)
}
final case class ListResponse[+T](items: Seq[T], meta: ListResponse.Meta)
object ListResponse {
def apply[T](items: Seq[T], size: Int, pagination: Option[Pagination]): ListResponse[T] =
ListResponse(
items = items,
meta = ListResponse.Meta(size, pagination.fold(1)(_.pageNumber), pagination.fold(size)(_.pageSize)))
final case class Meta(itemsCount: Int, pageNumber: Int, pageSize: Int)
object Meta {
def apply(itemsCount: Int, pagination: Pagination): Meta =
Meta(itemsCount, pagination.pageNumber, pagination.pageSize)
}
}
|
