1 files changed, 55 insertions, 0 deletions
diff --git a/crashbox-http/src/main/scala/io/crashbox/ci/Main.scala b/crashbox-http/src/main/scala/io/crashbox/ci/Main.scala
new file mode 100644
index 0000000..6a61e51
--- /dev/null
+++ b/crashbox-http/src/main/scala/io/crashbox/ci/Main.scala
@@ -0,0 +1,55 @@
+package io.crashbox.ci
+
+import akka.actor.ActorSystem
+import akka.http.scaladsl.Http
+import akka.http.scaladsl.server.directives.Credentials
+import akka.stream.ActorMaterializer
+import java.text.SimpleDateFormat
+import java.util.Date
+import scala.util.{Failure, Success}
+
+object Main {
+
+  implicit val system = ActorSystem("crashbox")
+  implicit val materializer = ActorMaterializer()
+  implicit val executionContext = system.dispatcher
+
+  def main(args: Array[String]): Unit = {
+    val host = system.settings.config.getString("crashbox.host")
+    val port = system.settings.config.getInt("crashbox.port")
+
+    Http(system).bindAndHandle(Route.route, host, port) onComplete {
+      case Success(_) =>
+        system.log.info(s"Listening on $host:$port")
+      case Failure(ex) =>
+        system.log.error(ex, s"Failed to bind to $host:$port")
+        system.terminate()
+    }
+  }
+
+}
+
+object Route {
+  import akka.http.scaladsl.server._
+  import Directives._
+
+  private val formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")
+
+  def route: Route = {
+    pathEndOrSingleSlash {
+      complete(s"Served at ${formatter.format(new Date)}")
+    } ~ path("secure") {
+      authenticateBasic(realm = "secure site", myUserPassAuthenticator) {
+        userName =>
+          complete(s"The user is '$userName'")
+      }
+    }
+  }
+
+  def myUserPassAuthenticator(credentials: Credentials): Option[String] = {
+    credentials match {
+      case p @ Credentials.Provided(id) if p.verify("guest") => Some(id)
+      case _ => None
+    }
+  }
+}