Update AnonymusSessionRegistry.java

src/main/java/stirling/software/SPDF/config/anonymus/session/AnonymusSessionRegistry.java

@@ -1,10 +1,15 @@
 package stirling.software.SPDF.config.anonymus.session;
 
+import java.time.Duration;
+import java.time.Instant;
+import java.time.temporal.ChronoUnit;
 import java.util.Collection;
+import java.util.Comparator;
 import java.util.Date;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 
 import jakarta.servlet.http.HttpSession;
@@ -13,9 +18,16 @@ import jakarta.servlet.http.HttpSessionListener;
 
 import lombok.extern.slf4j.Slf4j;
 
+import stirling.software.SPDF.config.interfaces.SessionsInterface;
+
 @Component
 @Slf4j
-public class AnonymusSessionRegistry implements HttpSessionListener {
+public class AnonymusSessionRegistry implements HttpSessionListener, SessionsInterface {
+
+    @Value("${server.servlet.session.timeout:120s}") // TODO: Change to 30m
+    private Duration defaultMaxInactiveInterval;
+
+    private static final int MAX_SESSIONS = 1;
 
     // Map zur Speicherung der Sessions inkl. Timestamp
     private static final Map<String, AnonymusSessionInfo> sessions = new ConcurrentHashMap<>();
@@ -42,33 +54,75 @@ public class AnonymusSessionRegistry implements HttpSessionListener {
         // Speichern des Erstellungszeitpunkts
         Date creationTime = new Date();
         session.setAttribute("creationTimestamp", creationTime);
+
+        int allNonExpiredSessions = getAllNonExpiredSessions().size();
+
+        if (allNonExpiredSessions >= MAX_SESSIONS) {
+            log.info("Maximale Anzahl an Sessions erreicht");
+            sessions.put(
+                    session.getId(),
+                    new AnonymusSessionInfo(session, creationTime, creationTime, true));
+        } else {
             sessions.put(
                     session.getId(),
                     new AnonymusSessionInfo(session, creationTime, creationTime, false));
-
+        }
-        log.info("Session {} erstellt um {}", session.getId(), creationTime);
     }
 
     @Override
     public void sessionDestroyed(HttpSessionEvent event) {
         HttpSession session = event.getSession();
         if (session == null) {
-            log.info("Session ist null");
             return;
         }
         AnonymusSessionInfo sessionsInfo = sessions.get(session.getId());
         if (sessionsInfo == null) {
-            log.info("Session {} existiert nicht", session.getId());
             return;
         }
+
+        Date lastRequest = sessionsInfo.getLastRequest();
+        int maxInactiveInterval = (int) defaultMaxInactiveInterval.getSeconds();
+        Instant now = Instant.now();
+        Instant expirationTime =
+                lastRequest.toInstant().plus(maxInactiveInterval, ChronoUnit.SECONDS);
+
+        if (now.isAfter(expirationTime)) {
             sessionsInfo.setExpired(true);
+            session.invalidate();
             log.info("Session {} wurde Expired=TRUE", session.getId());
         }
+    }
 
+    @Override
+    public boolean isSessionValid(String sessionId) {
+        boolean exists = sessions.containsKey(sessionId);
+        boolean expired = exists ? sessions.get(sessionId).isExpired() : false;
+        return exists && !expired;
+    }
+
+    @Override
+    public boolean isOldestNonExpiredSession(String sessionId) {
+        Collection<AnonymusSessionInfo> nonExpiredSessions = getAllNonExpiredSessions();
+        return nonExpiredSessions.stream()
+                .min(Comparator.comparing(AnonymusSessionInfo::getLastRequest))
+                .map(oldest -> oldest.getSession().getId().equals(sessionId))
+                .orElse(false);
+    }
+
+    @Override
+    public void updateSessionLastRequest(String sessionId) {
+        if (sessions.containsKey(sessionId)) {
+            AnonymusSessionInfo sessionInfo = sessions.get(sessionId);
+            sessionInfo.setLastRequest(new Date());
+        }
+    }
+
+    @Override
     public Collection<AnonymusSessionInfo> getAllSessions() {
         return sessions.values();
     }
 
+    @Override
     public Collection<AnonymusSessionInfo> getAllNonExpiredSessions() {
         return sessions.values().stream().filter(info -> !info.isExpired()).toList();
     }