.Net: Initial check-in for the A2A Agent implementation

dotnet/Directory.Packages.props

@@ -95,6 +95,9 @@
     <PackageVersion Include="System.Text.Json" Version="8.0.5" />
     <PackageVersion Include="System.ValueTuple" Version="4.6.1" />
     <PackageVersion Include="System.Threading.Tasks.Extensions" Version="4.6.3" />
+    <PackageVersion Include="SharpA2A.Core" Version="0.1.0-preview.4" />
+    <PackageVersion Include="SharpA2A.AspNetCore" Version="0.1.0-preview.4" />
+    <PackageVersion Include="System.CommandLine" Version="2.0.0-beta4.22272.1" />
     <!-- Tokenizers -->
     <PackageVersion Include="Microsoft.ML.Tokenizers" Version="1.0.2" />
     <PackageVersion Include="Microsoft.DeepDev.TokenizerLib" Version="1.3.3" />

dotnet/SK-dotnet.sln

@@ -550,6 +550,17 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Runtime.InProcess.UnitTests
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "VectorData.UnitTests", "src\Connectors\VectorData.UnitTests\VectorData.UnitTests.csproj", "{AAC7B5E8-CC4E-49D0-AF6A-2B4F7B43BD84}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Agents.A2A", "src\Agents\A2A\Agents.A2A.csproj", "{38F1D24F-C7B4-58CC-D104-311D786A73CF}"
+EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "A2AClientServer", "A2AClientServer", "{5B1ECD1B-3C38-4458-A227-89846AF13760}"
+	ProjectSection(SolutionItems) = preProject
+		samples\Demos\A2AClientServer\README.md = samples\Demos\A2AClientServer\README.md
+	EndProjectSection
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "A2AClient", "samples\Demos\A2AClientServer\A2AClient\A2AClient.csproj", "{F293D014-97E2-18CB-FA0F-0A0FBE149286}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "A2AServer", "samples\Demos\A2AClientServer\A2AServer\A2AServer.csproj", "{D5324629-DFED-4095-EA74-A0234AC9EB4E}"
+EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Agents.Orchestration", "src\Agents\Orchestration\Agents.Orchestration.csproj", "{D1A02387-FA60-22F8-C2ED-4676568B6CC3}"
 EndProject
 Global
@@ -1513,6 +1524,24 @@ Global
 		{AAC7B5E8-CC4E-49D0-AF6A-2B4F7B43BD84}.Publish|Any CPU.Build.0 = Debug|Any CPU
 		{AAC7B5E8-CC4E-49D0-AF6A-2B4F7B43BD84}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{AAC7B5E8-CC4E-49D0-AF6A-2B4F7B43BD84}.Release|Any CPU.Build.0 = Release|Any CPU
+		{38F1D24F-C7B4-58CC-D104-311D786A73CF}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{38F1D24F-C7B4-58CC-D104-311D786A73CF}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{38F1D24F-C7B4-58CC-D104-311D786A73CF}.Publish|Any CPU.ActiveCfg = Publish|Any CPU
+		{38F1D24F-C7B4-58CC-D104-311D786A73CF}.Publish|Any CPU.Build.0 = Publish|Any CPU
+		{38F1D24F-C7B4-58CC-D104-311D786A73CF}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{38F1D24F-C7B4-58CC-D104-311D786A73CF}.Release|Any CPU.Build.0 = Release|Any CPU
+		{F293D014-97E2-18CB-FA0F-0A0FBE149286}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{F293D014-97E2-18CB-FA0F-0A0FBE149286}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{F293D014-97E2-18CB-FA0F-0A0FBE149286}.Publish|Any CPU.ActiveCfg = Release|Any CPU
+		{F293D014-97E2-18CB-FA0F-0A0FBE149286}.Publish|Any CPU.Build.0 = Release|Any CPU
+		{F293D014-97E2-18CB-FA0F-0A0FBE149286}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{F293D014-97E2-18CB-FA0F-0A0FBE149286}.Release|Any CPU.Build.0 = Release|Any CPU
+		{D5324629-DFED-4095-EA74-A0234AC9EB4E}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{D5324629-DFED-4095-EA74-A0234AC9EB4E}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{D5324629-DFED-4095-EA74-A0234AC9EB4E}.Publish|Any CPU.ActiveCfg = Release|Any CPU
+		{D5324629-DFED-4095-EA74-A0234AC9EB4E}.Publish|Any CPU.Build.0 = Release|Any CPU
+		{D5324629-DFED-4095-EA74-A0234AC9EB4E}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{D5324629-DFED-4095-EA74-A0234AC9EB4E}.Release|Any CPU.Build.0 = Release|Any CPU
 		{D1A02387-FA60-22F8-C2ED-4676568B6CC3}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
 		{D1A02387-FA60-22F8-C2ED-4676568B6CC3}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{D1A02387-FA60-22F8-C2ED-4676568B6CC3}.Publish|Any CPU.ActiveCfg = Publish|Any CPU
