[FEAT] 아바타 프로필 시스템 확장 구현

src/main/java/org/websoso/WSSServer/application/AccountApplication.java

@@ -0,0 +1,67 @@
+package org.websoso.WSSServer.application;
+
+import static org.websoso.WSSServer.domain.common.DiscordWebhookMessageType.WITHDRAW;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.websoso.WSSServer.domain.common.DiscordWebhookMessage;
+import org.websoso.WSSServer.dto.user.WithdrawalRequest;
+import org.websoso.WSSServer.feed.repository.CommentRepository;
+import org.websoso.WSSServer.feed.repository.FeedRepository;
+import org.websoso.WSSServer.oauth2.service.AppleService;
+import org.websoso.WSSServer.oauth2.service.KakaoService;
+import org.websoso.WSSServer.repository.RefreshTokenRepository;
+import org.websoso.WSSServer.service.DiscordMessageClient;
+import org.websoso.WSSServer.service.MessageFormatter;
+import org.websoso.WSSServer.user.domain.User;
+import org.websoso.WSSServer.user.domain.WithdrawalReason;
+import org.websoso.WSSServer.user.repository.UserRepository;
+import org.websoso.WSSServer.user.repository.WithdrawalReasonRepository;
+
+@Service
+@RequiredArgsConstructor
+@Transactional
+public class AccountApplication {
+    private static final String KAKAO_PREFIX = "kakao";
+    private static final String APPLE_PREFIX = "apple";
+
+    private final WithdrawalReasonRepository withdrawalReasonRepository;
+    private final DiscordMessageClient discordMessageClient;
+    private final AppleService appleService;
+    private final FeedRepository feedRepository;
+    private final UserRepository userRepository;
+    private final CommentRepository commentRepository;
+    private final RefreshTokenRepository refreshTokenRepository;
+    private final KakaoService kakaoService;
+
+    public void withdrawUser(User user, WithdrawalRequest withdrawalRequest) {
+        unlinkSocialAccount(user);
+
+        String messageContent = MessageFormatter.formatUserWithdrawMessage(user.getUserId(), user.getNickname(),
+                withdrawalRequest.reason());
+
+        cleanupUserData(user.getUserId());
+
+        discordMessageClient.sendDiscordWebhookMessage(
+                DiscordWebhookMessage.of(messageContent, WITHDRAW));
+
+        withdrawalReasonRepository.save(WithdrawalReason.create(withdrawalRequest.reason()));
+    }
+
+    private void unlinkSocialAccount(User user) {
+        if (user.getSocialId().startsWith(KAKAO_PREFIX)) {
+            kakaoService.unlinkFromKakao(user);
+        } else if (user.getSocialId().startsWith(APPLE_PREFIX)) {
+            appleService.unlinkFromApple(user);
+        }
+    }
+
+    private void cleanupUserData(Long userId) {
+        refreshTokenRepository.deleteAll(refreshTokenRepository.findAllByUserId(userId));
+        feedRepository.updateUserToUnknown(userId);
+        commentRepository.updateUserToUnknown(userId);
+        userRepository.deleteById(userId);
+    }
+
+}

src/main/java/org/websoso/WSSServer/service/AuthService.java → src/main/java/org/websoso/WSSServer/application/AuthApplication.java

@@ -1,4 +1,4 @@
-package org.websoso.WSSServer.service;
+package org.websoso.WSSServer.application;
 
 import static org.websoso.WSSServer.exception.error.CustomAuthError.INVALID_TOKEN;
 
@@ -9,19 +9,28 @@
 import org.websoso.WSSServer.config.jwt.JWTUtil;
 import org.websoso.WSSServer.config.jwt.JwtProvider;
 import org.websoso.WSSServer.config.jwt.JwtValidationType;
-import org.websoso.WSSServer.domain.RefreshToken;
+import org.websoso.WSSServer.dto.auth.LogoutRequest;
 import org.websoso.WSSServer.dto.auth.ReissueResponse;
+import org.websoso.WSSServer.dto.user.LoginResponse;
 import org.websoso.WSSServer.exception.exception.CustomAuthException;
+import org.websoso.WSSServer.oauth2.service.KakaoService;
 import org.websoso.WSSServer.repository.RefreshTokenRepository;
+import org.websoso.WSSServer.user.domain.RefreshToken;
+import org.websoso.WSSServer.user.domain.User;
+import org.websoso.WSSServer.user.repository.UserDeviceRepository;
+import org.websoso.WSSServer.user.service.UserService;
 
 @Service
 @RequiredArgsConstructor
