[BE] feat: 리뷰 삭제 기능 구현

backend/src/main/java/com/funeat/FuneatApplication.java

@@ -2,12 +2,13 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableAsync;
 
+@EnableAsync
 @SpringBootApplication
 public class FuneatApplication {
 
     public static void main(String[] args) {
         SpringApplication.run(FuneatApplication.class, args);
     }
-
 }

backend/src/main/java/com/funeat/common/ImageUploader.java

@@ -5,4 +5,6 @@
 public interface ImageUploader {
 
     String upload(final MultipartFile image);
+
+    void delete(final String fileName);
 }

backend/src/main/java/com/funeat/common/exception/CommonException.java

@@ -22,4 +22,10 @@ public S3UploadFailException(final CommonErrorCode errorCode) {
             super(errorCode.getStatus(), new ErrorCode<>(errorCode.getCode(), errorCode.getMessage()));
         }
     }
+
+    public static class S3DeleteFailException extends CommonException {
+        public S3DeleteFailException(final CommonErrorCode errorCode) {
+            super(errorCode.getStatus(), new ErrorCode<>(errorCode.getCode(), errorCode.getMessage()));
+        }
+    }
 }

backend/src/main/java/com/funeat/common/s3/S3Uploader.java

@@ -3,15 +3,19 @@
 import static com.funeat.exception.CommonErrorCode.IMAGE_EXTENSION_ERROR_CODE;
 import static com.funeat.exception.CommonErrorCode.UNKNOWN_SERVER_ERROR_CODE;
 
+import com.amazonaws.AmazonServiceException;
 import com.amazonaws.services.s3.AmazonS3;
 import com.amazonaws.services.s3.model.ObjectMetadata;
 import com.amazonaws.services.s3.model.PutObjectRequest;
 import com.funeat.common.ImageUploader;
 import com.funeat.common.exception.CommonException.NotAllowedFileExtensionException;
+import com.funeat.common.exception.CommonException.S3DeleteFailException;
 import com.funeat.common.exception.CommonException.S3UploadFailException;
 import java.io.IOException;
 import java.util.List;
 import java.util.UUID;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Profile;
 import org.springframework.stereotype.Component;
@@ -21,8 +25,11 @@
 @Profile("!test")
 public class S3Uploader implements ImageUploader {
 
+    private static final int BEGIN_FILE_NAME_INDEX_WITHOUT_CLOUDFRONT_PATH = 31;
     private static final List<String> INCLUDE_EXTENSIONS = List.of("image/jpeg", "image/png", "image/webp");
 
+    private final Logger log = LoggerFactory.getLogger(this.getClass());
+
     @Value("${cloud.aws.s3.bucket}")
     private String bucket;
 
@@ -53,6 +60,18 @@ public String upload(final MultipartFile image) {
         }
     }
 
