在Playframework 2.4中爲ReactiveMongoApi編寫ScalaTest？

Question

我想在我的應用程序中開始爲mongodb編寫測試。

看來，我不能得到它的工作，因爲在執行保存之前連接已關閉。

下面是結果

[info] UserDaoMongoSpec: 
[info] UserDao 
[info] - application - ReactiveMongoApi starting... 
[info] - application - ReactiveMongoApi successfully started with DB 'test'! Servers: 
      [localhost:27017] 
[info] - should save users and find them by userId 
[info] - application - ReactiveMongoApi stopping... 
[info] - application - ReactiveMongoApi connections stopped. [Success(Closed)] 
[INFO] [12/24/2015 15:36:43.961] [reactivemongo-akka.actor.default-dispatcher-4] [akka://reactivemongo/user/Monitor-3] Message [reactivemongo.core.actors.Close$] from Actor[akka://reactivemongo/deadLetters] to Actor[akka://reactivemongo/user/Monitor-3#1192398481] was not delivered. [1] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'. 
[info] ScalaTest 
[info] Run completed in 3 seconds, 989 milliseconds. 
[info] Total number of tests run: 1 
[info] Suites: completed 1, aborted 0 
[info] Tests: succeeded 1, failed 0, canceled 0, ignored 0, pending 0 
[info] All tests passed. 
[info] Passed: Total 1, Failed 0, Errors 0, Passed 1 

這是測試，這是不測試任何的代碼，但我想先寫數據庫。

package test.daos 

import scala.concurrent.ExecutionContext.Implicits.global 

import daos.impl.UserDaoMongo 

import org.scalatest._ 
import play.api.test._ 
import play.api.test.Helpers._ 
import org.scalatestplus.play._ 

class UserDaoMongoSpec extends DaosApplicationSpecOneAppPerTest { 

    "UserDao" should { 
    "save users and find them by userId" in { 
     val userDao = new UserDaoMongo 
     val future = for { 
     _ <- userDao.save(credentialsTestUser) 
     maybeUser <- userDao.find(credentialsTestUser.id) 
     } yield maybeUser.map(_ == credentialsTestUser) 
    } 
    } 

} 

而且DAO實現

package daos.impl 

import java.util.UUID 

import scala.concurrent.Future 

import play.api.Play.current 
import play.api.libs.concurrent.Execution.Implicits.defaultContext 
import play.api.libs.json.Json 

import play.modules.reactivemongo.ReactiveMongoApi 
import play.modules.reactivemongo.json._ 
import play.modules.reactivemongo.json.collection.JSONCollection 

import com.mohiva.play.silhouette.api.LoginInfo 

import models.{User, Profile} 
import models.User._ 

import daos.api.UserDao 

import play.api.Logger 

class UserDaoMongo extends UserDao { 
    lazy val reactiveMongoApi = current.injector.instanceOf[ReactiveMongoApi] 
    val users = reactiveMongoApi.db.collection[JSONCollection]("users") 

    def find(loginInfo:LoginInfo):Future[Option[User]] = 
    users.find(Json.obj("profiles.loginInfo" -> loginInfo)).one[User] 

    def find(userId:UUID):Future[Option[User]] ={ 
    Logger.debug("AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA") 
    users.find(Json.obj("id" -> userId)).one[User] 
    } 

    def save(user:User):Future[User] = 
    users.insert(user).map(_ => user) 

    def confirm(loginInfo:LoginInfo):Future[User] = for { 
    _ <- users.update(Json.obj(
     "profiles.loginInfo" -> loginInfo 
    ), Json.obj("$set" -> Json.obj("profiles.$.confirmed" -> true))) 
    user <- find(loginInfo) 
    } yield user.get 

    def link(user:User, profile:Profile) = for { 
    _ <- users.update(Json.obj(
     "id" -> user.id 
    ), Json.obj("$push" -> Json.obj("profiles" -> profile))) 
    user <- find(user.id) 
    } yield user.get 

    def update(profile:Profile) = for { 
    _ <- users.update(Json.obj(
     "profiles.loginInfo" -> profile.loginInfo 
    ), Json.obj("$set" -> Json.obj("profiles.$" -> profile))) 
    user <- find(profile.loginInfo) 
    } yield user.get 
} 

可能是什麼，我做錯了什麼？

謝謝

Answer 1

正如評論說，事實證明，錯誤的是，我並沒有等待將來完成。我決定用ScalaTest特定功能進行測試，等待期貨落成

下面是代碼

"UserDao" should { 

    "save users and find them by userId" in withUserDao { userDao => 
    val future = for { 
     user <- userDao.save(credentialsTestUser) 
     maybeUser <- userDao.find(credentialsTestUser.id) 
    } yield { 
     maybeUser.map(_ == credentialsTestUser) 
    } 
    whenReady (future) { result => 
     result.get must be (true) 
    } 
    } 
} 

以防萬一，我覆蓋默認行爲，因爲默認的時間是不夠的

implicit override val patienceConfig = 
    PatienceConfig(timeout = Span(2, Seconds), interval = Span(5, Millis)) 

謝謝