From c1976052b251986c10aeda5b853efe95c4f06fa7 Mon Sep 17 00:00:00 2001
From: Rodrigo Verdiani <rocverdiani@gmail.com>
Date: Sat, 28 Mar 2026 19:57:53 -0300
Subject: [PATCH] refactor: enhance session cleanup task with error handling
 and logging

---
 .../ingestion/task/FlareSessionCleanupTask.java      | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/magamochi/ingestion/task/FlareSessionCleanupTask.java b/src/main/java/com/magamochi/ingestion/task/FlareSessionCleanupTask.java
index 26610c5..a6a84f5 100644
--- a/src/main/java/com/magamochi/ingestion/task/FlareSessionCleanupTask.java
+++ b/src/main/java/com/magamochi/ingestion/task/FlareSessionCleanupTask.java
@@ -5,9 +5,11 @@ import com.magamochi.ingestion.service.FlareSessionRegistry;
 import java.time.Duration;
 import java.time.Instant;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.log4j.Log4j2;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
+@Log4j2
 @Component
 @RequiredArgsConstructor
 public class FlareSessionCleanupTask {
@@ -26,8 +28,14 @@ public class FlareSessionCleanupTask {
                 return;
               }
 
-              client.destroySession(
-                  FlareClient.SessionDestroyRequest.builder().session(session.sessionId()).build());
+              try {
+                client.destroySession(
+                    FlareClient.SessionDestroyRequest.builder()
+                        .session(session.sessionId())
+                        .build());
+              } catch (Exception e) {
+                log.warn("Failed to destroy session for provider {}: {}", provider, e.getMessage());
+              }
 
               registry.remove(provider);
             });