add stream test to csv test case 497 (#541)

Author: pjfanning

csv/src/test/java/com/fasterxml/jackson/dataformat/csv/deser/FuzzCSVReadTest.java

@@ -1,5 +1,6 @@
 package com.fasterxml.jackson.dataformat.csv.deser;
 
+import java.io.ByteArrayInputStream;
 import java.io.IOException;
 
 import org.junit.jupiter.api.Test;
@@ -14,12 +15,12 @@
 public class FuzzCSVReadTest extends StreamingCSVReadTest
 {
     private final CsvMapper CSV_MAPPER = mapperForCsv();
+    private final byte[] INPUT = new byte[] { 0x20, (byte) 0xCD };
 
     // https://bugs.chromium.org/p/oss-fuzz/issues/detail?id=50036
     @Test
     public void testUTF8Decoding50036() throws Exception
     {
-        byte[] INPUT = new byte[] { 0x20, (byte) 0xCD };
         try {
             CSV_MAPPER.readTree(INPUT);
             fail("Should not pass");
@@ -28,4 +29,15 @@ public void testUTF8Decoding50036() throws Exception
             verifyException(e, "of a UTF-8 character");
         }
     }
+
+    @Test
+    public void testUTF8Decoding50036Stream() throws Exception
+    {
+        try {
+            CSV_MAPPER.readTree(new ByteArrayInputStream(INPUT));
+            fail("Should not pass");
+        } catch (IOException e) {
+            verifyException(e, "Unexpected EOF in the middle of a multi-byte UTF-8 character");
+        }
+    }
 }

csv/src/test/java/com/fasterxml/jackson/dataformat/csv/tofix/UnicodeCSVRead497Test.java

@@ -1,5 +1,6 @@
 package com.fasterxml.jackson.dataformat.csv.tofix;
 
+import java.io.ByteArrayInputStream;
 import java.nio.charset.StandardCharsets;
 
 import org.junit.jupiter.api.Test;
@@ -21,17 +22,33 @@ public class UnicodeCSVRead497Test extends ModuleTestBase
     @Test
     public void testUnicodeAtEnd() throws Exception
     {
-        StringBuilder sb = new StringBuilder(4001);
-        for (int i = 0; i < 4000; ++i) {
-            sb.append('a');
-        }
-        sb.append('\u5496');
-        String doc = sb.toString();
+        String doc = buildTestString();
         JsonNode o = MAPPER.reader() //.with(schema)
                 .readTree(doc.getBytes(StandardCharsets.UTF_8));
         assertNotNull(o);
         assertTrue(o.isArray());
         assertEquals(1, o.size());
         assertEquals(o.get(0).textValue(), doc);
     }
+
+    @Test
+    public void testUnicodeAtEndStream() throws Exception
+    {
+        String doc = buildTestString();
+        JsonNode o = MAPPER.reader() //.with(schema)
+                .readTree(new ByteArrayInputStream(doc.getBytes(StandardCharsets.UTF_8)));
+        assertNotNull(o);
+        assertTrue(o.isArray());
+        assertEquals(1, o.size());
+        assertEquals(o.get(0).textValue(), doc);
+    }
+
+    private static String buildTestString() {
+        StringBuilder sb = new StringBuilder(4001);
+        for (int i = 0; i < 4000; ++i) {
+            sb.append('a');
+        }
+        sb.append('\u5496');
+        return sb.toString();
+    }
 }