Feat/58/shared refrigerator

build.gradle

@@ -78,6 +78,9 @@ dependencies {
 	implementation 'com.google.api-client:google-api-client'
 	implementation 'com.google.oauth-client:google-oauth-client'
 	implementation 'com.google.http-client:google-http-client-gson'
+
+    // ============= WebSocket =============
+    implementation 'org.springframework.boot:spring-boot-starter-websocket'
 }
 
 tasks.named('test') {

src/main/java/novaminds/gradproj/apiPayload/code/status/ErrorStatus.java

@@ -81,6 +81,14 @@ public enum ErrorStatus implements BaseErrorCode {
     STORED_ITEM_NOT_FOUND(HttpStatus.NOT_FOUND, "REFRIGERATOR403", "냉장고 재료를 찾을 수 없습니다."),
     STORED_ITEM_ACCESS_DENIED(HttpStatus.FORBIDDEN, "REFRIGERATOR404", "해당 냉장고 재료에 대한 접근 권한이 없습니다."),
 
+    // 냉장고 초대 관련 에러
+    INVITATION_NOT_FOUND(HttpStatus.NOT_FOUND, "INVITATION401", "초대를 찾을 수 없습니다."),
+    INVITATION_ALREADY_EXISTS(HttpStatus.BAD_REQUEST, "INVITATION402", "이미 초대를 보낸 사용자입니다."),
+    INVITATION_ALREADY_PROCESSED(HttpStatus.BAD_REQUEST, "INVITATION403", "이미 처리된 초대입니다."),
+    INVITATION_NOT_AUTHORIZED(HttpStatus.FORBIDDEN, "INVITATION404", "초대에 대한 권한이 없습니다."),
+    CANNOT_INVITE_SELF(HttpStatus.BAD_REQUEST, "INVITATION405", "자기 자신을 초대할 수 없습니다."),
+    ALREADY_IN_SAME_REFRIGERATOR(HttpStatus.BAD_REQUEST, "INVITATION406", "이미 같은 냉장고를 사용 중입니다."),
+
     //레시피 관련 에러
     RECIPE_NOT_FOUND(HttpStatus.NOT_FOUND, "RECIPE401", "해당 레시피를 찾을 수 없습니다."),
     RECIPE_NOT_AUTHORIZED(HttpStatus.FORBIDDEN, "RECIPE_402", "레시피 수정/삭제 권한이 없습니다."),

src/main/java/novaminds/gradproj/config/SecurityConfig.java

@@ -62,6 +62,7 @@ public SecurityFilterChain filterChain(HttpSecurity http) throws Exception {
                                 "/api/auth/login/naver", //TODO : 이건 없애고 프론트에서 바로 직접 접근하는게 나은 구조
                                 "/api/auth/reset-password/**",
                                 "/login/oauth2/**",
+                                "/ws-stomp/**",
                                 "/swagger-ui/**",
                                 "/v3/api-docs/**",
                                 "/swagger-resources/**"

src/main/java/novaminds/gradproj/config/WebSocketConfig.java

@@ -0,0 +1,41 @@
+package novaminds.gradproj.config;
+
+import lombok.RequiredArgsConstructor;
+import novaminds.gradproj.global.websocket.StompHandler;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.messaging.simp.config.ChannelRegistration;
+import org.springframework.messaging.simp.config.MessageBrokerRegistry;
+import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
+import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
+import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;
+
+@Configuration
+@EnableWebSocketMessageBroker
+@RequiredArgsConstructor
+public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
+
+    private final StompHandler stompHandler;
+
+    @Override
+    public void configureMessageBroker(MessageBrokerRegistry config) {
+        // 구독(sub) 경로 설정: 클라이언트가 메시지를 받을 경로의 prefix
+        config.enableSimpleBroker("/sub");
+
+        // 발행(pub) 경로 설정: 클라이언트가 메시지를 보낼 때 사용할 prefix
+        config.setApplicationDestinationPrefixes("/pub");
+    }
+
+    @Override
+    public void registerStompEndpoints(StompEndpointRegistry registry) {
+        // 웹소켓 연결 주소: ws://localhost:8080/ws-stomp
+        registry.addEndpoint("/ws-stomp")
+                .setAllowedOriginPatterns("*") // CORS 허용
+                .withSockJS();
+    }
+
+    @Override
+    public void configureClientInboundChannel(ChannelRegistration registration) {
+        // JWT 인증을 위한 인터셉터 추가
+        registration.interceptors(stompHandler);
+    }
+}

src/main/java/novaminds/gradproj/domain/member/entity/Member.java

@@ -66,8 +66,9 @@ public class Member extends BaseEntity {
 	@Builder.Default
 	private Integer point = 0;
 
-    @OneToOne(mappedBy = "member", cascade = CascadeType.ALL, orphanRemoval = true)
-	private Refrigerator refrigerator;
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "refrigerator_id", nullable = false)
+    private Refrigerator refrigerator;
 
 	@OneToMany(mappedBy = "author", cascade = CascadeType.ALL, orphanRemoval = true)
 	@Builder.Default
@@ -155,17 +156,17 @@ public String getRoleKey() {
 	}
 
 	public void setRefrigerator(Refrigerator refrigerator) {
-		// 기존 냉장고가 있고 새 냉장고와 다르면 기존 냉장고의 member 참조 해제
+		// 기존 냉장고가 있고 새 냉장고와 다르면 기존 냉장고의 memberList에서 제거
 		if (this.refrigerator != null && this.refrigerator != refrigerator) {
-			this.refrigerator.setMember(null);
+			this.refrigerator.removeMember(this);
 		}
-		
+
 		// 새 냉장고 할당
 		this.refrigerator = refrigerator;
-		
-		// 새 냉장고가 null이 아니면 양방향 연관관계 설정
+
+		// 새 냉장고가 null이 아니면 양방향 연관관계 설정 (memberList에 추가)
 		if (refrigerator != null) {
-			refrigerator.setMember(this);
+			refrigerator.addMember(this);
 		}
 	}
 }

src/main/java/novaminds/gradproj/domain/member/repository/FollowRepository.java

@@ -7,7 +7,7 @@
 import novaminds.gradproj.domain.member.entity.Follow;
 import org.springframework.data.jpa.repository.Modifying;
 
-public interface FollowRepository extends JpaRepository<Follow, Long> {
+public interface FollowRepository extends JpaRepository<Follow, Long>, FollowRepositoryCustom {
     // 특정 유저'가' 팔로우하는 사람들
     List<Follow> findByFollowerLoginId(String followerLoginId);
 

src/main/java/novaminds/gradproj/domain/member/repository/FollowRepositoryCustom.java

@@ -0,0 +1,14 @@
+package novaminds.gradproj.domain.member.repository;
+
+import novaminds.gradproj.domain.member.entity.Follow;
+
+import java.util.List;
+
+public interface FollowRepositoryCustom {
+
+    // 팔로워 목록 조회 (N+1 방지를 위한 fetch join)
+    List<Follow> findFollowersWithMemberByLoginId(String loginId);
+
+    // 팔로잉 목록 조회 (N+1 방지를 위한 fetch join)
+    List<Follow> findFollowingsWithMemberByLoginId(String loginId);
+}

src/main/java/novaminds/gradproj/domain/member/repository/FollowRepositoryCustomImpl.java

@@ -0,0 +1,39 @@
+package novaminds.gradproj.domain.member.repository;
+
+import com.querydsl.jpa.impl.JPAQueryFactory;
+import lombok.RequiredArgsConstructor;
+import novaminds.gradproj.domain.member.entity.Follow;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+import static novaminds.gradproj.domain.member.entity.QFollow.follow;
+import static novaminds.gradproj.domain.member.entity.QMember.member;
+import static novaminds.gradproj.domain.refrigerator.entity.QRefrigerator.refrigerator;
+
+@Repository
+@RequiredArgsConstructor
+public class FollowRepositoryCustomImpl implements FollowRepositoryCustom {
+
+    private final JPAQueryFactory queryFactory;
+
+    @Override
+    public List<Follow> findFollowersWithMemberByLoginId(String loginId) {
+        return queryFactory
+                .selectFrom(follow)
+                .join(follow.follower, member).fetchJoin()
+                .join(member.refrigerator, refrigerator).fetchJoin()
+                .where(follow.following.loginId.eq(loginId))
+                .fetch();
+    }
+
+    @Override
+    public List<Follow> findFollowingsWithMemberByLoginId(String loginId) {
+        return queryFactory
+                .selectFrom(follow)
+                .join(follow.following, member).fetchJoin()
+                .join(member.refrigerator, refrigerator).fetchJoin()
+                .where(follow.follower.loginId.eq(loginId))
+                .fetch();
+    }
+}

src/main/java/novaminds/gradproj/domain/member/service/MemberOnboardingService.java

@@ -7,7 +7,6 @@
 import novaminds.gradproj.domain.refrigerator.entity.MemberRefrigeratorSkin;
 import novaminds.gradproj.domain.refrigerator.repository.MemberRefrigeratorSkinRepository;
 import novaminds.gradproj.domain.refrigerator.entity.RefrigeratorSkin;
-import novaminds.gradproj.domain.refrigerator.repository.RefrigeratorRepository;
 import novaminds.gradproj.domain.refrigerator.repository.RefrigeratorSkinRepository;
 import novaminds.gradproj.domain.refrigerator.service.command.RefrigeratorCommandService;
 import org.springframework.stereotype.Service;
@@ -18,7 +17,6 @@
 @Transactional(readOnly = true)
 public class MemberOnboardingService {
 
-    private final RefrigeratorRepository refrigeratorRepository;
     private final RefrigeratorSkinRepository refrigeratorSkinRepository;
     private final MemberRefrigeratorSkinRepository memberRefrigeratorSkinRepository;
     private final RefrigeratorCommandService refrigeratorCommandService;
@@ -30,7 +28,7 @@ public class MemberOnboardingService {
      */
     @Transactional
     public void setupDefaultResources(Member member) {
-        if (refrigeratorRepository.existsByMember(member)) {
+        if (member.getRefrigerator() != null) {
             return;
         }
 

src/main/java/novaminds/gradproj/domain/member/service/query/FollowQueryService.java

@@ -0,0 +1,172 @@
+package novaminds.gradproj.domain.member.service.query;
+
+import lombok.RequiredArgsConstructor;
+import novaminds.gradproj.domain.member.entity.Follow;
+import novaminds.gradproj.domain.member.entity.Member;
+import novaminds.gradproj.domain.member.repository.FollowRepository;
+import novaminds.gradproj.domain.member.web.dto.MemberResponseDTO;
+import novaminds.gradproj.domain.refrigerator.entity.RefrigeratorInvitation;
+import novaminds.gradproj.domain.refrigerator.repository.RefrigeratorInvitationRepository;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+@RequiredArgsConstructor
+@Transactional(readOnly = true)
+@Service
+public class FollowQueryService {
+
+    private final FollowRepository followRepository;
+    private final RefrigeratorInvitationRepository refrigeratorInvitationRepository;
+
+    public MemberResponseDTO.FollowersResponse getFollowers(Member currentMember) {
+        // 나를 팔로우하는 사람들 조회 (fetch join으로 N+1 방지)
+        List<Follow> followers = followRepository.findFollowersWithMemberByLoginId(currentMember.getLoginId());
+
+        // 내가 팔로우하는 사람들의 loginId를 Set으로 (맞팔 확인용)
+        Set<String> myFollowingIds = followRepository.findByFollowerLoginId(currentMember.getLoginId())
+                .stream()
+                .map(follow -> follow.getFollowing().getLoginId())
+                .collect(Collectors.toSet());
+
+        // 나의 냉장고 ID
+        Long myRefrigeratorId = currentMember.getRefrigerator().getId();
+
+        // 팔로워 멤버 리스트
+        List<Member> followerMembers = followers.stream()
+                .map(Follow::getFollower)
+                .collect(Collectors.toList());
+
+        // 내가 보낸 PENDING 초대 조회 (batch)
+        List<RefrigeratorInvitation> pendingInvitations = refrigeratorInvitationRepository
+                .findByInviterAndInviteeInAndStatus(
+                        currentMember,
+                        followerMembers,
+                        RefrigeratorInvitation.InvitationStatus.PENDING
+                );
+
+        // PENDING 초대를 받은 사람들의 loginId를 Set으로
+        Set<String> pendingInviteeIds = pendingInvitations.stream()
+                .map(invitation -> invitation.getInvitee().getLoginId())
+                .collect(Collectors.toSet());
+
+        // DTO 변환
+        List<MemberResponseDTO.FollowMemberInfo> followerInfos = followers.stream()
+                .map(follow -> {
+                    Member followerMember = follow.getFollower();
+                    MemberResponseDTO.FollowMemberInfo.InvitationStatus status =
+                            determineInvitationStatus(
+                                    followerMember,
+                                    myFollowingIds,
+                                    myRefrigeratorId,
+                                    pendingInviteeIds
+                            );
+
+                    return MemberResponseDTO.FollowMemberInfo.builder()
+                            .nickname(followerMember.getNickname())
+                            .profileImgUrl(followerMember.getProfileImage())
+                            .invitationStatus(status)
+                            .build();
+                })
+                .collect(Collectors.toList());
+
+        return MemberResponseDTO.FollowersResponse.builder()
+                .followers(followerInfos)
+                .build();
+    }
+
+    public MemberResponseDTO.FollowingsResponse getFollowings(Member currentMember) {
+        // 내가 팔로우하는 사람들 조회 (fetch join으로 N+1 방지)
+        List<Follow> followings = followRepository.findFollowingsWithMemberByLoginId(currentMember.getLoginId());
+
+        // 나를 팔로우하는 사람들의 loginId를 Set으로 (맞팔 확인용)
+        Set<String> myFollowerIds = followRepository.findByFollowingLoginId(currentMember.getLoginId())
+                .stream()
+                .map(follow -> follow.getFollower().getLoginId())
+                .collect(Collectors.toSet());
+
+        // 나의 냉장고 ID
+        Long myRefrigeratorId = currentMember.getRefrigerator().getId();
+
+        // 팔로잉 멤버 리스트
+        List<Member> followingMembers = followings.stream()
+                .map(Follow::getFollowing)
+                .collect(Collectors.toList());
+
+        // 내가 보낸 PENDING 초대 조회 (batch)
+        List<RefrigeratorInvitation> pendingInvitations = refrigeratorInvitationRepository
+                .findByInviterAndInviteeInAndStatus(
+                        currentMember,
+                        followingMembers,
+                        RefrigeratorInvitation.InvitationStatus.PENDING
+                );
+
+        // PENDING 초대를 받은 사람들의 loginId를 Set으로
+        Set<String> pendingInviteeIds = pendingInvitations.stream()
+                .map(invitation -> invitation.getInvitee().getLoginId())
+                .collect(Collectors.toSet());
+
+        // DTO 변환
+        List<MemberResponseDTO.FollowMemberInfo> followingInfos = followings.stream()
+                .map(follow -> {
+                    Member followingMember = follow.getFollowing();
+                    MemberResponseDTO.FollowMemberInfo.InvitationStatus status =
+                            determineInvitationStatus(
+                                    followingMember,
+                                    myFollowerIds,
+                                    myRefrigeratorId,
+                                    pendingInviteeIds
+                            );
+
+                    return MemberResponseDTO.FollowMemberInfo.builder()
+                            .nickname(followingMember.getNickname())
+                            .profileImgUrl(followingMember.getProfileImage())
+                            .invitationStatus(status)
+                            .build();
+                })
+                .collect(Collectors.toList());
+
+        return MemberResponseDTO.FollowingsResponse.builder()
+                .followings(followingInfos)
+                .build();
+    }
+
+    /**
+     * 초대 상태를 결정하는 메서드
+     *
+     * @param targetMember 대상 멤버
+     * @param mutualCheckSet 맞팔 확인을 위한 Set (팔로워 목록이면 내 팔로잉 Set, 팔로잉 목록이면 내 팔로워 Set)
+     * @param myRefrigeratorId 나의 냉장고 ID
+     * @param pendingInviteeIds PENDING 상태 초대를 받은 사람들의 loginId Set
+     * @return InvitationStatus
+     */
+    private MemberResponseDTO.FollowMemberInfo.InvitationStatus determineInvitationStatus(
+            Member targetMember,
+            Set<String> mutualCheckSet,
+            Long myRefrigeratorId,
+            Set<String> pendingInviteeIds
+    ) {
+        // 맞팔이 아니면 NOT_MUTUAL
+        if (!mutualCheckSet.contains(targetMember.getLoginId())) {
+            return MemberResponseDTO.FollowMemberInfo.InvitationStatus.NOT_MUTUAL;
+        }
+
+        // 맞팔이면 추가 조건 확인
+        // 1. 같은 냉장고 사용 중인지 확인
+        if (targetMember.getRefrigerator().getId().equals(myRefrigeratorId)) {
+            return MemberResponseDTO.FollowMemberInfo.InvitationStatus.ALREADY_SAME_REFRIGERATOR;
+        }
+
+        // 2. 이미 초대장 보냈는지 확인
+        if (pendingInviteeIds.contains(targetMember.getLoginId())) {
+            return MemberResponseDTO.FollowMemberInfo.InvitationStatus.INVITATION_PENDING;
+        }
+
+        // 3. 둘 다 아니면 초대 가능
+        return MemberResponseDTO.FollowMemberInfo.InvitationStatus.MUTUAL_FOLLOW_INVITE;
+    }
+}

src/main/java/novaminds/gradproj/domain/member/service/security/auth/ProfileCompletionFilter.java

@@ -32,6 +32,7 @@ public class ProfileCompletionFilter extends OncePerRequestFilter {
             "/api/auth/additional-info-part2",
             "/api/auth/check-email",
             "/api/s3/image/upload-url",
+            "/ws-stomp/**",
             "/swagger-ui/**",
             "/v3/api-docs/**"
     );