feat(QTDI-1914): Change the SPI interface and add a unit test.

Author: ypiel-talend

sample-parent/sample-features/dynamic-dependencies/classloader-test-library/src/main/java/org/talend/sdk/component/sample/feature/dynamicdependencies/classloadertestlibrary/StringMapTransformer.java

@@ -22,44 +22,43 @@
 import java.nio.charset.StandardCharsets;
 import java.util.ArrayList;
 import java.util.List;
-import java.util.Map;
 import java.util.ServiceLoader;
-import java.util.function.BiFunction;
+import java.util.function.Function;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
 import org.talend.sdk.component.api.exception.ComponentException;
 
 public class StringMapTransformer<T> {
 
-    private final StringMapProvider stringMapProvider;
+    private final StringProvider stringMapProvider;
 
     public StringMapTransformer(final boolean failIfSeveralServicesFound) {
-        ServiceLoader<StringMapProvider> serviceLoader = ServiceLoader.load(StringMapProvider.class);
+        ServiceLoader<StringProvider> serviceLoader = ServiceLoader.load(StringProvider.class);
 
-        List<StringMapProvider> stringMapProviderList = new ArrayList<>();
+        List<StringProvider> stringMapProviderList = new ArrayList<>();
         serviceLoader.iterator().forEachRemaining(stringMapProviderList::add);
 
         if (stringMapProviderList.size() <= 0) {
-            throw new ComponentException("No %s service found.".formatted(StringMapProvider.class));
+            throw new ComponentException("No SPI service found for %s.".formatted(StringProvider.class));
         }
 
         if (stringMapProviderList.size() > 1 && failIfSeveralServicesFound) {
             String join = stringMapProviderList.stream()
                     .map(m -> m.getClass().getName())
                     .collect(Collectors.joining("\n"));
             throw new ComponentException("More than one %s service has been found: %s"
-                    .formatted(StringMapProvider.class, join));
+                    .formatted(StringProvider.class, join));
         }
 
         this.stringMapProvider = stringMapProviderList.get(0);
     }
 
