refactor: enhance session cleanup task with error handling and logging

This commit is contained in:
Rodrigo Verdiani 2026-03-28 19:57:53 -03:00
parent 9e562fbc1a
commit c1976052b2

View File

@ -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;
}
try {
client.destroySession(
FlareClient.SessionDestroyRequest.builder().session(session.sessionId()).build());
FlareClient.SessionDestroyRequest.builder()
.session(session.sessionId())
.build());
} catch (Exception e) {
log.warn("Failed to destroy session for provider {}: {}", provider, e.getMessage());
}
registry.remove(provider);
});