Feat : 동아리 구독 추가/삭제, 구독자 알림 기능 추가

src/main/java/com/kustacks/kuring/club/adapter/out/persistence/ClubPersistenceAdapter.java

@@ -0,0 +1,61 @@
+package com.kustacks.kuring.club.adapter.out.persistence;
+
+import com.kustacks.kuring.club.application.port.out.ClubQueryPort;
+import com.kustacks.kuring.club.application.port.out.ClubSubscriptionCommandPort;
+import com.kustacks.kuring.club.application.port.out.ClubSubscriptionQueryPort;
+import com.kustacks.kuring.club.domain.Club;
+import com.kustacks.kuring.club.domain.ClubSubscribe;
+import com.kustacks.kuring.common.annotation.PersistenceAdapter;
+import com.kustacks.kuring.user.domain.RootUser;
+import lombok.RequiredArgsConstructor;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Optional;
+
+@PersistenceAdapter
+@RequiredArgsConstructor
+public class ClubPersistenceAdapter implements ClubQueryPort, ClubSubscriptionCommandPort, ClubSubscriptionQueryPort {
+
+    private final ClubRepository clubRepository;
+    private final ClubSubscribeRepository clubSubscribeRepository;
+
+    @Override
+    public Optional<Club> findClubById(Long id) {
+        return clubRepository.findById(id);
+    }
+
+    @Override
+    public List<Club> findClubsBetweenDates(LocalDateTime start, LocalDateTime end) {
+        return clubRepository.findClubsBetweenDates(start, end);
+    }
+
+    @Override
+    public List<Club> findNextDayRecruitEndClubs(LocalDateTime now) {
+        LocalDate tomorrow = now.toLocalDate().plusDays(1);
+        LocalDateTime startInclusive = tomorrow.atStartOfDay();
+        LocalDateTime endExclusive = tomorrow.plusDays(1).atStartOfDay();
+        return findClubsBetweenDates(startInclusive, endExclusive);
+    }
+
+    @Override
+    public boolean existsSubscription(Long rootUserId, Long clubId) {
+        return clubSubscribeRepository.existsByRootUserIdAndClubId(rootUserId, clubId);
+    }
+
+    @Override
+    public void saveSubscription(RootUser rootUser, Club club) {
+        clubSubscribeRepository.save(new ClubSubscribe(rootUser, club));
+    }
+
+    @Override
+    public void deleteSubscription(RootUser rootUser, Club club) {
+        clubSubscribeRepository.deleteByRootUserAndClub(rootUser, club);
+    }
+
+    @Override
+    public long countSubscriptions(Long rootUserId) {
+        return clubSubscribeRepository.countByRootUserId(rootUserId);
+    }
+}

src/main/java/com/kustacks/kuring/club/adapter/out/persistence/ClubQueryRepository.java

@@ -0,0 +1,11 @@
+package com.kustacks.kuring.club.adapter.out.persistence;
+
+import com.kustacks.kuring.club.domain.Club;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+public interface ClubQueryRepository {
+
+    List<Club> findClubsBetweenDates(LocalDateTime start, LocalDateTime end);
+}

src/main/java/com/kustacks/kuring/club/adapter/out/persistence/ClubQueryRepositoryImpl.java

@@ -0,0 +1,36 @@
+package com.kustacks.kuring.club.adapter.out.persistence;
+
+import com.kustacks.kuring.club.domain.Club;
+import com.querydsl.core.types.dsl.BooleanExpression;
+import com.querydsl.jpa.impl.JPAQueryFactory;
+import lombok.RequiredArgsConstructor;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+import static com.kustacks.kuring.club.domain.QClub.club;
+
+@RequiredArgsConstructor
+class ClubQueryRepositoryImpl implements ClubQueryRepository {
+
+    private final JPAQueryFactory queryFactory;
+
+    @Override
+    public List<Club> findClubsBetweenDates(LocalDateTime start, LocalDateTime end) {
+        return queryFactory.selectFrom(club)
+                .where(
+                        club.isAlways.isFalse(),
+                        recruitEndAtGoe(start),
+                        recruitEndAtLt(end)
+                )
+                .fetch();
+    }
+
+    private BooleanExpression recruitEndAtGoe(LocalDateTime start) {
+        return start != null ? club.recruitEndAt.goe(start) : null;
+    }
+
+    private BooleanExpression recruitEndAtLt(LocalDateTime end) {
+        return end != null ? club.recruitEndAt.lt(end) : null;
+    }
+}

