))]
+[JsonSerializable(typeof(EventData))]
+[JsonSerializable(typeof(AgentRunResponseUpdate))]
+[JsonSerializable(typeof(AgentResponse))]
+[JsonSerializable(typeof(JsonElement))]
+internal sealed partial class AgentClientJsonContext : JsonSerializerContext;
diff --git a/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Components/App.razor b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Components/App.razor
new file mode 100644
index 0000000000..2a9bdedfe7
--- /dev/null
+++ b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Components/App.razor
@@ -0,0 +1,20 @@
+
+
+
+
+
+
+
+
+
+
+
+ @Body
+
+
+
+ An unhandled error has occurred.
+
Reload
+
🗙
+
Counter
+
+Counter
+
+Current count: @currentCount
+
+Click me
+
+@code {
+ private int currentCount = 0;
+
+ private void IncrementCount()
+ {
+ currentCount++;
+ }
+}
diff --git a/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Components/Pages/Error.razor b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Components/Pages/Error.razor
new file mode 100644
index 0000000000..fcaa7c6ef6
--- /dev/null
+++ b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Components/Pages/Error.razor
@@ -0,0 +1,38 @@
+@page "/Error"
+@using System.Diagnostics
+
+Error
+
+Error.
+An error occurred while processing your request.
+
+@if (ShowRequestId)
+{
+
+ Request ID: @requestId
+
+}
+
+Development Mode
+
+ Swapping to Development environment will display more detailed information about the error that occurred.
+
+
+ The Development environment shouldn't be enabled for deployed applications.
+ It can result in displaying sensitive information from exceptions to end users.
+ For local debugging, enable the Development environment by setting the ASPNETCORE_ENVIRONMENT environment variable to Development
+ and restarting the app.
+
+
+@code{
+ [CascadingParameter]
+ public HttpContext? HttpContext { get; set; }
+
+ private string? requestId;
+ private bool ShowRequestId => !string.IsNullOrEmpty(requestId);
+
+ protected override void OnInitialized()
+ {
+ requestId = Activity.Current?.Id ?? HttpContext?.TraceIdentifier;
+ }
+}
diff --git a/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Components/Pages/Home.razor b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Components/Pages/Home.razor
new file mode 100644
index 0000000000..9001e0bd27
--- /dev/null
+++ b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Components/Pages/Home.razor
@@ -0,0 +1,7 @@
+@page "/"
+
+Home
+
+Hello, world!
+
+Welcome to your new app.
diff --git a/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Components/Pages/PirateTalk.razor b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Components/Pages/PirateTalk.razor
new file mode 100644
index 0000000000..cba45d10a7
--- /dev/null
+++ b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Components/Pages/PirateTalk.razor
@@ -0,0 +1,208 @@
+@page "/pirate-talk"
+@attribute [StreamRendering(true)]
+@inject AgentClient AgentClient
+@inject IJSRuntime JSRuntime
+@inject ILogger Logger
+@rendermode InteractiveServer
+@using System.Text
+@using System.Text.Json
+@using Microsoft.Extensions.AI
+@using Microsoft.Extensions.AI.Agents
+
+Pirate Talk
+
+🏴☠️ Pirate Talk
+
+Chat with a pirate agent! Send a message and get a response in pirate speak.
+
+
+
+ @foreach (var message in chatMessages)
+ {
+
+
@(message.IsUser ? "You" : "🏴☠️ Pirate"):
+
@message.Content
+
+ }
+
+ @if (isStreaming && currentStreamedMessage.Length > 0)
+ {
+
+
🏴☠️ Pirate:
+
@currentStreamedMessage▋
+
+ }
+
+
+
+
+ @if (isStreaming)
+ {
+ Sending...
+ }
+ else
+ {
+ Send
+ }
+
+
+
chatMessages = new();
+ private string sessionId = Guid.NewGuid().ToString();
+ private const string AgentName = "agent:pirate";
+
+ protected override void OnInitialized()
+ {
+ Logger.LogDebug("Initializing PirateTalk component with session ID: {SessionId}", sessionId);
+ }
+
+ private async Task SendMessage()
+ {
+ if (string.IsNullOrWhiteSpace(currentMessage) || isStreaming)
+ return;
+
+ var userMessage = currentMessage.Trim();
+ currentMessage = "";
+
+ Logger.LogInformation("User sending message: '{UserMessage}' in session {SessionId}", userMessage, sessionId);
+
+ // Add user message to chat
+ chatMessages.Add(new ChatMessage { Content = userMessage, IsUser = true });
+ Logger.LogDebug("Chat message added to collection. Total messages: {MessageCount}, Is user message: {IsUserMessage}", chatMessages.Count, true);
+ Logger.LogTrace("StateHasChanged called during streaming for session {SessionId}", sessionId);
+ StateHasChanged();
+ await ScrollToBottom();
+
+ // Start streaming response
+ isStreaming = true;
+ currentStreamedMessage = "";
+ Logger.LogDebug("Starting streaming response for session {SessionId}", sessionId);
+ Logger.LogTrace("StateHasChanged called during streaming for session {SessionId}", sessionId);
+ StateHasChanged();
+
+ try
+ {
+ var responseContent = new StringBuilder();
+
+ await foreach (var update in AgentClient.SendMessageStreamAsync(AgentName, userMessage, sessionId))
+ {
+ Logger.LogTrace("Received streaming update with text length: {TextLength} for session {SessionId}", update.Text?.Length ?? 0, sessionId);
+
+ // Extract text content from the AgentRunResponseUpdate
+ var content = update.Text ?? "";
+ if (!string.IsNullOrEmpty(content))
+ {
+ Logger.LogDebug("Extracted content from update: '{ExtractedContent}' for session {SessionId}", content, sessionId);
+ responseContent.Append(content);
+ currentStreamedMessage = responseContent.ToString();
+ Logger.LogTrace("StateHasChanged called during streaming for session {SessionId}", sessionId);
+ StateHasChanged();
+ await ScrollToBottom();
+ }
+ }
+
+ // Add the complete pirate response to chat messages
+ if (responseContent.Length > 0)
+ {
+ Logger.LogInformation("Streaming completed with total response length: {ResponseLength} for session {SessionId}", responseContent.Length, sessionId);
+ chatMessages.Add(new ChatMessage { Content = responseContent.ToString(), IsUser = false });
+ Logger.LogDebug("Chat message added to collection. Total messages: {MessageCount}, Is user message: {IsUserMessage}", chatMessages.Count, false);
+ }
+ else
+ {
+ Logger.LogWarning("Empty response received from agent for session {SessionId}", sessionId);
+ chatMessages.Add(new ChatMessage { Content = "Arrr, something went wrong with me response, matey!", IsUser = false });
+ Logger.LogDebug("Chat message added to collection. Total messages: {MessageCount}, Is user message: {IsUserMessage}", chatMessages.Count, false);
+ }
+ }
+ catch (Exception ex)
+ {
+ Logger.LogError(ex, "Error occurred while processing message in session {SessionId}: {ErrorMessage}", sessionId, ex.Message);
+ chatMessages.Add(new ChatMessage { Content = $"Arrr, encountered rough seas: {ex.Message}", IsUser = false });
+ Logger.LogDebug("Chat message added to collection. Total messages: {MessageCount}, Is user message: {IsUserMessage}", chatMessages.Count, false);
+ }
+ finally
+ {
+ isStreaming = false;
+ currentStreamedMessage = "";
+ Logger.LogTrace("StateHasChanged called during streaming for session {SessionId}", sessionId);
+ StateHasChanged();
+ await ScrollToBottom();
+ }
+ }
+
+ private async Task HandleKeyPress(KeyboardEventArgs e)
+ {
+ Logger.LogDebug("Handling key press event: {Key} for session {SessionId}", e.Key, sessionId);
+ if (e.Key == "Enter" && !e.ShiftKey)
+ {
+ await SendMessage();
+ }
+ }
+
+ private async Task ScrollToBottom()
+ {
+ try
+ {
+ Logger.LogTrace("Scrolling chat to bottom for session {SessionId}", sessionId);
+ await JSRuntime.InvokeVoidAsync("scrollToBottom", "chat-messages");
+ }
+ catch (Exception ex)
+ {
+ Logger.LogWarning(ex, "Failed to scroll to bottom due to JavaScript error for session {SessionId}", sessionId);
+ // Ignore JS errors
+ }
+ }
+
+ protected override async Task OnAfterRenderAsync(bool firstRender)
+ {
+ if (firstRender)
+ {
+ Logger.LogDebug("Component first render completed, JavaScript functions initialized for session {SessionId}", sessionId);
+ await JSRuntime.InvokeVoidAsync("eval", @"
+ window.scrollToBottom = function(elementId) {
+ const element = document.getElementById(elementId);
+ if (element) {
+ element.scrollTop = element.scrollHeight;
+ }
+ };
+ ");
+ }
+ }
+
+ private class ChatMessage
+ {
+ public string Content { get; set; } = "";
+ public bool IsUser { get; set; }
+ }
+}
diff --git a/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Components/Routes.razor b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Components/Routes.razor
new file mode 100644
index 0000000000..f756e19dfb
--- /dev/null
+++ b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Components/Routes.razor
@@ -0,0 +1,6 @@
+
+
+
+
diff --git a/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Components/_Imports.razor b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Components/_Imports.razor
new file mode 100644
index 0000000000..4c2793f6db
--- /dev/null
+++ b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Components/_Imports.razor
@@ -0,0 +1,11 @@
+@using System.Net.Http
+@using System.Net.Http.Json
+@using Microsoft.AspNetCore.Components.Forms
+@using Microsoft.AspNetCore.Components.Routing
+@using Microsoft.AspNetCore.Components.Web
+@using static Microsoft.AspNetCore.Components.Web.RenderMode
+@using Microsoft.AspNetCore.Components.Web.Virtualization
+@using Microsoft.AspNetCore.OutputCaching
+@using Microsoft.JSInterop
+@using HelloHttpApi.Web
+@using HelloHttpApi.Web.Components
diff --git a/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/HelloHttpApi.Web.csproj b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/HelloHttpApi.Web.csproj
new file mode 100644
index 0000000000..e0aec4096f
--- /dev/null
+++ b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/HelloHttpApi.Web.csproj
@@ -0,0 +1,14 @@
+
+
+
+ net9.0
+ enable
+ enable
+
+
+
+
+
+
diff --git a/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Program.cs b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Program.cs
new file mode 100644
index 0000000000..68c8f8be5c
--- /dev/null
+++ b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Program.cs
@@ -0,0 +1,45 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using HelloHttpApi.Web;
+using HelloHttpApi.Web.Components;
+
+var builder = WebApplication.CreateBuilder(args);
+
+// Add service defaults & Aspire client integrations.
+builder.AddServiceDefaults();
+
+// Add services to the container.
+builder.Services.AddRazorComponents()
+ .AddInteractiveServerComponents();
+
+builder.Services.AddOutputCache();
+
+builder.Services.AddHttpClient(client =>
+ {
+ // This URL uses "https+http://" to indicate HTTPS is preferred over HTTP.
+ // Learn more about service discovery scheme resolution at https://aka.ms/dotnet/sdschemes.
+ client.BaseAddress = new("https+http://apiservice");
+ });
+
+var app = builder.Build();
+
+if (!app.Environment.IsDevelopment())
+{
+ app.UseExceptionHandler("/Error", createScopeForErrors: true);
+ // The default HSTS value is 30 days. You may want to change this for production scenarios, see https://aka.ms/aspnetcore-hsts.
+ app.UseHsts();
+}
+
+app.UseHttpsRedirection();
+
+app.UseStaticFiles();
+app.UseAntiforgery();
+
+app.UseOutputCache();
+
+app.MapRazorComponents()
+ .AddInteractiveServerRenderMode();
+
+app.MapDefaultEndpoints();
+
+app.Run();
diff --git a/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Properties/launchSettings.json b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Properties/launchSettings.json
new file mode 100644
index 0000000000..f0fb11469c
--- /dev/null
+++ b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/Properties/launchSettings.json
@@ -0,0 +1,23 @@
+{
+ "$schema": "https://json.schemastore.org/launchsettings.json",
+ "profiles": {
+ "http": {
+ "commandName": "Project",
+ "dotnetRunMessages": true,
+ "launchBrowser": true,
+ "applicationUrl": "http://localhost:5154",
+ "environmentVariables": {
+ "ASPNETCORE_ENVIRONMENT": "Development"
+ }
+ },
+ "https": {
+ "commandName": "Project",
+ "dotnetRunMessages": true,
+ "launchBrowser": true,
+ "applicationUrl": "https://localhost:7020;http://localhost:5154",
+ "environmentVariables": {
+ "ASPNETCORE_ENVIRONMENT": "Development"
+ }
+ }
+ }
+}
diff --git a/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/appsettings.Development.json b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/appsettings.Development.json
new file mode 100644
index 0000000000..527a02bb3c
--- /dev/null
+++ b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/appsettings.Development.json
@@ -0,0 +1,8 @@
+{
+ "Logging": {
+ "LogLevel": {
+ "Default": "Trace",
+ "Microsoft.AspNetCore": "Warning"
+ }
+ }
+}
diff --git a/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/appsettings.json b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/appsettings.json
new file mode 100644
index 0000000000..f41d5acb6b
--- /dev/null
+++ b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/appsettings.json
@@ -0,0 +1,9 @@
+{
+ "Logging": {
+ "LogLevel": {
+ "Default": "Trace",
+ "Microsoft.AspNetCore": "Warning"
+ }
+ },
+ "AllowedHosts": "*"
+}
diff --git a/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/wwwroot/app.css b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/wwwroot/app.css
new file mode 100644
index 0000000000..2a2a313024
--- /dev/null
+++ b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/wwwroot/app.css
@@ -0,0 +1,56 @@
+html, body {
+ font-family: 'Helvetica Neue', Helvetica, Arial, sans-serif;
+}
+
+a, .btn-link {
+ color: #006bb7;
+}
+
+.btn-primary {
+ color: #fff;
+ background-color: #1b6ec2;
+ border-color: #1861ac;
+}
+
+.btn:focus, .btn:active:focus, .btn-link.nav-link:focus, .form-control:focus, .form-check-input:focus {
+ box-shadow: 0 0 0 0.1rem white, 0 0 0 0.25rem #258cfb;
+}
+
+.content {
+ padding-top: 1.1rem;
+}
+
+h1:focus {
+ outline: none;
+}
+
+.valid.modified:not([type=checkbox]) {
+ outline: 1px solid #26b050;
+}
+
+.invalid {
+ outline: 1px solid #e51540;
+}
+
+.validation-message {
+ color: #e51540;
+}
+
+.blazor-error-boundary {
+ background: url(data:image/svg+xml;base64,PHN2ZyB3aWR0aD0iNTYiIGhlaWdodD0iNDkiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgeG1sbnM6eGxpbms9Imh0dHA6Ly93d3cudzMub3JnLzE5OTkveGxpbmsiIG92ZXJmbG93PSJoaWRkZW4iPjxkZWZzPjxjbGlwUGF0aCBpZD0iY2xpcDAiPjxyZWN0IHg9IjIzNSIgeT0iNTEiIHdpZHRoPSI1NiIgaGVpZ2h0PSI0OSIvPjwvY2xpcFBhdGg+PC9kZWZzPjxnIGNsaXAtcGF0aD0idXJsKCNjbGlwMCkiIHRyYW5zZm9ybT0idHJhbnNsYXRlKC0yMzUgLTUxKSI+PHBhdGggZD0iTTI2My41MDYgNTFDMjY0LjcxNyA1MSAyNjUuODEzIDUxLjQ4MzcgMjY2LjYwNiA1Mi4yNjU4TDI2Ny4wNTIgNTIuNzk4NyAyNjcuNTM5IDUzLjYyODMgMjkwLjE4NSA5Mi4xODMxIDI5MC41NDUgOTIuNzk1IDI5MC42NTYgOTIuOTk2QzI5MC44NzcgOTMuNTEzIDI5MSA5NC4wODE1IDI5MSA5NC42NzgyIDI5MSA5Ny4wNjUxIDI4OS4wMzggOTkgMjg2LjYxNyA5OUwyNDAuMzgzIDk5QzIzNy45NjMgOTkgMjM2IDk3LjA2NTEgMjM2IDk0LjY3ODIgMjM2IDk0LjM3OTkgMjM2LjAzMSA5NC4wODg2IDIzNi4wODkgOTMuODA3MkwyMzYuMzM4IDkzLjAxNjIgMjM2Ljg1OCA5Mi4xMzE0IDI1OS40NzMgNTMuNjI5NCAyNTkuOTYxIDUyLjc5ODUgMjYwLjQwNyA1Mi4yNjU4QzI2MS4yIDUxLjQ4MzcgMjYyLjI5NiA1MSAyNjMuNTA2IDUxWk0yNjMuNTg2IDY2LjAxODNDMjYwLjczNyA2Ni4wMTgzIDI1OS4zMTMgNjcuMTI0NSAyNTkuMzEzIDY5LjMzNyAyNTkuMzEzIDY5LjYxMDIgMjU5LjMzMiA2OS44NjA4IDI1OS4zNzEgNzAuMDg4N0wyNjEuNzk1IDg0LjAxNjEgMjY1LjM4IDg0LjAxNjEgMjY3LjgyMSA2OS43NDc1QzI2Ny44NiA2OS43MzA5IDI2Ny44NzkgNjkuNTg3NyAyNjcuODc5IDY5LjMxNzkgMjY3Ljg3OSA2Ny4xMTgyIDI2Ni40NDggNjYuMDE4MyAyNjMuNTg2IDY2LjAxODNaTTI2My41NzYgODYuMDU0N0MyNjEuMDQ5IDg2LjA1NDcgMjU5Ljc4NiA4Ny4zMDA1IDI1OS43ODYgODkuNzkyMSAyNTkuNzg2IDkyLjI4MzcgMjYxLjA0OSA5My41Mjk1IDI2My41NzYgOTMuNTI5NSAyNjYuMTE2IDkzLjUyOTUgMjY3LjM4NyA5Mi4yODM3IDI2Ny4zODcgODkuNzkyMSAyNjcuMzg3IDg3LjMwMDUgMjY2LjExNiA4Ni4wNTQ3IDI2My41NzYgODYuMDU0N1oiIGZpbGw9IiNGRkU1MDAiIGZpbGwtcnVsZT0iZXZlbm9kZCIvPjwvZz48L3N2Zz4=) no-repeat 1rem/1.8rem, #b32121;
+ padding: 1rem 1rem 1rem 3.7rem;
+ color: white;
+}
+
+ .blazor-error-boundary::after {
+ content: "An error has occurred."
+ }
+
+.form-floating > .form-control-plaintext::placeholder, .form-floating > .form-control::placeholder {
+ color: var(--bs-secondary-color);
+ text-align: end;
+}
+
+.form-floating > .form-control-plaintext:focus::placeholder, .form-floating > .form-control:focus::placeholder {
+ text-align: start;
+}
diff --git a/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/wwwroot/favicon.png b/dotnet/samples/HelloHttpApi/HelloHttpApi.Web/wwwroot/favicon.png
new file mode 100644
index 0000000000000000000000000000000000000000..8422b59695935d180d11d5dbe99653e711097819
GIT binary patch
literal 1148
zcmV-?1cUpDP)9h26h2-Cs%i*@Moc3?#6qJID|D#|3|2Hn7gTIYEkr|%Xjp);YgvFmB&0#2E2b=|
zkVr)lMv9=KqwN&%obTp-$<51T%rx*NCwceh-E+=&e(oLO`@Z~7gybJ#U|^tB2Pai}
zRN@5%1qsZ1e@R(XC8n~)nU1S0QdzEYlWPdUpH{wJ2Pd4V8kI3BM=)sG^IkUXF2-j{
zrPTYA6sxpQ`Q1c6mtar~gG~#;lt=s^6_OccmRd>o{*=>)KS=lM
zZ!)iG|8G0-9s3VLm`bsa6e
ze*TlRxAjXtm^F8V`M1%s5d@tYS>&+_ga#xKGb|!oUBx3uc@mj1%=MaH4GR0tPBG_&
z9OZE;->dO@`Q)nr<%dHAsEZRKl
zedN6+3+uGHejJp;Q==pskSAcRcyh@6mjm2z-uG;s%dM-u0*u##7OxI7wwyCGpS?4U
zBFAr(%GBv5j$jS@@t@iI8?ZqE36I^4t+P^J9D^ELbS5KMtZ
z{Qn#JnSd$15nJ$ggkF%I4yUQC+BjDF^}AtB7w348EL>7#sAsLWs}ndp8^DsAcOIL9
zTOO!!0!k2`9BLk25)NeZp7ev>I1Mn={cWI3Yhx2Q#DnAo4IphoV~R^c0x&nw*MoIV
zPthX?{6{u}sMS(MxD*dmd5rU(YazQE59b|TsB5Tm)I4a!VaN@HYOR)DwH1U5y(E)z
zQqQU*B%MwtRQ$%x&;1p%ANmc|PkoFJZ%<-uq%PX&C!c-7ypis=eP+FCeuv+B@h#{4
zGx1m0PjS~FJt}3mdt4c!lel`1;4W|03kcZRG+DzkTy|7-F~eDsV2Tx!73dM0H0CTh
zl)F-YUkE1zEzEW(;JXc|KR5{ox%YTh{$%F$a36JP6Nb<0%#NbSh$dMYF-{
z1_x(Vx)}fs?5_|!5xBTWiiIQHG<%)*e=45Fhjw_tlnmlixq;mUdC$R8v#j(
zhQ$9YR-o%i5Uc`S?6EC51!bTRK=Xkyb<18FkCKnS2;o*qlij1YA@-nRpq#OMTX&RbL<^2q@0qja!uIvI;j$6>~k@IMwD42=8$$!+R^@5o6HX(*n~
+[JsonConverter(typeof(Converter))]
public readonly struct ActorId : IEquatable
{
///
@@ -113,4 +116,28 @@ public readonly struct ActorId : IEquatable
return true;
#endif
}
+
+ ///
+ /// JSON converter for
+ public sealed class Converter : JsonConverter
+ {
+ ///
+/// Source-generated JSON type information for use by all Actor abstractions.
+///
+[JsonSourceGenerationOptions(
+ JsonSerializerDefaults.Web,
+ UseStringEnumConverter = true,
+ DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull,
+ WriteIndented = false)]
+[JsonSerializable(typeof(ActorMessage))]
+[JsonSerializable(typeof(ActorRequestMessage))]
+[JsonSerializable(typeof(ActorResponseMessage))]
+[JsonSerializable(typeof(ActorWriteOperation))]
+[JsonSerializable(typeof(SetValueOperation))]
+[JsonSerializable(typeof(RemoveKeyOperation))]
+[JsonSerializable(typeof(SendRequestOperation))]
+[JsonSerializable(typeof(UpdateRequestOperation))]
+[JsonSerializable(typeof(ActorReadOperation))]
+[JsonSerializable(typeof(ListKeysOperation))]
+[JsonSerializable(typeof(GetValueOperation))]
+[JsonSerializable(typeof(ActorReadResult))]
+[JsonSerializable(typeof(ListKeysResult))]
+[JsonSerializable(typeof(GetValueResult))]
+[JsonSerializable(typeof(ActorRequest))]
+[JsonSerializable(typeof(ActorRequestUpdate))]
+[JsonSerializable(typeof(ActorResponse))]
+[JsonSerializable(typeof(ActorId))]
+[JsonSerializable(typeof(RequestStatus))]
+[JsonSerializable(typeof(ActorWriteOperationBatch))]
+[JsonSerializable(typeof(ActorReadOperationBatch))]
+[JsonSerializable(typeof(ReadResponse))]
+[JsonSerializable(typeof(WriteResponse))]
+[JsonSerializable(typeof(ActorType))]
+[JsonSerializable(typeof(JsonElement))]
+internal sealed partial class ActorJsonContext : JsonSerializerContext;
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorMessage.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorMessage.cs
new file mode 100644
index 0000000000..c81a9ff244
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorMessage.cs
@@ -0,0 +1,39 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Collections.Generic;
+using System.Text.Json;
+using System.Text.Json.Serialization;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Base class for all actor messages that can be sent between actors.
+///
+///
+/// This abstract class serves as the foundation for all actor message types.
+/// Each concrete implementation represents a specific type of message,
+/// such as request messages or response messages.
+///
+//[JsonConverter(typeof(Converter))]
+[JsonPolymorphic(TypeDiscriminatorPropertyName = "type")]
+[JsonDerivedType(typeof(ActorRequestMessage), "request")]
+[JsonDerivedType(typeof(ActorResponseMessage), "response")]
+public abstract class ActorMessage
+{
+ /// Prevent external derivations.
+ private protected ActorMessage()
+ {
+ }
+
+ ///
+ /// Gets the type of the message.
+ ///
+ [JsonIgnore]
+ public abstract ActorMessageType Type { get; }
+
+ ///
+ /// Additional properties that can be used to extend the message with custom data.
+ ///
+ [JsonExtensionData]
+ public Dictionary? ExtensionData { get; set; }
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorMessageType.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorMessageType.cs
new file mode 100644
index 0000000000..46b3c689a5
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorMessageType.cs
@@ -0,0 +1,23 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Text.Json.Serialization;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Specifies the type of actor message.
+///
+public enum ActorMessageType
+{
+ ///
+ /// Represents a request message sent to an actor.
+ ///
+ [JsonStringEnumMemberName("request")]
+ Request,
+
+ ///
+ /// Represents a response message sent from an actor.
+ ///
+ [JsonStringEnumMemberName("response")]
+ Response
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorMessageWriteOperation.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorMessageWriteOperation.cs
new file mode 100644
index 0000000000..5e365927eb
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorMessageWriteOperation.cs
@@ -0,0 +1,14 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Base class for write operations that modify an actor's messaging (inbox/outbox).
+///
+public abstract class ActorMessageWriteOperation : ActorWriteOperation
+{
+ /// Prevent external derivations.
+ private protected ActorMessageWriteOperation()
+ {
+ }
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorReadOperation.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorReadOperation.cs
new file mode 100644
index 0000000000..1375fe639c
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorReadOperation.cs
@@ -0,0 +1,31 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Text.Json.Serialization;
+using System.Text.Json.Serialization.Metadata;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Base class for all actor read operations that can query actor state or messaging.
+///
+///
+/// This abstract class serves as the foundation for all actor read operation types.
+/// Each concrete implementation represents a specific type of read operation,
+/// such as querying actor state or messaging information.
+///
+[JsonPolymorphic(TypeDiscriminatorPropertyName = "type")]
+[JsonDerivedType(typeof(ListKeysOperation), "list_keys")]
+[JsonDerivedType(typeof(GetValueOperation), "get_value")]
+public abstract class ActorReadOperation
+{
+ /// Prevent external derivations.
+ private protected ActorReadOperation()
+ {
+ }
+
+ ///
+ /// Gets the type of the read operation.
+ ///
+ [JsonIgnore]
+ public abstract ActorReadOperationType Type { get; }
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorReadOperationBatch.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorReadOperationBatch.cs
new file mode 100644
index 0000000000..6a44e35095
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorReadOperationBatch.cs
@@ -0,0 +1,19 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Collections.Generic;
+using System.Text.Json.Serialization;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Represents a batch of read operations to be performed on an actor.
+///
+/// operations)
+{
+ ///
+ /// Gets the collection of read operations to perform.
+ ///
+ [JsonPropertyName("operations")]
+ public IReadOnlyList Operations { get; } = operations;
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorReadOperationType.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorReadOperationType.cs
new file mode 100644
index 0000000000..17e2a45ebe
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorReadOperationType.cs
@@ -0,0 +1,23 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Text.Json.Serialization;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Specifies the type of actor read operation.
+///
+public enum ActorReadOperationType
+{
+ ///
+ /// Represents a list keys operation.
+ ///
+ [JsonStringEnumMemberName("list_keys")]
+ ListKeys,
+
+ ///
+ /// Represents a get value operation.
+ ///
+ [JsonStringEnumMemberName("get_value")]
+ GetValue
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorReadResult.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorReadResult.cs
new file mode 100644
index 0000000000..e83ce179f4
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorReadResult.cs
@@ -0,0 +1,31 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Text.Json.Serialization;
+using System.Text.Json.Serialization.Metadata;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Base class for all actor read operation results.
+///
+///
+/// This abstract class serves as the foundation for all actor read operation result types.
+/// Each concrete implementation represents a specific type of read operation result,
+/// such as listing keys or retrieving values from an actor's state.
+///
+[JsonPolymorphic(TypeDiscriminatorPropertyName = "type")]
+[JsonDerivedType(typeof(ListKeysResult), "list_keys")]
+[JsonDerivedType(typeof(GetValueOperation), "get_value")]
+public abstract class ActorReadResult
+{
+ /// Prevent external derivations.
+ private protected ActorReadResult()
+ {
+ }
+
+ ///
+ /// Gets the type of the read result operation.
+ ///
+ [JsonIgnore]
+ public abstract ActorReadResultType Type { get; }
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorReadResultType.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorReadResultType.cs
new file mode 100644
index 0000000000..1fb79a7dba
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorReadResultType.cs
@@ -0,0 +1,23 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Text.Json.Serialization;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Specifies the type of actor read result operation.
+///
+public enum ActorReadResultType
+{
+ ///
+ /// Represents a list keys operation result.
+ ///
+ [JsonStringEnumMemberName("list_keys")]
+ ListKeys,
+
+ ///
+ /// Represents a get value operation result.
+ ///
+ [JsonStringEnumMemberName("get_value")]
+ GetValue
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorRequest.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorRequest.cs
new file mode 100644
index 0000000000..fa019e1cdd
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorRequest.cs
@@ -0,0 +1,36 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Text.Json;
+using System.Text.Json.Serialization;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Represents a request to be sent to an actor.
+///
+public class ActorRequest(ActorId actorId, string messageId, string method, JsonElement @params)
+{
+ ///
+ /// Gets or sets the identifier of the target actor.
+ ///
+ [JsonPropertyName("actorId")]
+ public ActorId ActorId { get; } = actorId;
+
+ ///
+ /// Gets or sets the unique identifier for this request.
+ ///
+ [JsonPropertyName("messageId")]
+ public string MessageId { get; } = messageId;
+
+ ///
+ /// Gets or sets the method name to invoke on the actor.
+ ///
+ [JsonPropertyName("method")]
+ public string Method { get; } = method;
+
+ ///
+ /// Gets or sets the parameters for the method invocation.
+ ///
+ [JsonPropertyName("params")]
+ public JsonElement Params { get; } = @params;
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorRequestMessage.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorRequestMessage.cs
new file mode 100644
index 0000000000..fb05194c8c
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorRequestMessage.cs
@@ -0,0 +1,39 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Text.Json;
+using System.Text.Json.Serialization;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Base class for request messages sent to actors.
+///
+public sealed class ActorRequestMessage(string MessageId) : ActorMessage
+{
+ ///
+ /// Gets or sets the actor ID of the sender.
+ ///
+ [JsonPropertyName("sender")]
+ public ActorId? SenderId { get; init; }
+
+ ///
+ /// Gets or sets the unique identifier for the request.
+ ///
+ [JsonPropertyName("messageId")]
+ public string MessageId { get; } = MessageId;
+
+ ///
+ /// Name of the method to invoke.
+ ///
+ [JsonPropertyName("method")]
+ public string? Method { get; init; }
+
+ ///
+ /// Optional parameters for the method invocation.
+ ///
+ [JsonPropertyName("params")]
+ public JsonElement Params { get; init; }
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorRequestUpdate.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorRequestUpdate.cs
new file mode 100644
index 0000000000..77e8c301c6
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorRequestUpdate.cs
@@ -0,0 +1,26 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Text.Json;
+using System.Text.Json.Serialization;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+// External (client) interface.
+
+///
+/// Represents an update to an actor request's status and data.
+///
+public class ActorRequestUpdate(RequestStatus status, JsonElement data)
+{
+ ///
+ /// Gets the updated status of the request.
+ ///
+ [JsonPropertyName("status")]
+ public RequestStatus Status { get; } = status;
+
+ ///
+ /// Gets the updated data associated with the request.
+ ///
+ [JsonPropertyName("data")]
+ public JsonElement Data { get; } = data;
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorResponse.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorResponse.cs
new file mode 100644
index 0000000000..7a97807faa
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorResponse.cs
@@ -0,0 +1,36 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Text.Json;
+using System.Text.Json.Serialization;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Represents a response handle for an actor request, providing access to the result and status updates.
+///
+public class ActorResponse
+{
+ ///
+ /// Gets the identifier of the actor that is processing the request.
+ ///
+ [JsonPropertyName("actorId")]
+ public ActorId ActorId { get; init; }
+
+ ///
+ /// Gets the unique identifier of the message/request.
+ ///
+ [JsonPropertyName("messageId")]
+ public string? MessageId { get; init; }
+
+ ///
+ /// Gets the response data from the actor.
+ ///
+ [JsonPropertyName("data")]
+ public JsonElement Data { get; init; }
+
+ ///
+ /// Gets or sets the current status of the request.
+ ///
+ [JsonPropertyName("status")]
+ public RequestStatus Status { get; init; }
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorResponseHandle.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorResponseHandle.cs
new file mode 100644
index 0000000000..2508bd28eb
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorResponseHandle.cs
@@ -0,0 +1,46 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Collections.Generic;
+using System.Diagnostics.CodeAnalysis;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Represents a handle to an actor response, allowing retrieval of the response data and status updates.
+///
+public abstract class ActorResponseHandle
+{
+ ///
+ /// Attempts to get the response from the request if it is immediately available.
+ ///
+ ///
+ /// This method does not block and returns immediately. If the request is still pending or processing,
+ /// this method returns
+ public abstract bool TryGetResponse([NotNullWhen(true)] out ActorResponse? response);
+
+ ///
+ /// Gets the response from the completed request.
+ ///
+ /// A task that completes when the request is finished.
+ public abstract ValueTask GetResponseAsync(CancellationToken cancellationToken);
+
+ ///
+ /// Cancels the request if it is still pending.
+ ///
+ /// A task representing the cancellation operation.
+ public abstract ValueTask CancelAsync(CancellationToken cancellationToken);
+
+ ///
+ /// Watches for status and data updates to the request.
+ ///
+ /// An asynchronous enumerable of request updates.
+ public abstract IAsyncEnumerable WatchUpdatesAsync(CancellationToken cancellationToken);
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorResponseMessage.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorResponseMessage.cs
new file mode 100644
index 0000000000..68510d38e5
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorResponseMessage.cs
@@ -0,0 +1,39 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Text.Json;
+using System.Text.Json.Serialization;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Base class for response messages sent from actors.
+///
+public sealed class ActorResponseMessage(string MessageId) : ActorMessage
+{
+ ///
+ /// Gets or sets the actor ID of the sender.
+ ///
+ [JsonPropertyName("senderId")]
+ public ActorId SenderId { get; init; }
+
+ ///
+ /// Gets or sets the unique identifier for the request.
+ ///
+ [JsonPropertyName("messageId")]
+ public string MessageId { get; } = MessageId;
+
+ ///
+ /// Gets or sets the status of the request.
+ ///
+ [JsonPropertyName("status")]
+ public RequestStatus Status { get; init; }
+
+ ///
+ /// Gets or sets the response data (result or error information).
+ ///
+ [JsonPropertyName("data")]
+ public JsonElement Data { get; init; }
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorStateReadOperation.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorStateReadOperation.cs
new file mode 100644
index 0000000000..43e830631a
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorStateReadOperation.cs
@@ -0,0 +1,14 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Base class for read operations that query an actor's internal state.
+///
+public abstract class ActorStateReadOperation : ActorReadOperation
+{
+ /// Prevent external derivations.
+ private protected ActorStateReadOperation()
+ {
+ }
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorStateWriteOperation.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorStateWriteOperation.cs
new file mode 100644
index 0000000000..f0ec2dcbd8
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorStateWriteOperation.cs
@@ -0,0 +1,19 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Base class for write operations that modify an actor's internal state.
+///
+///
+/// This abstract class serves as the foundation for all actor state write operation types.
+/// Each concrete implementation represents a specific type of state modification operation,
+/// such as setting or removing key-value pairs in an actor's state.
+///
+public abstract class ActorStateWriteOperation : ActorWriteOperation
+{
+ /// Prevent external derivations.
+ private protected ActorStateWriteOperation()
+ {
+ }
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorType.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorType.cs
index 6f101b46f4..619e018083 100644
--- a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorType.cs
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorType.cs
@@ -1,6 +1,8 @@
// Copyright (c) Microsoft. All rights reserved.
using System;
+using System.Text.Json;
+using System.Text.Json.Serialization;
using System.Text.RegularExpressions;
namespace Microsoft.Extensions.AI.Agents.Runtime;
@@ -8,6 +10,7 @@ namespace Microsoft.Extensions.AI.Agents.Runtime;
///
/// Represents the type of an actor.
///
+[JsonConverter(typeof(Converter))]
public readonly partial struct ActorType : IEquatable
{
///
@@ -60,9 +63,33 @@ public readonly partial struct ActorType : IEquatable
type is not null && TypeRegex().IsMatch(type);
#if NET
- [GeneratedRegex("^[a-zA-Z_][a-zA-Z_0-9]*$")]
+ [GeneratedRegex("^[a-zA-Z_][a-zA-Z_:0-9]*$")]
private static partial Regex TypeRegex();
#else
- private static Regex TypeRegex() => new("^[a-zA-Z_][a-zA-Z_0-9]*$", RegexOptions.Compiled);
+ private static Regex TypeRegex() => new("^[a-zA-Z_][a-zA-Z_:0-9:]*$", RegexOptions.Compiled);
#endif
+
+ ///
+ /// JSON converter for
+ public sealed class Converter : JsonConverter
+ {
+ ///
+/// Base class for all actor write operations that can modify actor state or messaging.
+///
+///
+/// This abstract class serves as the foundation for all actor write operation types.
+/// Each concrete implementation represents a specific type of write operation,
+/// such as modifying actor state or sending messages.
+///
+[JsonPolymorphic(TypeDiscriminatorPropertyName = "type")]
+[JsonDerivedType(typeof(SetValueOperation), "set_value")]
+[JsonDerivedType(typeof(RemoveKeyOperation), "remove_key")]
+[JsonDerivedType(typeof(UpdateRequestOperation), "update_request")]
+[JsonDerivedType(typeof(SendRequestOperation), "send_request")]
+public abstract class ActorWriteOperation
+{
+ /// Prevent external derivations.
+ private protected ActorWriteOperation()
+ {
+ }
+
+ ///
+ /// Gets the type of the write operation.
+ ///
+ [JsonIgnore]
+ public abstract ActorWriteOperationType Type { get; }
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorWriteOperationBatch.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorWriteOperationBatch.cs
new file mode 100644
index 0000000000..7f56e958ad
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorWriteOperationBatch.cs
@@ -0,0 +1,26 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Collections.Generic;
+using System.Text.Json.Serialization;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Represents a batch of write operations to be performed atomically on an actor.
+///
+/// operations)
+{
+ ///
+ /// Gets the collection of write operations to perform.
+ ///
+ [JsonPropertyName("operations")]
+ public IReadOnlyCollection Operations { get; } = operations;
+
+ ///
+ /// Gets the ETag for optimistic concurrency control.
+ ///
+ [JsonPropertyName("etag")]
+ public string ETag { get; } = eTag;
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorWriteOperationType.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorWriteOperationType.cs
new file mode 100644
index 0000000000..05e5240500
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ActorWriteOperationType.cs
@@ -0,0 +1,35 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Text.Json.Serialization;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Specifies the type of actor write operation.
+///
+public enum ActorWriteOperationType
+{
+ ///
+ /// Represents a set key-value operation.
+ ///
+ [JsonStringEnumMemberName("set_value")]
+ SetValue,
+
+ ///
+ /// Represents a remove key operation.
+ ///
+ [JsonStringEnumMemberName("remove_key")]
+ RemoveKey,
+
+ ///
+ /// Represents a send request operation.
+ ///
+ [JsonStringEnumMemberName("send_request")]
+ SendRequest,
+
+ ///
+ /// Represents an update request operation.
+ ///
+ [JsonStringEnumMemberName("update_request")]
+ UpdateRequest
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/GetValueOperation.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/GetValueOperation.cs
new file mode 100644
index 0000000000..66b4f09e64
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/GetValueOperation.cs
@@ -0,0 +1,23 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Text.Json.Serialization;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Represents a request to read a value from the actor's state by its key.
+///
+///
+ /// Gets the key corresponding to the value to read from the actor's state.
+ ///
+ [JsonPropertyName("key")]
+ public string Key { get; } = key;
+
+ ///
+ /// Gets the type of the read operation.
+ ///
+ public override ActorReadOperationType Type => ActorReadOperationType.GetValue;
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/GetValueResult.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/GetValueResult.cs
new file mode 100644
index 0000000000..024a45f441
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/GetValueResult.cs
@@ -0,0 +1,24 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Text.Json;
+using System.Text.Json.Serialization;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Represents the result of a get value operation containing the retrieved value.
+///
+///
+ /// Gets the value retrieved from the actor's state.
+ ///
+ [JsonPropertyName("value")]
+ public JsonElement? Value { get; } = value;
+
+ ///
+ /// Gets the type of the read result operation.
+ ///
+ public override ActorReadResultType Type => ActorReadResultType.GetValue;
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/IActor.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/IActor.cs
new file mode 100644
index 0000000000..9ba0babf10
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/IActor.cs
@@ -0,0 +1,23 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+// Implemented by the Agent Framework (eg, Agent, Orchestration, Process, etc)
+///
+/// Represents an actor in the actor system that can process messages and maintain state.
+///
+public interface IActor : IAsyncDisposable
+{
+ ///
+ /// Runs the actor.
+ /// When the value returned from this method completes, the actor is considered stopped.
+ /// IActor is expected to call IActorContext.WatchMessagesAsync() to receive messages.
+ ///
+ /// A task representing the start operation.
+ ValueTask RunAsync(CancellationToken cancellationToken);
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/IActorClient.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/IActorClient.cs
new file mode 100644
index 0000000000..aa51782dc0
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/IActorClient.cs
@@ -0,0 +1,30 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Interface for sending requests to actors and managing responses.
+///
+public interface IActorClient
+{
+ ///
+ /// Submits a request to an actor and gets a handle for the response.
+ /// This method is idempotent: if the request is already in progress, it will return the existing response.
+ ///
+ /// A task representing the actor response handle.
+ ValueTask SendRequestAsync(ActorRequest request, CancellationToken cancellationToken);
+
+ ///
+ /// Gets an already-running request by its identifier.
+ ///
+ /// A task representing the actor response handle.
+ ValueTask GetResponseAsync(ActorId actorId, string messageId, CancellationToken cancellationToken);
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/IActorRuntimeBuilder.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/IActorRuntimeBuilder.cs
new file mode 100644
index 0000000000..cc1a310854
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/IActorRuntimeBuilder.cs
@@ -0,0 +1,18 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Builder interface for configuring actor types in the runtime.
+///
+public interface IActorRuntimeBuilder
+{
+ ///
+ /// Registers an actor type with its factory method.
+ ///
+ /// activator);
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/IActorRuntimeContext.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/IActorRuntimeContext.cs
new file mode 100644
index 0000000000..43b87cdcba
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/IActorRuntimeContext.cs
@@ -0,0 +1,51 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Collections.Generic;
+using System.Text.Json;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Provides the runtime context for an actor, enabling it to interact with the actor system.
+///
+public interface IActorRuntimeContext
+{
+ ///
+ /// Gets the identifier of the actor.
+ ///
+ ActorId ActorId { get; }
+
+ ///
+ /// Watches for incoming requests and responses in the actor's inbox and outbox.
+ ///
+ /// An asynchronous enumerable of actor notifications.
+ IAsyncEnumerable WatchMessagesAsync(CancellationToken cancellationToken = default);
+
+ ///
+ /// Performs a batch of write operations atomically.
+ ///
+ /// A task representing the write response.
+ ValueTask WriteAsync(ActorWriteOperationBatch operations, CancellationToken cancellationToken = default);
+
+ ///
+ /// Performs a batch of read operations.
+ ///
+ /// A task representing the read response.
+ ValueTask ReadAsync(ActorReadOperationBatch operations, CancellationToken cancellationToken = default);
+
+ ///
+ /// Reports progress updates for streaming responses.
+ /// The messageId must correspond to a non-terminated request in the actor's inbox (Status is Pending).
+ ///
+ ///
+/// Interface for actor state storage operations, providing persistence for actor state data.
+///
+public interface IActorStateStorage
+{
+ ///
+ /// Writes state changes to the actor's persistent storage.
+ ///
+ /// A task representing the write response with success status and updated ETag.
+ ValueTask WriteStateAsync(ActorId actorId, IReadOnlyCollection operations, string etag, CancellationToken cancellationToken = default);
+
+ ///
+ /// Reads state data from the actor's persistent storage.
+ ///
+ /// A task representing the read response with results and current ETag.
+ ValueTask ReadStateAsync(ActorId actorId, IReadOnlyCollection operations, CancellationToken cancellationToken = default);
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/InMemoryActorStateStorage.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/InMemoryActorStateStorage.cs
new file mode 100644
index 0000000000..2063420ab3
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/InMemoryActorStateStorage.cs
@@ -0,0 +1,384 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System;
+using System.Collections.Concurrent;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.Linq;
+using System.Text.Json;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Provides an in-memory implementation of
+///
+///
+/// This implementation stores all actor state in memory using concurrent dictionaries for thread safety.
+/// State is not persisted across application restarts and is lost when the application terminates.
+///
+///
+/// The implementation provides optimistic concurrency control using ETags. Each write operation must
+/// provide the current ETag, and the operation will fail if the ETag has changed since the last read.
+/// This ensures that concurrent modifications to the same actor state are handled correctly.
+///
+///
+/// Supported operations:
+///
+///
+///
+///
+/// This implementation is suitable for:
+///
+/// Unit testing scenarios Development and prototyping Single-process applications where persistence is not required
+///
+///
+/// For production scenarios requiring persistence, consider implementing a custom storage provider
+/// that uses a database or other persistent storage mechanism.
+///
+///
+///
+///
+/// // Create storage instance
+/// var storage = new InMemoryActorStateStorage();
+/// var actorId = new ActorId("MyActor", "instance1");
+///
+/// // Write some state
+/// var writeOps = new List<ActorStateWriteOperation>
+/// {
+/// new SetValueOperation("name", JsonSerializer.SerializeToElement("John")),
+/// new SetValueOperation("age", JsonSerializer.SerializeToElement(30))
+/// };
+/// var writeResult = await storage.WriteStateAsync(actorId, writeOps, "0");
+///
+/// // Read the state back
+/// var readOps = new List<ActorStateReadOperation>
+/// {
+/// new GetValueOperation("name"),
+/// new ListKeysOperation(null), // List all keys
+/// new ListKeysOperation(null, "prefix_") // List keys starting with "prefix_"
+/// };
+/// var readResult = await storage.ReadStateAsync(actorId, readOps);
+///
+///
+public sealed class InMemoryActorStateStorage : IActorStateStorage
+{
+ private static readonly ActivitySource ActivitySource = new("Microsoft.Extensions.AI.Agents.Runtime.Abstractions.InMemoryActorStateStorage");
+
+ private readonly ConcurrentDictionary _actorStates = new();
+ private readonly object _lockObject = new();
+ private long _globalETagCounter = 0;
+
+ ///
+ /// Represents the internal state of an actor including its key-value pairs and ETag.
+ ///
+ private sealed class ActorState
+ {
+ public ConcurrentDictionary Data { get; } = new();
+ public string ETag { get; set; } = "0";
+ }
+
+ /// WriteStateAsync(ActorId actorId, IReadOnlyCollection operations, string etag, CancellationToken cancellationToken = default)
+ {
+ using var activity = ActivitySource.StartActivity("actor.state write");
+
+ if (operations is null)
+ {
+ throw new ArgumentNullException(nameof(operations));
+ }
+
+ if (etag is null)
+ {
+ throw new ArgumentNullException(nameof(etag));
+ }
+
+ cancellationToken.ThrowIfCancellationRequested();
+
+ // Set telemetry attributes
+ SetActorAttributes(activity, actorId);
+ SetStateAttributes(activity, "write", operations.Count, etag);
+
+ try
+ {
+ lock (this._lockObject)
+ {
+ var actorState = this._actorStates.GetOrAdd(actorId, _ => new ActorState());
+
+ // Check ETag for optimistic concurrency control
+ if (actorState.ETag != etag)
+ {
+ activity?.SetTag("state.success", false);
+ activity?.SetTag("error.type", "etag_mismatch");
+ activity?.SetStatus(ActivityStatusCode.Error, "ETag mismatch - concurrent modification detected");
+
+ // Return failure with current ETag
+ return new ValueTask(new WriteResponse(actorState.ETag, success: false));
+ }
+
+ // Apply all operations
+ var operationTypes = new List();
+ foreach (var operation in operations)
+ {
+ switch (operation)
+ {
+ case SetValueOperation setValue:
+ actorState.Data[setValue.Key] = setValue.Value;
+ operationTypes.Add("set");
+ break;
+
+ case RemoveKeyOperation removeKey:
+ actorState.Data.TryRemove(removeKey.Key, out _);
+ operationTypes.Add("remove");
+ break;
+
+ default:
+ var errorMessage = $"Unsupported write operation type: {operation.GetType().Name}";
+ var exception = new InvalidOperationException(errorMessage);
+ SetErrorAttributes(activity, exception);
+ throw exception;
+ }
+ }
+
+ // Update ETag
+ var newETag = Interlocked.Increment(ref this._globalETagCounter).ToString();
+ actorState.ETag = newETag;
+
+ // Set success attributes
+ SetOperationStatus(activity, true);
+ activity?.SetTag("state.success", true);
+ activity?.SetTag("state.new_etag", newETag);
+ activity?.SetTag("state.operations", string.Join(",", operationTypes));
+
+ return new ValueTask(new WriteResponse(newETag, success: true));
+ }
+ }
+ catch (Exception ex)
+ {
+ SetErrorAttributes(activity, ex);
+ throw;
+ }
+ }
+
+ /// ReadStateAsync(ActorId actorId, IReadOnlyCollection operations, CancellationToken cancellationToken = default)
+ {
+ using var activity = ActivitySource.StartActivity("actor.state read");
+
+ if (operations is null)
+ {
+ throw new ArgumentNullException(nameof(operations));
+ }
+
+ cancellationToken.ThrowIfCancellationRequested();
+
+ // Set telemetry attributes
+ SetActorAttributes(activity, actorId);
+ SetStateAttributes(activity, "read", operations.Count);
+
+ try
+ {
+ var actorState = this._actorStates.GetOrAdd(actorId, _ => new ActorState());
+ var results = new List();
+ var operationTypes = new List();
+
+ foreach (var operation in operations)
+ {
+ switch (operation)
+ {
+ case GetValueOperation getValue:
+ var hasValue = actorState.Data.TryGetValue(getValue.Key, out var value);
+ results.Add(new GetValueResult(hasValue ? value : null));
+ operationTypes.Add($"get:{getValue.Key}");
+ break;
+
+ case ListKeysOperation listKeys:
+ var keys = actorState.Data.Keys.ToList();
+
+ // Filter keys by prefix if provided
+ if (!string.IsNullOrEmpty(listKeys.KeyPrefix))
+ {
+ keys = [.. keys.Where(key => key.StartsWith(listKeys.KeyPrefix, StringComparison.Ordinal))];
+ }
+
+ // Handle pagination if continuation token is provided
+ if (!string.IsNullOrEmpty(listKeys.ContinuationToken))
+ {
+ // For this simple implementation, we'll parse the continuation token as an index
+ if (int.TryParse(listKeys.ContinuationToken, out int startIndex) && startIndex < keys.Count)
+ {
+ keys = [.. keys.Skip(startIndex)];
+ }
+ else
+ {
+ keys = [];
+ }
+ }
+
+ // For simplicity, we'll return all keys without pagination
+ // In a real implementation, you might want to implement proper pagination
+ results.Add(new ListKeysResult(keys.AsReadOnly(), continuationToken: null));
+ operationTypes.Add($"list:{listKeys.KeyPrefix ?? "*"}");
+ break;
+
+ default:
+ var errorMessage = $"Unsupported read operation type: {operation.GetType().Name}";
+ var exception = new InvalidOperationException(errorMessage);
+ SetErrorAttributes(activity, exception);
+ throw exception;
+ }
+ }
+
+ // Set success attributes
+ SetOperationStatus(activity, true);
+ activity?.SetTag("state.etag", actorState.ETag);
+ activity?.SetTag("state.operations", string.Join(",", operationTypes));
+ activity?.SetTag("state.success", true);
+
+ return new ValueTask(new ReadResponse(actorState.ETag, results.AsReadOnly()));
+ }
+ catch (Exception ex)
+ {
+ SetErrorAttributes(activity, ex);
+ throw;
+ }
+ }
+
+ ///
+ /// Clears all stored actor state. This method is primarily intended for testing scenarios.
+ ///
+ public void Clear()
+ {
+ lock (this._lockObject)
+ {
+ this._actorStates.Clear();
+ Interlocked.Exchange(ref this._globalETagCounter, 0);
+ }
+ }
+
+ ///
+ /// Gets the current count of actors that have state stored.
+ ///
+ /// The number of actors with stored state.
+ public int ActorCount => this._actorStates.Count;
+
+ ///
+ /// Gets the current count of keys stored for a specific actor.
+ ///
+ /// The number of keys stored for the specified actor, or 0 if the actor has no state.
+ public int GetKeyCount(ActorId actorId)
+ {
+ return this._actorStates.TryGetValue(actorId, out var state) ? state.Data.Count : 0;
+ }
+
+ ///
+ /// Gets the current ETag for a specific actor.
+ ///
+ /// The current ETag for the specified actor, or "0" if the actor has no state.
+ public string GetETag(ActorId actorId)
+ {
+ return this._actorStates.TryGetValue(actorId, out var state) ? state.ETag : "0";
+ }
+
+ ///
+ /// Sets actor attributes on an activity.
+ ///
+ ///
+ /// Sets state operation attributes on an activity.
+ ///
+ ///
+ /// Sets success/failure status on an activity.
+ ///
+ ///
+ /// Sets error attributes on an activity.
+ ///
+ ///
+/// Provides extension methods for JSON serialization with source generation support.
+///
+internal static class JsonSerializerExtensions
+{
+ ///
+ /// Gets the JsonTypeInfo for a type, preferring the one from options if available,
+ /// otherwise falling back to the source-generated context.
+ ///
+ /// The type to get JsonTypeInfo for.
+ /// The JsonTypeInfo for the requested type.
+ public static JsonTypeInfo GetTypeInfo(this JsonSerializerOptions options, JsonSerializerContext fallbackContext)
+ {
+ // Try to get from the options first (if a context is configured)
+ if (options.TypeInfoResolver?.GetTypeInfo(typeof(T), options) is JsonTypeInfo typeInfo)
+ {
+ return typeInfo;
+ }
+
+ // Fall back to the provided source-generated context
+ return (JsonTypeInfo)fallbackContext.GetTypeInfo(typeof(T))!;
+ }
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ListKeysOperation.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ListKeysOperation.cs
new file mode 100644
index 0000000000..981a66501d
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ListKeysOperation.cs
@@ -0,0 +1,30 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Text.Json.Serialization;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Represents an operation to list keys from an actor's state, with optional pagination support.
+///
+///
+ /// Gets the continuation token for pagination.
+ ///
+ [JsonPropertyName("continuationToken")]
+ public string? ContinuationToken { get; } = continuationToken;
+
+ ///
+ /// Gets the key prefix for filtering. Only keys starting with this prefix will be returned.
+ ///
+ [JsonPropertyName("keyPrefix")]
+ public string? KeyPrefix { get; } = keyPrefix;
+
+ ///
+ /// Gets the type of the read operation.
+ ///
+ public override ActorReadOperationType Type => ActorReadOperationType.ListKeys;
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ListKeysResult.cs b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ListKeysResult.cs
new file mode 100644
index 0000000000..a177aeec59
--- /dev/null
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/ListKeysResult.cs
@@ -0,0 +1,31 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Collections.Generic;
+using System.Text.Json.Serialization;
+
+namespace Microsoft.Extensions.AI.Agents.Runtime;
+
+///
+/// Represents the result of a list keys operation containing the found keys and optional continuation token.
+///
+/// keys, string? continuationToken) : ActorReadResult
+{
+ ///
+ /// Gets the collection of keys found in the actor's state.
+ ///
+ [JsonPropertyName("keys")]
+ public IReadOnlyCollection Keys { get; } = keys;
+
+ ///
+ /// Gets the continuation token for pagination.
+ ///
+ [JsonPropertyName("continuationToken")]
+ public string? ContinuationToken { get; } = continuationToken;
+
+ ///
+ /// Gets the type of the read result operation.
+ ///
+ public override ActorReadResultType Type => ActorReadResultType.ListKeys;
+}
diff --git a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/Microsoft.Extensions.AI.Agents.Runtime.Abstractions.csproj b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/Microsoft.Extensions.AI.Agents.Runtime.Abstractions.csproj
index 6941c59277..da893dbb4c 100644
--- a/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/Microsoft.Extensions.AI.Agents.Runtime.Abstractions.csproj
+++ b/dotnet/src/Microsoft.Extensions.AI.Agents.Runtime.Abstractions/Microsoft.Extensions.AI.Agents.Runtime.Abstractions.csproj
@@ -5,12 +5,14 @@
$(ProjectsDebugTargetFrameworks)
$(NoWarn);IDE1006;IDE0130
alpha
+ Microsoft.Extensions.AI.Agents.Runtime
true
true
true
+ true