Add scheduled cleaning job

app/src/main/scala/App.scala

@@ -21,9 +21,11 @@ object App extends IOApp.Simple:
  res <- AppResources.instance(config.redis)
  lilaClient = LilaClient(res.redisPubsub)
  executor <- Resource.eval(Executor.instance(lilaClient))
- job = RedisSubscriberJob(executor, res.redisPubsub)
- httpApi = HttpApi(executor, HealthCheck())
+ workListenerJob = RedisSubscriberJob(executor, res.redisPubsub)
+ cleanJob = CleanJob(executor)
+ httpApi = HttpApi(executor, HealthCheck())
  server <- MkHttpServer.apply.newEmber(config.server, httpApi.httpApp)
- _ <- job.run().background
+ _ <- workListenerJob.run().background
+ _ <- cleanJob.run().background
  _ <- Resource.eval(Logger[IO].info(s"Starting server on ${config.server.host}:${config.server.port}"))
  yield ()

app/src/main/scala/RedisSubscriberJob.scala

@@ -7,6 +7,8 @@ import io.chrisdavenport.rediculous.RedisPubSub
 import org.typelevel.log4cats.Logger
 import Lila.Request
 
+import scala.concurrent.duration.*
+
 trait RedisSubscriberJob:
  def run(): IO[Unit]
 
@@ -33,3 +35,14 @@ object RedisSubscriberJob:
  case Some(request) => executor.add(request)
  case None => Logger[IO].error(s"Failed to parse message: $msg"),
  ) *> pubsub.runMessages
+
+trait CleanJob:
+ def run(): IO[Unit]
+
+object CleanJob:
+ def apply(executor: Executor)(using Logger[IO]): CleanJob =
+ new CleanJob:
+ def run(): IO[Unit] =
+ Logger[IO].info("Start cleaning job") *>
+ IO.sleep(5.seconds) *>
+ IO.realTimeInstant.flatMap(executor.clean)

app/src/test/scala/ExecutorTest.scala

@@ -66,7 +66,7 @@ object ExecutorTest extends SimpleIOSuite:
  moves <- ref.get
  yield assert(moves.isEmpty)
 
- test("after timeout should move can be acruired again"):
+ test("after timeout move should be able to acquired again"):
  for
  ref <- Ref.of[IO, List[Lila.Move]](Nil)
  client = createLilaClient(ref)