-    public List<T> transform(final BiFunction<String, String, T> function) {
-        Map<String, String> map = stringMapProvider.getMap();
-        return map.entrySet()
+    public List<T> transform(final Function<String, T> function) {
+        List<String> strings = stringMapProvider.getStrings();
+        return strings
                 .stream()
-                .map(e -> function.apply(e.getKey(), e.getValue()))
+                .map(function::apply)
                 .toList();
     }
 

…loadertestlibrary/StringMapProvider.java …assloadertestlibrary/StringProvider.javasample-parent/sample-features/dynamic-dependencies/classloader-test-library/src/main/java/org/talend/sdk/component/sample/feature/dynamicdependencies/classloadertestlibrary/StringMapProvider.java renamed to sample-parent/sample-features/dynamic-dependencies/classloader-test-library/src/main/java/org/talend/sdk/component/sample/feature/dynamicdependencies/classloadertestlibrary/StringProvider.java sample-parent/sample-features/dynamic-dependencies/classloader-test-library/src/main/java/org/talend/sdk/component/sample/feature/dynamicdependencies/classloadertestlibrary/StringMapProvider.java renamed to sample-parent/sample-features/dynamic-dependencies/classloader-test-library/src/main/java/org/talend/sdk/component/sample/feature/dynamicdependencies/classloadertestlibrary/StringProvider.java

@@ -15,10 +15,10 @@
  */
 package org.talend.sdk.component.sample.feature.dynamicdependencies.classloadertestlibrary;
 
-import java.util.Map;
+import java.util.List;
 
-public interface StringMapProvider {
+public interface StringProvider {
 
-    Map<String, String> getMap();
+    List<String> getStrings();
 
 }

…loadertestspi/StringMapProviderImpl.java …assloadertestspi/StringProviderImpl.javasample-parent/sample-features/dynamic-dependencies/classloader-test-spi/src/main/java/org/talend/sdk/component/sample/feature/dynamicdependencies/classloadertestspi/StringMapProviderImpl.java renamed to sample-parent/sample-features/dynamic-dependencies/classloader-test-spi/src/main/java/org/talend/sdk/component/sample/feature/dynamicdependencies/classloadertestspi/StringProviderImpl.java sample-parent/sample-features/dynamic-dependencies/classloader-test-spi/src/main/java/org/talend/sdk/component/sample/feature/dynamicdependencies/classloadertestspi/StringMapProviderImpl.java renamed to sample-parent/sample-features/dynamic-dependencies/classloader-test-spi/src/main/java/org/talend/sdk/component/sample/feature/dynamicdependencies/classloadertestspi/StringProviderImpl.java

@@ -15,21 +15,15 @@
  */
 package org.talend.sdk.component.sample.feature.dynamicdependencies.classloadertestspi;
 
-import java.util.HashMap;
-import java.util.Map;
+import java.util.Arrays;
+import java.util.List;
 
-import org.talend.sdk.component.sample.feature.dynamicdependencies.classloadertestlibrary.StringMapProvider;
+import org.talend.sdk.component.sample.feature.dynamicdependencies.classloadertestlibrary.StringProvider;
 
-public class StringMapProviderImpl implements StringMapProvider {
+public class StringProviderImpl implements StringProvider {
 
     @Override
-    public Map<String, String> getMap() {
-        Map<String, String> map = new HashMap<>();
-        map.put("key1", "value1");
-        map.put("key2", "value2");
-        map.put("key3", "value3");
-        map.put("key4", "value4");
-        map.put("key5", "value5");
-        return map;
+    public List<String> getStrings() {
+        return Arrays.asList("value1", "value2", "value3");
     }
 }

…classloadertestlibrary.StringMapProvider …es.classloadertestlibrary.StringProvidersample-parent/sample-features/dynamic-dependencies/classloader-test-spi/src/main/resources/META-INF/services/org.talend.sdk.component.sample.feature.dynamicdependencies.classloadertestlibrary.StringMapProvider renamed to sample-parent/sample-features/dynamic-dependencies/classloader-test-spi/src/main/resources/META-INF/services/org.talend.sdk.component.sample.feature.dynamicdependencies.classloadertestlibrary.StringProvider sample-parent/sample-features/dynamic-dependencies/classloader-test-spi/src/main/resources/META-INF/services/org.talend.sdk.component.sample.feature.dynamicdependencies.classloadertestlibrary.StringMapProvider renamed to sample-parent/sample-features/dynamic-dependencies/classloader-test-spi/src/main/resources/META-INF/services/org.talend.sdk.component.sample.feature.dynamicdependencies.classloadertestlibrary.StringProvider

@@ -13,4 +13,4 @@
 #  limitations under the License.
 # Here you can change all your configuration display names to use more explicit labels
 # You can also translate your configuration by adding one file by local Messages_fr.properties for french for example
-org.talend.sdk.component.sample.feature.dynamicdependencies.classloadertestspi.StringMapProviderImpl
+org.talend.sdk.component.sample.feature.dynamicdependencies.classloadertestspi.StringProviderImpl

sample-parent/sample-features/dynamic-dependencies/classloader-test-spi/src/test/java/org/talend/sdk/component/sample/feature/dynamicdependencies/classloadertestspi/StringMapProviderImplTest.java

@@ -19,6 +19,7 @@
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.function.Function;
 
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
@@ -29,11 +30,11 @@ class StringMapProviderImplTest {
     @Test
     void testSPI() {
         StringMapTransformer<String> stringMapTransformer = new StringMapTransformer<>(true);
-        List<String> transform = stringMapTransformer.transform((s1, s2) -> s1 + ":" + s2);
+        List<String> transform = stringMapTransformer.transform(Function.identity());
         List<String> sorted = new ArrayList<>(transform);
         sorted.sort(String::compareTo);
         String collect = String.join("/", sorted);
-        Assertions.assertEquals("key1:value1/key2:value2/key3:value3/key4:value4/key5:value5",
+        Assertions.assertEquals("value1/value2/value3",
                 collect);
     }
 

sample-parent/sample-features/dynamic-dependencies/dynamic-dependencies-with-spi/src/main/java/org/talend/sdk/component/sample/feature/dynamicdependencies/withspi/service/DynamicDependenciesWithSPIService.java

@@ -67,7 +67,7 @@ public Schema guessSchema4Input(final @Option("configuration") Dataset dse) {
     public Iterator<Record> getRecordIterator() {
         StringMapTransformer<Record> stringMapTransformer = new StringMapTransformer<>(true);
         List<Record> records = stringMapTransformer
-                .transform((s1, s2) -> recordBuilderFactory.newRecordBuilder().withString(s1, s2).build());
+                .transform(s -> recordBuilderFactory.newRecordBuilder().withString("value", s).build());
         return records.iterator();
     }
 

sample-parent/sample-features/dynamic-dependencies/dynamic-dependencies-with-spi/src/test/java/org/talend/sdk/component/sample/feature/dynamicdependencies/withspi/input/DynamicDependenciesWithSPIInputTest.java

@@ -0,0 +1,57 @@
+/**
+ * Copyright (C) 2006-2025 Talend Inc. - www.talend.com
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.talend.sdk.component.sample.feature.dynamicdependencies.withspi.input;
+
+import java.util.List;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+import org.talend.sdk.component.api.record.Record;
+import org.talend.sdk.component.junit.BaseComponentsHandler;
+import org.talend.sdk.component.junit.SimpleFactory;
+import org.talend.sdk.component.junit5.Injected;
+import org.talend.sdk.component.junit5.WithComponents;
+import org.talend.sdk.component.runtime.manager.chain.Job;
+import org.talend.sdk.component.sample.feature.dynamicdependencies.withspi.config.Config;
+
+@WithComponents("org.talend.sdk.component.sample.feature.dynamicdependencies.withspi")
+class DynamicDependenciesWithSPIInputTest {
+
+    @Injected
+    protected BaseComponentsHandler handler;
+
+    @Test
+    public void testGeneratedRecord() {
+        Config config = new Config();
+        String queryString = SimpleFactory.configurationByExample().forInstance(config).configured().toQueryString();
+
+        Job.components()
+                .component("input", "DynamicDependenciesWithSPI://Input?" + queryString)
+                .component("collector", "test://collector")
+                .connections()
+                .from("input")
+                .to("collector")
+                .build()
+                .run();
+
+        List<Record> collectedData = handler.getCollectedData(Record.class);
+        Assertions.assertEquals(3, collectedData.size());
+        Assertions.assertEquals("value1", collectedData.get(0).getString("value"));
+        Assertions.assertEquals("value2", collectedData.get(1).getString("value"));
+        Assertions.assertEquals("value3", collectedData.get(2).getString("value"));
+    }
+
+}