refactor: 알림 허용 시 알림 발송 로직 추가

woowacourse-teams · Jan 17, 2024 · 837d2e1 · 837d2e1
1 parent 63422eb
commit 837d2e1
Showing 1 changed file with 14 additions and 5 deletions.
diff --git a/backend/pium/src/main/java/com/official/pium/member/application/MemberService.java b/backend/pium/src/main/java/com/official/pium/member/application/MemberService.java
@@ -1,16 +1,18 @@
 package com.official.pium.member.application;
 
-import com.official.pium.member.domain.Member;
-import com.official.pium.petPlant.domain.PetPlant;
 import com.official.pium.history.repository.HistoryRepository;
+import com.official.pium.member.application.dto.OAuthProvider;
+import com.official.pium.member.domain.Member;
 import com.official.pium.member.repository.MemberRepository;
-import com.official.pium.petPlant.repository.PetPlantRepository;
-import com.official.pium.sessionGroup.repository.SessionGroupRepository;
 import com.official.pium.notification.application.dto.NotificationCheckResponse;
 import com.official.pium.notification.application.dto.NotificationSubscribeRequest;
-import com.official.pium.member.application.dto.OAuthProvider;
+import com.official.pium.petPlant.domain.PetPlant;
+import com.official.pium.petPlant.event.notification.NotificationEvent;
+import com.official.pium.petPlant.repository.PetPlantRepository;
+import com.official.pium.sessionGroup.repository.SessionGroupRepository;
 import java.util.List;
 import lombok.RequiredArgsConstructor;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -24,6 +26,7 @@ public class MemberService {
     private final PetPlantRepository petPlantRepository;
     private final SessionGroupRepository sessionGroupRepository;
     private final OAuthProvider provider;
+    private final ApplicationEventPublisher publisher;
 
     @Transactional
     public void withdraw(Member member) {
@@ -51,6 +54,12 @@ public void subscribeNotification(Member member, NotificationSubscribeRequest re
             throw new IllegalArgumentException("이미 알림을 구독하고 있습니다.");
         }
         member.updateDeviceToken(request.getToken());
+        NotificationEvent event = NotificationEvent.builder()
+                .deviceToken(member.getDeviceToken())
+                .title("알림 설정 완료")
+                .body("리마인더 알림 받기 성공.")
+                .build();
+        publisher.publishEvent(event);
     }
 
     @Transactional