package org.argeo.slc.core.execution;\r
\r
+import java.util.HashMap;\r
+import java.util.Map;\r
+\r
+import junit.framework.TestCase;\r
+\r
+import org.apache.commons.logging.Log;\r
+import org.apache.commons.logging.LogFactory;\r
+import org.argeo.slc.core.test.BasicTestData;\r
+import org.argeo.slc.core.test.SimpleTestResult;\r
+import org.argeo.slc.execution.ExecutionContext;\r
import org.argeo.slc.execution.ExecutionFlow;\r
+import org.argeo.slc.test.TestResultPart;\r
+import org.argeo.slc.test.TestStatus;\r
import org.argeo.slc.unit.AbstractSpringTestCase;\r
import org.springframework.beans.factory.BeanCreationException;\r
import org.springframework.context.ConfigurableApplicationContext;\r
import org.springframework.context.support.ClassPathXmlApplicationContext;\r
\r
-public class ExecutionFlowTest extends AbstractSpringTestCase {\r
+public class ExecutionFlowTest extends TestCase {\r
\r
- public void testSimpleExecution() throws Exception {\r
-// configureAndExecuteSlcFlow("main");\r
- configureAndExecuteSlcFlow("applicationContext.xml", "main");\r
- }\r
+ protected final Log log = LogFactory.getLog(getClass());\r
+ \r
+ \r
+// to test: case with listener \r
+ \r
+// public void testMyTest() throws Exception {\r
+// ConfigurableApplicationContext applicationContext = createApplicationContext("test.xml");\r
+// log.info("Start Execution");\r
+// ((ExecutionFlow) applicationContext.getBean("fileDiff.SimulationView_Risk")).execute();\r
+// applicationContext.close(); \r
+// }\r
+// \r
+ public void testMultipleFlows() throws Exception {\r
+ ConfigurableApplicationContext applicationContext = createApplicationContext("multipleFlow.xml");\r
+ log.info("Start Execution");\r
+ ((ExecutionFlow) applicationContext.getBean("flow1")).execute();\r
+ ((ExecutionFlow) applicationContext.getBean("flow2")).execute();\r
+ applicationContext.close();\r
+ } \r
+ \r
+ /**\r
+ * Test placeholder resolution in a context without scope execution or proxy\r
+ * and with cascading flows (the flow A contains the flow B)\r
+ * @throws Exception\r
+ */\r
+ public void testPlaceHolders() throws Exception {\r
+ ConfigurableApplicationContext applicationContext = createApplicationContext("placeHolders.cascading.xml");\r
+ ((ExecutionFlow) applicationContext.getBean("flowA")).execute();\r
+ validateTestResult((SimpleTestResult) applicationContext.getBean("myTestResult"));\r
+ applicationContext.close();\r
+ } \r
\r
- public void testCanonic() throws Exception {\r
- configureAndExecuteSlcFlow("minimal.xml", "minimal");\r
- // Parameter without default value in specification\r
-// configureAndExecuteSlcFlow("canonic-001.xml", "canonic.001");\r
-// configureAndExecuteSlcFlow("canonic-002.xml", "canonic.002");\r
+ /**\r
+ * Test placeholder resolution in a context without scope execution or proxy\r
+ * and with cascading flows (the flow A contains the flow B)\r
+ * setting execution values (should have no effect)\r
+ * @throws Exception\r
+ */\r
+ public void testPlaceHoldersWithExecutionValues() throws Exception {\r
+ ConfigurableApplicationContext applicationContext = createApplicationContext("placeHolders.cascading.xml");\r
+ \r
+ ExecutionContext executionContext = (ExecutionContext)applicationContext.getBean("executionContext");\r
+ Map<String, String> executionParameters = new HashMap<String,String>();\r
+ executionParameters.put("p1", "e1");\r
+ executionParameters.put("p2", "e2");\r
+ executionParameters.put("p3", "e3");\r
+ executionParameters.put("p4", "e4");\r
+ executionParameters.put("p5", "e5");\r
+ executionParameters.put("p6", "e6");\r
+ executionParameters.put("p7", "e7");\r
+ executionParameters.put("p8", "e8");\r
+ executionContext.addVariables(executionParameters);\r
+ \r
+ ((ExecutionFlow) applicationContext.getBean("flowA")).execute();\r
+ validateTestResult((SimpleTestResult) applicationContext.getBean("myTestResult"));\r
+ applicationContext.close();\r
+ } \r
+ \r
+ public void testPlaceHoldersExec() throws Exception {\r
+ ConfigurableApplicationContext applicationContext = createApplicationContext("placeHolders.cascading.exec.xml");\r
+ \r
+ ExecutionContext executionContext = (ExecutionContext)applicationContext.getBean("executionContext");\r
+ Map<String, String> executionParameters = new HashMap<String,String>();\r
+ executionParameters.put("p1", "e1");\r
+ executionParameters.put("p2", "e2");\r
+ executionParameters.put("p3", "e3");\r
+ executionParameters.put("p4", "e4");\r
+ executionParameters.put("p5", "e5");\r
+ executionParameters.put("p6", "e6");\r
+ executionContext.addVariables(executionParameters);\r
+ \r
+ ((ExecutionFlow) applicationContext.getBean("flowA")).execute();\r
+ validateTestResult((SimpleTestResult) applicationContext.getBean("myTestResult"));\r
+ applicationContext.close();\r
+ } \r
+ \r
+ public void testCanonicFlowParameters() throws Exception {\r
+ configureAndExecuteSlcFlow("canonic-001.xml", "canonic.001");\r
+ }\r
\r
-/* try {\r
+ public void testCanonicDefaultValues() throws Exception {\r
+ configureAndExecuteSlcFlow("canonic-002.xml", "canonic.002");\r
+ }\r
+ \r
+ public void testCanonicMissingValues() throws Exception {\r
+ try {\r
configureAndExecuteSlcFlow("canonic-003.error.xml", "canonic.003");\r
fail("Parameter not set - should be rejected.");\r
} catch (BeanCreationException e) {\r
// exception expected\r
- //e.printStackTrace();\r
- }*/\r
- \r
-/* try {\r
+ logException(e);\r
+ } } \r
+ \r
+ public void testCanonicUnknownParameter() throws Exception { \r
+ try {\r
configureAndExecuteSlcFlow("canonic-004.error.xml", "canonic.004");\r
- fail("Unkown parameter set - should be rejected.");\r
+ fail("Unknown parameter set - should be rejected.");\r
} catch (BeanCreationException e) {\r
// exception expected\r
- //e.printStackTrace();\r
- } */\r
+ logException(e);\r
+ } \r
} \r
\r
- protected void configureSlcFlow(String beanName) {\r
- // if an execution context was registered, unregister it\r
- if(ExecutionContext.getCurrent() != null) {\r
- ExecutionContext.unregisterExecutionContext();\r
- }\r
- // register a new ExecutionContext\r
- ExecutionContext.registerExecutionContext(new ExecutionContext());\r
+ public void testListSetMap() throws Exception {\r
+ ConfigurableApplicationContext applicationContext = createApplicationContext("listSetMap.xml");\r
+ ExecutionFlow executionFlow = (ExecutionFlow) applicationContext.getBean("myFlow");\r
+ executionFlow.execute(); \r
+ \r
+ validateTestResult((SimpleTestResult) applicationContext.getBean("myTestResult"));\r
\r
-// ExecutionContext.getVariables().put("slc.flows", beanName);\r
- }\r
- \r
-/* \r
- @Override\r
- protected Boolean getIsStartContext() {\r
- return true;\r
- }\r
+// BasicTestData res = (BasicTestData) applicationContext.getBean("cascadingComplex.testData");\r
+// log.info("res=" + res.getReached().toString());\r
+ \r
+ applicationContext.close(); \r
+ } \r
\r
- @Override\r
- protected ConfigurableApplicationContext getContext() {\r
- return getStaticContext();\r
+// public void testListSetMapMultipleFlows() throws Exception {\r
+// ConfigurableApplicationContext applicationContext = createApplicationContext("listSetMapMultipleFlow.xml");\r
+// ((ExecutionFlow) applicationContext.getBean("flow1")).execute();\r
+// SimpleTestResult res = (SimpleTestResult) applicationContext.getBean("myTestResult");\r
+// validateTestResult(res); \r
+// res.getParts().clear();\r
+// ((ExecutionFlow) applicationContext.getBean("flow2")).execute();\r
+// validateTestResult(res, TestStatus.FAILED);\r
+// applicationContext.close(); \r
+// } \r
+ \r
+ protected void logException(Throwable ex) {\r
+ log.info("Got Exception of class " + ex.getClass().toString()\r
+ + " with message '" + ex.getMessage() + "'.");\r
}\r
-\r
- private static ConfigurableApplicationContext staticContext; \r
\r
- protected ConfigurableApplicationContext getStaticContext() {\r
- if (staticContext == null) {\r
- staticContext = new ClassPathXmlApplicationContext(\r
- getApplicationContextLocation());\r
- if(getIsStartContext())\r
- staticContext.start();\r
- }\r
- return staticContext; \r
+ protected void validateTestResult(SimpleTestResult testResult) {\r
+ validateTestResult(testResult, TestStatus.PASSED);\r
}\r
\r
- protected void configureAndExecuteSlcFlow(String beanName) {\r
- // Triggers a start of the ApplicationContext\r
- // Required before starting some tests\r
- // TODO: understand why !\r
- getContext(); \r
- configureSlcFlow(beanName);\r
- ExecutionFlow executionFlow = (ExecutionFlow) getContext().getBean(beanName);\r
- executionFlow.execute(); \r
+ protected void validateTestResult(SimpleTestResult testResult, int expectedStatus) {\r
+ for(TestResultPart part : testResult.getParts()) {\r
+ if(part.getStatus() != expectedStatus) {\r
+ fail("Error found in TestResult: " + part.getMessage());\r
+ }\r
+ } \r
+ } \r
+ \r
+ protected ConfigurableApplicationContext createApplicationContext(String applicationContextSuffix) {\r
+ ConfigurableApplicationContext applicationContext = new ClassPathXmlApplicationContext(inPackage(applicationContextSuffix));\r
+ applicationContext.start();\r
+ return applicationContext;\r
}\r
- */\r
\r
protected void configureAndExecuteSlcFlow(String applicationContextSuffix, String beanName) {\r
- // create a new context\r
- ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext(\r
- inPackage(applicationContextSuffix));\r
- applicationContext.start();\r
- \r
- configureSlcFlow(beanName);\r
+ ConfigurableApplicationContext applicationContext = createApplicationContext(applicationContextSuffix);\r
ExecutionFlow executionFlow = (ExecutionFlow) applicationContext.getBean(beanName);\r
executionFlow.execute(); \r
-// applicationContext.stop();\r
applicationContext.close();\r
} \r
+ \r
+ protected String inPackage(String suffix) {\r
+ String prefix = getClass().getPackage().getName().replace('.', '/');\r
+ return prefix + '/' + suffix;\r
+ } \r
}\r
projects / gpl / argeo-slc.git / blobdiff