feat: reactify-core

Author: hoangtien2k3

pom.xml

@@ -93,7 +93,6 @@
         <module>reactify-core</module>
         <module>reactify-utils</module>
         <module>reactify-cache</module>
-        <module>reactify-tracelog</module>
     </modules>
 
     <dependencies>

reactify-cache/src/main/java/com/reactify/cache/ApplicationContextProvider.java

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

reactify-cache/src/main/java/com/reactify/cache/CacheAspect.java

@@ -13,7 +13,6 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
 package com.reactify.cache;
 
 import com.github.benmanes.caffeine.cache.Cache;

reactify-cache/src/main/java/com/reactify/cache/CacheStore.java

@@ -13,7 +13,6 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
 package com.reactify.cache;
 
 import com.github.benmanes.caffeine.cache.Cache;

reactify-cache/src/main/java/com/reactify/cache/CacheUtils.java

@@ -13,7 +13,6 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
 package com.reactify.cache;
 
 import java.lang.reflect.Method;

reactify-cache/src/main/java/com/reactify/cache/CustomizeRemovalListener.java

@@ -13,7 +13,6 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
 package com.reactify.cache;
 
 import com.github.benmanes.caffeine.cache.RemovalCause;

reactify-cache/src/main/java/com/reactify/cache/LocalCache.java

@@ -13,7 +13,6 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
 package com.reactify.cache;
 
 import java.lang.annotation.ElementType;

reactify-core/pom.xml

@@ -8,12 +8,14 @@
         <version>3.3.5</version>
         <relativePath/>
     </parent>
-    <groupId>com.ezbuy.platform</groupId>
+    <groupId>io.github.hoangtien2k3</groupId>
     <artifactId>reactify-core</artifactId>
-    <version>1.0-SNAPSHOT</version>
-    <name>reactify-core</name>
-    <description>Java library for developing backend with reactive programming</description>
+    <version>1.1.7</version>
+    <name>reactify-cache</name>
+    <packaging>jar</packaging>
+    <description>Java lib using caffeine cache</description>
     <url>https://github.com/hoangtien2k3/reactify</url>
+
     <licenses>
         <license>
             <name>Apache License, Version 2.0</name>
@@ -43,6 +45,7 @@
             <url>https://s01.oss.sonatype.org/service/local/staging/deploy/maven2/</url>
         </repository>
     </distributionManagement>
+
     <properties>
         <revision>1.0-SNAPSHOT</revision>
         <java.version>21</java.version>
@@ -71,6 +74,7 @@
         <sonar.organization>hoangtien2k3</sonar.organization>
         <sonar.host.url>https://sonarcloud.io</sonar.host.url>
     </properties>
+
     <dependencyManagement>
         <dependencies>
             <dependency>
@@ -82,6 +86,7 @@
             </dependency>
         </dependencies>
     </dependencyManagement>
+
     <dependencies>
         <dependency>
             <groupId>org.springframework.boot</groupId>
@@ -237,6 +242,7 @@
             <version>${modelmapper.version}</version>
         </dependency>
     </dependencies>
+
     <build>
         <plugins>
             <plugin>
@@ -388,4 +394,5 @@
             </plugin>
         </plugins>
     </build>
+
 </project>

reactify-core/src/main/java/com/reactify/annotations/cache/CacheAspect.java

@@ -16,6 +16,8 @@
 package com.reactify.annotations.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 +30,6 @@
 import reactor.core.publisher.Mono;
 import reactor.core.publisher.Signal;
 
-import java.util.Objects;
-import java.util.Optional;
-
 /**
  * <p>
  * The {@code CacheAspect} class provides caching functionality for methods
@@ -47,10 +46,10 @@
  * </p>
  *
  * <p>
- * The class is annotated with {@link Aspect} and
- * {@link Configuration}, making it a
+ * The class is annotated with {@link org.aspectj.lang.annotation.Aspect} and
+ * {@link org.springframework.context.annotation.Configuration}, making it a
  * Spring managed bean that can intercept method calls. The logging is managed
- * using the Lombok {@link Slf4j} annotation.
+ * using the Lombok {@link lombok.extern.slf4j.Slf4j} annotation.
  * </p>
  *
  * @author hoangtien2k3
@@ -84,11 +83,11 @@ private void processAnnotation() {}
      * </p>
      *
      * @param joinPoint
-     *            a {@link ProceedingJoinPoint} object representing
+     *            a {@link org.aspectj.lang.ProceedingJoinPoint} object representing
      *            the method execution context.
-     * @return an {@link Object} that is the result of the method
+     * @return an {@link java.lang.Object} that is the result of the method
      *         execution or the cached result.
-     * @throws Throwable
+     * @throws java.lang.Throwable
      *             if any exception occurs during method execution or while
      *             accessing the cache.
      */

reactify-core/src/main/java/com/reactify/annotations/cache/CacheStore.java

@@ -19,6 +19,12 @@
 import com.github.benmanes.caffeine.cache.Caffeine;
 import com.github.benmanes.caffeine.cache.Scheduler;
 import com.reactify.annotations.LocalCache;
+import java.lang.reflect.Method;
+import java.time.Duration;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.Set;
+import javax.annotation.PostConstruct;
 import lombok.extern.slf4j.Slf4j;
 import org.reflections.Reflections;
 import org.reflections.scanners.Scanners;
@@ -31,25 +37,18 @@
 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>
  * The {@code CacheStore} class is responsible for managing and initializing
  * caches for methods annotated with
- * {@link LocalCache}. It uses the Caffeine caching
+ * {@link com.reactify.annotations.LocalCache}. It uses the Caffeine caching
  * library to provide an efficient caching mechanism, supporting features like
  * auto-loading of cache entries based on method annotations.
  * </p>
  *
  * <p>
  * This class implements
- * {@link ApplicationContextAware} to gain access to
+ * {@link org.springframework.context.ApplicationContextAware} to gain access to
  * the Spring application context, allowing it to dynamically discover and
  * initialize caches at startup. It automatically loads caches for methods that
  * have the {@code @LocalCache} annotation and meet the specified criteria.
@@ -69,7 +68,7 @@
  * </p>
  *
  * <p>
- * The caches are stored in a static {@link HashMap} for easy access
+ * The caches are stored in a static {@link java.util.HashMap} for easy access
  * based on the method name and class.
  * </p>
  *
@@ -136,8 +135,8 @@ private static void init() {
      * </p>
      *
      * @param key
-     *            a {@link String} object representing the cache name.
-     * @return a {@link Cache} object
+     *            a {@link java.lang.String} object representing the cache name.
+     * @return a {@link com.github.benmanes.caffeine.cache.Cache} object
      *         corresponding to the specified name, or {@code null} if no cache
      *         exists for the given key.
      */
@@ -149,11 +148,11 @@ public static Cache<Object, Object> getCache(String key) {
      * <p>
      * Automatically loads cache entries for methods that are configured to
      * auto-load. This method is triggered by the
-     * {@link ContextRefreshedEvent}.
+     * {@link org.springframework.context.event.ContextRefreshedEvent}.
      * </p>
      *
      * @param event
-     *            a {@link ContextRefreshedEvent}
+     *            a {@link org.springframework.context.event.ContextRefreshedEvent}
      *            object indicating the application context has been refreshed.
      */
     @Async