[Feat] - email task selection remove (#57)

* feat: implement email selection delete

* test : write test code for email selection delete

* fix : change api endpoint

* fix : fix endpoint

Author: ekgns33

src/main/java/gdsc/konkuk/platformcore/application/email/EmailService.java

@@ -11,6 +11,8 @@
 import java.util.HashSet;
 import java.util.List;
 import java.util.Set;
+
+import jakarta.validation.constraints.Email;
 import lombok.RequiredArgsConstructor;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.PageRequest;
@@ -30,11 +32,6 @@ public List<EmailTask> getAllTaskAsList() {
     return emailTaskRepository.findAll();
   }
 
-  public Page<EmailTask> getAllTaskWithPage(int pageNo) {
-    Pageable pageable = PageRequest.of(pageNo, 10);
-    return emailTaskRepository.findAll(pageable);
-  }
-
   public EmailTask getTaskDetails(Long taskId) {
     return findEmailTaskById(emailTaskRepository, taskId);
   }
@@ -75,6 +72,12 @@ public void delete(Long emailId) {
     emailTaskRepository.delete(task);
   }
 
+  @Transactional
+  public void deleteAll(List<Long> emailIds) {
+    List<EmailTask> tasks = emailTaskRepository.findAllById(emailIds);
+    emailTaskRepository.deleteAllInBatch(tasks);
+  }
+
   private void validateEmailTaskAlreadySent(EmailTask emailTask) {
     if (emailTask.isSent()) {
       throw EmailAlreadyProcessedException.of(EmailErrorCode.EMAIL_ALREADY_PROCESSED);

src/main/java/gdsc/konkuk/platformcore/application/email/EmailTaskFacade.java

@@ -5,6 +5,8 @@
 import gdsc.konkuk.platformcore.global.scheduler.TaskScheduler;
 import java.time.LocalDateTime;
 import java.time.temporal.ChronoUnit;
+import java.util.List;
+
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -35,6 +37,11 @@ public void cancel(Long emailId) {
     emailService.delete(emailId);
   }
 
+  public void cancelAll(List<Long> emailIds) {
+    emailIds.forEach(emailId -> emailTaskScheduler.cancelTask(String.valueOf(emailId)));
+    emailService.deleteAll(emailIds);
+  }
+
   private long getWaitingPeriod(EmailTask emailTask) {
     return ChronoUnit.SECONDS.between(LocalDateTime.now(), emailTask.getSendAt());
   }

src/main/java/gdsc/konkuk/platformcore/controller/email/EmailController.java

@@ -10,6 +10,8 @@
 import gdsc.konkuk.platformcore.global.responses.SuccessResponse;
 import jakarta.validation.Valid;
 import java.net.URI;
+import java.util.List;
+
 import lombok.RequiredArgsConstructor;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.DeleteMapping;
@@ -36,14 +38,6 @@ public ResponseEntity<SuccessResponse> getAllEmailTask() {
     return ResponseEntity.ok(SuccessResponse.of(emailTasks));
   }
 
-  @GetMapping("/pages")
-  public ResponseEntity<SuccessResponse> getAllEmailTask(
-      @RequestParam(required = false, defaultValue = "0", value = "page") int pageNo
-  ) {
-    EmailTaskListResponse emailTasks = EmailTaskMapper.mapToEmailTaskPageResponse(emailService.getAllTaskWithPage(pageNo));
-    return ResponseEntity.ok(SuccessResponse.of(emailTasks));
-  }
-
   @GetMapping("/{taskId}")
   public ResponseEntity<SuccessResponse> getEmailTask(@PathVariable Long taskId) {
     EmailTaskDetailResponse emailTask = EmailTaskMapper.mapToEmailTaskDetailsResponse(emailService.getTaskDetails(taskId));
@@ -67,4 +61,10 @@ public ResponseEntity<SuccessResponse> deleteEmailTask(@PathVariable Long emailI
     emailTaskFacade.cancel(emailId);
     return ResponseEntity.noContent().build();
   }
+
+  @DeleteMapping("")
+  public ResponseEntity<SuccessResponse> deleteEmailTaskInBatch(@RequestParam List<Long> emailIds) {
+    emailTaskFacade.cancelAll(emailIds);
+    return ResponseEntity.noContent().build();
+  }
 }

src/main/java/gdsc/konkuk/platformcore/domain/email/repository/EmailTaskRepository.java

@@ -13,5 +13,7 @@ public interface EmailTaskRepository extends JpaRepository<EmailTask, Long> {
   @Query("SELECT e FROM EmailTask e WHERE e.isSent = false")
   List<EmailTask> findAllWhereNotSent();
 
-  Page<EmailTask> findAll(Pageable pageable);
+  @Query("SELECT e FROM EmailTask e " +
+      "order by e.sendAt desc")
+  List<EmailTask> findAll();
 }

src/test/java/gdsc/konkuk/platformcore/application/email/EmailIntegrationTest.java

@@ -23,6 +23,7 @@
 import gdsc.konkuk.platformcore.global.scheduler.TaskNotFoundException;
 import gdsc.konkuk.platformcore.global.scheduler.TaskInMemoryRepository;
 import java.time.LocalDateTime;
+import java.util.List;
 import java.util.concurrent.ScheduledThreadPoolExecutor;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.DisplayName;
@@ -198,4 +199,34 @@ void should_send_discord_message_when_email_sending_error() throws InterruptedEx
     verify(emailClient).sendEmailToReceivers(any(EmailTask.class));
     verify(discordClient).sendErrorMessage(any());
   }
+
+  @Test
+  @DisplayName("모든 작업 취소 성공")
+  void should_cancel_all_tasks() {
+    // given
+    EmailSendRequest emailRequest1 = EmailSendRequestFixture.builder()
+        .sendAt(LocalDateTime.now().plusHours(1)).build()
+        .getFixture();
+    EmailSendRequest emailRequest2 = EmailSendRequestFixture.builder()
+        .sendAt(LocalDateTime.now().plusHours(2)).build()
+        .getFixture();
+    EmailTask emailTask1 = emailTaskFacade.register(emailRequest1);
+    EmailTask emailTask2 = emailTaskFacade.register(emailRequest2);
+    assertEquals(2, executor.getQueue().size());
+
+    // when
+    emailTaskFacade.cancelAll(List.of(emailTask1.getId(), emailTask2.getId()));
+
+    // then
+    assertEquals(0, executor.getQueue().size());
+    assertTrue(emailTaskRepository.findById(emailTask1.getId()).isEmpty());
+    assertTrue(emailTaskRepository.findById(emailTask2.getId()).isEmpty());
+    assertThrows(
+        TaskNotFoundException.class,
+        () -> taskInMemoryRepository.getTask(emailTask1.getId().toString()));
+    assertThrows(
+        TaskNotFoundException.class,
+        () -> taskInMemoryRepository.getTask(emailTask2.getId().toString()));
+  }
+
 }

src/test/java/gdsc/konkuk/platformcore/controller/email/EmailControllerTest.java

@@ -264,4 +264,33 @@ void should_success_when_cancel_registered_task() throws Exception {
               parameterWithName("emailId").description("취소할 이메일 작업 ID"))
             .build())));
   }
+
+  @Test
+  @DisplayName("선택한 모든 이메일 작업을 취소한다.")
+  void should_success_when_cancel_all_tasks() throws Exception {
+    //given
+    Member member = MemberFixture.builder().role(MemberRole.CORE).build().getFixture();
+    String jwt = jwtTokenProvider.createToken(member);
+    List<Long> emailIds = List.of(1L, 2L);
+    willDoNothing().given(emailTaskFacade).cancelAll(emailIds);
+
+    //when
+    ResultActions result = mockMvc.perform(
+      RestDocumentationRequestBuilders.delete("/api/v1/emails?emailIds=1&emailIds=2")
+        .header("Authorization", "Bearer " + jwt)
+        .contentType(APPLICATION_JSON)
+        .with(csrf()));
+
+    //then
+    result
+      .andDo(print())
+      .andExpect(status().isNoContent())
+      .andDo(
+        document("cancel all EmailTask",
+          preprocessRequest(prettyPrint()),
+          resource(ResourceSnippetParameters.builder()
+            .tag("email")
+            .description("선택한 모든 이메일 작업을 취소합니다.")
+            .build())));
+  }
 }