feat:idempotency aop feature and test code added

Author: helloJosh

.docker-compose/config/kafka_server_jaas.conf

@@ -0,0 +1,12 @@
+KafkaServer {
+    org.apache.kafka.common.security.plain.PlainLoginModule required
+    username="admin"
+    password="admin!23"
+    user_admin="admin!23";
+};
+
+Client {
+    org.apache.kafka.common.security.plain.PlainLoginModule required
+    username="admin"
+    password="admin!23";
+};

.gitignore

@@ -31,3 +31,5 @@ build/
 
 ### VS Code ###
 .vscode/
+
+.docker-compose/.docker-volumes

auth/logs/auth.log

@@ -1,10 +1,13 @@
 package com.woobeee.auth.aop;
 
-import com.fasterxml.jackson.databind.ObjectMapper;
 import com.woobeee.auth.dto.IdempotencyResult;
 import com.woobeee.auth.dto.response.ApiResponse;
-import com.woobeee.auth.exception.*;
-import com.woobeee.auth.service.IdempotencyService;
+import com.woobeee.auth.exception.CustomConflictException;
+import com.woobeee.auth.exception.JwtExpiredException;
+import com.woobeee.auth.exception.JwtNotValidException;
+import com.woobeee.auth.exception.PasswordNotMatchException;
+import com.woobeee.auth.exception.UserConflictException;
+import com.woobeee.auth.exception.UserNotFoundException;
 import jakarta.servlet.http.HttpServletRequest;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -20,14 +23,15 @@
 import org.springframework.web.server.ResponseStatusException;
 import org.springframework.web.util.ContentCachingRequestWrapper;
 import org.springframework.web.util.WebUtils;
+import tools.jackson.databind.ObjectMapper;
 
 import java.nio.charset.StandardCharsets;
 import java.util.Base64;
 
 @Aspect
 @Component
-@RequiredArgsConstructor
 @Slf4j
+@RequiredArgsConstructor
 public class IdempotencyAspect {
     private final IdempotencyService idempotencyService;
     private final ObjectMapper objectMapper;

auth/src/main/java/com/woobeee/auth/aop/IdempotencyAspect.java

@@ -1,4 +1,4 @@
-package com.woobeee.auth.service;
+package com.woobeee.auth.aop;
 
 
 import com.woobeee.auth.dto.IdempotencyResult;

auth/src/main/java/com/woobeee/auth/aop/IdempotencyService.java

@@ -1,7 +1,5 @@
-package com.woobeee.auth.service;
+package com.woobeee.auth.aop;
 
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
 import com.woobeee.auth.dto.IdempotencyResult;
 import com.woobeee.auth.entity.IdempotencyRecord;
 import com.woobeee.auth.exception.CustomConflictException;
@@ -13,14 +11,14 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
+import tools.jackson.databind.ObjectMapper;
 
 import java.time.Duration;
 
-
-@RequiredArgsConstructor
 @Slf4j
 @Service
 @Transactional
+@RequiredArgsConstructor
 public class IdempotencyServiceImpl implements IdempotencyService{
     private final IdempotencyRecordRepository idempotencyRecordRepository;
     private final ObjectMapper objectMapper;
@@ -66,26 +64,18 @@ public void complete(String clientId, String domainKey, int code, Object body) {
         IdempotencyRecord r = idempotencyRecordRepository
                 .findByClientIdAndDomainKey(clientId, domainKey).orElseThrow();
 
-        try {
-            String b = objectMapper.writeValueAsString(body);
-            r.markCompleted(code, b);
-            idempotencyRecordRepository.saveAndFlush(r);
-        } catch (JsonProcessingException e) {
-            throw new RuntimeException("Failed to serialize response body", e);
-        }
+        String b = objectMapper.writeValueAsString(body);
+        r.markCompleted(code, b);
+        idempotencyRecordRepository.saveAndFlush(r);
     }
 
     @Override
     public void fail(String clientId, String domainKey, int code, Object body) {
         IdempotencyRecord r = idempotencyRecordRepository
                 .findByClientIdAndDomainKey(clientId, domainKey).orElseThrow();
 
-        try {
-            String b = objectMapper.writeValueAsString(body);
-            r.markFailed(code, b);
-            idempotencyRecordRepository.saveAndFlush(r);
-        } catch (JsonProcessingException e) {
-            throw new RuntimeException("Failed to serialize response body", e);
-        }
+        String b = objectMapper.writeValueAsString(body);
+        r.markFailed(code, b);
+        idempotencyRecordRepository.saveAndFlush(r);
     }
 }

auth/src/main/java/com/woobeee/auth/aop/IdempotencyServiceImpl.java

@@ -1,13 +1,11 @@
 package com.woobeee.auth.entity;
 
 import jakarta.persistence.*;
-import lombok.Getter;
 
 import java.time.Duration;
 import java.time.LocalDateTime;
 
 @Entity
-@Getter
 @Table(
         uniqueConstraints = @UniqueConstraint(columnNames = {"clientId", "domainKey"})
 )
@@ -60,4 +58,40 @@ public void markFailed(int responseCode, String responseBody) {
         this.responseBody = responseBody;
     }
 
+    public Long getId() {
+        return id;
+    }
+
+    public String getClientId() {
+        return clientId;
+    }
+
+    public String getDomainKey() {
+        return domainKey;
+    }
+
+    public String getRequestHash() {
+        return requestHash;
+    }
+
+    public Status getStatus() {
+        return status;
+    }
+
+    public Integer getResponseCode() {
+        return responseCode;
+    }
+
+    public String getResponseBody() {
+        return responseBody;
+    }
+
+    public LocalDateTime getCreatedAt() {
+        return createdAt;
+    }
+
+    public LocalDateTime getExpiresAt() {
+        return expiresAt;
+    }
+
 }

