From 4d1197099ce4e721c18bf4cacbb2e1980e4210b5 Mon Sep 17 00:00:00 2001
From: Jakob Odersky <jakob@driver.xyz>
Date: Wed, 12 Sep 2018 16:40:57 -0700
Subject: Move REST functionality to separate project

---
 .../xyz/driver/core/rest/PooledHttpClient.scala    | 67 ----------------------
 1 file changed, 67 deletions(-)
 delete mode 100644 src/main/scala/xyz/driver/core/rest/PooledHttpClient.scala

(limited to 'src/main/scala/xyz/driver/core/rest/PooledHttpClient.scala')

diff --git a/src/main/scala/xyz/driver/core/rest/PooledHttpClient.scala b/src/main/scala/xyz/driver/core/rest/PooledHttpClient.scala
deleted file mode 100644
index 2854257..0000000
--- a/src/main/scala/xyz/driver/core/rest/PooledHttpClient.scala
+++ /dev/null
@@ -1,67 +0,0 @@
-package xyz.driver.core.rest
-
-import akka.actor.ActorSystem
-import akka.http.scaladsl.Http
-import akka.http.scaladsl.model.headers.`User-Agent`
-import akka.http.scaladsl.model.{HttpRequest, HttpResponse, Uri}
-import akka.http.scaladsl.settings.{ClientConnectionSettings, ConnectionPoolSettings}
-import akka.stream.scaladsl.{Keep, Sink, Source}
-import akka.stream.{ActorMaterializer, OverflowStrategy, QueueOfferResult, ThrottleMode}
-import xyz.driver.core.Name
-
-import scala.concurrent.{ExecutionContext, Future, Promise}
-import scala.concurrent.duration._
-import scala.util.{Failure, Success}
-
-class PooledHttpClient(
-    baseUri: Uri,
-    applicationName: Name[App],
-    applicationVersion: String,
-    requestRateLimit: Int = 64,
-    requestQueueSize: Int = 1024)(implicit actorSystem: ActorSystem, executionContext: ExecutionContext)
-    extends HttpClient {
-
-  private val host   = baseUri.authority.host.toString()
-  private val port   = baseUri.effectivePort
-  private val scheme = baseUri.scheme
-
-  protected implicit val materializer: ActorMaterializer = ActorMaterializer()(actorSystem)
-
-  private val clientConnectionSettings: ClientConnectionSettings =
-    ClientConnectionSettings(actorSystem).withUserAgentHeader(
-      Option(`User-Agent`(applicationName.value + "/" + applicationVersion)))
-
-  private val connectionPoolSettings: ConnectionPoolSettings = ConnectionPoolSettings(actorSystem)
-    .withConnectionSettings(clientConnectionSettings)
-
-  private val pool = if (scheme.equalsIgnoreCase("https")) {
-    Http().cachedHostConnectionPoolHttps[Promise[HttpResponse]](host, port, settings = connectionPoolSettings)
-  } else {
-    Http().cachedHostConnectionPool[Promise[HttpResponse]](host, port, settings = connectionPoolSettings)
-  }
-
-  private val queue = Source
-    .queue[(HttpRequest, Promise[HttpResponse])](requestQueueSize, OverflowStrategy.dropNew)
-    .via(pool)
-    .throttle(requestRateLimit, 1.second, maximumBurst = requestRateLimit, ThrottleMode.shaping)
-    .toMat(Sink.foreach({
-      case ((Success(resp), p)) => p.success(resp)
-      case ((Failure(e), p))    => p.failure(e)
-    }))(Keep.left)
-    .run
-
-  def makeRequest(request: HttpRequest): Future[HttpResponse] = {
-    val responsePromise = Promise[HttpResponse]()
-
-    queue.offer(request -> responsePromise).flatMap {
-      case QueueOfferResult.Enqueued =>
-        responsePromise.future
-      case QueueOfferResult.Dropped =>
-        Future.failed(new Exception(s"Request queue to the host $host is overflown"))
-      case QueueOfferResult.Failure(ex) =>
-        Future.failed(ex)
-      case QueueOfferResult.QueueClosed =>
-        Future.failed(new Exception("Queue was closed (pool shut down) while running the request"))
-    }
-  }
-}
-- 
cgit v1.2.3