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 bt...@apache.org on 2019/12/10 02:30:27 UTC

[james-project] 24/27: JAMES-2979 enhance assertions for IMAPMessageReader

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

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

commit e215a4d7870a4ae5cafebe07e8fe6a4c0457d233
Author: Matthieu Baechler <ma...@apache.org>
AuthorDate: Fri Nov 29 15:09:27 2019 +0100

    JAMES-2979 enhance assertions for IMAPMessageReader
---
 .../main/java/org/apache/james/utils/IMAPMessageReader.java | 13 +++++--------
 1 file changed, 5 insertions(+), 8 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 311c873..c9f841e 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
@@ -28,6 +28,7 @@ import java.util.stream.Stream;
 
 import org.apache.commons.net.imap.IMAPClient;
 import org.apache.james.core.Username;
+import org.assertj.core.api.Assertions;
 import org.awaitility.core.ConditionFactory;
 import org.junit.jupiter.api.extension.AfterEachCallback;
 import org.junit.jupiter.api.extension.ExtensionContext;
@@ -83,7 +84,7 @@ public class IMAPMessageReader extends ExternalResource implements Closeable, Af
     }
 
     public boolean hasAMessage() throws IOException {
-        imapClient.fetch("1:1", "ALL");
+        imapClient.fetch("1", "UID");
         return imapClient.getReplyString()
             .contains("OK FETCH completed");
     }
@@ -94,13 +95,9 @@ public class IMAPMessageReader extends ExternalResource implements Closeable, Af
     }
 
     public IMAPMessageReader awaitMessageCount(ConditionFactory conditionFactory, int messageCount) {
-        conditionFactory.until(() -> {
-            try {
-                imapClient.fetch("1:*", "ALL");
-                return countFetchedEntries() == messageCount;
-            } catch (Exception e) {
-                throw new RuntimeException(e);
-            }
+        conditionFactory.untilAsserted(() -> {
+            imapClient.fetch("1:*", "UID");
+            Assertions.assertThat(countFetchedEntries()).isEqualTo(messageCount);
         });
         return this;
     }


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