feat: update reactify-cache

Author: hoangtien2k3

reactify-cache/.mvn/wrapper/maven-wrapper.properties

@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.hoangtien2k3.cache;
 
 import org.springframework.beans.BeansException;

reactify-cache/src/main/java/io/hoangtien2k3/cache/ApplicationContextProvider.java

@@ -13,9 +13,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.hoangtien2k3.cache;
 
 import com.github.benmanes.caffeine.cache.Cache;
+import java.util.Objects;
+import java.util.Optional;
 import lombok.extern.slf4j.Slf4j;
 import org.aspectj.lang.ProceedingJoinPoint;
 import org.aspectj.lang.annotation.Around;
@@ -28,9 +31,6 @@
 import reactor.core.publisher.Mono;
 import reactor.core.publisher.Signal;
 
-import java.util.Objects;
-import java.util.Optional;
-
 /**
  * <p>
  * CacheAspect class.
@@ -64,7 +64,6 @@ public Object aroundAdvice(ProceedingJoinPoint joinPoint) throws Throwable {
         String name = ClassUtils.getUserClass(joinPoint.getTarget().getClass()).getSimpleName() + "."
                 + joinPoint.getSignature().getName();
         Cache<Object, Object> cache = CacheStore.getCache(name);
-        // return cached mono
         return CacheMono.lookup(k -> Mono.justOrEmpty(cache.getIfPresent(key)).map(Signal::next), key)
                 .onCacheMissResume((Mono<Object>) joinPoint.proceed(args))
                 .andWriteWith((k, sig) -> Mono.fromRunnable(() -> {

reactify-cache/src/main/java/io/hoangtien2k3/cache/CacheAspect.java

@@ -13,26 +13,28 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.hoangtien2k3.cache;
 
 import com.github.benmanes.caffeine.cache.Cache;
 import com.github.benmanes.caffeine.cache.Caffeine;
 import com.github.benmanes.caffeine.cache.Scheduler;
+import java.lang.reflect.Method;
+import java.time.Duration;
+import java.util.*;
+import javax.annotation.PostConstruct;
 import lombok.extern.slf4j.Slf4j;
 import org.reflections.Reflections;
 import org.reflections.scanners.Scanners;
+import org.springframework.beans.BeansException;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
 import org.springframework.context.event.ContextRefreshedEvent;
 import org.springframework.context.event.EventListener;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Component;
 
-import javax.annotation.PostConstruct;
-import java.lang.reflect.Method;
-import java.time.Duration;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.Set;
-
 /**
  * <p>
  * CacheStore class.
@@ -42,11 +44,11 @@
  */
 @Slf4j
 @Component
-public class CacheStore {
+public class CacheStore implements ApplicationContextAware {
 
     private static final HashMap<String, Cache<Object, Object>> caches = new HashMap<>();
     private static final Set<Method> autoLoadMethods = new HashSet<>();
-    private static final String reflectionPath = "com.ezbuy";
+    private static String reflectionPath;
 
     @PostConstruct
     private static void init() {
@@ -115,4 +117,15 @@ public void autoLoad(ContextRefreshedEvent event) {
             log.info("Finish auto load cache");
         }
     }
+
+    @Override
+    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
+        Class<?> mainApplicationClass = applicationContext
+                .getBeansWithAnnotation(SpringBootApplication.class)
+                .values()
+                .iterator()
+                .next()
+                .getClass();
+        reflectionPath = mainApplicationClass.getPackageName();
+    }
 }

reactify-cache/src/main/java/io/hoangtien2k3/cache/CacheStore.java

@@ -13,15 +13,15 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.hoangtien2k3.cache;
 
+import java.lang.reflect.Method;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 import reactor.core.publisher.Mono;
 
