From dba90dfc6d9bb357af506d7accf5a5174aa6e26b Mon Sep 17 00:00:00 2001
From: Thanh Le <lenguyenthanh@hotmail.com>
Date: Fri, 1 Dec 2023 20:34:34 +0100
Subject: [PATCH] Reverted logback pattern

---
 app/src/main/resources/logback.xml | 5 +++--
 app/src/main/scala/Executor.scala  | 1 +
 app/src/main/scala/Jobs.scala      | 4 ++++
 3 files changed, 8 insertions(+), 2 deletions(-)

diff --git a/app/src/main/resources/logback.xml b/app/src/main/resources/logback.xml
index 8cb3e54..bf700dd 100644
--- a/app/src/main/resources/logback.xml
+++ b/app/src/main/resources/logback.xml
@@ -1,14 +1,15 @@
 <configuration>
+
     <appender name="FILE" class="ch.qos.logback.core.FileAppender">
         <file>logs/application.log</file>
         <encoder>
-            <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
+            <pattern>%date [%level] from %logger in %thread - %message%n%xException</pattern>
         </encoder>
     </appender>
 
     <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
         <encoder>
-            <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
+            <pattern>%date [%level] from %logger in %thread - %message%n%xException</pattern>
         </encoder>
     </appender>
 
diff --git a/app/src/main/scala/Executor.scala b/app/src/main/scala/Executor.scala
index ea789d6..a97d40c 100644
--- a/app/src/main/scala/Executor.scala
+++ b/app/src/main/scala/Executor.scala
@@ -78,6 +78,7 @@ object Executor:
                   coll -> monitor.notAcquired(move, apikey)
 
           def clean(since: Instant): IO[Unit] =
+            Logger[IO].debug(s"cleaning moves before $since") *>
             ref
               .flatModify: coll =>
                 val timedOut = coll.values.filter(_.acquiredBefore(since)).toList
diff --git a/app/src/main/scala/Jobs.scala b/app/src/main/scala/Jobs.scala
index ef1c5e1..e168a9d 100644
--- a/app/src/main/scala/Jobs.scala
+++ b/app/src/main/scala/Jobs.scala
@@ -36,3 +36,7 @@ object WorkCleaningJob:
         Logger[IO].info("Start cleaning job") *>
           IO.sleep(5.seconds) *>
           (IO.realTimeInstant.flatMap(executor.clean) *> IO.sleep(3.seconds)).foreverM
+
+
+          // (IO.realTimeInstant.flatMap(now => executor.clean(now.minusSeconds(3))) *>
+          //   IO.sleep(3.seconds)).foreverM