Finagle: serve Thrift over HTTP

gistfile1.scala

object Main extends App {
  
  val filter = new FooFilter
  val fooService = new FooService.FinagledService(new FooServiceImpl, new TCompactProtocol.Factory()) // Use the protocol your client uses
  val httpService: Service[HttpRequest, HttpResponse] = filter andThen fooService

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

class FooFilter extends Filter[HttpRequest, HttpResponse, Array[Byte], Array[Byte]] {
  override def apply(request: HttpRequest, service: Service[Array[Byte], Array[Byte]]): Future[HttpResponse] = {
    val thriftFuture = service(request.getContent.array())
    thriftFuture flatMap { res =>
      val response = new DefaultHttpResponse(request.getProtocolVersion, HttpResponseStatus.OK)
      response.setContent(ChannelBuffers.wrappedBuffer(res))
      response.headers().set(HttpHeaders.Names.CONTENT_LENGTH, response.getContent.readableBytes.toString)
      Future.value(response)
    }
  }
}