130 - Support foreach

components/sbm-recipes-mule-to-boot/src/main/java/org/springframework/sbm/mule/actions/javadsl/translators/core/ForeachTranslator.java

@@ -0,0 +1,76 @@
+package org.springframework.sbm.mule.actions.javadsl.translators.core;
+
+import org.mulesoft.schema.mule.core.ForeachProcessorType;
+import org.springframework.sbm.mule.actions.javadsl.translators.Bean;
+import org.springframework.sbm.mule.actions.javadsl.translators.DslSnippet;
+import org.springframework.sbm.mule.actions.javadsl.translators.MuleComponentToSpringIntegrationDslTranslator;
+import org.springframework.sbm.mule.api.toplevel.ForeachTopLevelElement;
+import org.springframework.sbm.mule.api.toplevel.configuration.MuleConfigurations;
+import org.springframework.stereotype.Component;
+
+import javax.xml.namespace.QName;
+import java.util.Collection;
+import java.util.Map;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+import static java.util.Collections.emptySet;
+
+@Component
+public class ForeachTranslator implements MuleComponentToSpringIntegrationDslTranslator<ForeachProcessorType> {
+    @Override
+    public Class<ForeachProcessorType> getSupportedMuleType() {
+        return ForeachProcessorType.class;
+    }
+
+    @Override
+    public DslSnippet translate(int id,
+                                ForeachProcessorType component,
+                                QName name,
+                                MuleConfigurations muleConfigurations,
+                                String flowName,
+                                Map<Class, MuleComponentToSpringIntegrationDslTranslator> translatorsMap
+    ) {
+
+        ForeachTopLevelElement forEachTopLevelTranslations =
+                new ForeachTopLevelElement(
+                        flowName,
+                        component.getMessageProcessorOrOutboundEndpoint(),
+                        muleConfigurations,
+                        translatorsMap
+                );
+
+        Set<Bean> beans = forEachTopLevelTranslations
+                .getDslSnippets()
+                .stream()
+                .map(DslSnippet::getBeans)
+                .flatMap(Collection::stream)
+                .collect(Collectors.toSet());
+
+
+        Set<String> requiredImports = forEachTopLevelTranslations
+                .getDslSnippets()
+                .stream()
+                .map(DslSnippet::getRequiredImports)
+                .flatMap(Collection::stream)
+                .collect(Collectors.toSet());
+
+        Set<String> dependencies = forEachTopLevelTranslations
+                .getDslSnippets()
+                .stream()
+                .map(DslSnippet::getRequiredDependencies)
+                .flatMap(Collection::stream)
+                .collect(Collectors.toSet());
+
+        return new DslSnippet(
+                "                //TODO: translate expression " + component.getCollection() + " which must produces an array\n" +
+                        "                // to iterate over\n" +
+                        "                .split()\n" +
+                        "                " + forEachTopLevelTranslations.renderDslSnippet() + "\n" +
+                        "                .aggregate()",
+                requiredImports,
+                dependencies,
+                beans
+        );
+    }
+}

components/sbm-recipes-mule-to-boot/src/main/java/org/springframework/sbm/mule/actions/javadsl/translators/db/SelectTranslator.java