@@ -1724,6 +1753,10 @@ Global
 		{CCC909E4-5269-A31E-0BFD-4863B4B29BBB} = {A70ED5A7-F8E1-4A57-9455-3C05989542DA}
 		{DA6B4ED4-ED0B-D25C-889C-9F940E714891} = {A70ED5A7-F8E1-4A57-9455-3C05989542DA}
 		{AAC7B5E8-CC4E-49D0-AF6A-2B4F7B43BD84} = {5A7028A7-4DDF-4E4F-84A9-37CE8F8D7E89}
+		{38F1D24F-C7B4-58CC-D104-311D786A73CF} = {6823CD5E-2ABE-41EB-B865-F86EC13F0CF9}
+		{5B1ECD1B-3C38-4458-A227-89846AF13760} = {5D4C0700-BBB5-418F-A7B2-F392B9A18263}
+		{F293D014-97E2-18CB-FA0F-0A0FBE149286} = {5B1ECD1B-3C38-4458-A227-89846AF13760}
+		{D5324629-DFED-4095-EA74-A0234AC9EB4E} = {5B1ECD1B-3C38-4458-A227-89846AF13760}
 		{D1A02387-FA60-22F8-C2ED-4676568B6CC3} = {6823CD5E-2ABE-41EB-B865-F86EC13F0CF9}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution

dotnet/samples/Demos/A2AClientServer/A2AClient/A2AClient.csproj

@@ -0,0 +1,25 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+    <UserSecretsId>5ee045b0-aea3-4f08-8d31-32d1a6f8fed0</UserSecretsId>
+    <NoWarn>$(NoWarn);CS1591;VSTHRD111;CA2007;SKEXP0110</NoWarn>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="SharpA2A.Core" />
+    <PackageReference Include="SharpA2A.AspNetCore" />
+    <PackageReference Include="System.CommandLine" />
+    <PackageReference Include="Microsoft.Extensions.Hosting" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\..\..\..\src\Agents\A2A\Agents.A2A.csproj" />
+    <ProjectReference Include="..\..\..\..\src\Agents\Core\Agents.Core.csproj" />
+    <ProjectReference Include="..\..\..\..\src\Connectors\Connectors.OpenAI\Connectors.OpenAI.csproj" />
+  </ItemGroup>
+
+</Project>

dotnet/samples/Demos/A2AClientServer/A2AClient/HostClientAgent.cs

