feat: supports log config

Author: cjbi

pom.xml

@@ -7,15 +7,15 @@
   <artifactId>flexmodel-server</artifactId>
   <version>0.0.1-SNAPSHOT</version>
   <properties>
-    <compiler-plugin.version>3.12.1</compiler-plugin.version>
+    <compiler-plugin.version>3.13.0</compiler-plugin.version>
     <maven.compiler.release>21</maven.compiler.release>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
     <quarkus.platform.artifact-id>quarkus-bom</quarkus.platform.artifact-id>
     <quarkus.platform.group-id>io.quarkus.platform</quarkus.platform.group-id>
-    <quarkus.platform.version>3.10.1</quarkus.platform.version>
+    <quarkus.platform.version>3.15.1</quarkus.platform.version>
     <skipITs>true</skipITs>
-    <surefire-plugin.version>3.2.5</surefire-plugin.version>
+    <surefire-plugin.version>3.3.1</surefire-plugin.version>
     <HikariCP.version>5.1.0</HikariCP.version>
     <testcontainers.version>1.19.3</testcontainers.version>
   </properties>
@@ -28,15 +28,13 @@
         <type>pom</type>
         <scope>import</scope>
       </dependency>
-      <dependency>
-        <groupId>com.graphql-java</groupId>
-        <artifactId>graphql-java</artifactId>
-        <version>22.3</version>
-      </dependency>
     </dependencies>
   </dependencyManagement>
   <dependencies>
-
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-scheduler</artifactId>
+    </dependency>
     <dependency>
       <groupId>org.mongodb</groupId>
       <artifactId>mongodb-driver-sync</artifactId>
@@ -185,9 +183,7 @@
         <artifactId>maven-compiler-plugin</artifactId>
         <version>${compiler-plugin.version}</version>
         <configuration>
-          <compilerArgs>
-            <arg>-parameters</arg>
-          </compilerArgs>
+          <parameters>true</parameters>
         </configuration>
       </plugin>
       <plugin>

src/main/java/tech/wetech/flexmodel/domain/model/api/ApiLogService.java

@@ -2,15 +2,18 @@
 
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.inject.Inject;
+import lombok.extern.slf4j.Slf4j;
 import tech.wetech.flexmodel.codegen.entity.ApiLog;
 import tech.wetech.flexmodel.criterion.Example;
 
+import java.time.LocalDateTime;
 import java.util.List;
 import java.util.function.UnaryOperator;
 
 /**
  * @author cjbi
  */
+@Slf4j
 @ApplicationScoped
 public class ApiLogService {
 
@@ -29,4 +32,9 @@ public List<LogStat> stat(UnaryOperator<Example.Criteria> filter) {
     return apiLogRepository.stat(filter);
   }
 
+  public void purgeOldLogs(int maxDays) {
+    log.info("Purging old logs older than {} days", maxDays);
+    LocalDateTime purgeDate = LocalDateTime.now().minusDays(maxDays);
+    apiLogRepository.delete(f -> f.lessThanOrEqualTo("createDate", purgeDate));
+  }
 }

src/main/java/tech/wetech/flexmodel/infrastructrue/Jobs.java

@@ -0,0 +1,26 @@
+package tech.wetech.flexmodel.infrastructrue;
+
+import io.quarkus.scheduler.Scheduled;
+import jakarta.inject.Inject;
+import tech.wetech.flexmodel.domain.model.api.ApiLogService;
+import tech.wetech.flexmodel.domain.model.settings.Settings;
+import tech.wetech.flexmodel.domain.model.settings.SettingsService;
+
+/**
+ * @author cjbi
+ */
+public class Jobs {
+
+  @Inject
+  SettingsService settingsService;
+
+  @Inject
+  ApiLogService apiLogService;
+
+  @Scheduled(cron = "0 0 1 * * ?")
+  void purgeOldLogs() {
+    Settings settings = settingsService.getSettings();
+    apiLogService.purgeOldLogs(settings.getLog().getMaxDays());
+  }
+
+}

src/main/java/tech/wetech/flexmodel/infrastructrue/LogFilter.java

@@ -11,6 +11,7 @@
 import tech.wetech.flexmodel.domain.model.api.ApiLogService;
 import tech.wetech.flexmodel.domain.model.api.LogData;
 import tech.wetech.flexmodel.domain.model.api.LogLevel;
+import tech.wetech.flexmodel.domain.model.settings.Settings;
 import tech.wetech.flexmodel.domain.model.settings.SettingsService;
 import tech.wetech.flexmodel.util.JsonUtils;
 
@@ -47,7 +48,10 @@ public void filter(ContainerRequestContext requestContext, ContainerResponseCont
       execTime = -1L;
     }
     CompletableFuture.runAsync(() -> {
-      saveLog(requestContext, responseContext, execTime);
+      Settings settings = settingsService.getSettings();
+      if (settings.getLog().isConsoleLoggingEnabled()) {
+        saveLog(requestContext, responseContext, execTime);
+      }
     });
   }