Adding domain entitiesv0.1.0

3 files changed, 0 insertions, 215 deletions

diff --git a/src/main/scala/xyz/driver/common/http/AsyncHttpClientFetcher.scala b/src/main/scala/xyz/driver/common/http/AsyncHttpClientFetcher.scala
deleted file mode 100644
index 5d54f0d..0000000
--- a/src/main/scala/xyz/driver/common/http/AsyncHttpClientFetcher.scala
+++ /dev/null
@@ -1,90 +0,0 @@
-package xyz.driver.common.http
-
-import java.io.Closeable
-import java.net.URL
-import java.util.concurrent.{ExecutorService, Executors}
-
-import com.typesafe.scalalogging.StrictLogging
-import org.asynchttpclient._
-import org.slf4j.MDC
-import xyz.driver.common.concurrent.MdcThreadFactory
-import xyz.driver.common.utils.RandomUtils
-
-import scala.concurrent.duration.FiniteDuration
-import scala.concurrent.{ExecutionContext, Future, Promise}
-
-class AsyncHttpClientFetcher(settings: AsyncHttpClientFetcher.Settings)
-  extends HttpFetcher with Closeable with StrictLogging {
-
-  private val es: ExecutorService = {
-    val threadFactory = MdcThreadFactory.from(Executors.defaultThreadFactory())
-    Executors.newSingleThreadExecutor(threadFactory)
-  }
-
-  private implicit val executionContext = ExecutionContext.fromExecutor(es)
-
-  private def httpClientConfig: DefaultAsyncHttpClientConfig = {
-    val builder = new DefaultAsyncHttpClientConfig.Builder()
-    builder.setConnectTimeout(settings.connectTimeout.toMillis.toInt)
-    builder.setReadTimeout(settings.readTimeout.toMillis.toInt)
-    // builder.setThreadFactory(threadFactory) // Doesn't help to push MDC context into AsyncCompletionHandler
-    builder.build()
-  }
-
-  private val httpClient = new DefaultAsyncHttpClient(httpClientConfig)
-
-  override def apply(url: URL): Future[Array[Byte]] = {
-    val fingerPrint = RandomUtils.randomString(10)
-
-    // log all outcome connections
-    logger.info("{}, apply({})", fingerPrint, url)
-    val promise = Promise[Response]()
-
-    httpClient.prepareGet(url.toString).execute(new AsyncCompletionHandler[Response] {
-      override def onCompleted(response: Response): Response = {
-        promise.success(response)
-        response
-      }
-
-      override def onThrowable(t: Throwable): Unit = {
-        promise.failure(t)
-        super.onThrowable(t)
-      }
-    })
-
-    // Promises have their own ExecutionContext
-    // So, we have to hack it.
-    val parentMdcContext = MDC.getCopyOfContextMap
-    promise.future.flatMap { response =>
-      setContextMap(parentMdcContext)
-
-      if (response.getStatusCode == 200) {
-        // DO NOT LOG body, it could be PHI
-        // logger.trace(response.getResponseBody())
-        val bytes = response.getResponseBodyAsBytes
-        logger.debug("{}, size is {}B", fingerPrint, bytes.size.asInstanceOf[AnyRef])
-        Future.successful(bytes)
-      } else {
-        logger.error("{}, HTTP {}", fingerPrint, response.getStatusCode.asInstanceOf[AnyRef])
-        logger.trace(response.getResponseBody().take(100))
-        Future.failed(new IllegalStateException("An unexpected response from the server"))
-      }
-    }
-  }
-
-  private[this] def setContextMap(context: java.util.Map[String, String]): Unit =
-    Option(context).fold(MDC.clear())(MDC.setContextMap)
-
-  override def close(): Unit = {
-    httpClient.close()
-    es.shutdown()
-  }
-
-}
-
-object AsyncHttpClientFetcher {
-
-  case class Settings(connectTimeout: FiniteDuration,
-                      readTimeout: FiniteDuration)
-
-}
diff --git a/src/main/scala/xyz/driver/common/http/AsyncHttpClientUploader.scala b/src/main/scala/xyz/driver/common/http/AsyncHttpClientUploader.scala
deleted file mode 100644
index 97c96cd..0000000
--- a/src/main/scala/xyz/driver/common/http/AsyncHttpClientUploader.scala
+++ /dev/null
@@ -1,116 +0,0 @@
-package xyz.driver.common.http
-
-import java.io.Closeable
-import java.net.URI
-import java.util.concurrent.{ExecutorService, Executors}
-
-import xyz.driver.common.concurrent.MdcThreadFactory
-import xyz.driver.common.http.AsyncHttpClientUploader._
-import xyz.driver.common.utils.RandomUtils
-import com.typesafe.scalalogging.StrictLogging
-import org.asynchttpclient._
-import org.slf4j.MDC
-
-import scala.concurrent.duration.FiniteDuration
-import scala.concurrent.{ExecutionContext, Future, Promise}
-
-class AsyncHttpClientUploader(settings: Settings) extends Closeable with StrictLogging {
-
-  private val es: ExecutorService = {
-    val threadFactory = MdcThreadFactory.from(Executors.defaultThreadFactory())
-    Executors.newSingleThreadExecutor(threadFactory)
-  }
-
-  private implicit val executionContext = ExecutionContext.fromExecutor(es)
-
-  private def httpClientConfig: DefaultAsyncHttpClientConfig = {
-    val builder = new DefaultAsyncHttpClientConfig.Builder()
-    builder.setConnectTimeout(settings.connectTimeout.toMillis.toInt)
-    builder.setRequestTimeout(settings.requestTimeout.toMillis.toInt)
-    // builder.setThreadFactory(threadFactory) // Doesn't help to push MDC context into AsyncCompletionHandler
-    builder.build()
-  }
-
-  private val httpClient = new DefaultAsyncHttpClient(httpClientConfig)
-
-  def run(method: Method, uri: URI, contentType: String, data: String): Future[Unit] = {
-    // log all outcome connections
-    val fingerPrint = RandomUtils.randomString(10)
-    logger.info("{}, apply(method={}, uri={}, contentType={})", fingerPrint, method, uri, contentType)
-    val promise = Promise[Response]()
-
-    val q = new RequestBuilder(method.toString)
-      .setUrl(uri.toString)
-      .setBody(data)
-
-    settings.defaultHeaders.foreach {
-      case (k, v) =>
-        q.setHeader(k, v)
-    }
-
-    q.addHeader("Content-Type", contentType)
-
-    httpClient.prepareRequest(q).execute(new AsyncCompletionHandler[Unit] {
-      override def onCompleted(response: Response): Unit = {
-        promise.success(response)
-      }
-
-      override def onThrowable(t: Throwable): Unit = {
-        promise.failure(t)
-        super.onThrowable(t)
-      }
-    })
-
-    // see AsyncHttpClientFetcher
-    val parentMdcContext = MDC.getCopyOfContextMap
-    promise.future.flatMap { response =>
-      setContextMap(parentMdcContext)
-
-      val statusCode = response.getStatusCode
-      // https://en.wikipedia.org/wiki/List_of_HTTP_status_codes#2xx_Success
-      if (statusCode >= 200 && statusCode < 300) {
-        logger.debug("{}, success", fingerPrint)
-        Future.successful(())
-      } else {
-        logger.error(
-          "{}, HTTP {}, BODY:\n{}",
-          fingerPrint,
-          response.getStatusCode.asInstanceOf[AnyRef],
-          response.getResponseBody.take(100)
-        )
-        Future.failed(new IllegalStateException("An unexpected response from the server"))
-      }
-    }
-  }
-
-  private[this] def setContextMap(context: java.util.Map[String, String]): Unit =
-    Option(context).fold(MDC.clear())(MDC.setContextMap)
-
-  override def close(): Unit = {
-    httpClient.close()
-    es.shutdown()
-  }
-
-}
-
-object AsyncHttpClientUploader {
-
-  case class Settings(connectTimeout: FiniteDuration,
-                      requestTimeout: FiniteDuration,
-                      defaultHeaders: Map[String, String] = Map.empty)
-
-  sealed trait Method
-
-  object Method {
-
-    case object Put extends Method {
-      override val toString = "PUT"
-    }
-
-    case object Post extends Method {
-      override val toString = "POST"
-    }
-
-  }
-
-}
diff --git a/src/main/scala/xyz/driver/common/http/package.scala b/src/main/scala/xyz/driver/common/http/package.scala
deleted file mode 100644
index 3aff80c..0000000
--- a/src/main/scala/xyz/driver/common/http/package.scala
+++ /dev/null
@@ -1,9 +0,0 @@
-package xyz.driver.common
-
-import java.net.URL
-
-import scala.concurrent.Future
-
-package object http {
-  type HttpFetcher = URL => Future[Array[Byte]]
-}