Package io.jmix.dynmodelai.agent.runtime

Class AgentRunCoordinator

java.lang.Object

io.jmix.dynmodelai.agent.runtime.AgentRunCoordinator

@Component("dmagent_AgentRunCoordinator")
public class AgentRunCoordinator
extends Object

Conversation commands own state; Embabel runs outside their serial queue.

Constructor Summary

Constructors

Constructor	Description
AgentRunCoordinator(AgentRunWorker worker, ModelDraftService draftService, ConversationRepository conversations, AgentEventStreams events, AgentPlanDetailsMapper planMapper, ConversationCommands commands, PlanningMessages planningMessages, CurrentAuthentication currentAuthentication, Messages messages, ConversationSessions sessions, ModelPresentationComposer presentation)

Method Summary

Modifier and Type	Method	Description
AgentRun	answerHumanInput(AnswerHumanInputRequest request, String actor)
void	approvePlan(ApprovePlanRequest request)
boolean	cancelRun(CancelRunRequest request)
void	closeConversationSession(UUID conversationId)
boolean	closeIdleConversationSession(UUID conversationId, Instant idleSince)
boolean	isRunActive(AgentRun run)
reactor.core.publisher.Flux<AgentEvent>	streamEvents(AgentEventsRequest request)
AgentRun	submitMessage(SubmitMessageRequest request, String actor)

Methods inherited from class java.lang.Object

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

Constructor Details

AgentRunCoordinator

public AgentRunCoordinator(AgentRunWorker worker,
 ModelDraftService draftService,
 ConversationRepository conversations,
 AgentEventStreams events,
 AgentPlanDetailsMapper planMapper,
 ConversationCommands commands,
 PlanningMessages planningMessages,
 CurrentAuthentication currentAuthentication,
 Messages messages,
 ConversationSessions sessions,
 ModelPresentationComposer presentation)

Method Details

submitMessage

public AgentRun submitMessage(SubmitMessageRequest request,
 String actor)

answerHumanInput

public AgentRun answerHumanInput(AnswerHumanInputRequest request,
 String actor)

isRunActive

public boolean isRunActive(AgentRun run)

approvePlan

public void approvePlan(ApprovePlanRequest request)

streamEvents

public reactor.core.publisher.Flux<AgentEvent> streamEvents(AgentEventsRequest request)

cancelRun

public boolean cancelRun(CancelRunRequest request)

closeConversationSession

public void closeConversationSession(UUID conversationId)

closeIdleConversationSession

public boolean closeIdleConversationSession(UUID conversationId,
 Instant idleSince)