This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch 2778-teststringcounterprocessor
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to
refs/heads/2778-teststringcounterprocessor by this push:
new aa4eaab81e refactor(#2778): Fix junit test TestStringCounterProcessor
aa4eaab81e is described below
commit aa4eaab81e7e4ce57792255dfdaf634bb7aec9bb
Author: Philipp Zehnder <[email protected]>
AuthorDate: Tue Jul 16 08:47:32 2024 +0200
refactor(#2778): Fix junit test TestStringCounterProcessor
---
.../counter/TestStringCounterProcessor.java | 186 +++++++--------------
1 file changed, 57 insertions(+), 129 deletions(-)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/TestStringCounterProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/TestStringCounterProcessor.java
index 5887dda629..7db3fcb8a8 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/TestStringCounterProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/TestStringCounterProcessor.java
@@ -18,133 +18,61 @@
package
org.apache.streampipes.processors.transformation.jvm.processor.stringoperator.counter;
-//@RunWith(Parameterized.class)
+import org.apache.streampipes.test.executors.PrefixStrategy;
+import org.apache.streampipes.test.executors.ProcessingElementTestExecutor;
+import org.apache.streampipes.test.executors.StreamPrefix;
+import org.apache.streampipes.test.executors.TestConfiguration;
+
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.params.ParameterizedTest;
+import org.junit.jupiter.params.provider.Arguments;
+import org.junit.jupiter.params.provider.MethodSource;
+
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Stream;
+
public class TestStringCounterProcessor {
-// private static final Logger LOG =
LoggerFactory.getLogger(TestStringCounterProcessor.class);
-//
-// @org.junit.runners.Parameterized.Parameters
-// public static Iterable<Object[]> data() {
-// return Arrays.asList(new Object[][] {
-// {"Test", List.of("t1"), new Tuple3<>("", "", 0)},
-// {"Test", Arrays.asList("t1", "t2"), new Tuple3<>("t1", "t2", 1)},
-// {"Test", Arrays.asList("t1", "t2", "t1", "t2"), new Tuple3<>("t1",
"t2", 2)},
-// {"Test", Arrays.asList("t1", "t2", "t1", "t3"), new Tuple3<>("t1",
"t3", 1)}
-// });
-// }
-//
-// @org.junit.runners.Parameterized.Parameter
-// public String selectedFieldName;
-//
-// @org.junit.runners.Parameterized.Parameter(1)
-// public List<String> eventStrings;
-//
-// @org.junit.runners.Parameterized.Parameter(2)
-// public Tuple3<String, String, Integer> expectedValue;
-//
-// @Test
-// public void testStringCounter() {
-// StringCounterProcessor stringCounter = new StringCounterProcessor();
-// DataProcessorDescription originalGraph = stringCounter.declareModel();
-//
originalGraph.setSupportedGrounding(EventGroundingGenerator.makeDummyGrounding());
-//
-// DataProcessorInvocation graph =
InvocationGraphGenerator.makeEmptyInvocation(originalGraph);
-// graph.setInputStreams(Collections
-// .singletonList(EventStreamGenerator
-//
.makeStreamWithProperties(Collections.singletonList(selectedFieldName))));
-// graph.setOutputStream(EventStreamGenerator.makeStreamWithProperties(
-// Collections.singletonList(selectedFieldName)));
-//
graph.getOutputStream().getEventGrounding().getTransportProtocol().getTopicDefinition()
-// .setActualTopicName("output-topic");
-//
-// MappingPropertyUnary mappingPropertyUnary =
graph.getStaticProperties().stream()
-// .filter(p -> p instanceof MappingPropertyUnary)
-// .map((p -> (MappingPropertyUnary) p))
-// .filter(p ->
p.getInternalName().equals(StringCounterProcessor.FIELD_ID))
-// .findFirst().orElse(null);
-// assert mappingPropertyUnary != null;
-// mappingPropertyUnary.setSelectedProperty("s0::" + selectedFieldName);
-// ProcessorParams params = new ProcessorParams(graph);
-//
-// SpOutputCollector spOut = new SpOutputCollector() {
-// @Override
-// public void registerConsumer(String routeId,
InternalEventProcessor<Map<String, Object>> consumer) {
-// }
-//
-// @Override
-// public void unregisterConsumer(String routeId) {
-// }
-//
-// @Override
-// public void connect() throws SpRuntimeException {
-// }
-//
-// @Override
-// public void disconnect() throws SpRuntimeException {
-// }
-//
-// @Override
-// public void collect(Event event) {
-// }
-// };
-//
-// stringCounter.onInvocation(params, spOut, null);
-// Tuple3<String, String, Integer> tuple = sendEvents(stringCounter, spOut);
-// LOG.info("Expected match count is {}.", expectedValue.x);
-// LOG.info("Actual match count is {}.", tuple.x);
-// assertEquals(expectedValue.x, tuple.x);
-// LOG.info("Expected change from is {}.", expectedValue.k);
-// LOG.info("Actual change from is {}.", tuple.k);
-// assertEquals(expectedValue.k, tuple.k);
-// LOG.info("Expected change to is {}.", expectedValue.k);
-// LOG.info("Actual change to is {}.", tuple.k);
-// assertEquals(expectedValue.v, tuple.v);
-// }
-//
-// private Tuple3<String, String, Integer> sendEvents(StringCounterProcessor
stringCounter, SpOutputCollector spOut) {
-// int counter = 0;
-// String changeFrom = "", changeTo = "";
-// List<Event> events = makeEvents();
-// for (Event event : events) {
-// LOG.info("Sending event with value "
-// + event.getFieldBySelector("s0::" +
selectedFieldName).getAsPrimitive().getAsString());
-// stringCounter.onEvent(event, spOut);
-// try {
-// TimeUnit.MILLISECONDS.sleep(100);
-// } catch (InterruptedException e) {
-// throw new RuntimeException(e);
-// }
-// try {
-// counter =
event.getFieldBySelector(StringCounterProcessor.COUNT_FIELD_RUNTIME_NAME)
-// .getAsPrimitive()
-// .getAsInt();
-// changeFrom =
event.getFieldBySelector(StringCounterProcessor.CHANGE_FROM_FIELD_RUNTIME_NAME)
-// .getAsPrimitive()
-// .getAsString();
-// changeTo =
event.getFieldBySelector(StringCounterProcessor.CHANGE_TO_FIELD_RUNTIME_NAME)
-// .getAsPrimitive()
-// .getAsString();
-// LOG.info(changeFrom + " change to " + changeTo + ", value = " +
counter);
-// } catch (IllegalArgumentException e) {
-//
-// }
-// }
-// return new Tuple3<>(changeFrom, changeTo, counter);
-// }
-//
-//
-// private List<Event> makeEvents() {
-// List<Event> events = Lists.newArrayList();
-// for (String eventSetting : eventStrings) {
-// events.add(makeEvent(eventSetting));
-// }
-// return events;
-// }
-//
-// private Event makeEvent(String value) {
-// Map<String, Object> map = Maps.newHashMap();
-// map.put(selectedFieldName, value);
-// return EventFactory.fromMap(map,
-// new SourceInfo("test" + "-topic", "s0"),
-// new SchemaInfo(null, Lists.newArrayList()));
-// }
-}
+ private static final String KEY_1 = "key1";
+
+ private StringCounterProcessor processor;
+
+ @BeforeEach
+ public void setup() {
+ processor = new StringCounterProcessor();
+ }
+
+
+ static Stream<Arguments> arguments() {
+ return Stream.of(
+ Arguments.of(
+ List.of(Map.of(KEY_1, "v1"), Map.of(KEY_1, "v2")),
+ List.of(Map.of(
+ KEY_1, "v2",
+ StringCounterProcessor.CHANGE_FROM_FIELD_RUNTIME_NAME, "v1",
+ StringCounterProcessor.CHANGE_TO_FIELD_RUNTIME_NAME, "v2",
+ StringCounterProcessor.COUNT_FIELD_RUNTIME_NAME, 1
+ ))
+ )
+ );
+ }
+
+ @ParameterizedTest
+ @MethodSource("arguments")
+ public void testStringToState(
+ List<Map<String, Object>> intpuEvents,
+ List<Map<String, Object>> outputEvents
+ ) {
+
+ var configuration = TestConfiguration
+ .builder()
+ .config(StringCounterProcessor.FIELD_ID, StreamPrefix.s0(KEY_1))
+ .prefixStrategy(PrefixStrategy.SAME_PREFIX)
+ .build();
+
+ var testExecutor = new ProcessingElementTestExecutor(processor,
configuration);
+
+ testExecutor.run(intpuEvents, outputEvents);
+ }
+
+}
\ No newline at end of file
