Publish server log event for ee plugin to consume

aq-ikhwa-tech · ludomikula · commit ec518d8274ba · 2023-11-24T20:03:52.000+01:00
diff --git a/server/api-service/lowcoder-infra/pom.xml b/server/api-service/lowcoder-infra/pom.xml
@@ -127,6 +127,12 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-webflux</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.lowcoder.plugin</groupId>
+            <artifactId>lowcoder-plugin-api</artifactId>
+            <version>2.1.0</version>
+            <scope>compile</scope>
+        </dependency>
 
     </dependencies>
 
diff --git a/server/api-service/lowcoder-infra/src/main/java/org/lowcoder/infra/serverlog/ServerLogService.java b/server/api-service/lowcoder-infra/src/main/java/org/lowcoder/infra/serverlog/ServerLogService.java
@@ -8,7 +8,9 @@
 
 import org.apache.commons.collections4.CollectionUtils;
 import org.lowcoder.infra.perf.PerfHelper;
+import org.lowcoder.plugin.events.ServerLogEvent;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
 
@@ -23,6 +25,9 @@ public class ServerLogService {
     @Autowired
     private PerfHelper perfHelper;
 
+    @Autowired
+    private ApplicationEventPublisher applicationEventPublisher;
+
     private volatile Queue<ServerLog> serverLogs = new ConcurrentLinkedQueue<>();
 
     public void record(ServerLog serverLog) {
@@ -39,7 +44,15 @@ private void scheduledInsert() {
         serverLogRepository.saveAll(tmp)
                 .collectList()
                 .subscribe(result -> {
+                    int count = result.size();
                     perfHelper.count(SERVER_LOG_BATCH_INSERT, Tags.of("size", String.valueOf(result.size())));
+                    publishServerLogEvent(count);
                 });
     }
+
+    private void publishServerLogEvent(int count) {
+        ServerLogEvent event = new ServerLogEvent();
+        event.setApiCallsCount(count);
+        applicationEventPublisher.publishEvent(event);
+    }
 }
