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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
