♻️ blocking logic

Author: HaiSeong

backend/src/main/java/net/pengcook/user/aop/BlockedUserFilterAspect.java

@@ -5,7 +5,9 @@
 import lombok.RequiredArgsConstructor;
 import net.pengcook.authentication.domain.UserInfo;
 import net.pengcook.user.domain.BlockeeGroup;
+import net.pengcook.user.domain.BlockerGroup;
 import net.pengcook.user.domain.Ownable;
+import net.pengcook.user.exception.ForbiddenException;
 import net.pengcook.user.service.UserService;
 import org.aspectj.lang.ProceedingJoinPoint;
 import org.aspectj.lang.annotation.Around;
@@ -36,8 +38,9 @@ public Object filterBlockedAuthorsFromList(ProceedingJoinPoint joinPoint) throws
         }
 
         BlockeeGroup blockeeGroup = userService.getBlockeeGroup(userInfo.getId());
+        BlockerGroup blockerGroup = userService.getBlockerGroup(userInfo.getId());
 
-        return filterBlockedUsers(ownables, blockeeGroup);
+        return filterBlockedUsers(ownables, blockeeGroup, blockerGroup);
     }
 
     @Pointcut("execution(java.util.Optional<net.pengcook.user.domain.Ownable+> net.pengcook..repository..*(..))")
@@ -55,17 +58,22 @@ public Object filterBlockedAuthorFromOptional(ProceedingJoinPoint joinPoint) thr
 
         BlockeeGroup blockeeGroup = userService.getBlockeeGroup(userInfo.getId());
         if (blockeeGroup.contains(ownableOptional.get().getOwnerId())) {
-            return Optional.empty();
+            throw new ForbiddenException("차단한 사용자입니다.");
+        }
+
+        BlockerGroup blockerGroup = userService.getBlockerGroup(userInfo.getId());
+        if (blockerGroup.contains(ownableOptional.get().getOwnerId())) {
+            throw new ForbiddenException("게시글을 이용할 수 없습니다.");
         }
 
         return ownableOptional;
     }
 
     @Pointcut("execution(net.pengcook.user.domain.Ownable+ net.pengcook..repository..*(..))")
-    public void repositoryMethodsReturningOwnable() {
+    public void repositoryMethodsReturningAuthorAble() {
     }
 
-    @Around("repositoryMethodsReturningOwnable()")
+    @Around("repositoryMethodsReturningAuthorAble()")
     public Object filterBlockedAuthor(ProceedingJoinPoint joinPoint) throws Throwable {
         Ownable ownable = (Ownable) joinPoint.proceed();
 
@@ -76,7 +84,12 @@ public Object filterBlockedAuthor(ProceedingJoinPoint joinPoint) throws Throwabl
 
         BlockeeGroup blockeeGroup = userService.getBlockeeGroup(userInfo.getId());
         if (blockeeGroup.contains(ownable.getOwnerId())) {
-            return null;
+            throw new ForbiddenException("차단한 사용자입니다.");
+        }
+
+        BlockerGroup blockerGroup = userService.getBlockerGroup(userInfo.getId());
+        if (blockerGroup.contains(ownable.getOwnerId())) {
+            throw new ForbiddenException("게시글을 이용할 수 없습니다.");
         }
 
         return ownable;
@@ -91,9 +104,14 @@ private UserInfo getCurrentUserInfo() {
         }
     }
 
-    private List<Ownable> filterBlockedUsers(List<Ownable> ownables, BlockeeGroup blockeeGroup) {
-        return ownables.stream()
+    private List<Ownable> filterBlockedUsers(
+            List<Ownable> authorAbles,
+            BlockeeGroup blockeeGroup,
+            BlockerGroup blockerGroup
+    ) {
+        return authorAbles.stream()
                 .filter(item -> !blockeeGroup.contains(item.getOwnerId()))
+                .filter(item -> !blockerGroup.contains(item.getOwnerId()))
                 .toList();
     }
 }

backend/src/main/java/net/pengcook/user/domain/BlockerGroup.java

@@ -0,0 +1,15 @@
+package net.pengcook.user.domain;
+
+import java.util.Set;
+import lombok.AllArgsConstructor;
+
+@AllArgsConstructor
+public class BlockerGroup {
+
+    private final Set<User> users;
+
+    public boolean contains(long userId) {
+        return users.stream()
+                .anyMatch(user -> user.isSameUser(userId));
+    }
+}

backend/src/main/java/net/pengcook/user/exception/ForbiddenException.java

@@ -0,0 +1,9 @@
+package net.pengcook.user.exception;
+
+import org.springframework.http.HttpStatus;
+
+public class ForbiddenException extends UserException {
+    public ForbiddenException(String message) {
+        super(HttpStatus.FORBIDDEN, message);
+    }
+}

backend/src/main/java/net/pengcook/user/repository/UserBlockRepository.java

@@ -9,6 +9,8 @@
 public interface UserBlockRepository extends JpaRepository<UserBlock, Long> {
     List<UserBlock> findAllByBlockerId(long blockerId);
 
+    List<UserBlock> findAllByBlockeeId(long blockeeId);
+
     void deleteByBlockeeId(long blockeeId);
 
     void deleteByBlockerId(long blockerId);

backend/src/main/java/net/pengcook/user/service/UserService.java

@@ -10,6 +10,7 @@
 import net.pengcook.recipe.repository.RecipeRepository;
 import net.pengcook.recipe.service.RecipeService;
 import net.pengcook.user.domain.BlockeeGroup;
+import net.pengcook.user.domain.BlockerGroup;
 import net.pengcook.user.domain.User;
 import net.pengcook.user.domain.UserBlock;
 import net.pengcook.user.domain.UserReport;
@@ -116,6 +117,14 @@ public BlockeeGroup getBlockeeGroup(long blockerId) {
                 .collect(Collectors.collectingAndThen(Collectors.toSet(), BlockeeGroup::new));
     }
 
+    @Transactional(readOnly = true)
+    public BlockerGroup getBlockerGroup(long blockeeId) {
+
+        return userBlockRepository.findAllByBlockeeId(blockeeId).stream()
+                .map(UserBlock::getBlocker)
+                .collect(Collectors.collectingAndThen(Collectors.toSet(), BlockerGroup::new));
+    }
+
     @Transactional
     public void deleteUser(UserInfo userInfo) {
         User user = userRepository.findById(userInfo.getId())