implement LogStatusNotification

Author: goekay

src/main/java/de/rwth/idsg/steve/repository/SecurityRepository.java

@@ -30,6 +30,8 @@ public interface SecurityRepository {
 
     void insertSecurityEvent(String chargeBoxId, String eventType, DateTime timestamp, String techInfo);
 
+    void insertLogUploadStatus(String chargeBoxIdentity, Integer requestId, String status, DateTime timestamp);
+
     List<SecurityEvent> getSecurityEvents(String chargeBoxId, Integer limit);
 
     int insertCertificate(String chargeBoxId, String certificateType, String certificateData,

src/main/java/de/rwth/idsg/steve/repository/impl/SecurityRepositoryImpl.java

@@ -32,6 +32,7 @@
 import java.util.Collections;
 import java.util.List;
 
+import static jooq.steve.db.Tables.CHARGE_BOX_LOG_UPLOAD_STATUS;
 import static jooq.steve.db.tables.ChargeBox.CHARGE_BOX;
 import static jooq.steve.db.tables.ChargeBoxSecurityEvent.CHARGE_BOX_SECURITY_EVENT;
 
@@ -61,6 +62,22 @@ public void insertSecurityEvent(String chargeBoxId, String eventType, DateTime t
         log.info("Security event '{}' recorded for chargeBox '{}'", eventType, chargeBoxId);
     }
 
+    @Override
+    public void insertLogUploadStatus(String chargeBoxId, Integer requestId, String status, DateTime timestamp) {
+        var chargeBoxPk = getChargeBoxPk(chargeBoxId);
+        if (chargeBoxPk == null) {
+            log.error("Cannot insert log upload status for unknown chargeBoxId: {}", chargeBoxId);
+            return;
+        }
+
+        ctx.insertInto(CHARGE_BOX_LOG_UPLOAD_STATUS)
+            .set(CHARGE_BOX_LOG_UPLOAD_STATUS.CHARGE_BOX_PK, chargeBoxPk)
+            .set(CHARGE_BOX_LOG_UPLOAD_STATUS.JOB_ID, requestId)
+            .set(CHARGE_BOX_LOG_UPLOAD_STATUS.EVENT_STATUS, status)
+            .set(CHARGE_BOX_LOG_UPLOAD_STATUS.EVENT_TIMESTAMP, timestamp)
+            .execute();
+    }
+
     @Override
     public List<SecurityEvent> getSecurityEvents(String chargeBoxId, Integer limit) {
         return Collections.emptyList();

src/main/java/de/rwth/idsg/steve/service/CentralSystemService16_Service.java

@@ -359,6 +359,25 @@ public SecurityEventNotificationResponse securityEventNotification(SecurityEvent
 
         return new SecurityEventNotificationResponse();
     }
+    public LogStatusNotificationResponse logStatusNotification(LogStatusNotification parameters,
+                                                               String chargeBoxIdentity) {
+        try {
+            if (parameters.getRequestId() == null) {
+                log.warn("No requestId in {}", parameters);
+            } else {
+                securityRepository.insertLogUploadStatus(
+                    chargeBoxIdentity,
+                    parameters.getRequestId(),
+                    parameters.getStatus().value(),
+                    DateTime.now()
+                );
+            }
+        } catch (Exception e) {
+            log.error("Error processing log status notification from '{}': {}", chargeBoxIdentity, e.getMessage(), e);
+        }
+
+        return new LogStatusNotificationResponse();
+    }
 
     public SignedFirmwareStatusNotificationResponse signedFirmwareStatusNotification(
             SignedFirmwareStatusNotification parameters, String chargeBoxIdentity) {
@@ -384,30 +403,6 @@ public SignedFirmwareStatusNotificationResponse signedFirmwareStatusNotification
         return new SignedFirmwareStatusNotificationResponse();
     }
 
-    public LogStatusNotificationResponse logStatusNotification(LogStatusNotification parameters, String chargeBoxIdentity) {
-        var status = parameters.getStatus() != null ? parameters.getStatus().toString() : "Unknown";
-        var requestId = parameters.getRequestId();
-
-        log.info("LogStatus from '{}': status={}, requestId={}", chargeBoxIdentity, status, requestId);
-
-        try {
-            if (requestId != null) {
-                var logFile = securityRepository.getLogFile(requestId);
-
-                if (logFile != null) {
-                    securityRepository.updateLogFileStatus(requestId, status, null);
-                    log.info("Updated log file status for requestId {} to '{}'", requestId, status);
-                } else {
-                    log.warn("No log file found for requestId {}", requestId);
-                }
-            }
-        } catch (Exception e) {
-            log.error("Error processing log status notification from '{}': {}", chargeBoxIdentity, e.getMessage(), e);
-        }
-
-        return new LogStatusNotificationResponse();
-    }
-
     // -------------------------------------------------------------------------
     // Helpers
     // -------------------------------------------------------------------------