1 package net.sumaris.server.http.security;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25 import com.google.common.base.Preconditions;
26 import com.google.common.cache.Cache;
27 import com.google.common.cache.CacheBuilder;
28 import net.sumaris.server.config.SumarisServerConfiguration;
29 import org.apache.commons.lang3.StringUtils;
30 import org.springframework.stereotype.Component;
31
32 import java.util.Objects;
33 import java.util.concurrent.TimeUnit;
34
35
36
37
38 public class ValidationExpiredCache {
39
40 private final Cache<String, String> cache;
41
42 public ValidationExpiredCache(final int lifeTimeInSeconds) {
43 this.cache = CacheBuilder.newBuilder()
44 .expireAfterWrite(Math.max(lifeTimeInSeconds, 60 ), TimeUnit.SECONDS)
45 .build();
46 }
47
48 public boolean contains(String data) {
49 Preconditions.checkArgument(StringUtils.isNotBlank(data));
50 String storedData = cache.getIfPresent(data);
51 return Objects.equals(storedData, data);
52 }
53
54 public void remove(String data) {
55 cache.invalidate(data);
56 }
57
58 public void add(String data) {
59 cache.put(data, data);
60 }
61
62 public void clean() {
63 this.cache.invalidateAll();
64 }
65 }