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

---
 .../scala/xyz/driver/core/rest/ProxyRoute.scala    | 26 ++++++++++++++++++++++
 1 file changed, 26 insertions(+)
 create mode 100644 core-rest/src/main/scala/xyz/driver/core/rest/ProxyRoute.scala

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

diff --git a/core-rest/src/main/scala/xyz/driver/core/rest/ProxyRoute.scala b/core-rest/src/main/scala/xyz/driver/core/rest/ProxyRoute.scala
new file mode 100644
index 0000000..c0e9f99
--- /dev/null
+++ b/core-rest/src/main/scala/xyz/driver/core/rest/ProxyRoute.scala
@@ -0,0 +1,26 @@
+package xyz.driver.core.rest
+
+import akka.http.scaladsl.server.{RequestContext, Route, RouteResult}
+import com.typesafe.config.Config
+import xyz.driver.core.Name
+
+import scala.concurrent.ExecutionContext
+
+trait ProxyRoute extends DriverRoute {
+  implicit val executionContext: ExecutionContext
+  val config: Config
+  val httpClient: HttpClient
+
+  protected def proxyToService(serviceName: Name[Service]): Route = { ctx: RequestContext =>
+    val httpScheme = config.getString(s"services.${serviceName.value}.httpScheme")
+    val baseUrl    = config.getString(s"services.${serviceName.value}.baseUrl")
+
+    val originalUri     = ctx.request.uri
+    val originalRequest = ctx.request
+
+    val newUri     = originalUri.withScheme(httpScheme).withHost(baseUrl)
+    val newRequest = originalRequest.withUri(newUri)
+
+    httpClient.makeRequest(newRequest).map(RouteResult.Complete)
+  }
+}
-- 
cgit v1.2.3