-@Transactional(readOnly = true)
-public class AuthService {
-
+public class AuthApplication {
     private final JwtProvider jwtProvider;
     private final JWTUtil jwtUtil;
     private final RefreshTokenRepository refreshTokenRepository;
+    private final UserDeviceRepository userDeviceRepository;
+    private final UserService userService;
+    private final KakaoService kakaoService;
+    private static final String KAKAO_PREFIX = "kakao";
+    private static final String APPLE_PREFIX = "apple";
 
     public ReissueResponse reissue(String refreshToken) {
         RefreshToken storedRefreshToken = refreshTokenRepository.findByRefreshToken(refreshToken)
@@ -41,4 +50,27 @@ public ReissueResponse reissue(String refreshToken) {
 
         return ReissueResponse.of(newAccessToken, newRefreshToken);
     }
+
+    // TODO: getUserOrException -> existUserOrException 변경
+    @Transactional(readOnly = true)
+    public LoginResponse login(Long userId) {
+        User user = userService.getUserOrException(userId);
+
+        CustomAuthenticationToken customAuthenticationToken = new CustomAuthenticationToken(user.getUserId(), null,
+                null);
+        String token = jwtProvider.generateAccessToken(customAuthenticationToken);
+
+        return LoginResponse.of(token);
+    }
+
+    public void logout(User user, LogoutRequest request) {
+        refreshTokenRepository.findByRefreshToken(request.refreshToken())
+                .ifPresent(refreshTokenRepository::delete);
+
+        userDeviceRepository.deleteByUserAndDeviceIdentifier(user, request.deviceIdentifier());
+
+        if (user.getSocialId().startsWith(KAKAO_PREFIX)) {
+            kakaoService.kakaoLogout(user);
+        }
+    }
 }

src/main/java/org/websoso/WSSServer/application/CommentFindApplication.java

@@ -0,0 +1,62 @@
+package org.websoso.WSSServer.application;
+
+import static org.websoso.WSSServer.exception.error.CustomAvatarError.AVATAR_NOT_FOUND;
+import static org.websoso.WSSServer.exception.error.CustomUserError.USER_NOT_FOUND;
+
+import java.util.AbstractMap;
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.websoso.WSSServer.repository.AvatarProfileRepository;
+import org.websoso.WSSServer.user.domain.User;
+import org.websoso.WSSServer.dto.comment.CommentGetResponse;
+import org.websoso.WSSServer.dto.comment.CommentsGetResponse;
+import org.websoso.WSSServer.dto.user.UserBasicInfo;
+import org.websoso.WSSServer.exception.exception.CustomAvatarException;
+import org.websoso.WSSServer.exception.exception.CustomUserException;
+import org.websoso.WSSServer.feed.domain.Feed;
+import org.websoso.WSSServer.feed.service.FeedServiceImpl;
+import org.websoso.WSSServer.repository.BlockRepository;
+import org.websoso.WSSServer.user.repository.UserRepository;
+
+@Service
+@RequiredArgsConstructor
+public class CommentFindApplication {
+
+    private final FeedServiceImpl feedServiceImpl;
+
+    //ToDo : 의존성 제거 필요 부분
+    private final UserRepository userRepository;
+    private final BlockRepository blockRepository;
+    private final AvatarProfileRepository avatarProfileRepository;
+
+    @Transactional(readOnly = true)
+    public CommentsGetResponse getComments(User user, Long feedId) {
+        Feed feed = feedServiceImpl.getFeedOrException(feedId);
+        List<CommentGetResponse> responses = feed.getComments().stream()
+                .map(comment -> new AbstractMap.SimpleEntry<>(comment, userRepository.findById(comment.getUserId())
+                        .orElseThrow(
+                                () -> new CustomUserException(USER_NOT_FOUND, "user with the given id was not found"))))
+                .map(entry -> CommentGetResponse.of(getUserBasicInfo(entry.getValue()), entry.getKey(),
+                        isUserCommentOwner(entry.getValue(), user), entry.getKey().getIsSpoiler(),
+                        isBlocked(user, entry.getValue()), entry.getKey().getIsHidden())).toList();
+
+        return CommentsGetResponse.of(responses);
+    }
+
+    private Boolean isUserCommentOwner(User createdUser, User user) {
+        return createdUser.equals(user);
+    }
+
+    private Boolean isBlocked(User user, User createdFeedUser) {
+        return blockRepository.existsByBlockingIdAndBlockedId(user.getUserId(), createdFeedUser.getUserId());
+    }
+
+    private UserBasicInfo getUserBasicInfo(User user) {
+        return user.getUserBasicInfo(
+                avatarProfileRepository.findById(user.getAvatarProfileId()).orElseThrow(() ->
+                                new CustomAvatarException(AVATAR_NOT_FOUND, "avatar with the given id was not found"))
+                        .getAvatarProfileImage());
+    }
+}

src/main/java/org/websoso/WSSServer/application/CommentManagementApplication.java

@@ -0,0 +1,167 @@
+package org.websoso.WSSServer.application;
+
+import static java.lang.Boolean.TRUE;
+import static org.websoso.WSSServer.domain.common.Action.DELETE;
+import static org.websoso.WSSServer.domain.common.Action.UPDATE;
+import static org.websoso.WSSServer.exception.error.CustomUserError.USER_NOT_FOUND;
+
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.websoso.WSSServer.domain.Notification;
+import org.websoso.WSSServer.domain.NotificationType;
+import org.websoso.WSSServer.user.domain.User;
+import org.websoso.WSSServer.user.domain.UserDevice;
+import org.websoso.WSSServer.dto.comment.CommentCreateRequest;
+import org.websoso.WSSServer.dto.comment.CommentUpdateRequest;
+import org.websoso.WSSServer.exception.exception.CustomUserException;
+import org.websoso.WSSServer.feed.domain.Comment;
+import org.websoso.WSSServer.feed.domain.Feed;
+import org.websoso.WSSServer.feed.service.CommentServiceImpl;
+import org.websoso.WSSServer.feed.service.FeedServiceImpl;
+import org.websoso.WSSServer.notification.FCMClient;
+import org.websoso.WSSServer.notification.dto.FCMMessageRequest;
+import org.websoso.WSSServer.novel.domain.Novel;
+import org.websoso.WSSServer.novel.service.NovelServiceImpl;
+import org.websoso.WSSServer.repository.BlockRepository;
+import org.websoso.WSSServer.repository.NotificationRepository;
+import org.websoso.WSSServer.repository.NotificationTypeRepository;
+import org.websoso.WSSServer.user.repository.UserRepository;
+
+@Service
+@RequiredArgsConstructor
+public class CommentManagementApplication {
+
+    private final CommentServiceImpl commentServiceImpl;
+    private final FeedServiceImpl feedServiceImpl;
+    private final NovelServiceImpl novelServiceImpl;
+    private final FCMClient fcmClient;
+
+    private static final int NOTIFICATION_TITLE_MAX_LENGTH = 12;
+    private static final int NOTIFICATION_TITLE_MIN_LENGTH = 0;
+
+    //ToDo : 의존성 제거 필요 부분
+    private final BlockRepository blockRepository;
+    private final NotificationRepository notificationRepository;
+    private final NotificationTypeRepository notificationTypeRepository;
+    private final UserRepository userRepository;
+
+    @Transactional
+    public void createComment(User user, Long feedId, CommentCreateRequest request) {
+        Feed feed = feedServiceImpl.getFeedOrException(feedId);
+        commentServiceImpl.createComment(user, feed, request);
+        sendCommentPushMessageToFeedOwner(user, feed);
+        sendCommentPushMessageToCommenters(user, feed);
+    }
+
+    private void sendCommentPushMessageToFeedOwner(User user, Feed feed) {
+        User feedOwner = feed.getUser();
+        if (user.equals(feedOwner) || blockRepository.existsByBlockingIdAndBlockedId(feedOwner.getUserId(),
+                user.getUserId())) {
+            return;
+        }
+
+        // ToDo : 해당 로직 NotificationSerivce에서 처리하도록 수정
+        NotificationType notificationTypeComment = notificationTypeRepository.findByNotificationTypeName("댓글");
+
+        String notificationTitle = createNotificationTitle(feed);
+        String notificationBody = String.format("%s님이 내 글에 댓글을 남겼어요.", user.getNickname());
+        Long feedId = feed.getFeedId();
+
+        Notification notification = Notification.create(notificationTitle, notificationBody, null,
+                feedOwner.getUserId(), feedId, notificationTypeComment);
+        notificationRepository.save(notification);
+
+        if (!TRUE.equals(feedOwner.getIsPushEnabled())) {
+            return;
+        }
+
+        List<UserDevice> feedOwnerDevices = feedOwner.getUserDevices();
+        if (feedOwnerDevices.isEmpty()) {
+            return;
+        }
+
+        FCMMessageRequest fcmMessageRequest = FCMMessageRequest.of(notificationTitle, notificationBody,
+                String.valueOf(feedId), "feedDetail", String.valueOf(notification.getNotificationId()));
+
+        List<String> targetFCMTokens = feedOwnerDevices.stream().map(UserDevice::getFcmToken).toList();
+
+        fcmClient.sendMulticastPushMessage(targetFCMTokens, fcmMessageRequest);
+    }
+
+    private void sendCommentPushMessageToCommenters(User user, Feed feed) {
+        User feedOwner = feed.getUser();
+
+        List<User> commenters = feed.getComments().stream().map(Comment::getUserId)
+                .filter(userId -> !userId.equals(user.getUserId()))
+                .filter(userId -> !userId.equals(feedOwner.getUserId()))
+                .filter(userId -> !blockRepository.existsByBlockingIdAndBlockedId(userId, user.getUserId())
+                        && !blockRepository.existsByBlockingIdAndBlockedId(userId, feed.getUser().getUserId()))
+                .distinct().map(userId -> userRepository.findById(userId).orElseThrow(
+                        () -> new CustomUserException(USER_NOT_FOUND, "user with the given id was not found")))
+                .toList();
+
+        if (commenters.isEmpty()) {
+            return;
+        }
+
+        // ToDo : 해당 로직 NotificationSerivce에서 처리하도록 수정
+        NotificationType notificationTypeComment = notificationTypeRepository.findByNotificationTypeName("댓글");
+
+        String notificationTitle = createNotificationTitle(feed);
+        String notificationBody = "내가 댓글 단 글에 또 다른 댓글이 달렸어요.";
+        Long feedId = feed.getFeedId();
+
+        commenters.forEach(commenter -> {
+            Notification notification = Notification.create(notificationTitle, notificationBody, null,
+                    commenter.getUserId(), feedId, notificationTypeComment);
+            notificationRepository.save(notification);
+
+            if (!TRUE.equals(commenter.getIsPushEnabled())) {
+                return;
+            }
+
+            List<UserDevice> commenterDevices = commenter.getUserDevices();
+            if (commenterDevices.isEmpty()) {
+                return;
+            }
+
+            List<String> targetFCMTokens = commenterDevices.stream().map(UserDevice::getFcmToken).distinct().toList();
+
+            FCMMessageRequest fcmMessageRequest = FCMMessageRequest.of(notificationTitle, notificationBody,
+                    String.valueOf(feedId), "feedDetail", String.valueOf(notification.getNotificationId()));
+            fcmClient.sendMulticastPushMessage(targetFCMTokens, fcmMessageRequest);
+        });
+    }
+
+
+    private String createNotificationTitle(Feed feed) {
+        if (feed.getNovelId() == null) {
+            String feedContent = feed.getFeedContent();
+            feedContent = feedContent.length() <= NOTIFICATION_TITLE_MAX_LENGTH ? feedContent
+                    : feedContent.substring(NOTIFICATION_TITLE_MIN_LENGTH, NOTIFICATION_TITLE_MAX_LENGTH);
+            return "'" + feedContent + "...'";
+        }
+        Novel novel = novelServiceImpl.getNovelOrException(feed.getNovelId());
+        return novel.getTitle();
+    }
+
+    @Transactional
+    public void updateComment(User user, Long feedId, Long commentId, CommentUpdateRequest request) {
+        Feed feed = feedServiceImpl.getFeedOrException(feedId);
+        Comment comment = commentServiceImpl.findComment(commentId);
+        comment.validateFeedAssociation(feed);
+        comment.validateUserAuthorization(user.getUserId(), UPDATE);
+        commentServiceImpl.updateComment(comment, request);
+    }
+
+    @Transactional
+    public void deleteComment(User user, Long feedId, Long commentId) {
+        Feed feed = feedServiceImpl.getFeedOrException(feedId);
+        Comment comment = commentServiceImpl.findComment(commentId);
+        comment.validateFeedAssociation(feed);
+        comment.validateUserAuthorization(user.getUserId(), DELETE);
+        commentServiceImpl.deleteComment(comment);
+    }
+}