🔗 :: (#722) 알림 기본값 넣어줌

jobis-application/src/main/java/team/retum/jobis/domain/notification/spi/CommandTopicSubscriptionPort.java

@@ -5,4 +5,5 @@
 public interface CommandTopicSubscriptionPort {
 
     void save(TopicSubscription topicSubscription);
+
 }

jobis-infrastructure/src/main/java/team/retum/jobis/domain/notification/persistence/TopicSubscriptionPersistenceAdapter.java

@@ -9,9 +9,12 @@
 import team.retum.jobis.domain.notification.persistence.mapper.TopicSubscriptionMapper;
 import team.retum.jobis.domain.notification.persistence.repository.TopicSubscriptionJpaRepository;
 import team.retum.jobis.domain.notification.spi.TopicSubscriptionPort;
+import team.retum.jobis.thirdparty.fcm.FCMUtil;
 
+import java.util.Arrays;
 import java.util.List;
 import java.util.Optional;
+import java.util.stream.Collectors;
 
 import static team.retum.jobis.domain.notification.persistence.entity.QTopicSubscriptionEntity.topicSubscriptionEntity;
 
@@ -22,10 +25,17 @@ public class TopicSubscriptionPersistenceAdapter implements TopicSubscriptionPor
     private final TopicSubscriptionJpaRepository topicSubscriptionJpaRepository;
     private final TopicSubscriptionMapper topicSubscriptionMapper;
     private final JPAQueryFactory queryFactory;
+    private final FCMUtil fcmUtil;
 
     @Override
     public List<TopicVO> getAllByDeviceToken(String deviceToken) {
-        return topicSubscriptionJpaRepository.findAllByDeviceToken(deviceToken);
+        List<TopicVO> topics = topicSubscriptionJpaRepository.findAllByDeviceToken(deviceToken);
+
+        if (topics.isEmpty()) {
+            topics = getDefaultSubscribedTopics(deviceToken);
+        }
+
+        return topics;
     }
 
     @Override
@@ -47,4 +57,13 @@ public Optional<TopicSubscription> getByDeviceTokenAndTopic(String deviceToken,
     public void save(TopicSubscription topicSubscription) {
         topicSubscriptionJpaRepository.save(topicSubscriptionMapper.toEntity(topicSubscription));
     }
+
+    private List<TopicVO> getDefaultSubscribedTopics(String token) {
+        return Arrays.stream(Topic.values())
+            .map(topic -> {
+                fcmUtil.subscribeTopic(token, topic);
+                return new TopicVO(topic, true);
+            })
+            .collect(Collectors.toList());
+    }
 }

jobis-infrastructure/src/main/java/team/retum/jobis/domain/notification/persistence/repository/TopicSubscriptionJpaRepository.java

@@ -10,4 +10,6 @@
 public interface TopicSubscriptionJpaRepository extends CrudRepository<TopicSubscriptionEntity, TopicSubscriptionId> {
 
     List<TopicVO> findAllByDeviceToken(String deviceToken);
+
+    Boolean existsByDeviceToken(String deviceToken);
 }