@@ -0,0 +1,120 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using Microsoft.Extensions.Logging;
+using Microsoft.SemanticKernel;
+using Microsoft.SemanticKernel.Agents;
+using Microsoft.SemanticKernel.Agents.A2A;
+using SharpA2A.Core;
+
+namespace A2A;
+
+internal sealed class HostClientAgent
+{
+    internal HostClientAgent(ILogger logger)
+    {
+        this._logger = logger;
+    }
+    internal async Task InitializeAgentAsync(string modelId, string apiKey, string[] agentUrls)
+    {
+        try
+        {
+            this._logger.LogInformation("Initializing Semantic Kernel agent with model: {ModelId}", modelId);
+
+            // Connect to the remote agents via A2A
+            var createAgentTasks = agentUrls.Select(agentUrl => this.CreateAgentAsync(agentUrl));
+            var agents = await Task.WhenAll(createAgentTasks);
+            var agentFunctions = agents.Select(agent => AgentKernelFunctionFactory.CreateFromAgent(agent)).ToList();
+            var agentPlugin = KernelPluginFactory.CreateFromFunctions("AgentPlugin", agentFunctions);
+
+            // Define the Host agent
+            var builder = Kernel.CreateBuilder();
+            builder.AddOpenAIChatCompletion(modelId, apiKey);
+            builder.Plugins.Add(agentPlugin);
+            var kernel = builder.Build();
+            kernel.FunctionInvocationFilters.Add(new ConsoleOutputFunctionInvocationFilter());
+
+            this.Agent = new ChatCompletionAgent()
+            {
+                Kernel = kernel,
+                Name = "HostClient",
+                Instructions =
+                    """
+                    You specialize in handling queries for users and using your tools to provide answers.
+                    """,
+                Arguments = new KernelArguments(new PromptExecutionSettings() { FunctionChoiceBehavior = FunctionChoiceBehavior.Auto() }),
+            };
+        }
+        catch (Exception ex)
+        {
+            this._logger.LogError(ex, "Failed to initialize HostClientAgent");
+            throw;
+        }
+    }
+
+    /// <summary>
+    /// The associated <see cref="Agent"/>
+    /// </summary>
+    public Agent? Agent { get; private set; }
+
+    #region private
+    private readonly ILogger _logger;
+
+    private async Task<A2AAgent> CreateAgentAsync(string agentUri)
+    {
+        var httpClient = new HttpClient
+        {
+            BaseAddress = new Uri(agentUri),
+            Timeout = TimeSpan.FromSeconds(60)
+        };
+
+        var client = new A2AClient(httpClient);
+        var cardResolver = new A2ACardResolver(httpClient);
+        var agentCard = await cardResolver.GetAgentCardAsync();
+
+        return new A2AAgent(client, agentCard!);
+    }
+    #endregion
+}
+
+internal sealed class ConsoleOutputFunctionInvocationFilter() : IFunctionInvocationFilter
+{
+    private static string IndentMultilineString(string multilineText, int indentLevel = 1, int spacesPerIndent = 4)
+    {
+        // Create the indentation string
+        var indentation = new string(' ', indentLevel * spacesPerIndent);
+
+        // Split the text into lines, add indentation, and rejoin
+        char[] NewLineChars = { '\r', '\n' };
+        string[] lines = multilineText.Split(NewLineChars, StringSplitOptions.None);
+
+        return string.Join(Environment.NewLine, lines.Select(line => indentation + line));
+    }
+    public async Task OnFunctionInvocationAsync(FunctionInvocationContext context, Func<FunctionInvocationContext, Task> next)
+    {
+        Console.ForegroundColor = ConsoleColor.DarkGray;
+
+        Console.WriteLine($"\nCalling Agent {context.Function.Name} with arguments:");
+        Console.ForegroundColor = ConsoleColor.Gray;
+
+        foreach (var kvp in context.Arguments)
+        {
+            Console.WriteLine(IndentMultilineString($"  {kvp.Key}: {kvp.Value}"));
+        }
+
+        await next(context);
+
+        if (context.Result.GetValue<object>() is ChatMessageContent[] chatMessages)
+        {
+            Console.ForegroundColor = ConsoleColor.DarkGray;
+
+            Console.WriteLine($"Got Response from Agent {context.Function.Name}:");
+            foreach (var message in chatMessages)
+            {
+                Console.ForegroundColor = ConsoleColor.Gray;
+
+                Console.WriteLine(IndentMultilineString($"{message}"));
+            }
+        }
+        Console.ResetColor();
+    }
+}

dotnet/samples/Demos/A2AClientServer/A2AClient/Program.cs