+    @Override
+    public void delete(final String image) {
+        final String imageName = image.substring(BEGIN_FILE_NAME_INDEX_WITHOUT_CLOUDFRONT_PATH);
+        try {
+            final String key = folder + imageName;
+            amazonS3.deleteObject(bucket, key);
+        } catch (final AmazonServiceException e) {
+            log.error("S3 이미지 삭제에 실패했습니다. 이미지 경로 : {}", image);
+            throw new S3DeleteFailException(UNKNOWN_SERVER_ERROR_CODE);
+        }
+    }
+
     private void validateExtension(final MultipartFile image) {
         final String contentType = image.getContentType();
         if (!INCLUDE_EXTENSIONS.contains(contentType)) {

backend/src/main/java/com/funeat/member/persistence/ReviewFavoriteRepository.java

@@ -3,10 +3,15 @@
 import com.funeat.member.domain.Member;
 import com.funeat.member.domain.favorite.ReviewFavorite;
 import com.funeat.review.domain.Review;
+import java.util.List;
 import java.util.Optional;
 import org.springframework.data.jpa.repository.JpaRepository;
 
 public interface ReviewFavoriteRepository extends JpaRepository<ReviewFavorite, Long> {
 
     Optional<ReviewFavorite> findByMemberAndReview(final Member member, final Review review);
+
+    void deleteByReview(final Review review);
+
+    List<ReviewFavorite> findByReview(final Review review);
 }

backend/src/main/java/com/funeat/member/presentation/MemberApiController.java

@@ -15,7 +15,9 @@
 import org.springframework.data.web.PageableDefault;
 import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.DeleteMapping;
 import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.PutMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestPart;
@@ -69,4 +71,13 @@ public ResponseEntity<MemberRecipesResponse> getMemberRecipe(@AuthenticationPrin
 
         return ResponseEntity.ok().body(response);
     }
+
+    @Logging
+    @DeleteMapping("/reviews/{reviewId}")
+    public ResponseEntity<Void> deleteReview(@PathVariable final Long reviewId,
+                                             @AuthenticationPrincipal final LoginInfo loginInfo) {
+        reviewService.deleteReview(reviewId, loginInfo.getId());
+
+        return ResponseEntity.noContent().build();
+    }
 }

backend/src/main/java/com/funeat/member/presentation/MemberController.java

@@ -12,7 +12,9 @@
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.web.PageableDefault;
 import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.DeleteMapping;
 import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.PutMapping;
 import org.springframework.web.bind.annotation.RequestPart;
 import org.springframework.web.multipart.MultipartFile;
@@ -55,4 +57,13 @@ ResponseEntity<MemberReviewsResponse> getMemberReview(@AuthenticationPrincipal f
     @GetMapping
     ResponseEntity<MemberRecipesResponse> getMemberRecipe(@AuthenticationPrincipal final LoginInfo loginInfo,
                                                           @PageableDefault final Pageable pageable);
+
+    @Operation(summary = "리뷰 삭제", description = "자신이 작성한 리뷰를 삭제한다.")
+    @ApiResponse(
+            responseCode = "204",
+            description = "리뷰 삭제 성공."
+    )
+    @DeleteMapping
+    ResponseEntity<Void> deleteReview(@PathVariable final Long reviewId,
+                                      @AuthenticationPrincipal final LoginInfo loginInfo);
 }

backend/src/main/java/com/funeat/review/application/ReviewDeleteEvent.java

@@ -0,0 +1,14 @@
+package com.funeat.review.application;
+
+public class ReviewDeleteEvent {
+
+    private final String image;
+
+    public ReviewDeleteEvent(final String image) {
+        this.image = image;
+    }
+
+    public String getImage() {
+        return image;
+    }
+}

backend/src/main/java/com/funeat/review/application/ReviewDeleteEventListener.java

@@ -0,0 +1,27 @@
+package com.funeat.review.application;
+
+import com.funeat.common.ImageUploader;
+import io.micrometer.core.instrument.util.StringUtils;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.event.TransactionPhase;
+import org.springframework.transaction.event.TransactionalEventListener;
+
+@Component
+public class ReviewDeleteEventListener {
+
+    private final ImageUploader imageUploader;
+
+    public ReviewDeleteEventListener(final ImageUploader imageUploader) {
+        this.imageUploader = imageUploader;
+    }
+
+    @Async
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    public void deleteReviewImageInS3(final ReviewDeleteEvent event) {
+        final String image = event.getImage();
+        if (StringUtils.isBlank(image)) {
+            imageUploader.delete(image);
+        }
+    }
+}

backend/src/main/java/com/funeat/review/application/ReviewService.java

@@ -3,6 +3,7 @@
 import static com.funeat.member.exception.MemberErrorCode.MEMBER_DUPLICATE_FAVORITE;
 import static com.funeat.member.exception.MemberErrorCode.MEMBER_NOT_FOUND;
 import static com.funeat.product.exception.ProductErrorCode.PRODUCT_NOT_FOUND;
+import static com.funeat.review.exception.ReviewErrorCode.NOT_AUTHOR_OF_REVIEW;
 import static com.funeat.review.exception.ReviewErrorCode.REVIEW_NOT_FOUND;
 
 import com.funeat.common.ImageUploader;
@@ -26,6 +27,7 @@
 import com.funeat.review.dto.ReviewFavoriteRequest;
 import com.funeat.review.dto.SortingReviewDto;
 import com.funeat.review.dto.SortingReviewsResponse;
+import com.funeat.review.exception.ReviewException.NotAuthorOfReviewException;
 import com.funeat.review.exception.ReviewException.ReviewNotFoundException;
 import com.funeat.review.persistence.ReviewRepository;
 import com.funeat.review.persistence.ReviewTagRepository;
@@ -34,6 +36,7 @@
 import java.util.List;
 import java.util.Optional;
 import java.util.stream.Collectors;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.dao.DataIntegrityViolationException;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.PageRequest;
@@ -57,18 +60,21 @@ public class ReviewService {
     private final ProductRepository productRepository;
     private final ReviewFavoriteRepository reviewFavoriteRepository;
     private final ImageUploader imageUploader;
+    private final ApplicationEventPublisher eventPublisher;
 
     public ReviewService(final ReviewRepository reviewRepository, final TagRepository tagRepository,
                          final ReviewTagRepository reviewTagRepository, final MemberRepository memberRepository,
                          final ProductRepository productRepository,
-                         final ReviewFavoriteRepository reviewFavoriteRepository, final ImageUploader imageUploader) {
+                         final ReviewFavoriteRepository reviewFavoriteRepository,
+                         final ImageUploader imageUploader, final ApplicationEventPublisher eventPublisher) {
         this.reviewRepository = reviewRepository;
         this.tagRepository = tagRepository;
         this.reviewTagRepository = reviewTagRepository;
         this.memberRepository = memberRepository;
         this.productRepository = productRepository;
         this.reviewFavoriteRepository = reviewFavoriteRepository;
         this.imageUploader = imageUploader;
+        this.eventPublisher = eventPublisher;
     }
 
     @Transactional
@@ -123,14 +129,11 @@ private ReviewFavorite saveReviewFavorite(final Member member, final Review revi
     }
 
     @Transactional
-    public void updateProductImage(final Long reviewId) {
-        final Review review = reviewRepository.findById(reviewId)
-                .orElseThrow(() -> new ReviewNotFoundException(REVIEW_NOT_FOUND, reviewId));
+    public void updateProductImage(final Long productId) {
+        final Product product = productRepository.findById(productId)
+                .orElseThrow(() -> new ProductNotFoundException(PRODUCT_NOT_FOUND, productId));
 
-        final Product product = review.getProduct();
-        final Long productId = product.getId();
         final PageRequest pageRequest = PageRequest.of(TOP, ONE);
-
         final List<Review> topFavoriteReview = reviewRepository.findPopularReviewWithImage(productId, pageRequest);
         if (!topFavoriteReview.isEmpty()) {
             final String topFavoriteReviewImage = topFavoriteReview.get(TOP).getImage();
@@ -178,4 +181,44 @@ public MemberReviewsResponse findReviewByMember(final Long memberId, final Pagea
 
         return MemberReviewsResponse.toResponse(pageDto, dtos);
     }
+
+    @Transactional
+    public void deleteReview(final Long reviewId, final Long memberId) {
+        final Member member = memberRepository.findById(memberId)
+                .orElseThrow(() -> new MemberNotFoundException(MEMBER_NOT_FOUND, memberId));
+        final Review review = reviewRepository.findById(reviewId)
+                .orElseThrow(() -> new ReviewNotFoundException(REVIEW_NOT_FOUND, reviewId));
+        final Product product = review.getProduct();
+        final String image = review.getImage();
+
+        if (review.checkAuthor(member)) {
+            eventPublisher.publishEvent(new ReviewDeleteEvent(image));
+            deleteThingsRelatedToReview(review);
+            updateProductImage(product.getId());
+            return;
+        }
+        throw new NotAuthorOfReviewException(NOT_AUTHOR_OF_REVIEW, memberId);
+    }
+
+    private void deleteThingsRelatedToReview(final Review review) {
+        deleteReviewTags(review);
+        deleteReviewFavorites(review);
+        reviewRepository.delete(review);
+    }
+
+    private void deleteReviewTags(final Review review) {
+        final List<ReviewTag> reviewTags = reviewTagRepository.findByReview(review);
+        final List<Long> ids = reviewTags.stream()
+                .map(ReviewTag::getId)
+                .collect(Collectors.toList());
+        reviewTagRepository.deleteAllByIdInBatch(ids);
+    }
+
+    private void deleteReviewFavorites(final Review review) {
+        final List<ReviewFavorite> reviewFavorites = reviewFavoriteRepository.findByReview(review);
+        final List<Long> ids = reviewFavorites.stream()
+                .map(ReviewFavorite::getId)
+                .collect(Collectors.toList());
+        reviewFavoriteRepository.deleteAllByIdInBatch(ids);
+    }
 }

backend/src/main/java/com/funeat/review/domain/Review.java

@@ -88,6 +88,10 @@ public void minusFavoriteCount() {
         this.favoriteCount--;
     }
 
+    public boolean checkAuthor(final Member member) {
+        return Objects.equals(this.member, member);
+    }
+
     public Long getId() {
         return id;
     }

backend/src/main/java/com/funeat/review/exception/ReviewErrorCode.java

@@ -5,6 +5,7 @@
 public enum ReviewErrorCode {
 
     REVIEW_NOT_FOUND(HttpStatus.NOT_FOUND, "존재하지 않는 리뷰입니다. 리뷰 id를 확인하세요.", "3001"),
+    NOT_AUTHOR_OF_REVIEW(HttpStatus.BAD_REQUEST, "해당 리뷰를 작성한 회원이 아닙니다", "3002")
     ;
 
     private final HttpStatus status;

backend/src/main/java/com/funeat/review/exception/ReviewException.java

@@ -15,4 +15,10 @@ public ReviewNotFoundException(final ReviewErrorCode errorCode, final Long revie
             super(errorCode.getStatus(), new ErrorCode<>(errorCode.getCode(), errorCode.getMessage(), reviewId));
         }
     }
+
+    public static class NotAuthorOfReviewException extends ReviewException {
+        public NotAuthorOfReviewException(final ReviewErrorCode errorCode, final Long memberId) {
+            super(errorCode.getStatus(), new ErrorCode<>(errorCode.getCode(), errorCode.getMessage(), memberId));
+        }
+    }
 }

backend/src/main/java/com/funeat/review/persistence/ReviewTagRepository.java

@@ -1,5 +1,6 @@
 package com.funeat.review.persistence;
 
+import com.funeat.review.domain.Review;
 import com.funeat.review.domain.ReviewTag;
 import com.funeat.tag.domain.Tag;
 import java.util.List;
@@ -16,4 +17,8 @@ public interface ReviewTagRepository extends JpaRepository<ReviewTag, Long> {
             + "GROUP BY rt.tag "
             + "ORDER BY cnt DESC")
     List<Tag> findTop3TagsByReviewIn(final Long productId, final Pageable pageable);
+
+    void deleteByReview(final Review review);
+
+    List<ReviewTag> findByReview(final Review review);
 }

backend/src/main/java/com/funeat/review/presentation/ReviewApiController.java

@@ -14,6 +14,7 @@
 import org.springframework.data.web.PageableDefault;
 import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.DeleteMapping;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PatchMapping;
 import org.springframework.web.bind.annotation.PathVariable;
@@ -46,11 +47,12 @@ public ResponseEntity<Void> writeReview(@PathVariable final Long productId,
 
     @Logging
     @PatchMapping("/api/products/{productId}/reviews/{reviewId}")
-    public ResponseEntity<Void> toggleLikeReview(@PathVariable final Long reviewId,
+    public ResponseEntity<Void> toggleLikeReview(@PathVariable final Long productId,
+                                                 @PathVariable final Long reviewId,
                                                  @AuthenticationPrincipal final LoginInfo loginInfo,
                                                  @RequestBody @Valid final ReviewFavoriteRequest request) {
         reviewService.likeReview(reviewId, loginInfo.getId(), request);
-        reviewService.updateProductImage(reviewId);
+        reviewService.updateProductImage(productId);
 
         return ResponseEntity.noContent().build();
     }

backend/src/main/java/com/funeat/review/presentation/ReviewController.java

@@ -12,6 +12,7 @@
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.web.PageableDefault;
 import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.DeleteMapping;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PatchMapping;
 import org.springframework.web.bind.annotation.PathVariable;
@@ -40,7 +41,8 @@ ResponseEntity<Void> writeReview(@PathVariable final Long productId,
             description = "리뷰 좋아요(취소) 성공."
     )
     @PatchMapping
-    ResponseEntity<Void> toggleLikeReview(@PathVariable final Long reviewId,
+    ResponseEntity<Void> toggleLikeReview(@PathVariable final Long productId,
+                                          @PathVariable final Long reviewId,
                                           @AuthenticationPrincipal final LoginInfo loginInfo,
                                           @RequestBody final ReviewFavoriteRequest request);