From 354a21d1a72867b352edbd0aa25b4980938d2749 Mon Sep 17 00:00:00 2001 From: Zach Smith Date: Mon, 16 Oct 2017 11:54:59 -0700 Subject: Consolidate files --- src/main/scala/xyz/driver/core/rest/package.scala | 23 ++++++++++++++++++++--- 1 file changed, 20 insertions(+), 3 deletions(-) (limited to 'src/main/scala/xyz/driver/core/rest/package.scala') diff --git a/src/main/scala/xyz/driver/core/rest/package.scala b/src/main/scala/xyz/driver/core/rest/package.scala index e6eb8d6..6019c33 100644 --- a/src/main/scala/xyz/driver/core/rest/package.scala +++ b/src/main/scala/xyz/driver/core/rest/package.scala @@ -1,16 +1,33 @@ -package xyz.driver.core +package xyz.driver.core.rest -import akka.http.scaladsl.model.HttpRequest +import akka.http.scaladsl.model.{HttpRequest, HttpResponse, ResponseEntity} import akka.http.scaladsl.server.Directives._ import akka.http.scaladsl.server._ +import akka.http.scaladsl.unmarshalling.Unmarshal import akka.stream.scaladsl.Flow import akka.util.ByteString import xyz.driver.tracing.TracingDirectives +import scala.concurrent.Future import scalaz.Scalaz.{intInstance, stringInstance} import scalaz.syntax.equal._ -package object rest { +trait 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): Future[Unmarshal[ResponseEntity]] +} + +final case class Pagination(pageSize: Int, pageNumber: Int) + +object `package` { object ContextHeaders { val AuthenticationTokenHeader: String = "Authorization" val PermissionsTokenHeader: String = "Permissions" -- cgit v1.2.3