What if I include AWS-1, AWS-2, and AWS-3?

.github/issue_template.md

@@ -0,0 +1,53 @@
+<!-- 
+Please fill the report below. Your issue will be added to the overall list of issues and will be reviewed on a first-come first-serve basis. 
+-->
+
+# Issue Details
+
+**Type of Issue**  (check one with "X")
+```
+[ ] Bug Report => Please search GitHub for a similar issue or PR before submitting
+[ ] Feature Request => Please ensure feature is not already in progress
+[ ] Support Request => Please do not submit support requests here, instead see: https://discourse.oss.antheminc.com/
+```
+
+## Current Behavior
+<!-- 
+Please describe the issue in a short summary. 
+-->
+
+
+## Expected Behavior
+<!-- 
+Please describe the expectation of what should occur in the scenario previously described. 
+-->
+
+
+## How to Reproduce the Issue
+### Steps to Reproduce
+<!--
+Please list the steps required to reproduce the issue (if any)
+-->
+
+
+### Code Snippet
+<!-- 
+Please add any code that is necessary to reproduce the issue.
+
+If the current behavior is recreated better with an example, please provide the *STEPS TO REPRODUCE* and if possible a *MINIMAL DEMO* of the problem via
+https://plnkr.co or similar.
+-->
+
+
+# Environment Details
+* **Nimbus Version:**
+<!--
+Please tell us the version of the framework was this issue found in.
+-->
+
+
+* **Browser:**
+<!--
+Please list all browsers where this could be reproduced.
+-->
+

.gitignore

@@ -48,6 +48,9 @@ local.properties
 # STS (Spring Tool Suite)
 .springBeans
 
+# Maven flatten plugin
+*.flattened-pom.xml
+
 # Code Recommenders
 .recommenders/
 

.mvn/maven.config

@@ -0,0 +1 @@
+-B -Drevision=1.3.0.BUILD-SNAPSHOT

nimbus-core/pom.xml

@@ -4,7 +4,7 @@
 	<parent>
 		<groupId>com.antheminc.oss</groupId>
 		<artifactId>nimbus-parent</artifactId>
-		<version>1.2.0.BUILD-SNAPSHOT</version>
+		<version>${revision}</version>
 	</parent>
 
 	<artifactId>nimbus-core</artifactId>

nimbus-core/src/main/java/com/antheminc/oss/nimbus/app/extension/config/BPMEngineConfig.java

@@ -28,10 +28,11 @@
 import org.activiti.engine.impl.bpmn.parser.factory.DefaultActivityBehaviorFactory;
 import org.activiti.engine.impl.history.HistoryLevel;
 import org.activiti.engine.impl.persistence.deploy.Deployer;
+import org.activiti.runtime.api.identity.UserGroupManager;
 import org.activiti.spring.SpringAsyncExecutor;
 import org.activiti.spring.SpringProcessEngineConfiguration;
 import org.activiti.spring.boot.AbstractProcessEngineAutoConfiguration;
