Package com.flowable.agent.engine.impl.util

Class AgentUtil

java.lang.Object

com.flowable.agent.engine.impl.util.AgentUtil

public class AgentUtil
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	AGENT_COMPLETED_SIGNAL_NAME
static final String	AGENT_INVOCATION_RESULT_TRANSIENT_VARIABLE_NAME
static final String	AGENT_SIGNAL_TRANSIENT_VARIABLE_NAME
protected static final Collection<String>	DEFAULT_SUPPORTED_MIME_TYPES
static final String	EXTENSION_ELEMENT_AGENT_ASYNC

Constructor Summary

Constructors

Constructor	Description
AgentUtil()

Method Summary

Modifier and Type	Method	Description
static AgentInvocationEntity	auditAiInvocation(AgentEngineConfiguration engineConfiguration, AgentInstance agentInstance, String agentInvocationId, AgentInvocationResultResponse.Invocation aiInvocation, String userId, boolean storeAsHumanContent)
static AgentInvocationEntity	auditAiInvocation(AgentEngineConfiguration engineConfiguration, AgentInvocationContext agentInvocationContext, AgentInvocationResultResponse.Invocation aiInvocation, boolean storeAsHumanContent)
protected static Date	calculateDueDate(org.flowable.common.engine.impl.runtime.Clock clock, int initialRetryCount, Duration retryTimeout)
protected static void	createAgentEngineTimerJob(AgentEngineConfiguration agentEngineConfiguration, String jobHandlerType, String scopeId, String tenantId, String subScopeId, com.fasterxml.jackson.databind.JsonNode jobConfiguration, Duration retryTimeout)
static void	createAsyncJob(AgentEngineConfiguration agentEngineConfiguration, AgentInstance agentInstance, String jobHandlerType, com.fasterxml.jackson.databind.JsonNode jobConfiguration, boolean exclusive)
static void	createAsyncJob(AgentEngineConfiguration agentEngineConfiguration, String agentInstanceId, String tenantId, String jobHandlerType, com.fasterxml.jackson.databind.JsonNode jobConfiguration, boolean exclusive)
protected static org.flowable.common.engine.api.delegate.Expression	createExpression(String expression, AgentEngineConfiguration agentEngineConfiguration)
static String	getAgentDefinitionKey(org.flowable.cmmn.model.CmmnModel cmmnModel)
static AgentDefinitionModel.AgentOperation	getOperation(AgentDefinitionModel agentDefinitionModel, String operationKey)
protected static String	getPromptMessage(AgentEngineConfiguration agentEngineConfiguration, AgentDefinitionModel.AgentBehavior behavior, String getParentDeploymentId, org.flowable.common.engine.api.variable.VariableContainer variableContainer, Function<AgentDefinitionModel.AgentBehavior,String> messageStringSupplier, Function<AgentDefinitionModel.AgentBehavior,AgentDefinitionModel.TemplateReference> messageTemplateSupplier)
static Collection<String>	getSupportedMimeTypes(AgentDefinitionModel agentDefinitionModel)
static String	getSystemMessage(AgentEngineConfiguration agentEngineConfiguration, AgentDefinitionModel.AgentOperation agentOperation, String getParentDeploymentId, org.flowable.common.engine.api.variable.VariableContainer variableContainer)
static String	getUserMessage(AgentEngineConfiguration agentEngineConfiguration, AgentDefinitionModel.AgentOperation agentOperation, String getParentDeploymentId, org.flowable.common.engine.api.variable.VariableContainer variableContainer)
static void	handleAgentInstanceCallback(AgentInstance agentInstance, AgentInvocationResult agentInvocationResult, org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
static void	handleAgentInstanceCallback(String callbackId, String callbackType, AgentInvocationResult agentInvocationResult, org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
static void	handleAgentInvocationResponse(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, AgentInvocationContext agentInvocationContext, AgentInstanceEntity agentInstance, AgentInvocationResultResponse resultResponse, boolean storeInteractionsAsHumanContent)
static boolean	hasDefaultBehavior(AgentDefinitionModel.AgentOperation agentOperation)
protected static AgentInvocationEntity	processExchangeMessages(AgentEngineConfiguration agentEngineConfiguration, AgentInvocationContext agentInvocationContext, boolean storeInteractionsAsHumanContent, AgentInvocationResultResponse resultResponse)
protected static String	resolveTemplate(AgentDefinitionModel.TemplateReference templateReference, String getParentDeploymentId, org.flowable.common.engine.api.variable.VariableContainer variableContainer)
static void	scheduleTriggerJobIfNeeded(AgentInstance agentInstance, org.flowable.common.engine.impl.interceptor.CommandContext commandContext, String customValues)
static void	scheduleTriggerJobIfNeeded(AgentInstance agentInstance, org.flowable.common.engine.impl.interceptor.CommandContext commandContext, String jobHandlerType, String configuration, String customValues)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_SUPPORTED_MIME_TYPES

protected static final Collection<String> DEFAULT_SUPPORTED_MIME_TYPES

AGENT_INVOCATION_RESULT_TRANSIENT_VARIABLE_NAME

public static final String AGENT_INVOCATION_RESULT_TRANSIENT_VARIABLE_NAME

See Also:

• Constant Field Values

AGENT_SIGNAL_TRANSIENT_VARIABLE_NAME

public static final String AGENT_SIGNAL_TRANSIENT_VARIABLE_NAME

See Also:

• Constant Field Values

EXTENSION_ELEMENT_AGENT_ASYNC

public static final String EXTENSION_ELEMENT_AGENT_ASYNC

See Also:

• Constant Field Values

AGENT_COMPLETED_SIGNAL_NAME

public static final String AGENT_COMPLETED_SIGNAL_NAME

See Also:

• Constant Field Values

Constructor Details

AgentUtil

public AgentUtil()

Method Details

getAgentDefinitionKey

public static String getAgentDefinitionKey(org.flowable.cmmn.model.CmmnModel cmmnModel)

getUserMessage

public static String getUserMessage(AgentEngineConfiguration agentEngineConfiguration,
 AgentDefinitionModel.AgentOperation agentOperation,
 String getParentDeploymentId,
 org.flowable.common.engine.api.variable.VariableContainer variableContainer)

getSystemMessage

public static String getSystemMessage(AgentEngineConfiguration agentEngineConfiguration,
 AgentDefinitionModel.AgentOperation agentOperation,
 String getParentDeploymentId,
 org.flowable.common.engine.api.variable.VariableContainer variableContainer)

getPromptMessage

protected static String getPromptMessage(AgentEngineConfiguration agentEngineConfiguration,
 AgentDefinitionModel.AgentBehavior behavior,
 String getParentDeploymentId,
 org.flowable.common.engine.api.variable.VariableContainer variableContainer,
 Function<AgentDefinitionModel.AgentBehavior,String> messageStringSupplier,
 Function<AgentDefinitionModel.AgentBehavior,AgentDefinitionModel.TemplateReference> messageTemplateSupplier)

resolveTemplate

protected static String resolveTemplate(AgentDefinitionModel.TemplateReference templateReference,
 String getParentDeploymentId,
 org.flowable.common.engine.api.variable.VariableContainer variableContainer)

createExpression

protected static org.flowable.common.engine.api.delegate.Expression createExpression(String expression,
 AgentEngineConfiguration agentEngineConfiguration)

getOperation

public static AgentDefinitionModel.AgentOperation getOperation(AgentDefinitionModel agentDefinitionModel,
 String operationKey)

hasDefaultBehavior

public static boolean hasDefaultBehavior(AgentDefinitionModel.AgentOperation agentOperation)

getSupportedMimeTypes

public static Collection<String> getSupportedMimeTypes(AgentDefinitionModel agentDefinitionModel)

handleAgentInvocationResponse

public static void handleAgentInvocationResponse(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
 AgentInvocationContext agentInvocationContext,
 AgentInstanceEntity agentInstance,
 AgentInvocationResultResponse resultResponse,
 boolean storeInteractionsAsHumanContent)

auditAiInvocation

public static AgentInvocationEntity auditAiInvocation(AgentEngineConfiguration engineConfiguration,
 AgentInvocationContext agentInvocationContext,
 AgentInvocationResultResponse.Invocation aiInvocation,
 boolean storeAsHumanContent)

auditAiInvocation

public static AgentInvocationEntity auditAiInvocation(AgentEngineConfiguration engineConfiguration,
 AgentInstance agentInstance,
 String agentInvocationId,
 AgentInvocationResultResponse.Invocation aiInvocation,
 String userId,
 boolean storeAsHumanContent)

processExchangeMessages

protected static AgentInvocationEntity processExchangeMessages(AgentEngineConfiguration agentEngineConfiguration,
 AgentInvocationContext agentInvocationContext,
 boolean storeInteractionsAsHumanContent,
 AgentInvocationResultResponse resultResponse)

createAgentEngineTimerJob

protected static void createAgentEngineTimerJob(AgentEngineConfiguration agentEngineConfiguration,
 String jobHandlerType,
 String scopeId,
 String tenantId,
 String subScopeId,
 com.fasterxml.jackson.databind.JsonNode jobConfiguration,
 Duration retryTimeout)

calculateDueDate

protected static Date calculateDueDate(org.flowable.common.engine.impl.runtime.Clock clock,
 int initialRetryCount,
 Duration retryTimeout)

handleAgentInstanceCallback

public static void handleAgentInstanceCallback(AgentInstance agentInstance,
 AgentInvocationResult agentInvocationResult,
 org.flowable.common.engine.impl.interceptor.CommandContext commandContext)

handleAgentInstanceCallback

public static void handleAgentInstanceCallback(String callbackId,
 String callbackType,
 AgentInvocationResult agentInvocationResult,
 org.flowable.common.engine.impl.interceptor.CommandContext commandContext)

createAsyncJob

public static void createAsyncJob(AgentEngineConfiguration agentEngineConfiguration,
 AgentInstance agentInstance,
 String jobHandlerType,
 com.fasterxml.jackson.databind.JsonNode jobConfiguration,
 boolean exclusive)

createAsyncJob

public static void createAsyncJob(AgentEngineConfiguration agentEngineConfiguration,
 String agentInstanceId,
 String tenantId,
 String jobHandlerType,
 com.fasterxml.jackson.databind.JsonNode jobConfiguration,
 boolean exclusive)

scheduleTriggerJobIfNeeded

public static void scheduleTriggerJobIfNeeded(AgentInstance agentInstance,
 org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
 String customValues)

scheduleTriggerJobIfNeeded

public static void scheduleTriggerJobIfNeeded(AgentInstance agentInstance,
 org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
 String jobHandlerType,
 String configuration,
 String customValues)