Adding unit tests...

fcrepo · Oct 9, 2013 · 65407be · 65407be
1 parent 954f94a
commit 65407be
Show file tree

Hide file tree

Showing 4 changed files with 135 additions and 4 deletions.
diff --git a/...crepo/kernel/utils/EventIteratorTest.java → ...el/utils/iterators/EventIteratorTest.java b/...crepo/kernel/utils/EventIteratorTest.java → ...el/utils/iterators/EventIteratorTest.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package org.fcrepo.kernel.utils;
+package org.fcrepo.kernel.utils.iterators;
 
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;

diff --git a/...fcrepo/kernel/utils/NodeIteratortest.java → ...nel/utils/iterators/NodeIteratorTest.java b/...fcrepo/kernel/utils/NodeIteratortest.java → ...nel/utils/iterators/NodeIteratorTest.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package org.fcrepo.kernel.utils;
+package org.fcrepo.kernel.utils.iterators;
 
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
@@ -30,7 +30,7 @@
 import org.junit.Test;
 import org.mockito.Mock;
 
-public class NodeIteratortest {
+public class NodeIteratorTest {
 
     @Mock
     javax.jcr.NodeIterator i;

diff --git a/...po/kernel/utils/PropertyIteratorTest.java → ...utils/iterators/PropertyIteratorTest.java b/...po/kernel/utils/PropertyIteratorTest.java → ...utils/iterators/PropertyIteratorTest.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package org.fcrepo.kernel.utils;
+package org.fcrepo.kernel.utils.iterators;
 
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;

diff --git a/fcrepo-kernel/src/test/java/org/fcrepo/kernel/utils/iterators/RdfStreamTest.java b/fcrepo-kernel/src/test/java/org/fcrepo/kernel/utils/iterators/RdfStreamTest.java
@@ -0,0 +1,131 @@
+
+package org.fcrepo.kernel.utils.iterators;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+import static org.mockito.MockitoAnnotations.initMocks;
+
+import java.util.Iterator;
+import java.util.Map;
+
+import javax.jcr.RepositoryException;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.mockito.Mock;
+import org.modeshape.jcr.api.NamespaceRegistry;
+
+import com.google.common.collect.ImmutableMap;
+import com.google.common.collect.ImmutableSet;
+import com.google.common.collect.Iterators;
+import com.hp.hpl.jena.graph.Triple;
+import com.hp.hpl.jena.rdf.model.Model;
+
+public class RdfStreamTest {
+
+    private RdfStream testStream;
+
+    @Mock
+    private Iterator<Triple> mockIterator;
+
+    @Mock
+    private Triple triple1, triple2;
+
+    private final static String prefix1 = "testNS";
+
+    private final static String uri1 = "http://testNS";
+
+    private final static String prefix2 = "testNS2";
+
+    private final static String uri2 = "http://testNS2";
+
+    private final Map<String, String> testNamespaces = ImmutableMap.of(prefix1,
+            uri1, prefix2, uri2);
+
+    @Mock
+    private NamespaceRegistry mockNamespaceRegistry;
+
+    @Before
+    public void setUp() {
+        initMocks(this);
+        testStream = new RdfStream(mockIterator);
+    }
+
+    @Test
+    public void testHasNext() {
+        when(mockIterator.hasNext()).thenReturn(true, false);
+        assertTrue(testStream.hasNext());
+        assertFalse(testStream.hasNext());
+    }
+
+    @Test
+    public void testNext() {
+        when(mockIterator.next()).thenReturn(triple1, triple2);
+        assertEquals(triple1, testStream.next());
+        assertEquals(triple2, testStream.next());
+    }
+
+    @Test
+    public void testRemove() {
+        testStream.remove();
+        verify(mockIterator).remove();
+    }
+
+    @Test
+    public void testIterator() {
+        assertEquals(testStream, testStream.iterator());
+    }
+
+    @Test
+    public void testDefaultConstructor() {
+        assertFalse(new RdfStream().hasNext());
+    }
+
+    @Test
+    public void testCollectionConstructor() {
+        testStream = new RdfStream(ImmutableSet.of(triple1, triple2));
+        assertEquals(triple1, testStream.next());
+    }
+
+    @Test
+    public void testConcat() {
+        when(mockIterator.next()).thenReturn(triple1, triple2);
+        final RdfStream testStream2 = new RdfStream(ImmutableSet.of(triple1));
+        testStream.concat(testStream2);
+        assertEquals(triple1, Iterators.getLast(testStream));
+    }
+
+    @Test
+    public void testCollectionConcat() {
+        when(mockIterator.next()).thenReturn(triple1, triple2);
+        testStream.concat(ImmutableSet.of(triple1));
+        assertEquals(triple1, Iterators.getLast(testStream));
+    }
+
+    @Test
+    public void testAddNamespace() {
+        testStream.addNamespace(prefix1, uri1);
+        assertTrue(testStream.namespaces().containsKey(prefix1));
+        assertTrue(testStream.namespaces().containsValue(uri1));
+    }
+
+    @Test
+    public void testAddNamespaces() {
+        testStream.addNamespaces(testNamespaces);
+        assertTrue(testStream.namespaces().containsKey(prefix1));
+        assertTrue(testStream.namespaces().containsValue(uri1));
+        assertTrue(testStream.namespaces().containsKey(prefix2));
+        assertTrue(testStream.namespaces().containsValue(uri2));
+    }
+
+    @Test
+    public void testAsModel() throws RepositoryException {
+        testStream.addNamespaces(testNamespaces);
+        final Model testModel = testStream.asModel();
+        assertEquals(testModel.getNsPrefixMap(), testNamespaces);
+
+    }
+}