Package io.jmix.dynmodelai.repository

Class ConversationRepository

java.lang.Object

io.jmix.dynmodelai.repository.ConversationRepository

@Component("dmagent_ConversationRepository")
public class ConversationRepository
extends Object

Persistence adapter for conversations and their messages.

Constructor Summary

Constructors

Constructor	Description
ConversationRepository(UnconstrainedDataManager dataManager, TimeSource timeSource, Messages messages)

Method Summary

Modifier and Type	Method	Description
void	appendMessage(UUID conversationId, UUID runId, AgentMessageRole role, String content, String actor)
void	appendMessage(UUID conversationId, UUID runId, AgentMessageRole role, String content, String actor, @Nullable RunOutcome outcome)	outcome marks the assistant message that ended a run.
AgentConversationMessage	appendPublication(UUID conversationId, @Nullable UUID baselineSettingsId, UUID publishedSettingsId, String content, String actor)	The parent lock makes repeated callbacks idempotent across application nodes too.
void	checkConversationExists(UUID conversationId)
org.springframework.data.domain.Page<AgentConversation>	conversationsByLastModifiedDateDesc(org.springframework.data.domain.Pageable pageable)
long	countMessages(UUID conversationId)
AgentConversation	create(String initialMessageText)
Optional<AgentConversation>	findById(UUID conversationId)	Returns an empty Optional when the Conversation does not exist.
RunHistoryLocation	locateRun(UUID runId, int pageSize)
org.springframework.data.domain.Page<AgentConversationMessage>	messagesByCreatedDateAsc(UUID conversationId, org.springframework.data.domain.Pageable pageable)

Methods inherited from class java.lang.Object

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

Constructor Details

ConversationRepository

public ConversationRepository(UnconstrainedDataManager dataManager,
 TimeSource timeSource,
 Messages messages)

Method Details

create

public AgentConversation create(String initialMessageText)

appendMessage

public void appendMessage(UUID conversationId,
 UUID runId,
 AgentMessageRole role,
 String content,
 String actor)
                   throws NoSuchElementException

Throws:

NoSuchElementException - if the Conversation does not exist

appendMessage

public void appendMessage(UUID conversationId,
 UUID runId,
 AgentMessageRole role,
 String content,
 String actor,
 @Nullable RunOutcome outcome)
                   throws NoSuchElementException

outcome marks the assistant message that ended a run.

Throws:

NoSuchElementException - if the Conversation does not exist

conversationsByLastModifiedDateDesc

public org.springframework.data.domain.Page<AgentConversation> conversationsByLastModifiedDateDesc(org.springframework.data.domain.Pageable pageable)

locateRun

public RunHistoryLocation locateRun(UUID runId,
 int pageSize)

findById

public Optional<AgentConversation> findById(UUID conversationId)

Returns an empty Optional when the Conversation does not exist.

checkConversationExists

public void checkConversationExists(UUID conversationId)
                             throws NoSuchElementException

Throws:

NoSuchElementException - if the Conversation does not exist

messagesByCreatedDateAsc

public org.springframework.data.domain.Page<AgentConversationMessage> messagesByCreatedDateAsc(UUID conversationId,
 org.springframework.data.domain.Pageable pageable)
                                                                                        throws NoSuchElementException

Throws:

NoSuchElementException - if the Conversation does not exist

countMessages

public long countMessages(UUID conversationId)

appendPublication

@Transactional
public AgentConversationMessage appendPublication(UUID conversationId,
 @Nullable UUID baselineSettingsId,
 UUID publishedSettingsId,
 String content,
 String actor)

The parent lock makes repeated callbacks idempotent across application nodes too.