You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by rc...@apache.org on 2020/05/15 05:02:21 UTC

[james-project] 09/12: JAMES-3143 Add create method in IMAPMessageReader

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 bc8fb0a8a0c1b79aaf4c727278d3e0cfc280bff8
Author: LanKhuat <kh...@gmail.com>
AuthorDate: Tue May 12 15:10:36 2020 +0700

    JAMES-3143 Add create method in IMAPMessageReader
---
 .../java/org/apache/james/utils/IMAPMessageReader.java    | 15 +++++++++++----
 1 file changed, 11 insertions(+), 4 deletions(-)

diff --git a/server/testing/src/main/java/org/apache/james/utils/IMAPMessageReader.java b/server/testing/src/main/java/org/apache/james/utils/IMAPMessageReader.java
index 36a57e0..1512897 100644
--- a/server/testing/src/main/java/org/apache/james/utils/IMAPMessageReader.java
+++ b/server/testing/src/main/java/org/apache/james/utils/IMAPMessageReader.java
@@ -94,6 +94,13 @@ public class IMAPMessageReader extends ExternalResource implements Closeable, Af
         return this;
     }
 
+    public IMAPMessageReader create(String mailbox) throws IOException {
+        if (!imapClient.create(mailbox)) {
+            throw new RuntimeException(imapClient.getReplyString());
+        }
+        return this;
+    }
+
     public IMAPMessageReader delete(String mailbox) throws IOException {
         imapClient.delete(mailbox);
         return this;
@@ -105,7 +112,7 @@ public class IMAPMessageReader extends ExternalResource implements Closeable, Af
             .contains("OK FETCH completed");
     }
 
-    public IMAPMessageReader awaitMessage(ConditionFactory conditionFactory) throws IOException {
+    public IMAPMessageReader awaitMessage(ConditionFactory conditionFactory) {
         conditionFactory.until(this::hasAMessage);
         return this;
     }
@@ -127,7 +134,7 @@ public class IMAPMessageReader extends ExternalResource implements Closeable, Af
             .count();
     }
 
-    public IMAPMessageReader awaitNoMessage(ConditionFactory conditionFactory) throws IOException {
+    public IMAPMessageReader awaitNoMessage(ConditionFactory conditionFactory) {
         conditionFactory.until(this::userDoesNotReceiveMessage);
         return this;
     }
@@ -144,10 +151,10 @@ public class IMAPMessageReader extends ExternalResource implements Closeable, Af
             && Splitter.on(" ")
                 .splitToList(flags)
                 .stream()
-                .allMatch(s -> replyString.contains(s));
+                .allMatch(replyString::contains);
     }
 
-    public boolean userGetNotifiedForNewMessagesWhenSelectingMailbox(int numOfNewMessage) throws IOException {
+    public boolean userGetNotifiedForNewMessagesWhenSelectingMailbox(int numOfNewMessage) {
         return imapClient.getReplyString().contains("OK [UNSEEN " + numOfNewMessage + "]");
     }
 


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