Merge pull request #134 from dionisos198/refactor/#133-trendingProgra…

…m-caching

Refactor/#133 trending program caching

build.gradle

@@ -69,6 +69,9 @@ dependencies {
     implementation 'com.querydsl:querydsl-jpa'
     implementation 'com.querydsl:querydsl-apt'
 
+    //cache
+    implementation 'com.github.ben-manes.caffeine:caffeine:3.1.1'
+
 
 }
 

src/main/java/tavebalak/OTTify/common/config/CacheConfig.java

@@ -0,0 +1,38 @@
+package tavebalak.OTTify.common.config;
+
+import com.github.benmanes.caffeine.cache.Caffeine;
+import java.util.Arrays;
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+import java.util.stream.Collectors;
+import org.springframework.cache.CacheManager;
+import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.cache.caffeine.CaffeineCache;
+import org.springframework.cache.support.SimpleCacheManager;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import tavebalak.OTTify.common.constant.CacheType;
+
+@Configuration
+@EnableCaching
+public class CacheConfig {
+
+    @Bean
+    public CacheManager cacheManager() {
+        SimpleCacheManager cacheManager = new SimpleCacheManager();
+        List<CaffeineCache> caches = Arrays.stream(CacheType.values())
+            .map(
+                cache -> new CaffeineCache(cache.getCacheName(),
+                    Caffeine.newBuilder()
+                        .expireAfterWrite(cache.getExpiredAfterWrite(), TimeUnit.SECONDS)
+                        .maximumSize(cache.getMaximumSize())
+                        .build()
+                )
+            )
+            .collect(Collectors.toList());
+        cacheManager.setCaches(caches);
+        return cacheManager;
+    }
+
+
+}

src/main/java/tavebalak/OTTify/common/constant/CacheType.java

@@ -0,0 +1,19 @@
+package tavebalak.OTTify.common.constant;
+
+import lombok.Getter;
+
+@Getter
+public enum CacheType {
+
+    PROGRAM_TRENDING("programTrending", 60 * 60, 100);
+
+    CacheType(String cacheName, int expiredAfterWrite, int maximumSize) {
+        this.cacheName = cacheName;
+        this.expiredAfterWrite = expiredAfterWrite;
+        this.maximumSize = maximumSize;
+    }
+
+    private String cacheName;
+    private int expiredAfterWrite;
+    private int maximumSize;
+}