@@ -0,0 +1,89 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.CommandLine;
+using System.CommandLine.Invocation;
+using System.Reflection;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Logging;
+using Microsoft.SemanticKernel;
+using Microsoft.SemanticKernel.Agents;
+
+namespace A2A;
+
+public static class Program
+{
+    public static async Task<int> Main(string[] args)
+    {
+        // Create root command with options
+        var rootCommand = new RootCommand("A2AClient");
+        rootCommand.SetHandler(HandleCommandsAsync);
+
+        // Run the command
+        return await rootCommand.InvokeAsync(args);
+    }
+
+    public static async System.Threading.Tasks.Task HandleCommandsAsync(InvocationContext context)
+    {
+        await RunCliAsync();
+    }
+
+    #region private
+    private static async System.Threading.Tasks.Task RunCliAsync()
+    {
+        // Set up the logging
+        using var loggerFactory = LoggerFactory.Create(builder =>
+        {
+            builder.AddConsole();
+            builder.SetMinimumLevel(LogLevel.Information);
+        });
+        var logger = loggerFactory.CreateLogger("A2AClient");
+
+        // Retrieve configuration settings
+        IConfigurationRoot configRoot = new ConfigurationBuilder()
+            .AddEnvironmentVariables()
+            .AddUserSecrets(Assembly.GetExecutingAssembly())
+            .Build();
+        var apiKey = configRoot["A2AClient:ApiKey"] ?? throw new ArgumentException("A2AClient:ApiKey must be provided");
+        var modelId = configRoot["A2AClient:ModelId"] ?? "gpt-4.1";
+        var agentUrls = configRoot["A2AClient:AgentUrls"] ?? "http://localhost:5000/policy/ http://localhost:5000/invoice/ http://localhost:5000/logistics/";
+
+        // Create the Host agent
+        var hostAgent = new HostClientAgent(logger);
+        await hostAgent.InitializeAgentAsync(modelId, apiKey, agentUrls!.Split(" "));
+        AgentThread thread = new ChatHistoryAgentThread();
+        try
+        {
+            while (true)
+            {
+                // Get user message
+                Console.Write("\nUser (:q or quit to exit): ");
+                string? message = Console.ReadLine();
+                if (string.IsNullOrWhiteSpace(message))
+                {
+                    Console.WriteLine("Request cannot be empty.");
+                    continue;
+                }
+
+                if (message == ":q" || message == "quit")
+                {
+                    break;
+                }
+
+                await foreach (AgentResponseItem<ChatMessageContent> response in hostAgent.Agent!.InvokeAsync(message, thread))
+                {
+                    Console.ForegroundColor = ConsoleColor.Cyan;
+                    Console.WriteLine($"Agent: {response.Message.Content}");
+                    Console.ResetColor();
+
+                    thread = response.Thread;
+                }
+            }
+        }
+        catch (Exception ex)
+        {
+            logger.LogError(ex, "An error occurred while running the A2AClient");
+            return;
+        }
+    }
+    #endregion
+}

dotnet/samples/Demos/A2AClientServer/A2AClient/README.md

@@ -0,0 +1,26 @@
+
+# A2A Client Sample
+Show how to create an A2A Client with a command line interface which invokes agents using the A2A protocol.
+
+## Run the Sample
+
+To run the sample, follow these steps:
+
+1. Run the A2A client:
+    ```bash
+    cd A2AClient
+    dotnet run
+    ```  
+2. Enter your request e.g. "Show me all invoices for Contoso?"
+
+## Set Secrets with Secret Manager
+
+The agent urls are provided as a ` ` delimited list of strings
+
+```text
+cd dotnet/samples/Demos/A2AClientServer/A2AClient
+
+dotnet user-secrets set "A2AClient:ModelId" "..."
+dotnet user-secrets set "A2AClient":ApiKey" "..."
+dotnet user-secrets set "A2AClient:AgentUrls" "http://localhost:5000/policy http://localhost:5000/invoice http://localhost:5000/logistics"
+```

dotnet/samples/Demos/A2AClientServer/A2AServer/A2AServer.csproj

@@ -0,0 +1,24 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+    <UserSecretsId>5ee045b0-aea3-4f08-8d31-32d1a6f8fed0</UserSecretsId>
+    <NoWarn>$(NoWarn);CS1591;VSTHRD111;CA2007;SKEXP0110</NoWarn>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="SharpA2A.Core" />
+    <PackageReference Include="SharpA2A.AspNetCore" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\..\..\..\src\Agents\A2A\Agents.A2A.csproj" />
+    <ProjectReference Include="..\..\..\..\src\Agents\AzureAI\Agents.AzureAI.csproj" />
+    <ProjectReference Include="..\..\..\..\src\Agents\Core\Agents.Core.csproj" />
+    <ProjectReference Include="..\..\..\..\src\Connectors\Connectors.OpenAI\Connectors.OpenAI.csproj" />
+  </ItemGroup>
+
+</Project>