라이브 예약 후 시작 시 푸시 - 테스트

src/main/kotlin/kr/co/vividnext/sodalive/member/MemberRepository.kt

@@ -12,7 +12,6 @@ import kr.co.vividnext.sodalive.member.following.QCreatorFollowing.creatorFollow
 import kr.co.vividnext.sodalive.member.nickname.QNicknameChangeLog.nicknameChangeLog
 import kr.co.vividnext.sodalive.member.notification.QMemberNotification.memberNotification
 import kr.co.vividnext.sodalive.message.QMessage.message
-import org.slf4j.LoggerFactory
 import org.springframework.data.jpa.repository.JpaRepository
 import org.springframework.stereotype.Repository
 
@@ -35,6 +34,7 @@ interface MemberQueryRepository {
 
     fun getStartLiveRoomNotificationRecipientPushTokens(
         creatorId: Long,
+        roomId: Long,
         isAuth: Boolean,
         container: String
     ): List<List<String>>
@@ -59,7 +59,6 @@ class MemberQueryRepositoryImpl(
     private val queryFactory: JPAQueryFactory,
     private val blockMemberRepository: BlockMemberRepository
 ) : MemberQueryRepository {
-    private val logger = LoggerFactory.getLogger(this::class.java)
     override fun findByPushToken(pushToken: String): List<Member> {
         return queryFactory
             .selectFrom(member)
@@ -148,6 +147,7 @@ class MemberQueryRepositoryImpl(
 
     override fun getStartLiveRoomNotificationRecipientPushTokens(
         creatorId: Long,
+        roomId: Long,
         isAuth: Boolean,
         container: String
     ): List<List<String>> {
@@ -172,16 +172,13 @@ class MemberQueryRepositoryImpl(
             .from(creatorFollowing)
             .where(where)
             .fetch()
-            .toSet()
-            .chunked(500)
 
-        logger.info("팔로잉 한 사람: $followingMemberPushToken")
-
-        var where2 = liveReservation.isActive.isTrue
+        where = liveReservation.isActive.isTrue
             .and(liveReservation.member.notification.live.isTrue)
             .and(liveReservation.member.container.eq(container))
             .and(liveReservation.member.email.notIn("admin@sodalive.net"))
             .and(liveReservation.member.pushToken.isNotNull)
+            .and(liveReservation.room.id.eq(roomId))
             .and(
                 liveReservation.member.id.notIn(
                     blockMemberRepository.getBlockedMemberList(creatorId)
@@ -189,20 +186,18 @@ class MemberQueryRepositoryImpl(
             )
 
         if (isAuth) {
-            where2 = where2.and(liveReservation.member.auth.isNotNull)
+            where = where.and(liveReservation.member.auth.isNotNull)
         }
 
         val reservationMemberPushToken = queryFactory
             .select(liveReservation.member.pushToken)
             .from(liveReservation)
-            .where(where2)
+            .where(where)
             .fetch()
+
+        return (followingMemberPushToken + reservationMemberPushToken)
             .toSet()
             .chunked(500)
-
-        logger.info("예약한 사람: $reservationMemberPushToken")
-
-        return followingMemberPushToken + reservationMemberPushToken
     }
 
     override fun getUploadContentNotificationRecipientPushTokens(