broadcast started game cache with sync.delay

lichess-org · Jun 29, 2024 · e01aa50 · e01aa50
1 parent 362ba23
commit e01aa50
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/modules/relay/src/main/RelayFetch.scala b/modules/relay/src/main/RelayFetch.scala
@@ -267,7 +267,7 @@ final private class RelayFetch(
  httpGetPgn(url).map { MultiPgn.split(_, RelayFetch.maxChapters) }.flatMap(multiPgnToGames.future)
  case RelayFormat.LccWithGames(lcc) =>
  httpGetJson[RoundJson](lcc.indexUrl).flatMap: round =>
- val nearStart = rt.round.secondsAfterStart.exists(_ < 300)
+ val nearStart = rt.round.secondsAfterSyncStart.exists(_ < 300)
  round.pairings
  .mapWithIndex: (pairing, i) =>
  val game = i + 1

diff --git a/modules/relay/src/main/RelayRound.scala b/modules/relay/src/main/RelayRound.scala
@@ -58,11 +58,11 @@ case class RelayRound(
 
  def withTour(tour: RelayTour) = RelayRound.WithTour(this, tour)
 
- def secondsAfterStart: Option[Seconds] =
+ def secondsAfterSyncStart: Option[Seconds] =
  startedAt
  .orElse(startsAt)
  .map: start =>
- (nowSeconds - start.toSeconds).toInt
+ (nowSeconds - start.toSeconds - sync.delay.so(_.value)).toInt
  .filter(0 < _)
  .map(Seconds.apply)