♻️ refactor: refactor codebase #2

Author: pnguyen215

plugin/src/main/groovy/org/clarify4j/common/Clarify4j.java

@@ -1,4 +1,57 @@
 package org.clarify4j.common;
 
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+import org.unify4j.common.UniqueId4j;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpSession;
+
 public class Clarify4j {
+
+    /**
+     * @return the HTTP servlet request, class {@link HttpServletRequest}
+     */
+    public static HttpServletRequest getRequest() {
+        ServletRequestAttributes s = (ServletRequestAttributes) RequestContextHolder.currentRequestAttributes();
+        return s.getRequest();
+    }
+
+    /**
+     * Retrieves the current session ID from the request context.
+     * <p>
+     * This method accesses the current request attributes from the RequestContextHolder
+     * and extracts the session ID associated with the current request. This is useful
+     * for tracking the session of the user making the request, especially in web
+     * applications where session management is crucial for user authentication and
+     * maintaining user state across multiple requests.
+     *
+     * @return the session ID of the current request, or null if no session is associated with the current request context
+     */
+    public static String getCurrentSessionId() {
+        try {
+            ServletRequestAttributes s = (ServletRequestAttributes) RequestContextHolder.currentRequestAttributes();
+            return s.getSessionId();
+        } catch (IllegalStateException e) {
+            return String.valueOf(UniqueId4j.getUniqueId19());
+        }
+    }
+
+    /**
+     * Retrieves the session ID from the given HttpServletRequest.
+     * <p>
+     * This method gets the current HttpSession associated with the request,
+     * and then extracts the session ID from it. If there is no current session
+     * and create is false, it returns null.
+     *
+     * @param request the HttpServletRequest from which to retrieve the session ID
+     * @return the session ID, or null if there is no current session
+     */
+    public static String getSessionId(HttpServletRequest request) {
+        if (request == null) {
+            return String.valueOf(UniqueId4j.getUniqueId19());
+        }
+        HttpSession session = request.getSession(false); // Pass false to prevent creating a new session if one does not exist
+        return (session != null) ? session.getId() : null;
+    }
 }

plugin/src/main/groovy/org/clarify4j/common/annotation/Saga.java

@@ -8,5 +8,5 @@
 public @interface Saga {
     String expression();
 
-    boolean disable() default false;
+    boolean disabled() default false;
 }

plugin/src/main/groovy/org/clarify4j/common/annotation/SagaHeader.java

@@ -0,0 +1,10 @@
+package org.clarify4j.common.annotation;
+
+import java.lang.annotation.*;
+
+@Documented
+@Retention(RetentionPolicy.RUNTIME)
+@Target({ElementType.METHOD, ElementType.TYPE})
+public @interface SagaHeader {
+    boolean disabled() default false;
+}

plugin/src/main/groovy/org/clarify4j/config/handler/SagaHandler.java

@@ -33,7 +33,7 @@ public void execute(JoinPoint joinPoint) throws Throwable {
         MethodSignature signature = (MethodSignature) joinPoint.getSignature();
         Method method = signature.getMethod();
         Saga saga = method.getAnnotation(Saga.class);
-        if (saga.disable()) {
+        if (saga.disabled()) {
             return;
         }
         EvaluationContext context = new StandardEvaluationContext();

plugin/src/main/groovy/org/clarify4j/config/handler/SagaHeaderHandler.java

@@ -0,0 +1,36 @@
+package org.clarify4j.config.handler;
+
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.aspectj.lang.reflect.MethodSignature;
+import org.clarify4j.common.Clarify4j;
+import org.clarify4j.common.annotation.SagaHeader;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+import org.unify4j.common.Json4j;
+import org.unify4j.common.Request4j;
+
+import java.lang.reflect.Method;
+import java.util.Map;
+
+@Aspect
+@Component
+public class SagaHeaderHandler {
+    protected static Logger logger = LoggerFactory.getLogger(SagaHeaderHandler.class);
+
+    @Around(value = "@annotation(org.clarify4j.common.annotation.SagaHeader)")
+    public Object execute(ProceedingJoinPoint joinPoint) throws Throwable {
+        Object proceed = joinPoint.proceed();
+        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
+        Method method = signature.getMethod();
+        SagaHeader saga = method.getAnnotation(SagaHeader.class);
+        if (saga.disabled()) {
+            return proceed;
+        }
+        Map<String, Object> headers = Request4j.getHeaders(Clarify4j.getRequest());
+        logger.info("Clarify4j, header(s) requesting: {}", Json4j.toJson(headers));
+        return proceed;
+    }
+}