src/main/java/com/kustacks/kuring/club/adapter/out/persistence/ClubRepository.java

@@ -0,0 +1,7 @@
+package com.kustacks.kuring.club.adapter.out.persistence;
+
+import com.kustacks.kuring.club.domain.Club;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+interface ClubRepository extends JpaRepository<Club, Long>, ClubQueryRepository {
+}

src/main/java/com/kustacks/kuring/club/adapter/out/persistence/ClubSubscribeRepository.java

@@ -0,0 +1,15 @@
+package com.kustacks.kuring.club.adapter.out.persistence;
+
+import com.kustacks.kuring.club.domain.Club;
+import com.kustacks.kuring.club.domain.ClubSubscribe;
+import com.kustacks.kuring.user.domain.RootUser;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+interface ClubSubscribeRepository extends JpaRepository<ClubSubscribe, Long> {
+
+    boolean existsByRootUserIdAndClubId(Long rootUserId, Long clubId);
+
+    long countByRootUserId(Long rootUserId);
+
+    void deleteByRootUserAndClub(RootUser rootUser, Club club);
+}

src/main/java/com/kustacks/kuring/club/application/port/in/ClubNotificationUseCase.java

@@ -0,0 +1,6 @@
+package com.kustacks.kuring.club.application.port.in;
+
+public interface ClubNotificationUseCase {
+
+    void sendDeadlineNotifications();
+}

src/main/java/com/kustacks/kuring/club/application/port/in/ClubSubscriptionUseCase.java

@@ -0,0 +1,10 @@
+package com.kustacks.kuring.club.application.port.in;
+
+import com.kustacks.kuring.club.application.port.in.dto.ClubSubscriptionCommand;
+
+public interface ClubSubscriptionUseCase {
+
+    long addSubscription(ClubSubscriptionCommand command);
+
+    long removeSubscription(ClubSubscriptionCommand command);
+}

src/main/java/com/kustacks/kuring/club/application/port/in/dto/ClubSubscriptionCommand.java

@@ -0,0 +1,7 @@
+package com.kustacks.kuring.club.application.port.in.dto;
+
+public record ClubSubscriptionCommand(
+        String email,
+        Long clubId
+) {
+}

src/main/java/com/kustacks/kuring/club/application/port/out/ClubQueryPort.java

@@ -0,0 +1,16 @@
+package com.kustacks.kuring.club.application.port.out;
+
+import com.kustacks.kuring.club.domain.Club;
+
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Optional;
+
+public interface ClubQueryPort {
+
+    Optional<Club> findClubById(Long id);
+
+    List<Club> findClubsBetweenDates(LocalDateTime start, LocalDateTime end);
+
+    List<Club> findNextDayRecruitEndClubs(LocalDateTime now);
+}

src/main/java/com/kustacks/kuring/club/application/port/out/ClubSubscriptionCommandPort.java

@@ -0,0 +1,11 @@
+package com.kustacks.kuring.club.application.port.out;
+
+import com.kustacks.kuring.club.domain.Club;
+import com.kustacks.kuring.user.domain.RootUser;
+
+public interface ClubSubscriptionCommandPort {
+
+    void saveSubscription(RootUser rootUser, Club club);
+
+    void deleteSubscription(RootUser rootUser, Club club);
+}

src/main/java/com/kustacks/kuring/club/application/port/out/ClubSubscriptionQueryPort.java

