RoundtripSpec.scala

package com.github.reikje

import java.net.{InetAddress, InetSocketAddress}

import com.twitter.finagle.{Address, Name, ThriftMux, param}
import com.twitter.util.{Await, Future}
import org.scalatest.{Matchers, WordSpec}

class RoundtripSpec extends WordSpec with Matchers {
  "Microservice" should {
    "respond to requests" in {
      val service = new MicroServiceImpl("foo")

      val server = ThriftMux.server
        .configured(param.Label("zuul-thrift"))
        .serveIface(new InetSocketAddress(InetAddress.getLoopbackAddress, 0), service)

      val client = ThriftMux.client.newIface[MicroService.FutureIface](
        Name.bound(Address(server.boundAddress.asInstanceOf[InetSocketAddress])), "microservice-client"
      )

      val response = Await.result(client.request())
      response shouldBe "foo"
    }
  }
}

class MicroServiceImpl(response: String) extends MicroService.FutureIface {
  override def request(): Future[String] = Future.value(response)
}