(streampipes) branch 4650-file-adapter-string-parsing-fails-for-quoted-delimiter updated: Add tests

[oe...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

SvenO3 pushed a commit to branch 4650-file-adapter-string-parsing-fails-for-quoted-delimiter
in repository https://gitbox.apache.org/repos/asf/streampipes.git


The following commit(s) were added to refs/heads/4650-file-adapter-string-parsing-fails-for-quoted-delimiter by this push:
     new d67244c695 Add tests
d67244c695 is described below

commit d67244c695baabafa72979cebcca8fb0a70ed108
Author: Sven Oehler <oe...@web.de>
AuthorDate: Wed Jul 8 11:43:09 2026 +0200

    Add tests
---
 .../connect/adapter/parser/CsvParserTest.java      | 30 ++++++++++++++++++++++
 1 file changed, 30 insertions(+)

diff --git a/streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/parser/CsvParserTest.java b/streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/parser/CsvParserTest.java
index 283bd362ea..b4cbd85609 100644
--- a/streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/parser/CsvParserTest.java
+++ b/streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/parser/CsvParserTest.java
@@ -76,4 +76,34 @@ public class CsvParserTest extends ParserTest {
     verify(mockEventHandler, times(1)).handle(expectedEvent);
   }
 
+  @Test
+  public void parseHeaderWithQuotedDelimiter() {
+    var event = toStream("column1,column2,\"column2,5\"\n1,2,3");
+    var mockEventHandler = mock(IParserEventHandler.class);
+
+    var parser = new CsvParser(true, ',');
+    parser.parse(event, mockEventHandler);
+
+    Map<String, Object> expectedEvent = new HashMap<>();
+    expectedEvent.put("column1", 1);
+    expectedEvent.put("column2", 2);
+    expectedEvent.put("column2,5", 3);
+    verify(mockEventHandler).handle(expectedEvent);
+  }
+
+  @Test
+  public void parseValueWithQuotedDelimiter() {
+    var event = toStream("k1,k2,k3\nv1,\"2,5\",3");
+    var mockEventHandler = mock(IParserEventHandler.class);
+
+    var parser = new CsvParser(true, ',');
+    parser.parse(event, mockEventHandler);
+
+    Map<String, Object> expectedEvent = new HashMap<>();
+    expectedEvent.put(K1, "v1");
+    expectedEvent.put(K2, "2,5");
+    expectedEvent.put("k3", 3);
+    verify(mockEventHandler).handle(expectedEvent);
+  }
+
 }