Files
Dmytro Struk 67a8147151 .NET: Python: Azure Functions feature branch (#1916)
* Python: Add Scaffolding for Durable AzureFunctions package to Agent Framework (#1823)

* Add scafolding

* update readme

* add code owners and label

* update owners

* .NET: Durable extension: initial src and unit tests (#1900)

* Python: Add Durable Agent Wrapper code (#1913)

* add initial changes

* Move code and add single sample

* Update logger

* Remove unused code

* address PR comments

* cleanup code and address comments

---------

Co-authored-by: Dmytro Struk <13853051+dmytrostruk@users.noreply.github.com>

* Azure Functions .NET samples (#1939)

* Python: Add Unit tests for Azurefunctions package (#1976)

* Add Unit tests for Azurefunctions

* remove duplicate import

* .NET: [Feature Branch] Migrate state schema updates and support for agents as MCP tools (#1979)

* Python: Add more samples for Azure Functions (#1980)

* Move all samples

* fix comments

* remove dead lines

* Make samples simpler

* .NET: [Feature Branch] Durable Task extension integration tests (#2017)

* .NET: [Feature Branch] Update OpenAI config for integration tests (#2063)

* Python: Add Integration tests for AzureFunctions  (#2020)

* Add Integration tests

* Remove DTS extension

* Apply suggestions from code review

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Apply suggestions from code review

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Add pyi file for type safety

* Add samples in readme

* Updated all readme instructions

* Address comments

* Update readmes

* Fix requirements

* Address comments

---------

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* .NET: [Feature Branch] Update dotnet-build-and-test.yml to support integration tests (#2070)

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Fix DTS startup issue and improve logging (#2103)

* .NET: [Feature Branch] Introduce Azure OpenAI config for .NET pipeline (#2106)

Also fixes an issue where we were trying to start docker containers for integration tests on Windows, which doesn't work.

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Fix uv.lock after merge

* Python: Add README for Azure Functions samples setup (#2100)

* Add README for Azure Functions samples setup

Added setup instructions for Azure Functions samples, including environment setup, virtual environment creation, and running samples.

* Update python/samples/getting_started/azure_functions/README.md

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Apply suggestions from code review

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Apply suggestion from @Copilot

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Apply suggestions from code review

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

---------

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
Co-authored-by: Laveesh Rohra <larohra@microsoft.com>

* Fix or remove broken markdown file links (#2115)

* .NET: [Feature Branch] Update HTTP API to be consistent across languages (#2118)

* Python: Fix AzureFunctions Integration Tests (#2116)

* Add Identity Auth to samples

* Update python/samples/getting_started/azure_functions/README.md

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Update python/samples/getting_started/azure_functions/01_single_agent/function_app.py

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Update python/samples/getting_started/azure_functions/02_multi_agent/function_app.py

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Update python/samples/getting_started/azure_functions/06_multi_agent_orchestration_conditionals/README.md

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

---------

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Python: Fix Http Schema (#2112)

* Rename to threadid

* Respond in plain text

* Make snake-case

* Add http prefix

* rename to wait-for-response

* Add query param check

* address comments

* .NET: Remove IsPackable=false in preparation for nuget release (#2142)

* Python: Move `azurefunctions` to `azure` for import (#2141)

* Move import to Azure

* fix mypy

* Update python/packages/azurefunctions/README.md

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Add missing types

* Address comments

---------

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Update python/packages/azurefunctions/pyproject.toml

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Update python/packages/azurefunctions/agent_framework_azurefunctions/__init__.py

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Fix imports

* Address PR feedback from westey-m (#2150)

- Adds a link from the /dotnet/samples/README.md to /dotnet/samples/AzureFunctions
- Make DurableAgentThread deserialization internal for future-proofing
- Update JSON serialization logic to address recently discovered issues with source generator serialization

* Address comments (#2160)

---------

Co-authored-by: Laveesh Rohra <larohra@microsoft.com>
Co-authored-by: Chris Gillum <cgillum@microsoft.com>
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
Co-authored-by: Anirudh Garg <anirudhg@microsoft.com>
2025-11-13 02:00:53 +00:00

325 lines
12 KiB
C#

// Copyright (c) Microsoft. All rights reserved.
using System.Text.Json;
using System.Text.Json.Serialization.Metadata;
using Microsoft.Agents.AI.DurableTask.State;
using Microsoft.Extensions.AI;
namespace Microsoft.Agents.AI.DurableTask.Tests.Unit.State;
public sealed class DurableAgentStateContentTests
{
private static readonly JsonTypeInfo s_stateContentTypeInfo =
DurableAgentStateJsonContext.Default.GetTypeInfo(typeof(DurableAgentStateContent))!;
[Fact]
public void ErrorContentSerializationDeserialization()
{
// Arrange
ErrorContent errorContent = new("message")
{
Details = "details",
ErrorCode = "code"
};
DurableAgentStateContent durableContent = DurableAgentStateContent.FromAIContent(errorContent);
// Act
string jsonContent = JsonSerializer.Serialize(durableContent, s_stateContentTypeInfo);
DurableAgentStateContent? convertedJsonContent =
(DurableAgentStateContent?)JsonSerializer.Deserialize(jsonContent, s_stateContentTypeInfo);
// Assert
Assert.NotNull(convertedJsonContent);
AIContent convertedContent = convertedJsonContent.ToAIContent();
ErrorContent convertedErrorContent = Assert.IsType<ErrorContent>(convertedContent);
Assert.Equal(errorContent.Message, convertedErrorContent.Message);
Assert.Equal(errorContent.Details, convertedErrorContent.Details);
Assert.Equal(errorContent.ErrorCode, convertedErrorContent.ErrorCode);
}
[Fact]
public void TextContentSerializationDeserialization()
{
// Arrange
TextContent textContent = new("Hello, world!");
DurableAgentStateContent durableContent = DurableAgentStateContent.FromAIContent(textContent);
// Act
string jsonContent = JsonSerializer.Serialize(durableContent, s_stateContentTypeInfo);
DurableAgentStateContent? convertedJsonContent =
(DurableAgentStateContent?)JsonSerializer.Deserialize(jsonContent, s_stateContentTypeInfo);
// Assert
Assert.NotNull(convertedJsonContent);
AIContent convertedContent = convertedJsonContent.ToAIContent();
TextContent convertedTextContent = Assert.IsType<TextContent>(convertedContent);
Assert.Equal(textContent.Text, convertedTextContent.Text);
}
[Fact]
public void FunctionCallContentSerializationDeserialization()
{
// Arrange
FunctionCallContent functionCallContent = new(
"call-123",
"MyFunction",
new Dictionary<string, object?>
{
{ "param1", 42 },
{ "param2", "value" }
});
DurableAgentStateContent durableContent = DurableAgentStateContent.FromAIContent(functionCallContent);
// Act
string jsonContent = JsonSerializer.Serialize(durableContent, s_stateContentTypeInfo);
DurableAgentStateContent? convertedJsonContent =
(DurableAgentStateContent?)JsonSerializer.Deserialize(jsonContent, s_stateContentTypeInfo);
// Assert
Assert.NotNull(convertedJsonContent);
AIContent convertedContent = convertedJsonContent.ToAIContent();
FunctionCallContent convertedFunctionCallContent = Assert.IsType<FunctionCallContent>(convertedContent);
Assert.Equal(functionCallContent.CallId, convertedFunctionCallContent.CallId);
Assert.Equal(functionCallContent.Name, convertedFunctionCallContent.Name);
Assert.NotNull(functionCallContent.Arguments);
Assert.NotNull(convertedFunctionCallContent.Arguments);
Assert.Equal(functionCallContent.Arguments.Keys.Order(), convertedFunctionCallContent.Arguments.Keys.Order());
// NOTE: Deserialized dictionaries will have JSON element values rather than the original native types,
// so we only check the keys here.
foreach (string key in functionCallContent.Arguments.Keys)
{
Assert.Equal(
JsonSerializer.Serialize(functionCallContent.Arguments[key]),
JsonSerializer.Serialize(convertedFunctionCallContent.Arguments[key]));
}
}
[Fact]
public void FunctionResultContentSerializationDeserialization()
{
// Arrange
FunctionResultContent functionResultContent = new("call-123", "return value");
DurableAgentStateContent durableContent = DurableAgentStateContent.FromAIContent(functionResultContent);
// Act
string jsonContent = JsonSerializer.Serialize(durableContent, s_stateContentTypeInfo);
DurableAgentStateContent? convertedJsonContent =
(DurableAgentStateContent?)JsonSerializer.Deserialize(jsonContent, s_stateContentTypeInfo);
// Assert
Assert.NotNull(convertedJsonContent);
AIContent convertedContent = convertedJsonContent.ToAIContent();
FunctionResultContent convertedFunctionResultContent = Assert.IsType<FunctionResultContent>(convertedContent);
Assert.Equal(functionResultContent.CallId, convertedFunctionResultContent.CallId);
// NOTE: We serialize both results to JSON for comparison since deserialized objects will be
// JSON elements rather than the original native types.
Assert.Equal(
JsonSerializer.Serialize(functionResultContent.Result),
JsonSerializer.Serialize(convertedFunctionResultContent.Result));
}
[Theory]
[InlineData("data:text/plain;base64,SGVsbG8sIFdvcmxkIQ==", null)] // Valid data URI containing media type; pass null for separate mediaType parameter.
[InlineData("data:;base64,SGVsbG8sIFdvcmxkIQ==", "text/plain")] // Valid data URI without media type; pass media
public void DataContentSerializationDeserialization(string dataUri, string? mediaType)
{
// Arrange
DataContent dataContent = new(dataUri, mediaType);
DurableAgentStateContent durableContent = DurableAgentStateContent.FromAIContent(dataContent);
// Act
string jsonContent = JsonSerializer.Serialize(durableContent, s_stateContentTypeInfo);
DurableAgentStateContent? convertedJsonContent =
(DurableAgentStateContent?)JsonSerializer.Deserialize(jsonContent, s_stateContentTypeInfo);
// Assert
Assert.NotNull(convertedJsonContent);
AIContent convertedContent = convertedJsonContent.ToAIContent();
DataContent convertedDataContent = Assert.IsType<DataContent>(convertedContent);
Assert.Equal(dataContent.Uri, convertedDataContent.Uri);
Assert.Equal(dataContent.MediaType, convertedDataContent.MediaType);
}
[Fact]
public void HostedFileContentSerializationDeserialization()
{
// Arrange
HostedFileContent hostedFileContent = new("file-123");
DurableAgentStateContent durableContent = DurableAgentStateContent.FromAIContent(hostedFileContent);
// Act
string jsonContent = JsonSerializer.Serialize(durableContent, s_stateContentTypeInfo);
DurableAgentStateContent? convertedJsonContent =
(DurableAgentStateContent?)JsonSerializer.Deserialize(jsonContent, s_stateContentTypeInfo);
// Assert
Assert.NotNull(convertedJsonContent);
AIContent convertedContent = convertedJsonContent.ToAIContent();
HostedFileContent convertedHostedFileContent = Assert.IsType<HostedFileContent>(convertedContent);
Assert.Equal(hostedFileContent.FileId, convertedHostedFileContent.FileId);
}
[Fact]
public void HostedVectorStoreContentSerializationDeserialization()
{
// Arrange
HostedVectorStoreContent hostedVectorStoreContent = new("vs-123");
DurableAgentStateContent durableContent = DurableAgentStateContent.FromAIContent(hostedVectorStoreContent);
// Act
string jsonContent = JsonSerializer.Serialize(durableContent, s_stateContentTypeInfo);
DurableAgentStateContent? convertedJsonContent =
(DurableAgentStateContent?)JsonSerializer.Deserialize(jsonContent, s_stateContentTypeInfo);
// Assert
Assert.NotNull(convertedJsonContent);
AIContent convertedContent = convertedJsonContent.ToAIContent();
HostedVectorStoreContent convertedHostedVectorStoreContent = Assert.IsType<HostedVectorStoreContent>(convertedContent);
Assert.Equal(hostedVectorStoreContent.VectorStoreId, convertedHostedVectorStoreContent.VectorStoreId);
}
[Fact]
public void TextReasoningContentSerializationDeserialization()
{
// Arrange
TextReasoningContent textReasoningContent = new("Reasoning chain...");
DurableAgentStateContent durableContent = DurableAgentStateContent.FromAIContent(textReasoningContent);
// Act
string jsonContent = JsonSerializer.Serialize(durableContent, s_stateContentTypeInfo);
DurableAgentStateContent? convertedJsonContent =
(DurableAgentStateContent?)JsonSerializer.Deserialize(jsonContent, s_stateContentTypeInfo);
// Assert
Assert.NotNull(convertedJsonContent);
AIContent convertedContent = convertedJsonContent.ToAIContent();
TextReasoningContent convertedTextReasoningContent = Assert.IsType<TextReasoningContent>(convertedContent);
Assert.Equal(textReasoningContent.Text, convertedTextReasoningContent.Text);
}
[Fact]
public void UriContentSerializationDeserialization()
{
// Arrange
UriContent uriContent = new(new Uri("https://example.com"), "text/html");
DurableAgentStateContent durableContent = DurableAgentStateContent.FromAIContent(uriContent);
// Act
string jsonContent = JsonSerializer.Serialize(durableContent, s_stateContentTypeInfo);
DurableAgentStateContent? convertedJsonContent =
(DurableAgentStateContent?)JsonSerializer.Deserialize(jsonContent, s_stateContentTypeInfo);
// Assert
Assert.NotNull(convertedJsonContent);
AIContent convertedContent = convertedJsonContent.ToAIContent();
UriContent convertedUriContent = Assert.IsType<UriContent>(convertedContent);
Assert.Equal(uriContent.Uri, convertedUriContent.Uri);
Assert.Equal(uriContent.MediaType, convertedUriContent.MediaType);
}
[Fact]
public void UsageContentSerializationDeserialization()
{
// Arrange
UsageDetails usageDetails = new()
{
InputTokenCount = 10,
OutputTokenCount = 5,
TotalTokenCount = 15
};
UsageContent usageContent = new(usageDetails);
DurableAgentStateContent durableContent = DurableAgentStateContent.FromAIContent(usageContent);
// Act
string jsonContent = JsonSerializer.Serialize(durableContent, s_stateContentTypeInfo);
DurableAgentStateContent? convertedJsonContent =
(DurableAgentStateContent?)JsonSerializer.Deserialize(jsonContent, s_stateContentTypeInfo);
// Assert
Assert.NotNull(convertedJsonContent);
AIContent convertedContent = convertedJsonContent.ToAIContent();
UsageContent convertedUsageContent = Assert.IsType<UsageContent>(convertedContent);
Assert.NotNull(convertedUsageContent.Details);
Assert.Equal(usageDetails.InputTokenCount, convertedUsageContent.Details.InputTokenCount);
Assert.Equal(usageDetails.OutputTokenCount, convertedUsageContent.Details.OutputTokenCount);
Assert.Equal(usageDetails.TotalTokenCount, convertedUsageContent.Details.TotalTokenCount);
}
[Fact]
public void UnknownContentSerializationDeserialization()
{
// Arrange
TextContent originalContent = new("Some unknown content");
DurableAgentStateContent durableContent = DurableAgentStateUnknownContent.FromUnknownContent(originalContent);
// Act
string jsonContent = JsonSerializer.Serialize(durableContent, s_stateContentTypeInfo);
DurableAgentStateContent? convertedJsonContent =
(DurableAgentStateContent?)JsonSerializer.Deserialize(jsonContent, s_stateContentTypeInfo);
// Assert
Assert.NotNull(convertedJsonContent);
AIContent convertedContent = convertedJsonContent.ToAIContent();
TextContent convertedTextContent = Assert.IsType<TextContent>(convertedContent);
Assert.Equal(originalContent.Text, convertedTextContent.Text);
}
}