chore: 테스트 메서드 주석 해제

woowacourse-teams · Jan 25, 2024 · 1e79b97 · 1e79b97
1 parent 04f7066
commit 1e79b97
Show file tree

Hide file tree

Showing 2 changed files with 57 additions and 66 deletions.
diff --git a/backend/pium/src/main/java/com/official/pium/admin/service/TestService.java b/backend/pium/src/main/java/com/official/pium/admin/service/TestService.java
@@ -1,6 +1,9 @@
 package com.official.pium.admin.service;
 
+import com.official.pium.petPlant.domain.PetPlant;
+import com.official.pium.petPlant.event.notification.NotificationEvent;
 import com.official.pium.petPlant.repository.PetPlantRepository;
+import java.util.List;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.context.ApplicationEventPublisher;
@@ -16,63 +19,49 @@ public class TestService {
     private final PetPlantRepository petPlantRepository;
     private final ApplicationEventPublisher publisher;
 
-//    public void sendWaterNotificationTest() {
-//        List<PetPlant> petPlants = petPlantRepository.findAllByMemberId(7L);
-//        List<NotificationEvent> events = petPlants.stream()
-//                .map(plant -> NotificationEvent.builder()
-//                        .title(plant.getNickname())
-//                        .body("(테스트 중) 물을 줄 시간이에요!")
-//                        .deviceToken(plant.getMember().getDeviceToken())
-//                        .build()
-//                ).toList();
-//        log.info("동기 알림 테스트 시작. Thread: " + Thread.currentThread().getId() + " " + Thread.currentThread().getName());
-//        publisher.publishEvent(NotificationEvents.from(events));
-//        log.info("동기 알림 테스트 종료. Thread: " + Thread.currentThread().getId() + " " + Thread.currentThread().getName());
-//    }
+    public void sendWaterNotificationAsyncRampTest() {
+        List<PetPlant> petPlants = petPlantRepository.findAllByMemberId(7L);
+        List<NotificationEvent> events = petPlants.stream()
+                .map(plant -> NotificationEvent.builder()
+                        .title(plant.getNickname())
+                        .body("(테스트 중) 물을 줄 시간이에요!")
+                        .deviceToken(plant.getMember().getDeviceToken())
+                        .build()
+                ).toList();
 
-//    public void sendWaterNotificationAsyncRampTest() {
-//        List<PetPlant> petPlants = petPlantRepository.findAllByMemberId(7L);
-//        List<NotificationEvent> events = petPlants.stream()
-//                .map(plant -> NotificationEvent.builder()
-//                        .title(plant.getNickname())
-//                        .body("(테스트 중) 물을 줄 시간이에요!")
-//                        .deviceToken(plant.getMember().getDeviceToken())
-//                        .build()
-//                ).toList();
+        for (int i = 0; i < 100; i++) {
+            PetPlant petPlant = petPlants.get(i);
+            NotificationEvent event = NotificationEvent.builder()
+                    .title(petPlant.getNickname())
+                    .body("물줘")
+                    .deviceToken(petPlant.getMember().getDeviceToken())
+                    .build();
+            publisher.publishEvent(event);
+        }
 
-//        for (int i = 0; i < 100; i++) {
-//            PetPlant petPlant = petPlants.get(i);
-//            NotificationEvent event = NotificationEvent.builder()
-//                    .title(petPlant.getNickname())
-//                    .body("물줘")
-//                    .deviceToken(petPlant.getMember().getDeviceToken())
-//                    .build();
-//            publisher.publishEvent(event);
-//        }
+        log.info("비동기 테스트 램프업 시작");
+        for (int i = 0; i < 100; i++) {
+            NotificationEvent notificationEvent = events.get(i);
+            publisher.publishEvent(notificationEvent);
+        }
+    }
 
-//        log.info("비동기 테스트 램프업 시작");
-//        for (int i = 0; i < 100; i++) {
-//            NotificationEvent notificationEvent = events.get(i);
-//            publisher.publishEvent(notificationEvent);
-//        }
-//    }
+    public void sendWaterNotificationAsyncTest() {
+        List<PetPlant> petPlants = petPlantRepository.findAllByMemberId(7L);
+        List<NotificationEvent> events = petPlants.stream()
+                .map(plant -> NotificationEvent.builder()
+                        .title(plant.getNickname())
+                        .body("(테스트 중) 물을 줄 시간이에요!")
+                        .deviceToken(plant.getMember().getDeviceToken())
+                        .build()
+                ).toList();
 
-//    public void sendWaterNotificationAsyncTest() {
-//        List<PetPlant> petPlants = petPlantRepository.findAllByMemberId(7L);
-//        List<NotificationEvent> events = petPlants.stream()
-//                .map(plant -> NotificationEvent.builder()
-//                        .title(plant.getNickname())
-//                        .body("(테스트 중) 물을 줄 시간이에요!")
-//                        .deviceToken(plant.getMember().getDeviceToken())
-//                        .build()
-//                ).toList();
-//
-//        int i = 1;
-//        log.info("비동기 알림 테스트 시작. Thread: " + Thread.currentThread().getId() + " " + Thread.currentThread().getName());
-//        for (NotificationEvent event : events) {
-//            log.info(i++ + "번째 알림 이벤트");
-//            publisher.publishEvent(event);
-//        }
-//        log.info("비동기 알림 테스트 종료. Thread: " + Thread.currentThread().getId() + " " + Thread.currentThread().getName());
-//    }
+        int i = 1;
+        log.info("비동기 알림 테스트 시작. Thread: " + Thread.currentThread().getId() + " " + Thread.currentThread().getName());
+        for (NotificationEvent event : events) {
+            log.info(i++ + "번째 알림 이벤트");
+            publisher.publishEvent(event);
+        }
+        log.info("비동기 알림 테스트 종료. Thread: " + Thread.currentThread().getId() + " " + Thread.currentThread().getName());
+    }
 }
diff --git a/backend/pium/src/main/java/com/official/pium/admin/ui/TestController.java b/backend/pium/src/main/java/com/official/pium/admin/ui/TestController.java
@@ -2,6 +2,8 @@
 
 import com.official.pium.admin.service.TestService;
 import lombok.RequiredArgsConstructor;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
@@ -12,15 +14,15 @@ public class TestController {
 
     private final TestService testService;
 
-//    @GetMapping("/notifications/ramp")
-//    public ResponseEntity<String> notificationRampTest() {
-//        testService.sendWaterNotificationAsyncRampTest();
-//        return ResponseEntity.ok("비동기 알림 기능 테스트 램프업 성공");
-//    }
-//
-//    @GetMapping("/notifications/async")
-//    public ResponseEntity<String> notificationAsyncTest() {
-//        testService.sendWaterNotificationAsyncTest();
-//        return ResponseEntity.ok("비동기 알림 기능 테스트 성공");
-//    }
+    @GetMapping("/notifications/ramp")
+    public ResponseEntity<String> notificationRampTest() {
+        testService.sendWaterNotificationAsyncRampTest();
+        return ResponseEntity.ok("비동기 알림 기능 테스트 램프업 성공");
+    }
+
+    @GetMapping("/notifications/async")
+    public ResponseEntity<String> notificationAsyncTest() {
+        testService.sendWaterNotificationAsyncTest();
+        return ResponseEntity.ok("비동기 알림 기능 테스트 성공");
+    }
 }