lila/modules/relay/src/main/RelaySync.scala

package lila.relay

import akka.actor._
import play.api.libs.ws.WS
import play.api.Play.current
import scala.concurrent.duration._

private final class RelaySync(
    api: RelayApi
) extends Actor {

  override def preStart {
    logger.info("Start RelaySync")
    context setReceiveTimeout 15.seconds
    scheduleNext
  }

  case object Tick

  def scheduleNext =
    context.system.scheduler.scheduleOnce(3 seconds, self, Tick)

  def receive = {

    case ReceiveTimeout =>
      val msg = "RelaySync timed out!"
      logger.error(msg)
      throw new RuntimeException(msg)

    case Tick =>
      val startAt = nowMillis
      api.currents.map { relay =>
        WS.url(relay.url).get().flatMap { res =>
          api.sync(relay, res.body)
        } recover {
          case e: Exception =>
            logger.info(s"Can't fetch $relay")
            ()
        }
      }.sequenceFu.chronometer
        .logIfSlow(3000, logger)(_ => "RelaySync.tick")
        .result addEffectAnyway scheduleNext
  }
}