db620d33df
dotnet-build-and-test / dotnet-test-functions (push) Has been cancelled
dotnet-build-and-test / paths-filter (push) Has been cancelled
dotnet-build-and-test / dotnet-build (Debug, windows-latest, net9.0) (push) Has been cancelled
dotnet-build-and-test / dotnet-build (Release, ubuntu-latest, net10.0) (push) Has been cancelled
dotnet-build-and-test / dotnet-build (Release, ubuntu-latest, net8.0) (push) Has been cancelled
dotnet-build-and-test / dotnet-build (Release, windows-latest, net472) (push) Has been cancelled
dotnet-build-and-test / dotnet-test (Release, integration, true, ubuntu-latest, net10.0) (push) Has been cancelled
dotnet-build-and-test / dotnet-test (Release, integration, true, windows-latest, net472) (push) Has been cancelled
dotnet-build-and-test / dotnet-foundry-hosted-it (push) Has been cancelled
dotnet-build-and-test / dotnet-build-and-test-check (push) Has been cancelled
dotnet-build-and-test / Integration Test Report (push) Has been cancelled
CodeQL / Analyze (csharp) (push) Has been cancelled
CodeQL / Analyze (python) (push) Has been cancelled
78 lines
2.7 KiB
C#
78 lines
2.7 KiB
C#
// Copyright (c) Microsoft. All rights reserved.
|
|
|
|
using System.CommandLine;
|
|
using System.Reflection;
|
|
using Microsoft.Agents.AI;
|
|
using Microsoft.Extensions.Configuration;
|
|
using Microsoft.Extensions.Logging;
|
|
|
|
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.SetAction((_, ct) => HandleCommandsAsync(ct));
|
|
|
|
// Run the command
|
|
return await rootCommand.Parse(args).InvokeAsync();
|
|
}
|
|
|
|
private static async Task HandleCommandsAsync(CancellationToken cancellationToken)
|
|
{
|
|
// 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-5.4-mini";
|
|
var agentUrls = configRoot["A2AClient:AgentUrls"] ?? "http://localhost:5000/;http://localhost:5001/;http://localhost:5002/";
|
|
|
|
// Create the Host agent
|
|
var hostAgent = new HostClientAgent(loggerFactory);
|
|
await hostAgent.InitializeAgentAsync(modelId, apiKey, agentUrls!.Split(";"));
|
|
AgentSession session = await hostAgent.Agent!.CreateSessionAsync(cancellationToken);
|
|
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 is ":q" or "quit")
|
|
{
|
|
break;
|
|
}
|
|
|
|
var agentResponse = await hostAgent.Agent!.RunAsync(message, session, cancellationToken: cancellationToken);
|
|
|
|
Console.ForegroundColor = ConsoleColor.Cyan;
|
|
Console.WriteLine($"\nAgent: {agentResponse.Text}");
|
|
Console.ResetColor();
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
logger.LogError(ex, "An error occurred while running the A2AClient");
|
|
return;
|
|
}
|
|
}
|
|
}
|