relay.finishedAt

lichess-org/lila#16426
lichess-org · Nov 17, 2024 · 4c2b0fe · 4c2b0fe
1 parent e1370e2
commit 4c2b0fe
Showing 1 changed file with 17 additions and 2 deletions.
diff --git a/src/main/scala/RelayCrowd.scala b/src/main/scala/RelayCrowd.scala
@@ -36,8 +36,23 @@ final private class RelayCrowd(roomCrowd: RoomCrowd, mongo: Mongo)(using ex: Exe
                   "pipeline" -> List(
                     BSONDocument(
                       "$match" -> BSONDocument(
-                        "finished" -> false,
-                        "$expr"    -> BSONDocument("$eq" -> BSONArray("$tourId", "$$tourId"))
+                        "$expr" -> BSONDocument(
+                          "$and" ->
+                            BSONArray(
+                              BSONDocument(
+                                BSONDocument("$eq" -> BSONArray("$tourId", "$$tourId")),
+                                "$or" -> BSONArray(
+                                  BSONDocument("$exists" -> BSONArray("$finishedAt", false)),
+                                  BSONDocument(
+                                    "$gt" -> BSONArray(
+                                      "$finishedAt",
+                                      BSONDateTime(nowMillis - 1000 * 60 * 60 * 2) // 2 hours
+                                    )
+                                  )
+                                )
+                              )
+                            )
+                        )
                       )
                     ),
                     BSONDocument("$sort"    -> BSONDocument("createdAt" -> 1)),