-import org.apache.commons.dbcp.BasicDataSource;
+import org.apache.commons.dbcp2.BasicDataSource;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.beans.factory.annotation.Value;
@@ -116,10 +117,10 @@ public class BPMEngineConfig extends AbstractProcessEngineAutoConfiguration {
 	public SpringProcessEngineConfiguration springProcessEngineConfiguration(
 			@Qualifier("processDataSource") DataSource processDataSource,
 			PlatformTransactionManager jpaTransactionManager, SpringAsyncExecutor springAsyncExecutor,
-			BeanResolverStrategy beanResolver) throws Exception {
+			BeanResolverStrategy beanResolver, UserGroupManager userGroupManager) throws Exception {
 
 		SpringProcessEngineConfiguration engineConfiguration = this
-				.baseSpringProcessEngineConfiguration(processDataSource, jpaTransactionManager, springAsyncExecutor);
+				.baseSpringProcessEngineConfiguration(processDataSource, jpaTransactionManager, springAsyncExecutor,userGroupManager);
 
 		if (deploymentName.isPresent()) {
 			engineConfiguration.setDeploymentName(deploymentName.get());

nimbus-core/src/main/java/com/antheminc/oss/nimbus/app/extension/config/DefaultCoreConfiguration.java

@@ -16,12 +16,17 @@
 package com.antheminc.oss.nimbus.app.extension.config;
 
 
+import java.time.ZonedDateTime;
+import java.time.temporal.TemporalAccessor;
+import java.util.Optional;
+
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.boot.web.client.RestTemplateBuilder;
 import org.springframework.cache.annotation.EnableCaching;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.ComponentScan;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.data.auditing.DateTimeProvider;
 import org.springframework.data.domain.AuditorAware;
 import org.springframework.web.client.RestTemplate;
 
@@ -123,6 +128,7 @@ public AuditorAware<String> auditorProvider(BeanResolverStrategy beanResolver) {
 		return new SpringSecurityAuditorAware(beanResolver);
 	}
 
+
 	@Bean
 	public RestTemplate restTemplate(RestTemplateBuilder builder) {
 		return builder.build();
@@ -133,4 +139,15 @@ public ClassPropertyConverter classPropertyConverter() {
 		return new ClassPropertyConverter();
 	}
 
+	@Bean("default.zdt.provider")
+	public DateTimeProvider defaultZDTProvider() {
+		return new DateTimeProvider() {
+
+			@Override
+			public Optional<TemporalAccessor> getNow() {
+				return Optional.of(ZonedDateTime.now());
+			}
+		};
+	}
+
 }

nimbus-core/src/main/java/com/antheminc/oss/nimbus/app/extension/config/DefaultMongoConfig.java

@@ -23,7 +23,7 @@
 import org.springframework.context.annotation.Configuration;
 import org.springframework.data.mongodb.config.EnableMongoAuditing;
 import org.springframework.data.mongodb.core.MongoOperations;
-import org.springframework.data.mongodb.core.convert.CustomConversions;
+import org.springframework.data.mongodb.core.convert.MongoCustomConversions;
 
 import com.antheminc.oss.nimbus.context.BeanResolverStrategy;
 import com.antheminc.oss.nimbus.domain.model.state.repo.IdSequenceRepository;
@@ -38,11 +38,11 @@
  *
  */
 @Configuration
-@EnableMongoAuditing
+@EnableMongoAuditing(dateTimeProviderRef="default.zdt.provider")
 public class DefaultMongoConfig {
 
 	@Bean
-	public CustomConversions defaultMongoCustomConversions() {
+	public MongoCustomConversions defaultMongoCustomConversions() {
 		return new MongoConvertersBuilder().addDefaults().build();
 	}
 

nimbus-core/src/main/java/com/antheminc/oss/nimbus/app/extension/config/DefaultProcessConfig.java

@@ -112,8 +112,8 @@ public CommandExecutorTaskDelegate commandExecutorTaskDelegate(BeanResolverStrat
 	}	
 
 	@Bean(name="default._search$execute?fn=lookup")
-	public FunctionHandler<?, ?> lookupFunctionHandler(){
-		return new DefaultSearchFunctionHandlerLookup<>();
+	public FunctionHandler<?, ?> lookupFunctionHandler(BeanResolverStrategy beanResolver){
+		return new DefaultSearchFunctionHandlerLookup<>(beanResolver);
 	}
 
 	@Bean(name="default._search$execute?fn=example")

nimbus-core/src/main/java/com/antheminc/oss/nimbus/domain/cmd/CommandBuilder.java

@@ -18,6 +18,7 @@
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.LinkedList;
+import java.util.List;
 import java.util.Map;
 
 import org.apache.commons.collections.CollectionUtils;
@@ -58,6 +59,26 @@ public static CommandBuilder withUri(String absoluteUri) {
 		return cb;
 	}
 
+	public static CommandBuilder withCommand(Command cmd) {
+		CommandBuilder cb = new CommandBuilder(cmd);
+		cb.handleUriAndParamsIfAny(cmd.getAbsoluteUri());
+		return cb;
+	}
+
+	/**
+	 * Builds a CommandBuilder by appending a given platform path to a uri untill a given end CommandElementType 
+	 * @param rootCmd
+	 * @param endWhenType
+	 * @param appendPath
+	 * @return
+	 */
+	public static CommandBuilder withPlatformRelativePath(Command rootCmd, Type endWhenType, String appendPath) {
+		String hostUri = rootCmd.buildUri(endWhenType);
+		StringBuilder absoluteUri = new StringBuilder(hostUri);
+		absoluteUri.append(appendPath);
+		return withUri(absoluteUri.toString());	
+	}
+
 	public static CommandBuilder withDomainRelativePath(Command rootCmd, String domainRelPath) {
 		String rootDomainAlias = rootCmd.getRootDomainAlias();
 		String nestedDomainPath = StringUtils.removeStart(Constants.SEPARATOR_URI.code + rootDomainAlias, domainRelPath);
@@ -233,4 +254,13 @@ public CommandBuilder addParams(Map<String, String[]> rParams) {
 		return this;
 	}
 
+	public CommandBuilder setAction(Action action) {
+		cmd.setAction(action);
+		return withCommand(cmd);
+	}
+
+	public CommandBuilder setBehaviors(List<Behavior> behaviors) {
+		cmd.setBehaviors(behaviors);
+		return withCommand(cmd);
+	}
 }

nimbus-core/src/main/java/com/antheminc/oss/nimbus/domain/cmd/exec/internal/DefaultCommandPathVariableResolver.java

@@ -15,6 +15,8 @@
  */
 package com.antheminc.oss.nimbus.domain.cmd.exec.internal;
 
+import java.util.Arrays;
+import java.util.LinkedList;
 import java.util.Map;
 import java.util.Optional;
 import java.util.regex.Matcher;
@@ -27,8 +29,15 @@
 
 import com.antheminc.oss.nimbus.InvalidConfigException;
 import com.antheminc.oss.nimbus.context.BeanResolverStrategy;
+import com.antheminc.oss.nimbus.domain.cmd.Action;
+import com.antheminc.oss.nimbus.domain.cmd.Behavior;
+import com.antheminc.oss.nimbus.domain.cmd.Command;
+import com.antheminc.oss.nimbus.domain.cmd.CommandBuilder;
 import com.antheminc.oss.nimbus.domain.cmd.CommandElement.Type;
+import com.antheminc.oss.nimbus.domain.cmd.CommandMessage;
 import com.antheminc.oss.nimbus.domain.cmd.CommandMessageConverter;
+import com.antheminc.oss.nimbus.domain.cmd.exec.CommandExecution.MultiOutput;
+import com.antheminc.oss.nimbus.domain.cmd.exec.CommandExecutorGateway;
 import com.antheminc.oss.nimbus.domain.cmd.exec.CommandPathVariableResolver;
 import com.antheminc.oss.nimbus.domain.cmd.exec.ParamPathExpressionParser;
 import com.antheminc.oss.nimbus.domain.defn.Constants;
@@ -59,12 +68,14 @@ public class DefaultCommandPathVariableResolver implements CommandPathVariableRe
 	private final PropertyResolver propertyResolver;
 	private final SessionProvider sessionProvider;
 	private final Environment environment;
+	private final CommandExecutorGateway executorGateway;
 
 	public DefaultCommandPathVariableResolver(BeanResolverStrategy beanResolver, PropertyResolver propertyResolver) {
 		this.converter = beanResolver.get(CommandMessageConverter.class);
 		this.propertyResolver = propertyResolver;
 		this.sessionProvider = beanResolver.get(SessionProvider.class);
 		this.environment = beanResolver.get(Environment.class);
+		this.executorGateway = beanResolver.find(CommandExecutorGateway.class);
 	}
 
 
@@ -126,6 +137,9 @@ protected String map(Param<?> param, String pathToResolve) {
 		if(StringUtils.startsWithIgnoreCase(pathToResolve, Constants.MARKER_ELEM_ID.code)) 
 			return mapColElem(param, pathToResolve);
 
+		if(StringUtils.startsWithIgnoreCase(pathToResolve, Constants.SEGMENT_PLATFORM_MARKER.code))
+			return String.valueOf(mapCrossDomain(param, pathToResolve));
+
 		return mapQuad(param, pathToResolve);
 	}
 
@@ -149,12 +163,17 @@ protected String mapEnvironment(Param<?> param, String pathToResolve) {
 	protected String mapQuad(Param<?> param, String pathToResolve) {
 		if(StringUtils.startsWith(pathToResolve, "json(")) {
 			String paramPath = StringUtils.substringBetween(pathToResolve, "json(", ")");
-			Param<?> p = param.findParamByPath(paramPath) != null? param.findParamByPath(paramPath): param.getParentModel().findParamByPath(paramPath);
-			if(p == null) {
-				logit.error(() -> new StringBuffer().append(" Param (using paramPath) ").append(paramPath).append(" not found from param reference: ").append(param).toString());
-				return NULL_STRING;
+			Object state;
+			if (StringUtils.startsWithIgnoreCase(paramPath, Constants.SEGMENT_PLATFORM_MARKER.code)) {
+				state = mapCrossDomain(param, paramPath);
+			} else {
+				Param<?> p = param.findParamByPath(paramPath) != null? param.findParamByPath(paramPath): param.getParentModel().findParamByPath(paramPath);
+				if(p == null) {
+					logit.error(() -> new StringBuffer().append(" Param (using paramPath) ").append(paramPath).append(" not found from param reference: ").append(param).toString());
+					return NULL_STRING;
+				}				
+				state = p.getLeafState();
 			}
-			Object state = p.getLeafState();
 			String json = getConverter().toJson(state);
 			return String.valueOf(json);
 		} else {
@@ -179,4 +198,30 @@ protected String mapColElem(Param<?> commandParam, String pathToResolve) {
 		// throw ex ..or.. blank??
 		return "";
 	}
+
+	/**
+	 * 
+	 * @param commandParam
+	 * @param pathToResolve
+	 * @return
+	 * @since 1.1.11
+	 */
+	protected Object mapCrossDomain(Param<?> commandParam, String pathToResolve) {
+		Command rootCmd = commandParam.getRootExecution().getRootCommand();
+		CommandBuilder cmdBuilder = CommandBuilder.withPlatformRelativePath(rootCmd, Type.AppAlias, pathToResolve);
+		cmdBuilder.setAction(Action._get);
+		cmdBuilder.setBehaviors(new LinkedList<>(Arrays.asList(Behavior.$state)));
+		Command cmd = cmdBuilder.getCommand();
+		CommandMessage cmdMsg = new CommandMessage(cmd, null);		
+		MultiOutput output = executorGateway.execute(cmdMsg);
+		Object response = output.getSingleResult();
+
+		if (response == null) {
+			logit.error(() -> new StringBuffer().append(" Param (using paramPath) [").append(pathToResolve).append("] not found from param: ").append(commandParam).toString());
+			return null;
+		}
+
+		logit.debug(() -> new StringBuffer().append(" Param (using paramPath) [").append(pathToResolve).append("] has been resolved to ").append(response).toString());
+		return response;
+	}
 }