gistfile1.scala

object Main extends App {

  val thriftService = new FooService.FinagledService(new FooServiceImpl, new TBinaryProtocol.Factory())

  val httpService = new Service[HttpRequest, HttpResponse] {
    def apply(req: HttpRequest): Future[HttpResponse] = {
      val content = ChannelBuffers.wrappedBuffer(req.getContent)
      val thriftFuture = thriftService.apply(content.array())
      thriftFuture flatMap { res =>
        val response = new DefaultHttpResponse(req.getProtocolVersion, HttpResponseStatus.OK)
        response.setContent(ChannelBuffers.wrappedBuffer(res))
        response.headers().set(HttpHeaders.Names.CONTENT_LENGTH, response.getContent.readableBytes.toString)

        Future.value(response)
      }
    }
  }

  val server = Http.serve(":8080", httpService)
  Await.ready(server)
}