svn commit: r1582867 - /chemistry/opencmis/trunk/chemistry-opencmis-server/chemistry-opencmis-server-bindings/src/test/java/org/apache/chemistry/opencmis/server/impl/AtomEntryParserTest.java

[fm...@apache.org]

Author: fmui
Date: Fri Mar 28 19:46:10 2014
New Revision: 1582867

URL: http://svn.apache.org/r1582867
Log:
added big stream unit test 

Modified:
    chemistry/opencmis/trunk/chemistry-opencmis-server/chemistry-opencmis-server-bindings/src/test/java/org/apache/chemistry/opencmis/server/impl/AtomEntryParserTest.java

Modified: chemistry/opencmis/trunk/chemistry-opencmis-server/chemistry-opencmis-server-bindings/src/test/java/org/apache/chemistry/opencmis/server/impl/AtomEntryParserTest.java
URL: http://svn.apache.org/viewvc/chemistry/opencmis/trunk/chemistry-opencmis-server/chemistry-opencmis-server-bindings/src/test/java/org/apache/chemistry/opencmis/server/impl/AtomEntryParserTest.java?rev=1582867&r1=1582866&r2=1582867&view=diff
==============================================================================
--- chemistry/opencmis/trunk/chemistry-opencmis-server/chemistry-opencmis-server-bindings/src/test/java/org/apache/chemistry/opencmis/server/impl/AtomEntryParserTest.java (original)
+++ chemistry/opencmis/trunk/chemistry-opencmis-server/chemistry-opencmis-server-bindings/src/test/java/org/apache/chemistry/opencmis/server/impl/AtomEntryParserTest.java Fri Mar 28 19:46:10 2014
@@ -25,6 +25,7 @@ import static org.junit.Assert.assertTru
 
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
+import java.util.Arrays;
 
 import javax.xml.stream.XMLStreamException;
 
@@ -212,6 +213,33 @@ public class AtomEntryParserTest {
         new AtomEntryParser(new ByteArrayInputStream(new byte[0]), streamFactory);
     }
 
+    @Test
+    public void testBigStream() throws Exception {
+        byte[] begin = IOUtils
+                .toUTF8Bytes("<?xml version=\"1.0\" encoding=\"UTF-8\" ?>"
+                        + "<entry xmlns=\"http://www.w3.org/2005/Atom\" xmlns:app=\"http://www.w3.org/2007/app\" xmlns:cmisra=\"http://docs.oasis-open.org/ns/cmis/restatom/200908/\">"
+                        + "<cmisra:content><cmisra:mediatype>video/raw</cmisra:mediatype><cmisra:base64>");
+        byte[] end = IOUtils
+                .toUTF8Bytes("</cmisra:base64></cmisra:content><cmisra:object xmlns:cmis=\"http://docs.oasis-open.org/ns/cmis/core/200908/\">"
+                        + "<cmis:properties></cmis:properties></cmisra:object><title>some.file</title></entry>");
+
+        int contenSize = 50 * 1024 * 1024;
+
+        byte[] entry = new byte[begin.length + contenSize + end.length];
+
+        System.arraycopy(begin, 0, entry, 0, begin.length);
+        System.arraycopy(end, 0, entry, entry.length - end.length, end.length);
+        Arrays.fill(entry, begin.length, entry.length - end.length, (byte) 'a');
+
+        ThresholdOutputStreamFactory streamFactory = ThresholdOutputStreamFactory.newInstance(null, THRESHOLD,
+                MAX_SIZE, false);
+        AtomEntryParser aep = new AtomEntryParser(new ByteArrayInputStream(entry), streamFactory);
+        ContentStream contentStream = aep.getContentStream();
+
+        assertNotNull(contentStream);
+        assertNotNull(contentStream.getStream());
+    }
+
     private static byte[] parse(byte[] entry) throws Exception {
         ThresholdOutputStreamFactory streamFactory = ThresholdOutputStreamFactory.newInstance(null, THRESHOLD,
                 MAX_SIZE, false);