// Copyright (c) Microsoft. All rights reserved. using System.Linq; using System.Threading.Tasks; using Microsoft.Agents.AI.Workflows.Declarative.Extensions; using Microsoft.Agents.AI.Workflows.Declarative.ObjectModel; using Microsoft.Agents.ObjectModel; using Microsoft.Extensions.AI; namespace Microsoft.Agents.AI.Workflows.Declarative.UnitTests.ObjectModel; /// /// Tests for . /// public sealed class RetrieveConversationMessageExecutorTest(ITestOutputHelper output) : WorkflowActionExecutorTest(output) { [Fact] public async Task RetrieveMessageSuccessfullyAsync() { // Arrange, Act, Assert await this.ExecuteTestAsync(nameof(RetrieveMessageSuccessfullyAsync), "TestMessage"); } private async Task ExecuteTestAsync( string displayName, string variableName) { // Arrange MockAgentProvider mockAgentProvider = new(); RetrieveConversationMessage model = this.CreateModel( this.FormatDisplayName(displayName), FormatVariablePath(variableName), "TestConversationId", "DefaultMessageId"); RetrieveConversationMessageExecutor action = new(model, mockAgentProvider.Object, this.State); // Act await this.ExecuteAsync(action); // Assert ChatMessage? testMessage = mockAgentProvider.TestMessages?.FirstOrDefault(); Assert.NotNull(testMessage); VerifyModel(model, action); this.VerifyState(variableName, testMessage.ToRecord()); } private RetrieveConversationMessage CreateModel( string displayName, string messageVariable, string conversationId, string messageId) { RetrieveConversationMessage.Builder actionBuilder = new() { Id = this.CreateActionId(), DisplayName = this.FormatDisplayName(displayName), Message = PropertyPath.Create(messageVariable), ConversationId = StringExpression.Literal(conversationId), MessageId = StringExpression.Literal(messageId) }; return AssignParent(actionBuilder); } }