auth/src/main/java/com/woobeee/auth/entity/IdempotencyRecord.java

@@ -1,6 +1,19 @@
 package com.woobeee.auth.exception;
 
 public enum ErrorCode {
+    signIn_GoogleTokenNotValid,
+    signIn_userConflict,
+    login_userNotFound,
+    login_passwordNotMatch,
     login_jwtExpired,
-    login_jwtInvalid
+    login_jwtInvalid,
+    login_refreshTokenMissing,
+    login_refreshTokenNotFound,
+
+    comment_needAuthentication,
+    like_needAuthentication,
+    post_notFound,
+
+    api_idempotencyKeyConflictStopTryingToMessWithMyServer,
+    api_idempotencyKeyConflict
 }

auth/src/main/java/com/woobeee/auth/exception/ErrorCode.java

@@ -9,7 +9,6 @@
 import io.jsonwebtoken.JwtException;
 import io.jsonwebtoken.Jwts;
 import io.jsonwebtoken.security.Keys;
-import lombok.Getter;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
@@ -27,9 +26,7 @@ public class AccessTokenProvider {
     private static final String ACCESS_TOKEN_TYPE = "access";
     private static final String REFRESH_TOKEN_TYPE = "refresh";
 
-    @Getter
     private final long accessTokenExpirationMillis;
-    @Getter
     private final long refreshTokenExpirationMillis;
     private final SecretKey accessTokenKey;
     private final SecretKey refreshTokenKey;
@@ -109,9 +106,17 @@ private void validateTokenType(Claims claims) {
         }
     }
 
+    public long getAccessTokenExpirationMillis() {
+        return accessTokenExpirationMillis;
+    }
+
+    public long getRefreshTokenExpirationMillis() {
+        return refreshTokenExpirationMillis;
+    }
+
     public record RefreshTokenPayload(
             String loginId,
             UUID tokenId
     ) {
     }
-}
+}

auth/src/main/java/com/woobeee/auth/token/AccessTokenProvider.java

@@ -9,14 +9,14 @@
 import java.time.Duration;
 
 @Component
-public class RefreshTokenProvider {
+public class RefreshTokenCookieProvider {
     private final AccessTokenProvider accessTokenProvider;
     private final String cookieName;
     private final String cookiePath;
     private final boolean secureCookie;
     private final String sameSite;
 
-    public RefreshTokenProvider(
+    public RefreshTokenCookieProvider(
             AccessTokenProvider accessTokenProvider,
             @Value("${jwt.refresh-token.cookie-name:refreshToken}") String cookieName,
             @Value("${jwt.refresh-token.cookie-path:/api/auth}") String cookiePath,