deepcrayon/lila
deepcrayon/lila
1
0
Fork 0
Code Releases Activity

re-index games from secondary DB

Browse source
This commit is contained in:
Thibault Duplessis 2016-03-18 14:30:37 +07:00
parent 9eea99363e
commit 6a4ab765ae
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
modules/gameSearch/src/main/GameSearchApi.scala
View file

@ -99,6 +99,7 @@ final class GameSearchApi(client: ESClient) extends SearchReadApi[Game, Query] {
private def doIndex(client: ESClientHttp, since: DateTime): Funit = {
import lila.game.BSONHandlers._
import lila.db.BSON.BSONJodaDateTimeHandler
import reactivemongo.api._
import reactivemongo.bson._
var nbSkipped = 0
val batchSize = 1000
@ -108,7 +109,7 @@ final class GameSearchApi(client: ESClient) extends SearchReadApi[Game, Query] {
lila.game.tube.gameTube.coll.find(BSONDocument(
"ca" -> BSONDocument("$gt" -> since)
)).sort(BSONDocument("ca" -> 1))
.cursor[Game]()
.cursor[Game](ReadPreference.secondaryPreferred)
.enumerate(maxGames, stopOnError = true) &>
Enumeratee.grouped(Iteratee takeUpTo batchSize) |>>>
Enumeratee.mapM[Seq[Game]].apply[(Seq[Game], Set[String])] { games =>