ReactiveMongo FindAndModify Уточнение

Question

У меня есть коллекция в моей базе данных MongoDB с несколькими ключами. Теперь я хочу обновить эту коллекцию новым полем. Так вот, что я до сих пор:

def confirm(hash: String) = { 

    val myDb = dbConn.db(dbName) 
    val userCollection = myDb[BSONCollection]("user") 

    val selector = BSONDocument(idKey -> BSONObjectID(hash)) 
    val modifier = BSONDocument(
     "$set" -> BSONDocument("date" -> BSONString(now.toString)) // Line 1 
    ) 

    val command = FindAndModify(
     userCollection.name, 
     selector, 
     Update(modifier, fetchNewObject = true) 
    ) 

    myDb.command(command) 
     .map { user => // Line 2 
     Right(bidList) 
    }.recover { 
     case LastError(ok,err, code, errMsg, _) => 
     Left(ServiceError(errMsg.getOrElse("failure!"))) 
    } 
    } 

У меня есть две проблемы, связанные с реализацией выше:

On Line 1: Будет ли это обновление существующего документа с новым полем называется дата?

On Line 2: Сопоставление команды myDb.command (команда) дает мне опцию [BSONDocument], но меня удивляет то, что у меня есть неявное преобразование в сфере видимости. Поэтому я ожидал, что он вернет опцию [Пользователь]!

Answer 1

Вы можете посмотреть на .findAndUpdate и до FindAndModifyResult, который обеспечивает операцию .result, чтобы получить результат согласно имеющимся считывателям BSON.

val person: Future[Option[AType]] = collection.findAndUpdate(
    BSONDocument("name" -> "James"), 
    BSONDocument("$set" -> BSONDocument("age" -> 17)), 
    fetchNewObject = true).map(_.result[AType]) 

Answer 2

Я просто потратил некоторое время на поиск play-reactivemongo эквивалента. Может быть, этот пример поможет кому-то в будущем.

val collectionFut: Future[JSONCollection] = reactiveMongoApi.database.map(_.collection[JSONCollection]("sale.numberingCounter")) 

def updateIdx(nsId: NumberingSeriesId, month: Option[Int], year: Option[Int], value: Int): Future[Option[NumberingCounter]] = { 
val selector = Json.obj("numberingSeriesId" -> nsId, "month" -> month, "year" -> year)   
val modifier = Json.obj("$set" -> Json.obj("idx" -> value)) 
    for { 
     collection <- collectionFut 
     writeResult <- collection.findAndUpdate(selector,modifier,upsert = true) 
    } yield { 
     writeResult.value.map(_.as[NumberingCounter]) 
    } 
    }