corruptmemory · January 23, 2012 06:18 · Jan 23, 2012
diff --git a/gistfile1.scala b/gistfile1.scala
@@ -0,0 +1,75 @@
+package com.corruptmemory.blueeyes_pong
+
+import akka.dispatch.{Future,Promise}
+import akka.util.Timeout
+import blueeyes.{BlueEyesServer,BlueEyesServiceBuilder}
+import blueeyes.core.data.FileSource._
+import blueeyes.core.data.{FileSource, ByteChunk, BijectionsChunkJson, BijectionsChunkString, BijectionsChunkFutureJson}
+import blueeyes.core.http.HttpStatusCodes._
+import blueeyes.core.http.MimeTypes._
+import blueeyes.core.http.combinators.HttpRequestCombinators
+import blueeyes.core.http.{HttpHeaders, HttpStatusCodes, HttpStatus, HttpRequest, HttpResponse}
+import blueeyes.core.service.ServerHealthMonitorService
+import blueeyes.core.service.engines.HttpClientXLightWeb
+import blueeyes.health.metrics._
+import com.weiglewilczek.slf4s.Logging
+import java.io.File
+import java.util.concurrent.CountDownLatch
+import net.lag.configgy.{Configgy, ConfigMap}
+
+object Pong extends PongStart {
+  def main(args: Array[String]) {
+    startServer()
+  }
+}
+
+object PongServer extends BlueEyesServer with PongService
+
+trait PongStart extends Logging { self =>
+  private var server: Option[BlueEyesServer] = _
+
+  var port = 8084
+
+  private val configPattern = """server{
+    port = %d
+    sslPort = %d
+    sslEnable = false
+  }"""
+
+  def startServer() {
+    def start(port: Int) {
+      Configgy.configureFromString(configPattern.format(port, port + 1))
+
+      server = Some(PongServer)
+      server.get.start onFailure {
+        case v =>
+          logger.error("Server failed to start, trying port " + (port + 2))
+          start(port + 2)
+      }
+    }
+
+    start(port)
+  }
+
+  def stopServer = server.foreach(_.stop)
+}
+
+trait PongService extends BlueEyesServiceBuilder with HttpRequestCombinators {
+  implicit def queryTimeout = Timeout(30000)
+
+  import BijectionsChunkJson._
+  import BijectionsChunkString._
+  import BijectionsChunkFutureJson._
+  val pongService = service("pong", "1.0.0") { context =>
+    startup { Promise.successful(()) }->
+    request { (_:Unit) =>
+      describe("Returns PONG"){
+        path("/ping") {
+          produce(text/plain) {
+            get { request: HttpRequest[ByteChunk] => Future(HttpResponse(content = Some("PONG"))) }
+          }
+        }
+      }
+    }-> shutdown { _ => Future(()) }
+  }
+}