Make it possible to mock a Sone’s insert URI.

[Sone.git] / src / test / java / net / pterodactylus / sone / Matchers.java

diff --git a/src/test/java/net/pterodactylus/sone/Matchers.java b/src/test/java/net/pterodactylus/sone/Matchers.java
index c08ffb1..9bd4cbb 100644 (file)
--- a/src/test/java/net/pterodactylus/sone/Matchers.java
+++ b/src/test/java/net/pterodactylus/sone/Matchers.java
@@ -17,13 +17,19 @@
 
 package net.pterodactylus.sone;
 
+import static com.google.common.base.Objects.equal;
+import static com.google.common.collect.Iterators.size;
 import static java.util.Arrays.asList;
 import static java.util.regex.Pattern.compile;
 
+import java.io.IOException;
+import java.io.InputStream;
 import java.util.Collection;
 import java.util.Iterator;
 import java.util.List;
 
+import freenet.support.SimpleFieldSet;
+
 import com.google.common.base.Objects;
 import com.google.common.collect.Lists;
 import org.hamcrest.Description;
@@ -112,4 +118,65 @@ public class Matchers {
                };
        }
 
+       public static Matcher<InputStream> delivers(final byte[] data) {
+               return new TypeSafeMatcher<InputStream>() {
+                       byte[] readData = new byte[data.length];
+
+                       @Override
+                       protected boolean matchesSafely(InputStream inputStream) {
+                               int offset = 0;
+                               try {
+                                       while (true) {
+                                               int r = inputStream.read();
+                                               if (r == -1) {
+                                                       return offset == data.length;
+                                               }
+                                               if (offset == data.length) {
+                                                       return false;
+                                               }
+                                               if (data[offset] != (readData[offset] = (byte) r)) {
+                                                       return false;
+                                               }
+                                               offset++;
+                                       }
+                               } catch (IOException ioe1) {
+                                       return false;
+                               }
+                       }
+
+                       @Override
+                       public void describeTo(Description description) {
+                               description.appendValue(data);
+                       }
+
+                       @Override
+                       protected void describeMismatchSafely(InputStream item, Description mismatchDescription) {
+                               mismatchDescription.appendValue(readData);
+                       }
+               };
+       }
+
+       public static Matcher<SimpleFieldSet> matches(final SimpleFieldSet fieldSetToMatch) {
+               return new TypeSafeMatcher<SimpleFieldSet>() {
+                       @Override
+                       protected boolean matchesSafely(SimpleFieldSet fieldSet) {
+                               if (size(fieldSet.keyIterator()) != size(fieldSetToMatch.keyIterator())) {
+                                       return false;
+                               }
+                               for (Iterator<String> keys = fieldSetToMatch.keyIterator(); keys.hasNext(); ) {
+                                       String key = keys.next();
+                                       if (!equal(fieldSet.get(key), fieldSetToMatch.get(key))) {
+                                               return false;
+                                       }
+                               }
+                               return true;
+                       }
+
+                       @Override
+                       public void describeTo(Description description) {
+                               description.appendText("is ").appendValue(fieldSetToMatch);
+                       }
+               };
+       }
+
 }