Package com.flowable.platform.mcp.serviceregistry

Class McpServiceInvoker

java.lang.Object

com.flowable.platform.mcp.serviceregistry.McpServiceInvoker

All Implemented Interfaces:

ServiceInvoker

public class McpServiceInvoker
extends Object
implements ServiceInvoker

Field Summary

Fields

Modifier and Type	Field	Description
protected Map<String,Map<String,Object>>	globalMcpSettings
protected final tools.jackson.databind.json.JsonMapper	jsonMapper
static final String	KEY
protected final io.modelcontextprotocol.json.McpJsonMapper	mcpJsonMapper
protected final io.modelcontextprotocol.json.schema.JsonSchemaValidator	mcpJsonSchemaValidator
protected final ServiceRegistryEngineConfiguration	serviceRegistryEngineConfiguration

Constructor Summary

Constructors

Constructor	Description
McpServiceInvoker(ServiceRegistryEngineConfiguration serviceRegistryEngineConfiguration, tools.jackson.databind.json.JsonMapper jsonMapper)

Method Summary

Modifier and Type	Method	Description
void	addGlobalMcpSetting(String serviceKey, String key, Object value)
protected Map<String,Object>	buildArguments(ServiceDefinitionModel serviceDefinition, ServiceOperation serviceOperation, ServiceInvocationVariablesContainer variablesContainer)
protected String	collectTextContent(io.modelcontextprotocol.spec.McpSchema.CallToolResult callToolResult)
protected ServiceInvocationResultResponse	convertResult(io.modelcontextprotocol.spec.McpSchema.CallToolResult callToolResult, String toolName, String url)
protected Object	convertToMcpArgument(ServiceInvocationVariablesContainer serviceInvocationVariablesContainer, Object value, ServiceInputParameter inputParameter)
protected io.modelcontextprotocol.client.McpSyncClient	createClient(String url, Map<String,String> authHeaders)
protected String	createExceptionMessage(String prefix, ServiceDefinitionModel serviceDefinitionModel, org.flowable.common.engine.api.variable.VariableContainer variableContainer)
protected ServiceInvocationResultResponse	createResultResponse(tools.jackson.databind.JsonNode resultNode, Map<String,Object> metadata)
protected McpServiceAuthentication	getAuthentication(ServiceDefinitionModel serviceDefinitionModel)
Map<String,Map<String,Object>>	getGlobalMcpSettings()
ServiceInvocationResultResponse	invoke(ServiceDefinitionModel serviceDefinition, ServiceOperation serviceOperation, ServiceInvocationContext serviceInvocationContext)
protected String	lookupStringProperty(ServiceDefinitionModel serviceDefinitionModel, String field, String defaultValue)
protected Map<String,String>	resolveAuthenticationHeaders(ServiceDefinitionModel serviceDefinitionModel, ServiceInvocationVariablesContainer variablesContainer)
protected String	resolveCredentials(McpServiceAuthentication.Credentials credentials, org.flowable.common.engine.impl.el.ExpressionManager expressionManager, ServiceDefinitionModel serviceDefinitionModel, ServiceInvocationVariablesContainer variablesContainer, org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
protected String	resolveExpressionAsString(String value, org.flowable.common.engine.impl.el.ExpressionManager expressionManager, ServiceInvocationVariablesContainer variablesContainer)
protected String	resolveOAuth2ClientToken(String oauth2RegistrationKey, ServiceDefinitionModel serviceDefinitionModel, org.flowable.common.engine.api.variable.VariableContainer variableContainer, org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
protected String	resolveSecret(String secretName, ServiceDefinitionModel serviceDefinitionModel, ServiceInvocationVariablesContainer variablesContainer, org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
protected String	resolveUrl(ServiceDefinitionModel serviceDefinition, ServiceInvocationVariablesContainer variablesContainer)
void	setGlobalMcpSettings(Map<String,Map<String,Object>> globalMcpSettings)
protected tools.jackson.databind.JsonNode	tryParseAsJson(String text)

Methods inherited from class java.lang.Object

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

Field Details

KEY

public static final String KEY

See Also:

• Constant Field Values

serviceRegistryEngineConfiguration

protected final ServiceRegistryEngineConfiguration serviceRegistryEngineConfiguration

jsonMapper

protected final tools.jackson.databind.json.JsonMapper jsonMapper

mcpJsonMapper

protected final io.modelcontextprotocol.json.McpJsonMapper mcpJsonMapper

mcpJsonSchemaValidator

protected final io.modelcontextprotocol.json.schema.JsonSchemaValidator mcpJsonSchemaValidator

globalMcpSettings

protected Map<String,Map<String,Object>> globalMcpSettings

Constructor Details

McpServiceInvoker

public McpServiceInvoker(ServiceRegistryEngineConfiguration serviceRegistryEngineConfiguration,
 tools.jackson.databind.json.JsonMapper jsonMapper)

Method Details

invoke

public ServiceInvocationResultResponse invoke(ServiceDefinitionModel serviceDefinition,
 ServiceOperation serviceOperation,
 ServiceInvocationContext serviceInvocationContext)

Specified by:

invoke in interface ServiceInvoker

resolveUrl

protected String resolveUrl(ServiceDefinitionModel serviceDefinition,
 ServiceInvocationVariablesContainer variablesContainer)

lookupStringProperty

protected String lookupStringProperty(ServiceDefinitionModel serviceDefinitionModel,
 String field,
 String defaultValue)

buildArguments

protected Map<String,Object> buildArguments(ServiceDefinitionModel serviceDefinition,
 ServiceOperation serviceOperation,
 ServiceInvocationVariablesContainer variablesContainer)

convertToMcpArgument

protected Object convertToMcpArgument(ServiceInvocationVariablesContainer serviceInvocationVariablesContainer,
 Object value,
 ServiceInputParameter inputParameter)

createClient

protected io.modelcontextprotocol.client.McpSyncClient createClient(String url,
 Map<String,String> authHeaders)

getAuthentication

protected McpServiceAuthentication getAuthentication(ServiceDefinitionModel serviceDefinitionModel)

resolveAuthenticationHeaders

protected Map<String,String> resolveAuthenticationHeaders(ServiceDefinitionModel serviceDefinitionModel,
 ServiceInvocationVariablesContainer variablesContainer)

resolveCredentials

protected String resolveCredentials(McpServiceAuthentication.Credentials credentials,
 org.flowable.common.engine.impl.el.ExpressionManager expressionManager,
 ServiceDefinitionModel serviceDefinitionModel,
 ServiceInvocationVariablesContainer variablesContainer,
 org.flowable.common.engine.impl.interceptor.CommandContext commandContext)

resolveSecret

protected String resolveSecret(String secretName,
 ServiceDefinitionModel serviceDefinitionModel,
 ServiceInvocationVariablesContainer variablesContainer,
 org.flowable.common.engine.impl.interceptor.CommandContext commandContext)

resolveOAuth2ClientToken

protected String resolveOAuth2ClientToken(String oauth2RegistrationKey,
 ServiceDefinitionModel serviceDefinitionModel,
 org.flowable.common.engine.api.variable.VariableContainer variableContainer,
 org.flowable.common.engine.impl.interceptor.CommandContext commandContext)

resolveExpressionAsString

protected String resolveExpressionAsString(String value,
 org.flowable.common.engine.impl.el.ExpressionManager expressionManager,
 ServiceInvocationVariablesContainer variablesContainer)

createExceptionMessage

protected String createExceptionMessage(String prefix,
 ServiceDefinitionModel serviceDefinitionModel,
 org.flowable.common.engine.api.variable.VariableContainer variableContainer)

convertResult

protected ServiceInvocationResultResponse convertResult(io.modelcontextprotocol.spec.McpSchema.CallToolResult callToolResult,
 String toolName,
 String url)

createResultResponse

protected ServiceInvocationResultResponse createResultResponse(tools.jackson.databind.JsonNode resultNode,
 Map<String,Object> metadata)

collectTextContent

protected String collectTextContent(io.modelcontextprotocol.spec.McpSchema.CallToolResult callToolResult)

tryParseAsJson

protected tools.jackson.databind.JsonNode tryParseAsJson(String text)

getGlobalMcpSettings

public Map<String,Map<String,Object>> getGlobalMcpSettings()

setGlobalMcpSettings

public void setGlobalMcpSettings(Map<String,Map<String,Object>> globalMcpSettings)

addGlobalMcpSetting

public void addGlobalMcpSetting(String serviceKey,
 String key,
 Object value)