TestProbe未接收到来自RouteSpec的消息

Question

我在试图"模拟"Route后面的Actor时遇到了问题。我希望能够在测试时覆盖和模拟功能，我认为TestProbe是实现这一点的正确方法。

然而，我还没有得到一个TestProbe来接收一个请求。使用probe.expectMsg(request)时，使用assertion failed: timeout (3 seconds) during expectMsg while waiting for GetCardRequest(12345)测试失败。由于check块处的Request was rejected，移除expectMsg和reply调用仍将导致测试失败。我希望val result = request ~> routes ~> runRoute能够触及底层的TestProbe。

我觉得我只是不明白一些简单的设置！感谢您的提前帮助！

class MyRoutesSpec 
extends WordSpec 
with Matchers 
with ScalaFutures 
with ScalatestRouteTest
with MyRoutes {
lazy val routes = MyRoutes
val probe = new TestProbe(system)
override val cardLookupActor = probe.ref
//TODO figure out how to get TestProbe to actually work!!
"My Routes" should {
"be able to get a card from a request" in {
val cardRequest = GetCardRequest("12345")
val cardRequestEntity = Marshal(cardRequest).to[MessageEntity].futureValue // futureValue is from ScalaFutures
val request = Post("/getcard").withEntity(cardRequestEntity)
val cardResponse = ClientCard("Hello", "World")
val result = request ~> routes ~> runRoute
probe.expectMsg(cardRequest)
probe.reply(cardResponse)
check {
status should ===(StatusCodes.Created)
contentType should ===(ContentTypes.`application/json`)
entityAs[String] should ===("""{"cardName":"Hello", "cardType":"World"}""")
} (result)
}
}
}

trait MyRoutes extends JsonSupport {
// we leave these abstract, since they will be provided by the App
implicit def system: ActorSystem
lazy val log = Logging(system, classOf[MyRoutes])
// other dependencies that Routes use
def cardLookupActor: ActorRef
// Required by the `ask` (?) method below
implicit lazy val timeout = Timeout(5.seconds) 
lazy val myRoutes: Route =
pathPrefix("getcard") {
concat(
path(Segment) { id =>
concat(
get {
val cardFuture: Future[ClientCard] =
(cardLookupActor ? GetCardRequest(id = id)).mapTo[ClientCard]
})
})
}
}

Answer 1

您的测试是有效的，但它只是证明测试探针从未被调用。

检查通过OK 的测试

import akka.Done
import akka.actor.ActorRef
import akka.actor.ActorSystem
import akka.event.Logging
import akka.http.scaladsl.server._
import akka.http.scaladsl.server.Directives._
import akka.http.scaladsl.model.StatusCodes
import akka.http.scaladsl.testkit.ScalatestRouteTest
import akka.testkit.TestProbe
import akka.util.Timeout
import org.scalatest.Matchers
import org.scalatest.WordSpec
import org.scalatest.concurrent.ScalaFutures
import akka.pattern.ask
import concurrent.duration._
class MyRoutesSpec extends WordSpec with Matchers with ScalaFutures with ScalatestRouteTest with MyRoutes {
val probe = new TestProbe(system)
override val cardLookupActor = probe.ref
//TODO figure out how to get TestProbe to actually work!!
"My Routes" should {
"be able to get a card from a request" in {
val cardRequest = "12345"
val request = Get("/getcard/sss").withEntity(cardRequest)
val cardResponse = "HelloWorld"
val result = request ~> myRoutes ~> runRoute
probe.expectMsg(Done)
probe.reply(cardResponse)
check {
status should ===(StatusCodes.OK)
entityAs[String] should ===("""HelloWorld""")
}(result)
}
}
}
trait MyRoutes {
// we leave these abstract, since they will be provided by the App
implicit def system: ActorSystem
lazy val log = Logging(system, classOf[MyRoutes])
// other dependencies that Routes use
def cardLookupActor: ActorRef
// Required by the `ask` (?) method below
implicit lazy val timeout = Timeout(5.seconds)
lazy val myRoutes: Route =
pathPrefix("getcard") {
path(Segment) { _ =>
get {
complete((cardLookupActor ? Done).mapTo[String])
}
}
}
}

什么修复了

• lazy val routes = MyRoutes已删除
• 您发送Post，但路由需要Get
• 测试中没有通过的段，即/getcard在pathPrefix("getcard"(｛path(segment(｛id=>？？？｝｝中不匹配
• 调用request ~> myRoutes ~> runRoute而不是request ~> routes ~> runRoute
• 我删除了案例类只是为了能够运行它