enhance async

Author: mariobgsp

src/main/java/com/example/articlemanager/delivery/ArticleController.java

@@ -11,6 +11,8 @@
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.*;
 
+import java.util.concurrent.CompletableFuture;
+
 @RestController
 @RequestMapping("/articles")
 public class ArticleController {
@@ -124,7 +126,9 @@ public ResponseEntity<?> updateArticle(
             }
         }
 
-        GenericResponse genericResponse = articleUsecase.updateArticle(article, id);
+        CompletableFuture.runAsync(()->articleUsecase.updateArticle(article, id));
+        GenericResponse genericResponse = new GenericResponse();
+        genericResponse.setSuccessMsg("Article Updated Successfully");
         return ResponseEntity.status(genericResponse.getHttpStatusCode()).body(genericResponse);
     }
 
@@ -148,7 +152,10 @@ public ResponseEntity<?> deleteArticle(
             }
         }
 
-        GenericResponse genericResponse = articleUsecase.deleteArticleById(id);
+
+        CompletableFuture.runAsync(()->articleUsecase.deleteArticleById(id));
+        GenericResponse genericResponse = new GenericResponse();
+        genericResponse.setSuccessMsg("Article Deleted Successfully");
         return ResponseEntity.status(genericResponse.getHttpStatusCode()).body(genericResponse);
     }
 }

src/main/java/com/example/articlemanager/usecase/ArticleUsecase.java

@@ -3,6 +3,7 @@
 import java.util.List;
 
 import com.example.articlemanager.model.rqrs.AddArticleRs;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.HttpStatus;
 import org.springframework.stereotype.Repository;
@@ -14,6 +15,7 @@
 import com.example.articlemanager.repository.ArticleRepository;
 
 @Repository
+@Slf4j
 public class ArticleUsecase {
 
     @Autowired
@@ -67,8 +69,10 @@ public GenericResponse updateArticle(ArticleRequest article, Long id){
             articleRepository.save(newArticle);
 
             genericResponse.setSuccessMsg("Article Updated Successfully");
+            log.info("{}", genericResponse.getMessage());
         }catch(Exception e){
             genericResponse.setFailed(HttpStatus.INTERNAL_SERVER_ERROR, e.getMessage());
+            log.info("{}", genericResponse.getError());
         }
 
         return genericResponse;
@@ -115,22 +119,24 @@ public GenericResponse getArticleById(Long id){
         return genericResponse;
     }
 
-    public GenericResponse deleteArticleById(Long id){
+    public void deleteArticleById(Long id){
         GenericResponse genericResponse = new GenericResponse();
         try{
             List<Article> articles = articleRepository.findById(id).stream().toList();
             if(articles.isEmpty()){
                 genericResponse.setFailed(HttpStatus.NOT_FOUND, "Article not found");
-                return genericResponse;
+
             }
             articleRepository.deleteById(id);
 
             genericResponse.setSuccessMsg("Article Deleted Successfully");
+            log.info("{}", genericResponse.getMessage());
         }catch(Exception e){
-            genericResponse.setFailed(HttpStatus.INTERNAL_SERVER_ERROR, e.getMessage());  
+            genericResponse.setFailed(HttpStatus.INTERNAL_SERVER_ERROR, e.getMessage());
+            log.info("{}", genericResponse.getError());
         }
 
-        return genericResponse;
+
     }