@@ -0,0 +1,8 @@
+package com.kustacks.kuring.club.application.port.out;
+
+public interface ClubSubscriptionQueryPort {
+
+    boolean existsSubscription(Long rootUserId, Long clubId);
+
+    long countSubscriptions(Long rootUserId);
+}

src/main/java/com/kustacks/kuring/club/application/service/ClubCommandService.java

@@ -0,0 +1,95 @@
+package com.kustacks.kuring.club.application.service;
+
+import com.kustacks.kuring.club.application.port.in.ClubSubscriptionUseCase;
+import com.kustacks.kuring.club.application.port.in.dto.ClubSubscriptionCommand;
+import com.kustacks.kuring.club.application.port.out.ClubQueryPort;
+import com.kustacks.kuring.club.application.port.out.ClubSubscriptionCommandPort;
+import com.kustacks.kuring.club.application.port.out.ClubSubscriptionQueryPort;
+import com.kustacks.kuring.club.domain.Club;
+import com.kustacks.kuring.common.annotation.UseCase;
+import com.kustacks.kuring.common.exception.InvalidStateException;
+import com.kustacks.kuring.common.exception.code.ErrorCode;
+import com.kustacks.kuring.user.application.port.out.RootUserQueryPort;
+import com.kustacks.kuring.user.application.port.out.UserEventPort;
+import com.kustacks.kuring.user.application.port.out.UserQueryPort;
+import com.kustacks.kuring.user.domain.RootUser;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.transaction.annotation.Transactional;
+
+@Slf4j
+@UseCase
+@Transactional
+@RequiredArgsConstructor
+public class ClubCommandService implements ClubSubscriptionUseCase {
+
+    private static final String CLUB_TOPIC_PREFIX = "club.";
+
+    private final ClubQueryPort clubQueryPort;
+    private final ClubSubscriptionCommandPort clubSubscriptionCommandPort;
+    private final ClubSubscriptionQueryPort countSubscriptionsQueryPort;
+    private final RootUserQueryPort rootUserQueryPort;
+    private final UserQueryPort userQueryPort;
+    private final UserEventPort userEventPort;
+
+    @Override
+    public long addSubscription(ClubSubscriptionCommand command) {
+        RootUser rootUser = findRootUserByEmail(command.email());
+        Club club = findClubById(command.clubId());
+
+        if (isAlreadySubscription(rootUser, club)) {
+            throw new InvalidStateException(ErrorCode.CLUB_ALREADY_SUBSCRIBED);
+        }
+
+        clubSubscriptionCommandPort.saveSubscription(rootUser, club);
+        subscribeAllLoggedInDevices(rootUser.getId(), makeTopic(club));
+
+        return countSubscriptionsQueryPort.countSubscriptions(rootUser.getId());
+    }
+
+    @Override
+    public long removeSubscription(ClubSubscriptionCommand command) {
+        RootUser rootUser = findRootUserByEmail(command.email());
+        Club club = findClubById(command.clubId());
+
+        if (!isAlreadySubscription(rootUser, club)) {
+            throw new InvalidStateException(ErrorCode.CLUB_NOT_SUBSCRIBED);
+        }
+        clubSubscriptionCommandPort.deleteSubscription(rootUser, club);
+        unsubscribeAllLoggedInDevices(rootUser.getId(), makeTopic(club));
+
+        return countSubscriptionsQueryPort.countSubscriptions(rootUser.getId());
+    }
+
+    private boolean isAlreadySubscription(RootUser rootUser, Club club) {
+        return countSubscriptionsQueryPort.existsSubscription(rootUser.getId(), club.getId());
+    }
+
+    private RootUser findRootUserByEmail(String email) {
+        return rootUserQueryPort.findRootUserByEmail(email)
+                .orElseThrow(() -> new InvalidStateException(ErrorCode.ROOT_USER_NOT_FOUND));
+    }
+
+    private Club findClubById(Long id) {
+        return clubQueryPort.findClubById(id)
+                .orElseThrow(() -> new InvalidStateException(ErrorCode.CLUB_NOT_FOUND));
+    }
+
+    private void subscribeAllLoggedInDevices(Long rootUserId, String topic) {
+        userQueryPort.findByLoggedInUserId(rootUserId)
+                .forEach(user -> userEventPort.subscribeEvent(user.getFcmToken(), topic));
+
+        log.info("동아리 토픽 구독 완료. rootUserId={}, topic={}", rootUserId, topic);
+    }
+
+    private void unsubscribeAllLoggedInDevices(Long rootUserId, String topic) {
+        userQueryPort.findByLoggedInUserId(rootUserId)
+                .forEach(user -> userEventPort.unsubscribeEvent(user.getFcmToken(), topic));
+
+        log.info("동아리 토픽 구독 해제 완료. rootUserId={}, topic={}", rootUserId, topic);
+    }
+
+    private String makeTopic(Club club) {
+        return CLUB_TOPIC_PREFIX + club.getId();
+    }
+}

