refactor: notification을 타입계층으로 리팩터링

backend/src/main/java/com/ody/mate/service/MateService.java

@@ -14,8 +14,15 @@
 import com.ody.meeting.domain.Meeting;
 import com.ody.meeting.dto.response.MateEtaResponsesV2;
 import com.ody.member.domain.Member;
+import com.ody.notification.domain.FcmTopic;
 import com.ody.notification.domain.Notification;
+import com.ody.notification.domain.types.DepartureReminder;
+import com.ody.notification.domain.types.Entry;
+import com.ody.notification.domain.types.MateLeave;
+import com.ody.notification.domain.types.MemberDeletion;
+import com.ody.notification.domain.types.Nudge;
 import com.ody.notification.service.NotificationService;
+import com.ody.route.domain.DepartureTime;
 import com.ody.route.domain.RouteTime;
 import com.ody.route.service.RouteService;
 import com.ody.util.TimeUtil;
@@ -43,14 +50,32 @@ public MateSaveResponseV2 saveAndSendNotifications(
             Member member,
             Meeting meeting
     ) {
+        validateMeetingOverdue(meeting);
         validateAlreadyAttended(member, meeting);
+        Mate mate = saveMateAndEta(mateSaveRequest, member, meeting);
+
+        FcmTopic fcmTopic = new FcmTopic(meeting);
+        sendEntry(mate, fcmTopic);
+        notificationService.subscribeTopic(member.getDeviceToken(), fcmTopic);
+        sendDepartureReminder(meeting, mate, fcmTopic);
+        return MateSaveResponseV2.from(meeting);
+    }
+
+    private void sendEntry(Mate mate, FcmTopic fcmTopic) {
+        Entry entry = new Entry(mate, fcmTopic);
+        notificationService.saveAndSchedule(entry.toNotification());
+    }
+
+    private void sendDepartureReminder(Meeting meeting, Mate mate, FcmTopic fcmTopic) {
+        DepartureTime departureTime = new DepartureTime(meeting, mate.getEstimatedMinutes());
+        DepartureReminder departureReminder = new DepartureReminder(mate, departureTime, fcmTopic);
+        notificationService.saveAndSchedule(departureReminder.toNotification());
+    }
+
+    private void validateMeetingOverdue(Meeting meeting) {
         if (meeting.isOverdue()) {
             throw new OdyBadRequestException("참여 가능한 시간이 지난 약속에 참여할 수 없습니다.");
         }
-
-        Mate mate = saveMateAndEta(mateSaveRequest, member, meeting);
-        notificationService.saveAndSendNotifications(meeting, mate, member.getDeviceToken());
-        return MateSaveResponseV2.from(meeting);
     }
 
     public void validateAlreadyAttended(Member member, Meeting meeting) {
@@ -78,7 +103,8 @@ public void nudge(NudgeRequest nudgeRequest) {
         Mate requestMate = findFetchedMate(nudgeRequest.requestMateId());
         Mate nudgedMate = findFetchedMate(nudgeRequest.nudgedMateId());
         validateNudgeCondition(requestMate, nudgedMate);
-        notificationService.sendNudgeMessage(requestMate, nudgedMate);
+        Nudge nudge = new Nudge(nudgedMate);
+        notificationService.sendNudgeMessage(requestMate, nudge);
     }
 
     private void validateNudgeCondition(Mate requestMate, Mate nudgedMate) {
@@ -133,15 +159,15 @@ public void deleteAllByMember(Member member) {
 
     @Transactional
     public void withdraw(Mate mate) {
-        Notification memberDeletionNotification = Notification.createMemberDeletion(mate);
+        Notification memberDeletionNotification = new MemberDeletion(mate).toNotification();
         notificationService.save(memberDeletionNotification);
         delete(mate);
     }
 
     @Transactional
     public void leaveByMeetingIdAndMemberId(Long meetingId, Long memberId) {
         Mate mate = findByMeetingIdAndMemberId(meetingId, memberId);
-        Notification leaveNotification = Notification.createMateLeave(mate);
+        Notification leaveNotification = new MateLeave(mate).toNotification();
         notificationService.save(leaveNotification);
         delete(mate);
     }

backend/src/main/java/com/ody/notification/domain/Notification.java

@@ -60,58 +60,8 @@ public Notification(
         this(null, mate, type, sendAt, status, fcmTopic);
     }
 
-    public static Notification createEntry(Mate mate, FcmTopic fcmTopic) {
-        return new Notification(
-                mate,
-                NotificationType.ENTRY,
-                LocalDateTime.now(),
-                NotificationStatus.DONE,
-                fcmTopic
-        );
-    }
-
-    public static Notification createDepartureReminder(Mate mate, LocalDateTime sendAt, FcmTopic fcmTopic) {
-        return new Notification(
-                mate,
-                NotificationType.DEPARTURE_REMINDER,
-                sendAt,
-                NotificationStatus.PENDING,
-                fcmTopic
-        );
-    }
-
-    public static Notification createNudge(Mate nudgeMate) {
-        return new Notification(
-                nudgeMate,
-                NotificationType.NUDGE,
-                LocalDateTime.now(),
-                NotificationStatus.DONE,
-                null
-        );
-    }
-
-    public static Notification createMemberDeletion(Mate mate) {
-        return new Notification(
-                mate,
-                NotificationType.MEMBER_DELETION,
-                LocalDateTime.now(),
-                NotificationStatus.DONE,
-                null
-        );
-    }
-
-    public static Notification createMateLeave(Mate mate) {
-        return new Notification(
-                mate,
-                NotificationType.LEAVE,
-                LocalDateTime.now(),
-                NotificationStatus.DONE,
-                null
-        );
-    }
-
     public boolean isDepartureReminder() {
-        return this.type.isDepartureReminder();
+        return type.isDepartureReminder();
     }
 
     public boolean isStatusDismissed() {

backend/src/main/java/com/ody/notification/domain/types/AbstractNotification.java

@@ -0,0 +1,43 @@
+package com.ody.notification.domain.types;
+
+import com.ody.mate.domain.Mate;
+import com.ody.notification.domain.FcmTopic;
+import com.ody.notification.domain.Notification;
+import com.ody.notification.domain.NotificationStatus;
+import com.ody.notification.domain.NotificationType;
+import java.time.LocalDateTime;
+
+public abstract class AbstractNotification {
+
+    private final Mate mate;
+    private final NotificationType type;
+    private final LocalDateTime sendAt;
+    private final NotificationStatus status;
+    private final FcmTopic fcmTopic;
+
+    protected AbstractNotification(
+            Mate mate,
+            LocalDateTime sendAt,
+            NotificationStatus status,
+            FcmTopic fcmTopic
+    ) {
+        this.mate = mate;
+        this.type = getType();
+        this.sendAt = calculateSendAt(sendAt);
+        this.status = status;
+        this.fcmTopic = fcmTopic;
+    }
+
+    private static LocalDateTime calculateSendAt(LocalDateTime sendAt) {
+        if (sendAt.isBefore(LocalDateTime.now())) {
+            return LocalDateTime.now();
+        }
+        return sendAt;
+    }
+
+    abstract NotificationType getType();
+
+    public Notification toNotification() {
+        return new Notification(null, mate, type, sendAt, status, fcmTopic);
+    }
+}

backend/src/main/java/com/ody/notification/domain/types/DepartureReminder.java

@@ -0,0 +1,19 @@
+package com.ody.notification.domain.types;
+
+import com.ody.mate.domain.Mate;
+import com.ody.notification.domain.FcmTopic;
+import com.ody.notification.domain.NotificationStatus;
+import com.ody.notification.domain.NotificationType;
+import com.ody.route.domain.DepartureTime;
+
+public class DepartureReminder extends AbstractNotification {
+
+    public DepartureReminder(Mate mate, DepartureTime departureTime, FcmTopic fcmTopic) {
+        super(mate, departureTime.getValue(), NotificationStatus.PENDING, fcmTopic);
+    }
+
+    @Override
+    public NotificationType getType() {
+        return NotificationType.DEPARTURE_REMINDER;
+    }
+}

backend/src/main/java/com/ody/notification/domain/types/Entry.java

@@ -0,0 +1,20 @@
+package com.ody.notification.domain.types;
+
+import com.ody.mate.domain.Mate;
+import com.ody.notification.domain.FcmTopic;
+import com.ody.notification.domain.NotificationStatus;
+import com.ody.notification.domain.NotificationType;
+import java.time.LocalDateTime;
+
+public class Entry extends AbstractNotification {
+
+    public Entry(Mate mate, FcmTopic fcmTopic) {
+        super(mate, LocalDateTime.now(), NotificationStatus.DONE, fcmTopic);
+    }
+
+    @Override
+    public NotificationType getType() {
+        return NotificationType.ENTRY;
+    }
+}
+

backend/src/main/java/com/ody/notification/domain/types/MateLeave.java

@@ -0,0 +1,18 @@
+package com.ody.notification.domain.types;
+
+import com.ody.mate.domain.Mate;
+import com.ody.notification.domain.NotificationStatus;
+import com.ody.notification.domain.NotificationType;
+import java.time.LocalDateTime;
+
+public class MateLeave extends AbstractNotification {
+
+    public MateLeave(Mate mate) {
+        super(mate, LocalDateTime.now(), NotificationStatus.DONE, null);
+    }
+
+    @Override
+    public NotificationType getType() {
+        return NotificationType.LEAVE;
+    }
+}

backend/src/main/java/com/ody/notification/domain/types/MemberDeletion.java

@@ -0,0 +1,18 @@
+package com.ody.notification.domain.types;
+
+import com.ody.mate.domain.Mate;
+import com.ody.notification.domain.NotificationStatus;
+import com.ody.notification.domain.NotificationType;
+import java.time.LocalDateTime;
+
+public class MemberDeletion extends AbstractNotification {
+
+    public MemberDeletion(Mate mate) {
+        super(mate, LocalDateTime.now(), NotificationStatus.DONE, null);
+    }
+
+    @Override
+    public NotificationType getType() {
+        return NotificationType.MEMBER_DELETION;
+    }
+}

backend/src/main/java/com/ody/notification/domain/types/Nudge.java

@@ -0,0 +1,18 @@
+package com.ody.notification.domain.types;
+
+import com.ody.mate.domain.Mate;
+import com.ody.notification.domain.NotificationStatus;
+import com.ody.notification.domain.NotificationType;
+import java.time.LocalDateTime;
+
+public class Nudge extends AbstractNotification {
+
+    public Nudge(Mate nudgeMate) {
+        super(nudgeMate, LocalDateTime.now(), NotificationStatus.DONE, null);
+    }
+
+    @Override
+    public NotificationType getType() {
+        return NotificationType.NUDGE;
+    }
+}

backend/src/main/java/com/ody/notification/service/NotificationService.java

@@ -9,14 +9,14 @@
 import com.ody.notification.domain.NotificationStatus;
 import com.ody.notification.domain.NotificationType;
 import com.ody.notification.domain.message.GroupMessage;
+import com.ody.notification.domain.types.Nudge;
 import com.ody.notification.dto.response.NotiLogFindResponses;
 import com.ody.notification.repository.NotificationRepository;
 import com.ody.notification.service.event.NoticeEvent;
 import com.ody.notification.service.event.NudgeEvent;
 import com.ody.notification.service.event.PushEvent;
 import com.ody.notification.service.event.SubscribeEvent;
 import com.ody.notification.service.event.UnSubscribeEvent;
-import com.ody.route.domain.DepartureTime;
 import com.ody.util.InstantConverter;
 import java.time.Instant;
 import java.time.LocalDateTime;
@@ -40,35 +40,14 @@ public class NotificationService {
     private final TaskScheduler taskScheduler;
 
     @Transactional
-    public void saveAndSendNotifications(Meeting meeting, Mate mate, DeviceToken deviceToken) {
-        FcmTopic fcmTopic = new FcmTopic(meeting);
-
-        Notification entryNotification = Notification.createEntry(mate, fcmTopic);
-        saveAndScheduleNotification(entryNotification);
-
-        SubscribeEvent subscribeEvent = new SubscribeEvent(this, deviceToken, fcmTopic);
-        fcmEventPublisher.publish(subscribeEvent);
-
-        saveAndSendDepartureReminderNotification(meeting, mate, fcmTopic);
-    }
-
-    private void saveAndSendDepartureReminderNotification(Meeting meeting, Mate mate, FcmTopic fcmTopic) {
-        DepartureTime departureTime = new DepartureTime(meeting, mate.getEstimatedMinutes());
-        LocalDateTime sendAt = calculateSendAt(departureTime);
-        Notification notification = Notification.createDepartureReminder(mate, sendAt, fcmTopic);
-        saveAndScheduleNotification(notification);
-    }
-
-    private LocalDateTime calculateSendAt(DepartureTime departureTime) {
-        if (departureTime.isBefore(LocalDateTime.now())) {
-            return LocalDateTime.now();
-        }
-        return departureTime.getValue();
+    public void saveAndSchedule(Notification notification) {
+        Notification savedNotification = save(notification);
+        scheduleNotification(savedNotification);
     }
 
-    private void saveAndScheduleNotification(Notification notification) {
-        Notification savedNotification = notificationRepository.save(notification);
-        scheduleNotification(savedNotification);
+    @Transactional
+    public Notification save(Notification notification) {
+        return notificationRepository.save(notification);
     }
 
     private void scheduleNotification(Notification notification) {
@@ -83,9 +62,14 @@ private void scheduleNotification(Notification notification) {
         );
     }
 
+    public void subscribeTopic(DeviceToken deviceToken, FcmTopic fcmTopic){
+        SubscribeEvent subscribeEvent = new SubscribeEvent(this, deviceToken, fcmTopic);
+        fcmEventPublisher.publish(subscribeEvent);
+    }
+
     @Transactional
-    public void sendNudgeMessage(Mate requestMate, Mate nudgedMate) {
-        Notification nudgeNotification = notificationRepository.save(Notification.createNudge(nudgedMate));
+    public void sendNudgeMessage(Mate requestMate, Nudge nudge) {
+        Notification nudgeNotification = notificationRepository.save(nudge.toNotification());
         NudgeEvent nudgeEvent = new NudgeEvent(this, requestMate, nudgeNotification);
         fcmEventPublisher.publishWithTransaction(nudgeEvent);
     }
@@ -107,11 +91,6 @@ public void schedulePendingNotification() {
         log.info("애플리케이션 시작 - PENDING 상태 출발 알림 {}개 스케줄링", notifications.size());
     }
 
-    @Transactional
-    public Notification save(Notification notification) {
-        return notificationRepository.save(notification);
-    }
-
     @DisabledDeletedFilter
     public NotiLogFindResponses findAllNotiLogs(Long meetingId) {
         List<Notification> notifications = notificationRepository.findAllByMeetingIdAndSentAtBeforeDateTimeAndStatusIsNotDismissed(