string support for idempotency check

Jdempotent-core/pom.xml

@@ -6,7 +6,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.trendyol</groupId>
     <artifactId>Jdempotent-core</artifactId>
-    <version>1.0.8</version>
+    <version>1.0.9</version>
     <name>Jdempotent-core</name>
     <packaging>jar</packaging>
     <url>https://github.com/Trendyol/Jdempotent/tree/master/Jdempotent-core</url>

Jdempotent-core/src/main/java/com/trendyol/jdempotent/core/aspect/IdempotentAspect.java

@@ -199,7 +199,7 @@ public IdempotentRequestWrapper findIdempotentRequestArg(ProceedingJoinPoint pjp
         if (args.length == 0) {
             throw new IllegalStateException("Idempotent method not found");
         } else if (args.length == 1) {
-            return new IdempotentRequestWrapper(getIdempotentNonIgnorableWrapper(args));
+            return new IdempotentRequestWrapper(getIdempotentNonIgnorableWrapper(args[0]));
         } else {
             try {
                 MethodSignature signature = (MethodSignature) pjp.getSignature();
@@ -210,7 +210,7 @@ public IdempotentRequestWrapper findIdempotentRequestArg(ProceedingJoinPoint pjp
                 for (int i = 0; i < args.length; i++) {
                     for (Annotation annotation : annotations[i]) {
                         if (annotation instanceof IdempotentRequestPayload) {
-                            return new IdempotentRequestWrapper(getIdempotentNonIgnorableWrapper(args));
+                            return new IdempotentRequestWrapper(getIdempotentNonIgnorableWrapper(args[i]));
                         }
                     }
                 }
@@ -246,17 +246,21 @@ public void setJdempotentId(Object[] args, String idempotencyKey) throws Illegal
         }
     }
 
-    public IdempotentIgnorableWrapper getIdempotentNonIgnorableWrapper(Object[] args) throws IllegalAccessException {
+    public IdempotentIgnorableWrapper getIdempotentNonIgnorableWrapper(Object args) throws IllegalAccessException {
         var wrapper = new IdempotentIgnorableWrapper();
-        Field[] declaredFields = args[0].getClass().getDeclaredFields();
-        for (int i = 0; i < declaredFields.length; i++) {
-            declaredFields[i].setAccessible(true);
-            if (declaredFields[i].getDeclaredAnnotations().length == 0) {
-                wrapper.getNonIgnoredFields().put(declaredFields[i].getName(), declaredFields[i].get(args[0]));
+        Field[] declaredFields = args.getClass().getDeclaredFields();
+        if(args instanceof String){
+            wrapper.getNonIgnoredFields().put(args.toString(), args);
+            return wrapper;
+        }
+        for (Field declaredField : declaredFields) {
+            declaredField.setAccessible(true);
+            if (declaredField.getDeclaredAnnotations().length == 0) {
+                wrapper.getNonIgnoredFields().put(declaredField.getName(), declaredField.get(args));
             } else {
-                for (Annotation annotation : declaredFields[i].getDeclaredAnnotations()) {
+                for (Annotation annotation : declaredField.getDeclaredAnnotations()) {
                     if (!(annotation instanceof IdempotentIgnore)) {
-                        wrapper.getNonIgnoredFields().put(declaredFields[i].getName(), declaredFields[i].get(args[0]));
+                        wrapper.getNonIgnoredFields().put(declaredField.getName(), declaredField.get(args));
                     }
                 }
             }

Jdempotent-core/src/test/java/aspect/core/IdempotentTestPayload.java

@@ -1,16 +1,12 @@
 package aspect.core;
 
 import com.trendyol.jdempotent.core.annotation.IdempotentIgnore;
-import com.trendyol.jdempotent.core.annotation.JdempotentId;
 
 public class IdempotentTestPayload {
     private String name;
     @IdempotentIgnore
     private Long age;
 
-    @JdempotentId
-    private String jdempotentId;
-
     public IdempotentTestPayload() {
     }
 

Jdempotent-core/src/test/java/aspect/withaspect/IdempotentAspectIT.java

@@ -155,4 +155,20 @@ public void given_jdempotent_id_then_args_should_have_idempotency_id() throws No
         assertTrue(idempotentRepository.contains(idempotencyKey));
     }
 
+    @Test
+    public void given_new_payload_as_string_when_trigger_aspect_then_that_will_be_aviable_in_repository() throws NoSuchAlgorithmException {
+        //given
+        String idempotencyKey = "key";
+        IdempotentTestPayload test = new IdempotentTestPayload();
+        IdempotentIgnorableWrapper wrapper = new IdempotentIgnorableWrapper();
+        wrapper.getNonIgnoredFields().put(idempotencyKey, idempotencyKey);
+        IdempotencyKey key = defaultKeyGenerator.generateIdempotentKey(new IdempotentRequestWrapper(wrapper), "", new StringBuilder(), MessageDigest.getInstance(CryptographyAlgorithm.MD5.value()));
+
+        //when
+        testIdempotentResource.idempotencyKeyAsString(idempotencyKey);
+
+        //then
+        assertTrue(idempotentRepository.contains(key));
+    }
+
 }

Jdempotent-spring-boot-couchbase-starter/pom.xml

@@ -5,7 +5,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.trendyol</groupId>
     <artifactId>Jdempotent-spring-boot-couchbase-starter</artifactId>
-    <version>1.0.8</version>
+    <version>1.0.9</version>
     <name>Jdempotent-spring-boot-couchbase-starter</name>
     <packaging>jar</packaging>
     <url>https://github.com/Trendyol/Jdempotent/tree/master/Jdempotent-spring-boot-couchbase-starter</url>
@@ -54,7 +54,7 @@
         <dependency>
             <groupId>com.trendyol</groupId>
             <artifactId>Jdempotent-core</artifactId>
-            <version>1.0.8</version>
+            <version>1.0.9</version>
         </dependency>
         <dependency>
             <groupId>org.aspectj</groupId>

Jdempotent-spring-boot-redis-starter/pom.xml

@@ -6,7 +6,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.trendyol</groupId>
     <artifactId>Jdempotent-spring-boot-redis-starter</artifactId>
-    <version>1.0.8</version>
+    <version>1.0.9</version>
     <name>Jdempotent-spring-boot-redis-starter</name>
     <packaging>jar</packaging>
     <url>https://github.com/Trendyol/Jdempotent/tree/master/Jdempotent-spring-boot-redis-starter</url>
@@ -54,7 +54,7 @@
         <dependency>
             <groupId>com.trendyol</groupId>
             <artifactId>Jdempotent-core</artifactId>
-            <version>1.0.8</version>
+            <version>1.0.9</version>
         </dependency>
         <dependency>
             <groupId>redis.clients</groupId>

examples/jdempotent-couchbase-example/pom.xml

@@ -59,7 +59,7 @@
         <dependency>
             <groupId>com.trendyol</groupId>
             <artifactId>Jdempotent-spring-boot-couchbase-starter</artifactId>
-            <version>1.0.8</version>
+            <version>1.0.9</version>
         </dependency>
     </dependencies>
 

examples/jdempotent-redis-example/pom.xml

@@ -59,7 +59,7 @@
         <dependency>
             <groupId>com.trendyol</groupId>
             <artifactId>Jdempotent-spring-boot-redis-starter</artifactId>
-            <version>1.0.8</version>
+            <version>1.0.9</version>
         </dependency>
     </dependencies>
 

examples/jdempotent-redis-example/src/main/java/com/jdempotent/example/demo/controller/MailController.java

@@ -14,9 +14,10 @@
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RestController;
-
+import com.trendyol.jdempotent.core.annotation.IdempotentRequestPayload;
 import javax.mail.MessagingException;
 import java.util.concurrent.TimeUnit;
+import org.springframework.web.bind.annotation.RequestHeader;
 
 @RestController
 public class MailController {
@@ -42,6 +43,24 @@ public ResponseEntity<SendEmailResponse> sendEmail(@RequestBody SendEmailRequest
         return new ResponseEntity(new SendEmailResponse("We will send your message"), HttpStatus.ACCEPTED);
     }
 
+
+
+    @PostMapping("/send-email-header")
+    @IdempotentResource(cachePrefix = "MailController.sendEmail")
+    public ResponseEntity<SendEmailResponse> sendEmail(@IdempotentRequestPayload @RequestHeader("x-idempotency-key") String idempotencyKey, @RequestBody SendEmailRequest request) {
+        if (StringUtils.isEmpty(request.getEmail())) {
+            throw new InvalidEmailAddressException();
+        }
+
+        try {
+            mailSenderService.sendMail(request);
+        } catch (MessagingException e) {
+            logger.debug("MailSenderService.sendEmail() throw exception: {} request: {} ", e, request);
+        }
+
+        return new ResponseEntity(new SendEmailResponse("We will send your message"), HttpStatus.ACCEPTED);
+    }
+
     @PostMapping("v2/send-email")
     @IdempotentResource(
             cachePrefix = "MailController.sendEmailV2",

pom.xml

@@ -4,7 +4,7 @@
     <groupId>com.trendyol</groupId>
     <artifactId>jdempotent</artifactId>
     <packaging>pom</packaging>
-    <version>1.0.8</version>
+    <version>1.0.9</version>
     <name>Jdempotent</name>
     <url>https://github.com/Trendyol/Jdempotent</url>
     <description>Jdempotent</description>