reactify-core

Author: hoangtien2k3

reactify-core/pom.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!--
-  Copyright 2024-2025 the original author Hoàng Anh Tiến
+  Copyright 2024-2025 the original author Hoàng Anh Tiến.
 
   Licensed under the Apache License, Version 2.0 (the "License");
   you may not use this file except in compliance with the License.
@@ -27,9 +27,9 @@
     <!-- =========================================== -->
     <!-- The maven central for all the library       -->
     <!-- =========================================== -->
-    <groupId>io.github.hoangtien2k3</groupId>
+    <groupId>com.ezbuy.platform</groupId>
     <artifactId>reactify-core</artifactId>
-    <version>1.2.6</version>
+    <version>1.2.5</version>
     <name>reactify-core</name>
     <description>Java library for developing reactive programming(reactor-core) backend systems in microservices</description>
     <url>https://github.com/hoangtien2k3/reactify-core</url>

reactify-core/src/main/java/com/reactify/annotations/LocalCache.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2024-2025 the original author Hoàng Anh Tiến
+ * Copyright 2024-2025 the original author Hoàng Anh Tiến.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

reactify-core/src/main/java/com/reactify/annotations/LogPerformance.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2024-2025 the original author Hoàng Anh Tiến
+ * Copyright 2024-2025 the original author Hoàng Anh Tiến.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

reactify-core/src/main/java/com/reactify/annotations/Loggable.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2024-2025 the original author Hoàng Anh Tiến
+ * Copyright 2024-2025 the original author Hoàng Anh Tiến.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

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

@@ -1,5 +1,5 @@
 /*
- * Copyright 2024-2025 the original author Hoàng Anh Tiến
+ * Copyright 2024-2025 the original author Hoàng Anh Tiến.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

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

@@ -1,5 +1,5 @@
 /*
- * Copyright 2024-2025 the original author Hoàng Anh Tiến
+ * Copyright 2024-2025 the original author Hoàng Anh Tiến.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

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

@@ -1,5 +1,5 @@
 /*
- * Copyright 2024-2025 the original author Hoàng Anh Tiến
+ * Copyright 2024-2025 the original author Hoàng Anh Tiến.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

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

@@ -1,5 +1,5 @@
 /*
- * Copyright 2024-2025 the original author Hoàng Anh Tiến
+ * Copyright 2024-2025 the original author Hoàng Anh Tiến.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

reactify-core/src/main/java/com/reactify/annotations/logging/LoggerAspect.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2024-2025 the original author Hoàng Anh Tiến
+ * Copyright 2024-2025 the original author Hoàng Anh Tiến.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

reactify-core/src/main/java/com/reactify/annotations/logging/LoggerAspectUtils.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2024-2025 the original author Hoàng Anh Tiến
+ * Copyright 2024-2025 the original author Hoàng Anh Tiến.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -123,11 +123,11 @@ public Mono<Object> logAround(ProceedingJoinPoint joinPoint) throws Throwable {
 
         Span newSpan = tracer.nextSpan().name(name);
         var result = joinPoint.proceed();
-        if (result instanceof Mono<?> monoResult) {
+        if (result instanceof Mono) {
             return logMonoResult(
                     joinPoint,
                     start,
-                    monoResult.cast(Object.class),
+                    (Mono<Object>) result,
                     newSpan,
                     name,
                     logType,
@@ -136,11 +136,11 @@ public Mono<Object> logAround(ProceedingJoinPoint joinPoint) throws Throwable {
                     logInput,
                     title);
         }
-        if (result instanceof Flux<?> fluxResult) {
+        if (result instanceof Flux) {
             return logFluxResult(
                             joinPoint,
                             start,
-                            fluxResult.cast(Object.class),
+                            (Flux<Object>) result,
                             newSpan,
                             name,
                             logType,
@@ -149,7 +149,7 @@ public Mono<Object> logAround(ProceedingJoinPoint joinPoint) throws Throwable {
                             logInput,
                             title)
                     .collectList()
-                    .map(list -> list);
+                    .map(list -> (Object) list);
         } else {
             return Mono.just(result);
         }
@@ -264,30 +264,13 @@ private Flux<Object> logFluxResult(
             boolean logInput,
             String title) {
         var contextRef = new AtomicReference<Context>();
-        if (logInput) {
-            Object[] args = joinPoint.getArgs();
-            logPerf(contextRef, newSpan, name, start, "INPUT", null, logType, actionType, args, title);
-        }
-        return result.doOnNext(output -> {
-                    if (logOutput) {
-                        logPerf(
-                                contextRef,
-                                newSpan,
-                                name,
-                                start,
-                                "OUTPUT",
-                                null,
-                                logType,
-                                actionType,
-                                new Object[] {output},
-                                title);
-                    }
+        return result.doFinally(
+                        o -> logPerf(contextRef, newSpan, name, start, "1", null, logType, actionType, null, title))
+                .contextWrite(context -> {
+                    contextRef.set(context);
+                    return context;
                 })
-                .doOnError(error ->
-                        logPerf(contextRef, newSpan, name, start, "0", error, logType, actionType, null, title))
-                .doFinally(signalType ->
-                        logPerf(contextRef, newSpan, name, start, "1", null, logType, actionType, null, title))
-                .contextWrite(context -> contextRef.updateAndGet(ctx -> context));
+                .doOnError(o -> logPerf(contextRef, newSpan, name, start, "0", o, logType, actionType, null, title));
     }
 
     /**
@@ -307,45 +290,15 @@ private Flux<Object> logFluxResult(
      * @param result
      *            a string indicating the result status ("0" for success, "1" for
      *            failure)
-     * @param data
+     * @param o
      *            the output object from the method execution, may be {@code null}
      */
     private void logPerf(
-            AtomicReference<Context> contextRef,
-            Span newSpan,
-            String name,
-            long start,
-            String result,
-            Object data,
-            String logType,
-            String actionType,
-            String title) {
-        if (newSpan != null) {
-            newSpan.finish();
-        }
+            AtomicReference<Context> contextRef, Span newSpan, String name, Long start, String result, Object o) {
+        newSpan.finish();
         long duration = System.currentTimeMillis() - start;
         if (duration < 50) return;
-
-        Context context = contextRef != null ? contextRef.get() : Context.empty();
-        String contextInfo = context != null ? context.toString() : "-";
-        String dataInfo = "-";
-        if (data != null) {
-            if (data instanceof Throwable error) {
-                dataInfo = String.format("Error: %s - %s", error.getClass().getSimpleName(), error.getMessage());
-            } else {
-                dataInfo = data.toString();
-            }
-        }
-        logPerf.info(
-                "{} | {} | {} | {} | {} | {} | {} | {}",
-                title,
-                name,
-                duration,
-                result,
-                logType,
-                actionType,
-                contextInfo,
-                dataInfo);
+        logPerf.info("{} {} {} M2 {}", name, duration, result, o == null ? "-" : o.toString());
     }
 
     /**