-import java.lang.reflect.Method;
-
 /**
  * <p>
  * CacheUtils class.

reactify-cache/src/main/java/io/hoangtien2k3/cache/CacheUtils.java

@@ -13,17 +13,17 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.hoangtien2k3.cache;
 
 import com.github.benmanes.caffeine.cache.RemovalCause;
 import com.github.benmanes.caffeine.cache.RemovalListener;
+import java.lang.reflect.Method;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.checkerframework.checker.nullness.qual.NonNull;
 import org.checkerframework.checker.nullness.qual.Nullable;
 
-import java.lang.reflect.Method;
-
 /**
  * <p>
  * CustomizeRemovalListener class.

reactify-cache/src/main/java/io/hoangtien2k3/cache/CustomizeRemovalListener.java

@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.hoangtien2k3.cache;
 
 import java.lang.annotation.ElementType;
@@ -21,52 +22,51 @@
 import java.lang.annotation.Target;
 
 /**
- * Annotation to indicate that a method's result should be cached locally. This
- * can improve performance by avoiding redundant computations or repeated data
- * retrieval from external sources.
+ * Marks a method for local caching to enhance performance by reducing redundant
+ * computations or repeated data retrievals from external sources.
  *
  * <p>
- * The caching behavior is defined by the properties of the annotation:
+ * This annotation enables flexible caching configurations through the following
+ * properties:
  * <ul>
- * <li><strong>durationInMinute</strong>: The duration for which the cached
- * result is valid, specified in minutes.</li>
- * <li><strong>maxRecord</strong>: The maximum number of records that can be
- * stored in the cache.</li>
- * <li><strong>autoCache</strong>: A flag indicating whether caching should be
- * done automatically or manually.</li>
+ * <li><strong>durationInMinute</strong>: Specifies the validity duration of the
+ * cached result, in minutes.</li>
+ * <li><strong>maxRecord</strong>: Defines the maximum number of records the
+ * cache can store.</li>
+ * <li><strong>autoCache</strong>: A flag that determines whether the caching
+ * should activate automatically upon method invocation.</li>
  * </ul>
  *
  * <p>
- * This annotation should be applied to methods that return a result that can
- * benefit from caching.
+ * This annotation is best applied to methods where caching can notably improve
+ * efficiency by retaining data that does not require frequent recalculation.
  *
- * <h3>Usage Example:</h3>
+ * <h3>Example Usage:</h3>
  *
  * <pre>
  * &#64;LocalCache(durationInMinute = 10, maxRecord = 500, autoCache = true)
  * public MyObject fetchData(String param) {
- * 	// Method implementation that retrieves data
+ * 	// Implementation that fetches or computes data
  * }
  * </pre>
  *
  * <h3>Annotation Properties:</h3>
  * <dl>
- * <dt>durationInMinute</dt>
- * <dd>The time period in minutes for which the cached data is valid. Default is
- * 120 minutes.</dd>
+ * <dt><strong>durationInMinute</strong></dt>
+ * <dd>Defines the cache retention time in minutes. Default is 120 minutes.</dd>
  *
- * <dt>maxRecord</dt>
- * <dd>The maximum number of entries that can be cached. Default is 1000
- * entries.</dd>
+ * <dt><strong>maxRecord</strong></dt>
+ * <dd>Limits the number of records that can be cached simultaneously. Default
+ * is 1000 entries.</dd>
  *
- * <dt>autoCache</dt>
- * <dd>If set to true, the method result will be automatically cached. Default
- * is false.</dd>
+ * <dt><strong>autoCache</strong></dt>
+ * <dd>When set to <code>true</code>, the method result is automatically cached
+ * on execution. Default is <code>false</code>.</dd>
  * </dl>
  *
  * <p>
- * This annotation is intended for use in performance-sensitive applications
- * where reducing latency and resource consumption is critical.
+ * This annotation is ideal for performance-critical applications aiming to
+ * reduce latency and optimize resource usage through local caching.
  * </p>
  */
 @Target(ElementType.METHOD)

reactify-cache/src/main/java/io/hoangtien2k3/cache/LocalCache.java

@@ -28,6 +28,10 @@
 import lombok.extern.slf4j.Slf4j;
 import org.reflections.Reflections;
 import org.reflections.scanners.Scanners;
+import org.springframework.beans.BeansException;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
 import org.springframework.context.event.ContextRefreshedEvent;
 import org.springframework.context.event.EventListener;
 import org.springframework.scheduling.annotation.Async;
@@ -42,11 +46,11 @@
  */
 @Slf4j
 @Component
-public class CacheStore {
+public class CacheStore implements ApplicationContextAware {
 
     private static final HashMap<String, Cache<Object, Object>> caches = new HashMap<>();
     private static final Set<Method> autoLoadMethods = new HashSet<>();
-    private static final String reflectionPath = "io.hoangtien2k3";
+    private static String reflectionPath;
 
     @PostConstruct
     private static void init() {
@@ -115,4 +119,15 @@ public void autoLoad(ContextRefreshedEvent event) {
             log.info("Finish auto load cache");
         }
     }
+
+    @Override
+    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
+        Class<?> mainApplicationClass = applicationContext
+                .getBeansWithAnnotation(SpringBootApplication.class)
+                .values()
+                .iterator()
+                .next()
+                .getClass();
+        reflectionPath = mainApplicationClass.getPackageName();
+    }
 }