fix relay sync.period

lichess-org · Apr 23, 2023 · d32f7f4 · d32f7f4
1 parent 5f253cc
commit d32f7f4
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 5 deletions.
diff --git a/app/views/relay/roundForm.scala b/app/views/relay/roundForm.scala
@@ -100,9 +100,11 @@ object roundForm:
         )(form3.flatpickr(_, minDate = None)),
         isGranted(_.Relay) option
           form3.group(
-            form("throttle"),
-            raw("Throttle in seconds"),
-            help = raw("Optional, to manually throttle requests. Min 2s, max 60s.").some,
+            form("period"),
+            raw("Period in seconds"),
+            help = raw(
+              "Optional, how long to wait between requests. Min 2s, max 60s. Defaults to automatic based on the number of viewers."
+            ).some,
             half = true
           )(form3.input(_, typ = "number"))
       ),

diff --git a/modules/relay/src/main/RelayFetch.scala b/modules/relay/src/main/RelayFetch.scala
@@ -111,7 +111,7 @@ final private class RelayFetch(
             .filterNot(_ contains "Found an empty PGN")
             .foreach { irc.broadcastError(rt.round.id.value, rt.fullName, _) }
           Seconds(60)
-        else rt.round.sync.delay | Seconds(if upstream.local then 3 else 6)
+        else rt.round.sync.period | Seconds(if upstream.local then 3 else 6)
       rt.round.withSync {
         _.copy(
           nextAt = nowInstant plusSeconds {
@@ -144,7 +144,7 @@ final private class RelayFetch(
           gameProxy.upgradeIfPresent flatMap
           gameRepo.withInitialFens flatMap { games =>
             if (games.size == ids.size)
-              games.map { case (game, fen) =>
+              games.map { (game, fen) =>
                 pgnDump(game, fen, gameIdsUpstreamPgnFlags).dmap(_.render)
               }.parallel dmap MultiPgn.apply
             else