@@ -44,9 +44,11 @@ public DslSnippet translate(int id, SelectMessageProcessorType component,
 
         String limitString = component.getMaxRows() == null ? "" : " LIMIT " + component.getMaxRows();
 
+        String query = component.getDynamicQuery() == null ? component.getParameterizedQuery()
+                : component.getDynamicQuery();
         return new DslSnippet("// TODO: substitute expression language with appropriate java code \n" +
                 "                .handle((p, h) -> jdbcTemplate.queryForList(\"" +
-                escapeDoubleQuotes(component.getDynamicQuery())
+                escapeDoubleQuotes(query)
                 + limitString + "\"))",
                 Collections.emptySet(),
                 Set.of(

components/sbm-recipes-mule-to-boot/src/main/java/org/springframework/sbm/mule/api/toplevel/ApiRouterKitFlowTopLevelElement.java

@@ -65,6 +65,7 @@ protected String composeSuffixDslCode() {
     public Set<String> getRequiredImports() {
         Set<String> requiredImports = super.getRequiredImports();
         requiredImports.add("org.springframework.http.HttpMethod");
+        requiredImports.add("org.springframework.integration.http.dsl.Http");
         return requiredImports;
     }
 

components/sbm-recipes-mule-to-boot/src/main/java/org/springframework/sbm/mule/api/toplevel/ChoiceTopLevelElement.java

@@ -35,7 +35,6 @@ public String renderDslSnippet() {
         Set<String> requiredImports = getRequiredImports();
         requiredImports.add("org.springframework.integration.dsl.IntegrationFlow");
         requiredImports.add("org.springframework.integration.dsl.IntegrationFlows");
-        requiredImports.add("org.springframework.integration.amqp.dsl.Amqp");
         getDslSnippets().forEach(ds -> requiredImports.addAll(ds.getRequiredImports()));
         return sb.toString();
     }

components/sbm-recipes-mule-to-boot/src/main/java/org/springframework/sbm/mule/api/toplevel/ForeachTopLevelElement.java

@@ -0,0 +1,31 @@
+package org.springframework.sbm.mule.api.toplevel;
+
+import org.springframework.sbm.mule.actions.javadsl.translators.DslSnippet;
+import org.springframework.sbm.mule.actions.javadsl.translators.MuleComponentToSpringIntegrationDslTranslator;
+import org.springframework.sbm.mule.api.toplevel.configuration.MuleConfigurations;
+
+import javax.xml.bind.JAXBElement;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+public class ForeachTopLevelElement extends AbstractTopLevelElement{
+
+    protected String composePrefixDslCode() {
+        return "";
+    }
+
+    public String renderDslSnippet() {
+        StringBuilder sb = new StringBuilder();
+        String dsl = getDslSnippets().stream().map(DslSnippet::getRenderedSnippet).collect(Collectors.joining("\n"));
+        sb.append(dsl);
+        return sb.toString();
+    }
+
+    public ForeachTopLevelElement(String flowName,
+                                  List<JAXBElement<?>> elements,
+                                  MuleConfigurations muleConfigurations,
+                                  Map<Class, MuleComponentToSpringIntegrationDslTranslator> translatorsMap) {
+        super(flowName, elements, muleConfigurations, translatorsMap);
+    }
+}

components/sbm-recipes-mule-to-boot/src/test/java/org/springframework/sbm/mule/actions/JavaDSLActionBaseTest.java

@@ -76,7 +76,8 @@ public void setup() {
                 new DwlTransformTranslator(),
                 new HttpRequestTranslator(),
                 new ChoiceTranslator(),
-                new SelectTranslator()
+                new SelectTranslator(),
+                new ForeachTranslator()
         );
         List<TopLevelElementFactory> topLevelTypeFactories = List.of(
                 new FlowTopLevelElementFactory(translators),

components/sbm-recipes-mule-to-boot/src/test/java/org/springframework/sbm/mule/actions/MuleToJavaDSLDBTest.java

@@ -26,7 +26,7 @@
 public class MuleToJavaDSLDBTest extends JavaDSLActionBaseTest {
 
     @Test
-    public void translateDbSelectQuery() {
+    public void translateDbSelectDynamicQuery() {
         String muleXml = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n" +
                 "\n" +
                 "<mule xmlns:db=\"http://www.mulesoft.org/schema/mule/db\" xmlns:http=\"http://www.mulesoft.org/schema/mule/http\" xmlns=\"http://www.mulesoft.org/schema/mule/core\" xmlns:doc=\"http://www.mulesoft.org/schema/mule/documentation\"\n" +
@@ -84,4 +84,54 @@ public void translateDbSelectQuery() {
                                 "                .get();\n" +
                                 "    }}");
     }
+
+    @Test
+    public void translateDbSelectParameterisedQuery() {
+        String muleXml = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n" +
+                "\n" +
+                "<mule xmlns:db=\"http://www.mulesoft.org/schema/mule/db\" xmlns:http=\"http://www.mulesoft.org/schema/mule/http\" xmlns=\"http://www.mulesoft.org/schema/mule/core\" xmlns:doc=\"http://www.mulesoft.org/schema/mule/documentation\"\n" +
+                "    xmlns:spring=\"http://www.springframework.org/schema/beans\" \n" +
+                "    xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\"\n" +
+                "    xsi:schemaLocation=\"http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd\n" +
+                "http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd\n" +
+                "http://www.mulesoft.org/schema/mule/db http://www.mulesoft.org/schema/mule/db/current/mule-db.xsd\n" +
+                "http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd\">\n" +
+                "    <db:mysql-config name=\"MySQL_Configuration\" host=\"localhost\" port=\"3036\" user=\"root\" password=\"root\" doc:name=\"MySQL Configuration\"/>\n" +
+                "    <flow name=\"dbFlow\">\n" +
+                "        <http:listener config-ref=\"HTTP_Listener_Configuration\" path=\"/\" doc:name=\"HTTP\"/>\n" +
+                "        <logger level=\"INFO\" doc:name=\"Logger\"/>\n" +
+                "        <db:select config-ref=\"MySQL_Configuration\" doc:name=\"Database\" fetchSize=\"500\" maxRows=\"500\">\n" +
+                "            <db:parameterized-query><![CDATA[SELECT * FROM STUDENTS]]></db:parameterized-query>\n" +
+                "        </db:select>" +
+                "    </flow>\n" +
+                "</mule>\n";
+
+        addXMLFileToResource(muleXml);
+        runAction();
+        assertThat(projectContext.getProjectJavaSources().list()).hasSize(1);
+        assertThat(projectContext.getProjectJavaSources().list().get(0).print())
+                .isEqualTo(
+                        "package com.example.javadsl;\n" +
+                                "import org.springframework.context.annotation.Bean;\n" +
+                                "import org.springframework.context.annotation.Configuration;\n" +
+                                "import org.springframework.integration.dsl.IntegrationFlow;\n" +
+                                "import org.springframework.integration.dsl.IntegrationFlows;\n" +
+                                "import org.springframework.integration.handler.LoggingHandler;\n" +
+                                "import org.springframework.integration.http.dsl.Http;\n" +
+                                "\n" +
+                                "@Configuration\n" +
+                                "public class FlowConfigurations {\n" +
+                                "    void dbMysql_config() {\n" +
+                                "        //FIXME: element is not supported for conversion: <db:mysql-config/>\n" +
+                                "    }\n" +
+                                "\n" +
+                                "    @Bean\n" +
+                                "    IntegrationFlow dbFlow(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate) {\n" +
+                                "        return IntegrationFlows.from(Http.inboundChannelAdapter(\"/\")).handle((p, h) -> p)\n" +
+                                "                .log(LoggingHandler.Level.INFO)\n" +
+                                "                // TODO: substitute expression language with appropriate java code \n" +
+                                "                .handle((p, h) -> jdbcTemplate.queryForList(\"SELECT * FROM STUDENTS LIMIT 500\"))\n" +
+                                "                .get();\n" +
+                                "    }}");
+    }
 }