HttpxToHttpFilter.scala

import com.twitter.finagle.{Filter, Service}
import com.twitter.finagle.http.{Request ⇒ HttpRequest, Response ⇒ HttpResponse}
import com.twitter.util.Future
import io.finch.{HttpRequest ⇒ HttpxRequest, HttpResponse ⇒ HttpxResponse}
import org.jboss.netty.handler.codec.http.{HttpResponse ⇒ NettyHttpResponse}

/**
 * Convert from finagle new `Httpx` to the `Http` representation
 *
 * This is required to make `httpx` services compatible
 * with functionalities that are only available to `Http`
 */
object HttpxToHttpFilter extends Filter[HttpRequest, HttpResponse, HttpxRequest, HttpxResponse] {
  override def apply(request: HttpRequest, service: Service[HttpxRequest, HttpxResponse]): Future[HttpResponse] = {
    val httpxReq = new HttpxRequest {
      val httpRequest = request
      lazy val remoteSocketAddress = request.remoteSocketAddress
    }

    service(httpxReq).map { rep ⇒
      new HttpResponse {
        val httpResponse: NettyHttpResponse = rep.self.asInstanceOf[NettyHttpResponse]
      }
    }
  }
}