implement cache for user authorization data

admin-ch · Mar 30, 2022 · c170332 · c170332
1 parent fca3682
commit c170332
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 0 deletions.
diff --git a/...min/bag/covidcertificate/gateway/client/internal/AbstractIdentityAuthorizationClient.java b/...min/bag/covidcertificate/gateway/client/internal/AbstractIdentityAuthorizationClient.java
@@ -8,6 +8,9 @@
 import ch.admin.bag.covidcertificate.gateway.service.dto.CreateCertificateException;
 import ch.admin.bag.covidcertificate.gateway.service.model.UserAuthorizationData;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.cache.annotation.CacheEvict;
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.util.StringUtils;
 
 import java.util.Collection;
@@ -23,8 +26,11 @@
 @Slf4j
 public abstract class AbstractIdentityAuthorizationClient implements IdentityAuthorizationClient {
 
+    private static final String USER_AUTHORIZATION_DATA_CACHE = "USER_AUTHORIZATION_DATA_CACHE";
+
     protected abstract User searchUser(String uuid, String idpSource);
 
+    @Cacheable(USER_AUTHORIZATION_DATA_CACHE)
     @Override
     public UserAuthorizationData fetchUserAndGetAuthData(String uuid, String idpSource) {
         if (!StringUtils.hasText(uuid) || !StringUtils.hasText(idpSource)) {
@@ -53,4 +59,10 @@ public UserAuthorizationData fetchUserAndGetAuthData(String uuid, String idpSour
         log.trace("Authorization checked successfully.");
         return new UserAuthorizationData(uuid, idpSource, roles);
     }
+
+    @Scheduled(fixedRateString = "${cc-api-gateway-service.cache-duration}")
+    @CacheEvict(value = USER_AUTHORIZATION_DATA_CACHE, allEntries = true)
+    public void cleanUserAuthorizationDataCache() {
+        log.info("Cleaning cache of user autorization data.");
+    }
 }
diff --git a/...dmin/bag/covidcertificate/gateway/client/internal/DefaultIdentityAuthorizationClient.java b/...dmin/bag/covidcertificate/gateway/client/internal/DefaultIdentityAuthorizationClient.java
@@ -8,6 +8,7 @@
 import ch.admin.bag.covidcertificate.gateway.web.config.ProfileRegistry;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 

diff --git a/src/main/java/ch/admin/bag/covidcertificate/gateway/service/OtpRevocationService.java b/src/main/java/ch/admin/bag/covidcertificate/gateway/service/OtpRevocationService.java
@@ -28,6 +28,7 @@ public List<OtpRevocation> getOtpRevocations() {
     @Scheduled(fixedRateString = "${cc-api-gateway-service.cache-duration}")
     @CacheEvict(value = OTP_CACHE_NAME, allEntries = true)
     public void clearCache() {
+        log.info("Cleaning cache of otps list.");
     }
 
 }