tests for datastream service

fcrepo · Feb 12, 2013 · 2ad6e52 · 2ad6e52
1 parent c52a989
commit 2ad6e52
Showing 1 changed file with 12 additions and 2 deletions.
diff --git a/fcrepo-kernel/src/test/java/org/fcrepo/services/DatastreamServiceTest.java b/fcrepo-kernel/src/test/java/org/fcrepo/services/DatastreamServiceTest.java
@@ -1,5 +1,6 @@
 package org.fcrepo.services;
 
+import org.apache.tika.io.IOUtils;
 import org.fcrepo.AbstractTest;
 import org.junit.Test;
 import org.springframework.test.context.ContextConfiguration;
@@ -35,14 +36,23 @@ public void testCreateDatastreamNode() throws Exception {
         session = repository.login();
 
         assertTrue(session.getRootNode().hasNode("testDatastreamNode"));
-
-        System.out.println(session.getNode("/testDatastreamNode").getNode(JCR_CONTENT).getProperty(JCR_DATA).getString());
         assertEquals("asdf", session.getNode("/testDatastreamNode").getNode(JCR_CONTENT).getProperty(JCR_DATA).getString());
 
     }
 
     @Test
     public void testGetDatastreamContentInputStream() throws Exception {
+        Session session = repository.login();
+        InputStream is = new ByteArrayInputStream("asdf".getBytes());
+
+        Node n = new DatastreamService().createDatastreamNode(session, "testDatastreamNode", "application/octet-stream", is);
+
+        session.save();
+
+        session = repository.login();
+
+        InputStream contentInputStream = new DatastreamService().getDatastreamContentInputStream(session, "/testDatastreamNode");
 
+        assertEquals("asdf", IOUtils.toString(contentInputStream, "UTF-8"));
     }
 }