From af85ae593d86c6be1d26a608620e7dce180d99a8 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=EC=86=A1=EC=98=81=EB=AF=BC?= <jakgon@naver.com>
Date: Wed, 24 Jul 2024 14:32:59 +0900
Subject: [PATCH] feat: add transactional to photo

---
 .../src/main/java/kr/mafoo/photo/service/AlbumService.java | 7 +++++++
 .../src/main/java/kr/mafoo/photo/service/PhotoService.java | 4 ++++
 2 files changed, 11 insertions(+)

diff --git a/photo-service/src/main/java/kr/mafoo/photo/service/AlbumService.java b/photo-service/src/main/java/kr/mafoo/photo/service/AlbumService.java
index a681ab1..87fb4cc 100644
--- a/photo-service/src/main/java/kr/mafoo/photo/service/AlbumService.java
+++ b/photo-service/src/main/java/kr/mafoo/photo/service/AlbumService.java
@@ -7,6 +7,7 @@
 import kr.mafoo.photo.util.IdGenerator;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
@@ -15,6 +16,7 @@
 public class AlbumService {
     private final AlbumRepository albumRepository;
 
+    @Transactional
     public Mono<AlbumEntity> createNewAlbum(String ownerMemberId, String albumName, AlbumType albumType) {
         AlbumEntity albumEntity = AlbumEntity.newAlbum(IdGenerator.generate(), albumName, albumType, ownerMemberId);
         return albumRepository.save(albumEntity);
@@ -38,6 +40,7 @@ public Mono<AlbumEntity> findByAlbumId(String albumId, String requestMemberId) {
                 });
     }
 
+    @Transactional
     public Mono<Void> deleteAlbumById(String albumId, String requestMemberId) {
         return albumRepository
                 .findById(albumId)
@@ -52,6 +55,7 @@ public Mono<Void> deleteAlbumById(String albumId, String requestMemberId) {
                 });
     }
 
+    @Transactional
     public Mono<AlbumEntity> updateAlbumName(String albumId, String albumName, String requestMemberId) {
         return albumRepository
                 .findById(albumId)
@@ -66,6 +70,7 @@ public Mono<AlbumEntity> updateAlbumName(String albumId, String albumName, Strin
                 });
     }
 
+    @Transactional
     public Mono<AlbumEntity> updateAlbumType(String albumId, AlbumType albumType, String requestMemberId) {
         return albumRepository
                 .findById(albumId)
@@ -80,6 +85,7 @@ public Mono<AlbumEntity> updateAlbumType(String albumId, AlbumType albumType, St
                 });
     }
 
+    @Transactional
     public Mono<Void> increaseAlbumPhotoCount(String albumId, String requestMemberId) {
         return albumRepository
                 .findById(albumId)
@@ -94,6 +100,7 @@ public Mono<Void> increaseAlbumPhotoCount(String albumId, String requestMemberId
                 });
     }
 
+    @Transactional
     public Mono<Void> decreaseAlbumPhotoCount(String albumId, String requestMemberId) {
 
         if (albumId == null) {
diff --git a/photo-service/src/main/java/kr/mafoo/photo/service/PhotoService.java b/photo-service/src/main/java/kr/mafoo/photo/service/PhotoService.java
index 39fcdb0..efb2c5a 100644
--- a/photo-service/src/main/java/kr/mafoo/photo/service/PhotoService.java
+++ b/photo-service/src/main/java/kr/mafoo/photo/service/PhotoService.java
@@ -8,6 +8,7 @@
 import kr.mafoo.photo.util.IdGenerator;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
@@ -21,6 +22,7 @@ public class PhotoService {
     private final QrService qrService;
     private final ObjectStorageService objectStorageService;
 
+    @Transactional
     public Mono<PhotoEntity> createNewPhoto(String qrUrl, String requestMemberId) {
         return qrService
                 .getFileFromQrUrl(qrUrl)
@@ -46,6 +48,7 @@ public Flux<PhotoEntity> findAllByAlbumId(String albumId, String requestMemberId
                 });
     }
 
+    @Transactional
     public Mono<Void> deletePhotoById(String photoId, String requestMemberId) {
         return photoRepository
                 .findById(photoId)
@@ -61,6 +64,7 @@ public Mono<Void> deletePhotoById(String photoId, String requestMemberId) {
                 });
     }
 
+    @Transactional
     public Mono<PhotoEntity> updatePhotoAlbumId(String photoId, String albumId, String requestMemberId) {
         return photoRepository
                 .findById(photoId)