com.flowable.serviceregistry.engine.impl.cmd

Class InvokeServiceCmd<T>

java.lang.Object

com.flowable.serviceregistry.engine.impl.cmd.InvokeServiceCmd<T>

All Implemented Interfaces:

Command<T>

Direct Known Subclasses:

InvokeListServiceCmd, InvokeSingleServiceCmd

public abstract class InvokeServiceCmd<T>
extends Object
implements Command<T>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	InvokeServiceCmd.ServiceInvocationArrayResultResponse
static class	InvokeServiceCmd.ServiceInvocationResultResponseImpl
protected static class	InvokeServiceCmd.ValuePresence
protected static class	InvokeServiceCmd.ValueWrapper

Field Summary

Fields

Modifier and Type	Field and Description
protected ServiceInvocationBuilder	serviceInvocationBuilder

Constructor Summary

Constructors

Constructor and Description
InvokeServiceCmd(ServiceInvocationBuilder serviceInvocationBuilder)

Method Summary

Modifier and Type	Method and Description
protected ServiceInvocationResult	convertToServiceInvocationResult(ServiceInvocationResponse invocationResponse, ServiceInvocationResultResponse result)
protected Map<String,Object>	createValidateAndCompleteServiceInvocationInputDataMap(ServiceDefinitionModel serviceDefinitionModel, ServiceOperation serviceOperation, com.fasterxml.jackson.databind.ObjectMapper objectMapper, ExpressionManager expressionManager) Creates, validates and completes the service invocation data according the input parameter definition of the service.
T	execute(CommandContext commandContext)
protected InvokeServiceCmd.ValueWrapper	extractValue(Map<String,Object> responseMap, ServiceOutputParameter outputParameter)
protected InvokeServiceCmd.ValueWrapper	extractValue(com.fasterxml.jackson.databind.node.ObjectNode objectNode, ServiceOutputParameter outputParameter)
protected InvokeServiceCmd.ValueWrapper	extractValue(Object invocationResponse, ServiceOutputParameter outputParameter)
protected Object	getDefaultValue(ServiceOutputParameter outputParameter, String defaultValue, ServiceInvocationContext context, ExpressionManager expressionManager, com.fasterxml.jackson.databind.ObjectMapper objectMapper)
protected Object	getLookupId(ServiceDefinitionModel serviceDefinitionModel, ServiceInvocationResponse invocationResponse, Map<String,Object> resultMap, com.fasterxml.jackson.databind.ObjectMapper objectMapper) Search for the lookup id value in the response according the mapping in the service definition and do proper handling of the response type (e.g.
protected ServiceDefinitionEntity	getServiceDefinition(String tenantId, CommandContext commandContext)
protected ServiceDefinitionModel	getServiceDefinitionModel(ServiceDefinitionEntity serviceDefinition, CommandContext commandContext)
protected ServiceInvoker	getServiceInvoker(ServiceDefinitionModel serviceDefinitionModel, CommandContext commandContext)
protected ServiceOperation	getServiceOperation(ServiceDefinitionModel serviceDefinitionModel)
protected Map<String,Object>	handleOutputParameterValues(Object invocationResponse, ServiceDefinitionModel serviceDefinitionModel, ServiceOperation serviceOperation, ServiceInvocationContext context, ExpressionManager expressionManager, com.fasterxml.jackson.databind.ObjectMapper objectMapper) Verifies and handles output values according the output paramter definition of the service (specially missing and null-value output).
protected ServiceInvocationResultResponse	handleServiceInvocationResponse(ServiceDefinitionModel serviceDefinitionModel, ServiceOperation serviceOperation, ServiceInvoker serviceInvoker, ServiceInvocationContextImpl context, ExpressionManager expressionManager, com.fasterxml.jackson.databind.ObjectMapper objectMapper, ServiceInvocationResponse invocationResponse)
protected abstract T	invoke(ServiceInvoker serviceInvoker, ServiceDefinitionModel serviceDefinitionModel, ServiceOperation serviceOperation, ServiceInvocationContextImpl context, CommandContext commandContext)
protected T	invokeService(ServiceDefinitionModel serviceDefinitionModel, ServiceOperation serviceOperation, ServiceInvoker serviceInvoker, ServiceInvocationContextImpl context, CommandContext commandContext)
protected void	processAndValidateInputParameter(ServiceDefinitionModel serviceDefinitionModel, ServiceInputParameter inputParameter, Map<String,Object> serviceInvocationInputData, com.fasterxml.jackson.databind.ObjectMapper objectMapper, ExpressionManager expressionManager) Internal method to process a single input parameter by looking at its definition and checking its value.
protected ServiceDefinitionEntity	resolveServiceDefinitionByKey(String tenantId, ServiceRegistryEngineConfiguration serviceEngineConfiguration)
protected ServiceDefinitionEntity	resolveServiceDefinitionByReferenceKey(String tenantId, ServiceDefinitionEntityManager serviceDefinitionEntityManager, CommandContext commandContext)
protected void	validateOperationTypeMatchesRequestedType(ServiceOperation operation, String requestedOperationType)
protected void	validateParameters()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

serviceInvocationBuilder

protected ServiceInvocationBuilder serviceInvocationBuilder

Constructor Detail

InvokeServiceCmd

public InvokeServiceCmd(ServiceInvocationBuilder serviceInvocationBuilder)

Method Detail

execute

public T execute(CommandContext commandContext)

Specified by:

execute in interface Command<T>

validateParameters

protected void validateParameters()

createValidateAndCompleteServiceInvocationInputDataMap

protected Map<String,Object> createValidateAndCompleteServiceInvocationInputDataMap(ServiceDefinitionModel serviceDefinitionModel,
                                                                                    ServiceOperation serviceOperation,
                                                                                    com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                                                                    ExpressionManager expressionManager)

Creates, validates and completes the service invocation data according the input parameter definition of the service.

Parameters:

serviceDefinitionModel - the service definition model the invocation is based on

serviceOperation - the service operation representing the service to be invoked

objectMapper - the object mapper used for creating and initializing variable values in JSON

expressionManager - the expression manager used for evaluating default values for input parameters

Returns:

the initialized and validated variable data map

Throws:

FlowableIllegalArgumentException - if the input parameter validation failed (e.g. a required parameter value was missing)

processAndValidateInputParameter

protected void processAndValidateInputParameter(ServiceDefinitionModel serviceDefinitionModel,
                                                ServiceInputParameter inputParameter,
                                                Map<String,Object> serviceInvocationInputData,
                                                com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                                ExpressionManager expressionManager)

Internal method to process a single input parameter by looking at its definition and checking its value. If a required input parameters value is missing and no default one is provided, it will throw an exception.

Parameters:

serviceDefinitionModel - the service definition model the invocation is based on

inputParameter - the input parameter to be processed

serviceInvocationInputData - the service invocation input data map to be validated and completed for the given parameter

objectMapper - the object mapper used for creating and initializing variable values in JSON

expressionManager - the expression manager used for evaluating default values for input parameters

Throws:

FlowableIllegalArgumentException - if the input parameter validation failed (e.g. a required parameter value was missing)

getServiceDefinition

protected ServiceDefinitionEntity getServiceDefinition(String tenantId,
                                                       CommandContext commandContext)

resolveServiceDefinitionByKey

protected ServiceDefinitionEntity resolveServiceDefinitionByKey(String tenantId,
                                                                ServiceRegistryEngineConfiguration serviceEngineConfiguration)

resolveServiceDefinitionByReferenceKey

protected ServiceDefinitionEntity resolveServiceDefinitionByReferenceKey(String tenantId,
                                                                         ServiceDefinitionEntityManager serviceDefinitionEntityManager,
                                                                         CommandContext commandContext)

getServiceDefinitionModel

protected ServiceDefinitionModel getServiceDefinitionModel(ServiceDefinitionEntity serviceDefinition,
                                                           CommandContext commandContext)

getServiceInvoker

protected ServiceInvoker getServiceInvoker(ServiceDefinitionModel serviceDefinitionModel,
                                           CommandContext commandContext)

getServiceOperation

protected ServiceOperation getServiceOperation(ServiceDefinitionModel serviceDefinitionModel)

validateOperationTypeMatchesRequestedType

protected void validateOperationTypeMatchesRequestedType(ServiceOperation operation,
                                                         String requestedOperationType)

invokeService

protected T invokeService(ServiceDefinitionModel serviceDefinitionModel,
                          ServiceOperation serviceOperation,
                          ServiceInvoker serviceInvoker,
                          ServiceInvocationContextImpl context,
                          CommandContext commandContext)

invoke

protected abstract T invoke(ServiceInvoker serviceInvoker,
                            ServiceDefinitionModel serviceDefinitionModel,
                            ServiceOperation serviceOperation,
                            ServiceInvocationContextImpl context,
                            CommandContext commandContext)

handleServiceInvocationResponse

protected ServiceInvocationResultResponse handleServiceInvocationResponse(ServiceDefinitionModel serviceDefinitionModel,
                                                                          ServiceOperation serviceOperation,
                                                                          ServiceInvoker serviceInvoker,
                                                                          ServiceInvocationContextImpl context,
                                                                          ExpressionManager expressionManager,
                                                                          com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                                                          ServiceInvocationResponse invocationResponse)

convertToServiceInvocationResult

protected ServiceInvocationResult convertToServiceInvocationResult(ServiceInvocationResponse invocationResponse,
                                                                   ServiceInvocationResultResponse result)

handleOutputParameterValues

protected Map<String,Object> handleOutputParameterValues(Object invocationResponse,
                                                         ServiceDefinitionModel serviceDefinitionModel,
                                                         ServiceOperation serviceOperation,
                                                         ServiceInvocationContext context,
                                                         ExpressionManager expressionManager,
                                                         com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Verifies and handles output values according the output paramter definition of the service (specially missing and null-value output).

Parameters:

invocationResponse - the response returned by the invoker

serviceDefinitionModel - the service model

serviceOperation - the operation which was invoked

context - the context within which the service was invoked

expressionManager - the expression manager used to resolve default value expressions

objectMapper - the object mapper used to manipulate the output JSON object (if JSON based and not map based)

getDefaultValue

protected Object getDefaultValue(ServiceOutputParameter outputParameter,
                                 String defaultValue,
                                 ServiceInvocationContext context,
                                 ExpressionManager expressionManager,
                                 com.fasterxml.jackson.databind.ObjectMapper objectMapper)

extractValue

protected InvokeServiceCmd.ValueWrapper extractValue(com.fasterxml.jackson.databind.node.ObjectNode objectNode,
                                                     ServiceOutputParameter outputParameter)

extractValue

protected InvokeServiceCmd.ValueWrapper extractValue(Map<String,Object> responseMap,
                                                     ServiceOutputParameter outputParameter)

extractValue

protected InvokeServiceCmd.ValueWrapper extractValue(Object invocationResponse,
                                                     ServiceOutputParameter outputParameter)

getLookupId

protected Object getLookupId(ServiceDefinitionModel serviceDefinitionModel,
                             ServiceInvocationResponse invocationResponse,
                             Map<String,Object> resultMap,
                             com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Search for the lookup id value in the response according the mapping in the service definition and do proper handling of the response type (e.g. JSON vs map).

Parameters:

serviceDefinitionModel - the service definition model where the lookup id mapping is taken from

invocationResponse - the invocation response containing the lookup id field and its value

resultMap - the result map containing the lookup id

objectMapper - the object mapper needed for converting the value

Returns:

the lookup id value, if available, null otherwise