Package com.flowable.agent.engine.impl.model.chatclient

Class SpringChatClientAiModelInvoker

java.lang.Object

com.flowable.agent.engine.impl.model.chatclient.SpringChatClientAiModelInvoker

All Implemented Interfaces:

AiModelInvoker

public class SpringChatClientAiModelInvoker
extends Object
implements AiModelInvoker

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	SpringChatClientAiModelInvoker.ToolCollector

Field Summary

Fields

Modifier and Type	Field	Description
static final String	AGENT_INSTANCE_EXCHANGE_PART_ID
protected final AgentEngineConfiguration	agentEngineConfiguration
protected final org.springframework.ai.chat.client.ChatClient	chatClient

Constructor Summary

Constructors

Constructor	Description
SpringChatClientAiModelInvoker(org.springframework.ai.chat.client.ChatClient chatClient, AgentEngineConfiguration engineConfiguration)

Method Summary

Modifier and Type	Method	Description
protected void	addPreviousChatExchanges(AgentInvocationContext agentInvocationContext, org.springframework.ai.chat.client.ChatClient.ChatClientRequestSpec prompt)
protected void	applyTools(AgentInvocationContext agentInvocationContext, AgentEngineConfiguration agentEngineConfiguration, org.springframework.ai.model.tool.ToolCallingChatOptions.Builder optionsBuilder)
protected int	determineMaxNumberOfPreviousExchanges(AgentInvocationContext agentInvocationContext)
protected org.springframework.ai.chat.client.ResponseEntity<org.springframework.ai.chat.model.ChatResponse,AgentInvocationResult>	executeCallAndHandleOutput(AgentInvocationContext agentInvocationContext, org.springframework.ai.chat.client.ChatClient.ChatClientRequestSpec prompt)
protected org.springframework.ai.converter.StructuredOutputConverter<com.fasterxml.jackson.databind.JsonNode>	getOutputConverter(AgentInvocationContext agentInvocationContext)
protected List<AgentInvocationExchangePart>	getPageOfExchangeParts(AgentInvocationContext agentInvocationContext)
protected void	handleUserAndSystemPrompts(AgentInvocationContext agentInvocationContext, org.springframework.ai.chat.client.ChatClient.ChatClientRequestSpec prompt)
AgentInvocationResultResponse	invoke(AgentInvocationContext agentInvocationContext)
protected AgentInvocationResultResponseImpl	processChatResponse(FlowableSpringChatClientObservationContext observationContext)
protected static void	processExchanges(FlowableSpringChatClientObservationContext.ObservationExchange exchange, Consumer<FlowableSpringChatClientObservationContext.ObservationExchange> consumer)
protected List<org.springframework.ai.tool.ToolCallback>	resolveModelAndOperationToolCallbacks(AgentInvocationContext agentInvocationContext)

Methods inherited from class java.lang.Object

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

Field Details

AGENT_INSTANCE_EXCHANGE_PART_ID

public static final String AGENT_INSTANCE_EXCHANGE_PART_ID

See Also:

• Constant Field Values

chatClient

protected final org.springframework.ai.chat.client.ChatClient chatClient

agentEngineConfiguration

protected final AgentEngineConfiguration agentEngineConfiguration

Constructor Details

SpringChatClientAiModelInvoker

public SpringChatClientAiModelInvoker(org.springframework.ai.chat.client.ChatClient chatClient,
 AgentEngineConfiguration engineConfiguration)

Method Details

invoke

public AgentInvocationResultResponse invoke(AgentInvocationContext agentInvocationContext)

Specified by:

invoke in interface AiModelInvoker

processChatResponse

protected AgentInvocationResultResponseImpl processChatResponse(FlowableSpringChatClientObservationContext observationContext)

applyTools

protected void applyTools(AgentInvocationContext agentInvocationContext,
 AgentEngineConfiguration agentEngineConfiguration,
 org.springframework.ai.model.tool.ToolCallingChatOptions.Builder optionsBuilder)

resolveModelAndOperationToolCallbacks

protected List<org.springframework.ai.tool.ToolCallback> resolveModelAndOperationToolCallbacks(AgentInvocationContext agentInvocationContext)

handleUserAndSystemPrompts

protected void handleUserAndSystemPrompts(AgentInvocationContext agentInvocationContext,
 org.springframework.ai.chat.client.ChatClient.ChatClientRequestSpec prompt)

addPreviousChatExchanges

protected void addPreviousChatExchanges(AgentInvocationContext agentInvocationContext,
 org.springframework.ai.chat.client.ChatClient.ChatClientRequestSpec prompt)

getPageOfExchangeParts

protected List<AgentInvocationExchangePart> getPageOfExchangeParts(AgentInvocationContext agentInvocationContext)

determineMaxNumberOfPreviousExchanges

protected int determineMaxNumberOfPreviousExchanges(AgentInvocationContext agentInvocationContext)

getOutputConverter

protected org.springframework.ai.converter.StructuredOutputConverter<com.fasterxml.jackson.databind.JsonNode> getOutputConverter(AgentInvocationContext agentInvocationContext)

executeCallAndHandleOutput

protected org.springframework.ai.chat.client.ResponseEntity<org.springframework.ai.chat.model.ChatResponse,AgentInvocationResult> executeCallAndHandleOutput(AgentInvocationContext agentInvocationContext,
 org.springframework.ai.chat.client.ChatClient.ChatClientRequestSpec prompt)

processExchanges

protected static void processExchanges(FlowableSpringChatClientObservationContext.ObservationExchange exchange,
 Consumer<FlowableSpringChatClientObservationContext.ObservationExchange> consumer)