[james-project] 11/17: JAMES-3072 Add test for failing case

[rcordier]

This is an automated email from the ASF dual-hosted git repository.

rcordier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git

commit c2f461c4ad2f08cbb9b850c8bf02f0f865b8a77d
Author: Lan <dlkh...@linagora.com>
AuthorDate: Fri Mar 6 17:12:13 2020 +0700

    JAMES-3072 Add test for failing case
---
 .../service/MailboxesExportRequestToTaskTest.java  | 29 ++++++++++++++++++++++
 1 file changed, 29 insertions(+)

diff --git 
a/server/protocols/webadmin/webadmin-mailbox/src/test/java/org/apache/james/webadmin/service/MailboxesExportRequestToTaskTest.java
 
b/server/protocols/webadmin/webadmin-mailbox/src/test/java/org/apache/james/webadmin/service/MailboxesExportRequestToTaskTest.java
index 76d3b9d..6887eba 100644
--- 
a/server/protocols/webadmin/webadmin-mailbox/src/test/java/org/apache/james/webadmin/service/MailboxesExportRequestToTaskTest.java
+++ 
b/server/protocols/webadmin/webadmin-mailbox/src/test/java/org/apache/james/webadmin/service/MailboxesExportRequestToTaskTest.java
@@ -28,8 +28,11 @@ import static 
org.apache.james.webadmin.service.ExportServiceTestSystem.CEDRIC;
 import static 
org.apache.james.webadmin.service.ExportServiceTestSystem.PASSWORD;
 import static org.hamcrest.Matchers.is;
 import static org.hamcrest.Matchers.notNullValue;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.doReturn;
 
 import java.io.FileInputStream;
+import java.io.InputStream;
 import java.util.Optional;
 
 import org.apache.james.blob.export.file.FileSystemExtension;
@@ -59,6 +62,7 @@ import org.junit.jupiter.api.extension.ExtendWith;
 
 import io.restassured.RestAssured;
 import io.restassured.filter.log.LogDetail;
+import reactor.core.publisher.Mono;
 import spark.Service;
 
 @ExtendWith(FileSystemExtension.class)
@@ -281,6 +285,31 @@ class MailboxesExportRequestToTaskTest {
     }
 
     @Test
+    void exportMailboxesShouldFailWhenCannotSaveToBlobStore() throws Exception 
{
+        testSystem.mailboxManager.createMailbox(MailboxPath.inbox(BOB), 
testSystem.bobSession);
+
+        doReturn(Mono.error(new RuntimeException()))
+            .when(testSystem.blobStore)
+            .save(any(), any(InputStream.class), any());
+
+        String taskId = with()
+            .queryParam("action", "export")
+            .post()
+            .jsonPath()
+            .get("taskId");
+
+        given()
+            .basePath(TasksRoutes.BASE)
+        .when()
+            .get(taskId + "/await")
+        .then()
+            .body("status", is("failed"))
+            .body("taskId", is(taskId))
+            .body("type", is("MailboxesExportTask"))
+            .body("additionalInformation.username", is(BOB.asString()));
+    }
+
+    @Test
     void exportMailboxesShouldCompleteWhenUserHasMessage() throws Exception {
         MailboxId bobInboxboxId = 
testSystem.mailboxManager.createMailbox(MailboxPath.inbox(BOB), 
testSystem.bobSession)
             .get();


---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org
For additional commands, e-mail: server-dev-h...@james.apache.org