SCRUM-125 알림 템플릿 구현

src/main/java/com/wellmeet/exception/ErrorCode.java

@@ -16,7 +16,8 @@ public enum ErrorCode {
     INTERNAL_SERVER_ERROR(HttpStatus.INTERNAL_SERVER_ERROR, "서버 내부 오류가 발생했습니다."),
     CORS_ORIGIN_EMPTY(HttpStatus.INTERNAL_SERVER_ERROR, "CORS Origin 은 적어도 한 개 있어야 합니다"),
     WEB_PUSH_SEND_FAILED(HttpStatus.INTERNAL_SERVER_ERROR, "웹 푸시 전송에 실패했습니다."),
-    SENDER_NOT_FOUND(HttpStatus.BAD_REQUEST, "알림을 발송할 수 없습니다.");
+    SENDER_NOT_FOUND(HttpStatus.BAD_REQUEST, "알림을 발송할 수 없습니다."),
+    TEMPLATE_NOT_FOUND(HttpStatus.INTERNAL_SERVER_ERROR, "알림 템플릿을 찾을 수 없습니다.");
 
     private final HttpStatus status;
     private final String message;

src/main/java/com/wellmeet/notification/template/NotificationTemplate.java

@@ -0,0 +1,17 @@
+package com.wellmeet.notification.template;
+
+import com.wellmeet.notification.consumer.dto.NotificationType;
+import java.util.Map;
+import java.util.Objects;
+
+public interface NotificationTemplate {
+
+    boolean supports(NotificationType type);
+
+    NotificationTemplateData create(Map<String, Object> payload);
+
+    default String getStringOrDefault(Map<String, Object> payload, String key, String defaultValue) {
+        Object value = payload.get(key);
+        return Objects.toString(value, defaultValue);
+    }
+}

src/main/java/com/wellmeet/notification/template/NotificationTemplateData.java

@@ -0,0 +1,9 @@
+package com.wellmeet.notification.template;
+
+public record NotificationTemplateData(
+        String title,
+        String body,
+        String url,
+        boolean requireInteraction
+) {
+}

src/main/java/com/wellmeet/notification/template/NotificationTemplateFactory.java

@@ -0,0 +1,25 @@
+package com.wellmeet.notification.template;
+
+import com.wellmeet.exception.ErrorCode;
+import com.wellmeet.exception.WellMeetNotificationException;
+import com.wellmeet.notification.consumer.dto.NotificationType;
+import java.util.List;
+import java.util.Map;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class NotificationTemplateFactory {
+
+    private final List<NotificationTemplate> templates;
+
+    public NotificationTemplateData createTemplateData(NotificationType type, Map<String, Object> payload) {
+        NotificationTemplate template = templates.stream()
+                .filter(low -> low.supports(type))
+                .findFirst()
+                .orElseThrow(() -> new WellMeetNotificationException(ErrorCode.TEMPLATE_NOT_FOUND));
+
+        return template.create(payload);
+    }
+}

src/main/java/com/wellmeet/notification/template/impl/ReservationCanceledTemplate.java

@@ -0,0 +1,30 @@
+package com.wellmeet.notification.template.impl;
+
+import com.wellmeet.notification.consumer.dto.NotificationType;
+import com.wellmeet.notification.template.NotificationTemplate;
+import com.wellmeet.notification.template.NotificationTemplateData;
+import java.util.Map;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ReservationCanceledTemplate implements NotificationTemplate {
+
+    @Override
+    public boolean supports(NotificationType type) {
+        return NotificationType.RESERVATION_CANCELED == type;
+    }
+
+    @Override
+    public NotificationTemplateData create(Map<String, Object> payload) {
+        String restaurantName = getStringOrDefault(payload, "restaurantName", "식당");
+        String reservationTime = getStringOrDefault(payload, "reservationTime", "");
+        String reservationId = getStringOrDefault(payload, "reservationId", "");
+
+        String title = "예약이 취소되었습니다";
+        String body = String.format("%s 예약이 취소되었습니다. 예약 시간: %s",
+                restaurantName, reservationTime);
+        String url = "/reservations/" + reservationId;
+
+        return new NotificationTemplateData(title, body, url, false);
+    }
+}

src/main/java/com/wellmeet/notification/template/impl/ReservationConfirmedTemplate.java

@@ -0,0 +1,30 @@
+package com.wellmeet.notification.template.impl;
+
+import com.wellmeet.notification.consumer.dto.NotificationType;
+import com.wellmeet.notification.template.NotificationTemplate;
+import com.wellmeet.notification.template.NotificationTemplateData;
+import java.util.Map;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ReservationConfirmedTemplate implements NotificationTemplate {
+
+    @Override
+    public boolean supports(NotificationType type) {
+        return NotificationType.RESERVATION_CONFIRMED == type;
+    }
+
+    @Override
+    public NotificationTemplateData create(Map<String, Object> payload) {
+        String restaurantName = getStringOrDefault(payload, "restaurantName", "식당");
+        String reservationTime = getStringOrDefault(payload, "reservationTime", "");
+        String reservationId = getStringOrDefault(payload, "reservationId", "");
+
+        String title = "예약이 확정되었습니다";
+        String body = String.format("%s 예약이 확정되었습니다. 예약 시간: %s",
+                restaurantName, reservationTime);
+        String url = "/reservations/" + reservationId;
+
+        return new NotificationTemplateData(title, body, url, false);
+    }
+}

src/main/java/com/wellmeet/notification/template/impl/ReservationCreatedTemplate.java

@@ -0,0 +1,30 @@
+package com.wellmeet.notification.template.impl;
+
+import com.wellmeet.notification.consumer.dto.NotificationType;
+import com.wellmeet.notification.template.NotificationTemplate;
+import com.wellmeet.notification.template.NotificationTemplateData;
+import java.util.Map;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ReservationCreatedTemplate implements NotificationTemplate {
+
+    @Override
+    public boolean supports(NotificationType type) {
+        return NotificationType.RESERVATION_CREATED == type;
+    }
+
+    @Override
+    public NotificationTemplateData create(Map<String, Object> payload) {
+        String restaurantName = getStringOrDefault(payload, "restaurantName", "식당");
+        String reservationTime = getStringOrDefault(payload, "reservationTime", "");
+        String reservationId = getStringOrDefault(payload, "reservationId", "");
+
+        String title = "새로운 예약이 접수되었습니다";
+        String body = String.format("%s에 새로운 예약이 접수되었습니다. 예약 시간: %s",
+                restaurantName, reservationTime);
+        String url = "/reservations/" + reservationId;
+
+        return new NotificationTemplateData(title, body, url, true);
+    }
+}

src/main/java/com/wellmeet/notification/template/impl/ReservationReminderTemplate.java

@@ -0,0 +1,31 @@
+package com.wellmeet.notification.template.impl;
+
+import com.wellmeet.notification.consumer.dto.NotificationType;
+import com.wellmeet.notification.template.NotificationTemplate;
+import com.wellmeet.notification.template.NotificationTemplateData;
+import java.util.Map;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ReservationReminderTemplate implements NotificationTemplate {
+
+    @Override
+    public boolean supports(NotificationType type) {
+        return NotificationType.RESERVATION_REMINDER == type;
+    }
+
+    @Override
+    public NotificationTemplateData create(Map<String, Object> payload) {
+        String restaurantName = getStringOrDefault(payload, "restaurantName", "식당");
+        String reservationTime = getStringOrDefault(payload, "reservationTime", "");
+        String reservationId = getStringOrDefault(payload, "reservationId", "");
+        String minutesBefore = getStringOrDefault(payload, "minutesBefore", "30");
+
+        String title = "곧 예약 시간입니다";
+        String body = String.format("%s 예약 시간이 %s분 남았습니다. 예약 시간: %s",
+                restaurantName, minutesBefore, reservationTime);
+        String url = "/reservations/" + reservationId;
+
+        return new NotificationTemplateData(title, body, url, true);
+    }
+}

src/main/java/com/wellmeet/notification/template/impl/ReservationUpdatedTemplate.java

@@ -0,0 +1,30 @@
+package com.wellmeet.notification.template.impl;
+
+import com.wellmeet.notification.consumer.dto.NotificationType;
+import com.wellmeet.notification.template.NotificationTemplate;
+import com.wellmeet.notification.template.NotificationTemplateData;
+import java.util.Map;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ReservationUpdatedTemplate implements NotificationTemplate {
+
+    @Override
+    public boolean supports(NotificationType type) {
+        return NotificationType.RESERVATION_UPDATED == type;
+    }
+
+    @Override
+    public NotificationTemplateData create(Map<String, Object> payload) {
+        String restaurantName = getStringOrDefault(payload, "restaurantName", "식당");
+        String reservationTime = getStringOrDefault(payload, "reservationTime", "");
+        String reservationId = getStringOrDefault(payload, "reservationId", "");
+
+        String title = "예약 정보가 변경되었습니다";
+        String body = String.format("%s 예약 정보가 변경되었습니다. 변경된 예약 시간: %s",
+                restaurantName, reservationTime);
+        String url = "/reservations/" + reservationId;
+
+        return new NotificationTemplateData(title, body, url, false);
+    }
+}

src/main/java/com/wellmeet/notification/webpush/WebPushController.java

@@ -2,7 +2,6 @@
 
 import com.wellmeet.notification.webpush.dto.SubscribeRequest;
 import com.wellmeet.notification.webpush.dto.SubscribeResponse;
-import com.wellmeet.notification.webpush.dto.TestPushRequest;
 import com.wellmeet.notification.webpush.dto.UnsubscribeRequest;
 import jakarta.validation.Valid;
 import lombok.RequiredArgsConstructor;
@@ -31,14 +30,6 @@ public SubscribeResponse subscribe(
         return webPushService.subscribe(userId, subscribeRequest);
     }
 
-    @PostMapping("/test-push")
-    public void testPush(
-            @Valid @RequestBody TestPushRequest testPushRequest,
-            @RequestParam String userId
-    ) {
-        webPushService.sendTestPush(userId, testPushRequest);
-    }
-
     @DeleteMapping("/unsubscribe")
     @ResponseStatus(HttpStatus.NO_CONTENT)
     public void unsubscribe(

src/main/java/com/wellmeet/notification/webpush/WebPushService.java

@@ -5,10 +5,8 @@
 import com.wellmeet.notification.webpush.domain.PushSubscription;
 import com.wellmeet.notification.webpush.dto.SubscribeRequest;
 import com.wellmeet.notification.webpush.dto.SubscribeResponse;
-import com.wellmeet.notification.webpush.dto.TestPushRequest;
 import com.wellmeet.notification.webpush.dto.UnsubscribeRequest;
 import com.wellmeet.notification.webpush.repository.PushSubscriptionRepository;
-import com.wellmeet.notification.webpush.sender.WebPushSender;
 import java.util.List;
 import java.util.Optional;
 import lombok.RequiredArgsConstructor;
@@ -20,7 +18,6 @@
 public class WebPushService {
 
     private final PushSubscriptionRepository pushSubscriptionRepository;
-    private final WebPushSender webPushSender;
 
     @Transactional
     public SubscribeResponse subscribe(String userId, SubscribeRequest request) {
@@ -40,15 +37,6 @@ public SubscribeResponse subscribe(String userId, SubscribeRequest request) {
         return new SubscribeResponse(savedSubscription);
     }
 
-    public void sendTestPush(String userId, TestPushRequest request) {
-        List<PushSubscription> subscriptions = pushSubscriptionRepository.findByUserId(userId);
-        if (subscriptions.isEmpty()) {
-            throw new WellMeetNotificationException(ErrorCode.SUBSCRIPTION_NOT_FOUND);
-        }
-
-        subscriptions.forEach(subscription -> webPushSender.send(subscription, request));
-    }
-
     @Transactional
     public void unsubscribe(String userId, UnsubscribeRequest request) {
         if (!pushSubscriptionRepository.existsByUserIdAndEndpoint(userId, request.endpoint())) {

src/main/java/com/wellmeet/notification/webpush/sender/WebPushSender.java

@@ -6,8 +6,9 @@
 import com.wellmeet.notification.Sender;
 import com.wellmeet.notification.consumer.dto.NotificationMessage;
 import com.wellmeet.notification.domain.NotificationChannel;
+import com.wellmeet.notification.template.NotificationTemplateData;
+import com.wellmeet.notification.template.NotificationTemplateFactory;
 import com.wellmeet.notification.webpush.domain.PushSubscription;
-import com.wellmeet.notification.webpush.dto.TestPushRequest;
 import com.wellmeet.notification.webpush.repository.PushSubscriptionRepository;
 import java.io.IOException;
 import java.security.GeneralSecurityException;
@@ -29,6 +30,7 @@ public class WebPushSender implements Sender {
 
     private final PushSubscriptionRepository pushSubscriptionRepository;
     private final PushService pushService;
+    private final NotificationTemplateFactory templateFactory;
     private final ObjectMapper objectMapper = new ObjectMapper();
 
     @Override
@@ -53,39 +55,21 @@ public void send(NotificationMessage message) {
     }
 
     private Map<String, Object> getNotificationPayload(NotificationMessage message) {
-        Map<String, Object> notificationPayload = new HashMap<>();
-        notificationPayload.put("title", "WellMeet 알림");
-        notificationPayload.put("body", message.getPayload());
-        notificationPayload.put("icon", "/icon-192x192.png");
-        notificationPayload.put("badge", "/badge-72x72.png");
-        notificationPayload.put("vibrate", new int[]{100, 50, 100});
-        notificationPayload.put("requireInteraction", false);
-
-        Map<String, Object> defaultData = new HashMap<>();
-        defaultData.put("url", "/notifications");
-        defaultData.put("timestamp", System.currentTimeMillis());
-        notificationPayload.put("data", defaultData);
-        return notificationPayload;
-    }
-
-    public void send(PushSubscription subscription, TestPushRequest request) {
-        Keys keys = new Keys(subscription.getP256dh(), subscription.getAuth());
-        Subscription sub = new Subscription(subscription.getEndpoint(), keys);
-        Map<String, Object> notificationPayload = getNotificationPayload(request);
-        webPushSend(notificationPayload, sub);
-    }
+        NotificationTemplateData templateData = templateFactory.createTemplateData(
+                message.getNotification().getType(),
+                message.getPayload()
+        );
 
-    private Map<String, Object> getNotificationPayload(TestPushRequest request) {
         Map<String, Object> notificationPayload = new HashMap<>();
-        notificationPayload.put("title", request.title());
-        notificationPayload.put("body", request.body());
+        notificationPayload.put("title", templateData.title());
+        notificationPayload.put("body", templateData.body());
         notificationPayload.put("icon", "/icon-192x192.png");
         notificationPayload.put("badge", "/badge-72x72.png");
         notificationPayload.put("vibrate", new int[]{100, 50, 100});
-        notificationPayload.put("requireInteraction", false);
+        notificationPayload.put("requireInteraction", templateData.requireInteraction());
 
         Map<String, Object> defaultData = new HashMap<>();
-        defaultData.put("url", "/notifications");
+        defaultData.put("url", templateData.url());
         defaultData.put("timestamp", System.currentTimeMillis());
         notificationPayload.put("data", defaultData);
         return notificationPayload;