src/main/java/com/kustacks/kuring/club/application/service/ClubNotificationService.java

@@ -0,0 +1,82 @@
+package com.kustacks.kuring.club.application.service;
+
+import com.google.firebase.messaging.Message;
+import com.google.firebase.messaging.Notification;
+import com.kustacks.kuring.club.application.port.in.ClubNotificationUseCase;
+import com.kustacks.kuring.club.application.port.out.ClubQueryPort;
+import com.kustacks.kuring.club.domain.Club;
+import com.kustacks.kuring.common.annotation.UseCase;
+import com.kustacks.kuring.common.properties.ServerProperties;
+import com.kustacks.kuring.message.application.port.out.FirebaseMessagingPort;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Map;
+
+import static com.kustacks.kuring.message.domain.MessageType.CLUB;
+
+@Slf4j
+@UseCase
+@RequiredArgsConstructor
+public class ClubNotificationService implements ClubNotificationUseCase {
+
+    private static final String CLUB_TOPIC_PREFIX = "club.";
+    private static final String D_DAY_1_TITLE = "[D-1] %s 동아리 모집";
+    private static final String D_DAY_1_BODY = "내일 마감되기 전에 지원하세요!";
+
+    private final ClubQueryPort clubQueryPort;
+    private final FirebaseMessagingPort firebaseMessagingPort;
+    private final ServerProperties serverProperties;
+
+    @Override
+    public void sendDeadlineNotifications() {
+        List<Club> clubs = findDeadlineClubs();
+        clubs.forEach(this::sendDeadLineClubNotification);
+    }
+
+    private void sendDeadLineClubNotification(Club club) {
+        try {
+            Message message = buildMessage(club);
+            firebaseMessagingPort.send(message);
+            log.info("동아리 마감 알림 발송 완료. clubId={}", club.getId());
+        } catch (Exception e) {
+            log.error("동아리 마감 알림 발송 실패. clubId={}", club.getId(), e);
+        }
+    }
+
+    private List<Club> findDeadlineClubs() {
+        return clubQueryPort.findNextDayRecruitEndClubs(LocalDateTime.now());
+    }
+
+    private Message buildMessage(Club club) {
+        String messageTitle = String.format(D_DAY_1_TITLE, club.getName());
+
+        return Message.builder()
+                .setNotification(buildNotification(messageTitle, D_DAY_1_BODY))
+                .setTopic(buildTopic(club))
+                .putAllData(buildMessageData(messageTitle, D_DAY_1_BODY, club))
+                .build();
+    }
+
+    private Map<String, String> buildMessageData(String title, String body, Club club) {
+        return Map.of(
+                "clubId", String.valueOf(club.getId()),
+                "title", title,
+                "body", body,
+                "messageType", CLUB.getValue()
+        );
+    }
+
+    private String buildTopic(Club club) {
+        return serverProperties.ifDevThenAddSuffix(CLUB_TOPIC_PREFIX + club.getId());
+    }
+
+    private Notification buildNotification(String title, String body) {
+        return Notification.builder()
+                .setTitle(title)
+                .setBody(body)
+                .build();
+    }
+}