Package io.jmix.aitoolsflowuidata.service.impl

Class AiChatDataService

java.lang.Object

io.jmix.aitoolsflowuidata.service.impl.AiChatDataService

All Implemented Interfaces:

AiChatService, org.springframework.beans.factory.InitializingBean

public class AiChatDataService
extends Object
implements AiChatService, org.springframework.beans.factory.InitializingBean

Default AiChatService. For an already-persisted user message it:

1. loads the conversation history, windowed by jmix.aitools.ui.data.chat-memory-max-messages;
2. creates an empty ASSISTANT placeholder message;
3. invokes the chat client with that history;
4. writes the reply into the placeholder, or removes it if the call fails.

The optional status callback is delivered to tools via AiToolStatusPublisher for ephemeral progress messages.

Field Summary

Fields

Modifier and Type	Field	Description
protected AiToolRegistry	aiToolRegistry
protected static final String	ASSISTANT_MESSAGE_ID_KEY
protected @Nullable org.springframework.ai.chat.client.ChatClient	chatClient
protected ChatClientFactory	chatClientFactory
protected CurrentUserSubstitution	currentUserSubstitution
protected UnconstrainedDataManager	dataManager
protected AiToolsFlowuiDataProperties	dataProperties
protected ResponseLanguageProvider	responseLanguageProvider
protected AiChatSystemPromptProvider	systemPromptProvider

Constructor Summary

Constructors

Constructor	Description
AiChatDataService()

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
protected org.springframework.ai.chat.client.ChatClient.ChatClientRequestSpec	buildPromptSpec(List<org.springframework.ai.chat.messages.Message> history, UUID assistantMessageId, @Nullable Consumer<AiToolStatusUpdate> statusCallback)
protected void	checkChatClient()
protected AiChatMessageEntity	createAssistantPlaceholder(AiConversationEntity conversation)
protected String	currentUsername()
boolean	isAvailable()	Returns whether AI chat is currently available, i.e.
protected List<org.springframework.ai.chat.messages.Message>	loadHistory(UUID conversationId)
protected List<AiChatMessageEntity>	loadRecentMessages(UUID conversationId, int limit)
protected AiChatMessageEntity	loadUserMessage(UUID userMessageId)
protected org.springframework.ai.chat.messages.Message	mapEntityToMessage(AiChatMessageEntity chatMessage)
protected @Nullable String	process(UUID userMessageId, @Nullable Consumer<AiToolStatusUpdate> statusCallback)
String	processMessage(AiChatMessage message)	Generates the assistant's reply to the given user message.
String	processMessage(AiChatMessage message, @Nullable Consumer<AiToolStatusUpdate> statusCallback)	Generates the assistant's reply to the given user message, reporting progress while the reply is being prepared.
protected String	processMessageInternal(AiChatMessage message, @Nullable Consumer<AiToolStatusUpdate> statusCallback)
protected void	removeAssistantPlaceholderSafely(AiChatMessageEntity placeholder)
protected String	resolveResponseLanguage()
protected void	saveAssistantResponse(AiChatMessageEntity placeholder, @Nullable String response)

Methods inherited from class java.lang.Object

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

Field Details

ASSISTANT_MESSAGE_ID_KEY

protected static final String ASSISTANT_MESSAGE_ID_KEY

See Also:

• Constant Field Values

chatClientFactory

@Autowired
protected ChatClientFactory chatClientFactory

aiToolRegistry

@Autowired
protected AiToolRegistry aiToolRegistry

systemPromptProvider

@Autowired
protected AiChatSystemPromptProvider systemPromptProvider

responseLanguageProvider

@Autowired
protected ResponseLanguageProvider responseLanguageProvider

dataManager

@Autowired
protected UnconstrainedDataManager dataManager

dataProperties

@Autowired
protected AiToolsFlowuiDataProperties dataProperties

currentUserSubstitution

@Autowired
protected CurrentUserSubstitution currentUserSubstitution

chatClient

protected @Nullable org.springframework.ai.chat.client.ChatClient chatClient

Constructor Details

AiChatDataService

public AiChatDataService()

Method Details

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

isAvailable

public boolean isAvailable()

Description copied from interface: AiChatService

Returns whether AI chat is currently available, i.e. replies can be generated.

Specified by:

isAvailable in interface AiChatService

Returns:

true if chat is configured and ready to use

processMessage

public String processMessage(AiChatMessage message)

Description copied from interface: AiChatService

Generates the assistant's reply to the given user message.

Specified by:

processMessage in interface AiChatService

Parameters:

message - the user message to answer

Returns:

the assistant's reply text, or an empty string if no reply was produced

processMessage

public String processMessage(AiChatMessage message,
 @Nullable Consumer<AiToolStatusUpdate> statusCallback)

Description copied from interface: AiChatService

Generates the assistant's reply to the given user message, reporting progress while the reply is being prepared.

Specified by:

processMessage in interface AiChatService

Parameters:

message - the user message to answer

statusCallback - receives progress updates during processing

Returns:

the assistant's reply text, or an empty string if no reply was produced

processMessageInternal

protected String processMessageInternal(AiChatMessage message,
 @Nullable Consumer<AiToolStatusUpdate> statusCallback)

process

protected @Nullable String process(UUID userMessageId,
 @Nullable Consumer<AiToolStatusUpdate> statusCallback)

buildPromptSpec

protected org.springframework.ai.chat.client.ChatClient.ChatClientRequestSpec buildPromptSpec(List<org.springframework.ai.chat.messages.Message> history,
 UUID assistantMessageId,
 @Nullable Consumer<AiToolStatusUpdate> statusCallback)

loadUserMessage

protected AiChatMessageEntity loadUserMessage(UUID userMessageId)

currentUsername

protected String currentUsername()

loadHistory

protected List<org.springframework.ai.chat.messages.Message> loadHistory(UUID conversationId)

loadRecentMessages

protected List<AiChatMessageEntity> loadRecentMessages(UUID conversationId,
 int limit)

mapEntityToMessage

protected org.springframework.ai.chat.messages.Message mapEntityToMessage(AiChatMessageEntity chatMessage)

createAssistantPlaceholder

protected AiChatMessageEntity createAssistantPlaceholder(AiConversationEntity conversation)

saveAssistantResponse

protected void saveAssistantResponse(AiChatMessageEntity placeholder,
 @Nullable String response)

removeAssistantPlaceholderSafely

protected void removeAssistantPlaceholderSafely(AiChatMessageEntity placeholder)

resolveResponseLanguage

protected String resolveResponseLanguage()

checkChatClient

protected void checkChatClient()