Files
wehub-resource-sync b957a53def
CodeQL / Analyze (csharp) (push) Waiting to run
CodeQL / Analyze (python) (push) Waiting to run
chore: import upstream snapshot with attribution
2026-07-13 13:21:23 +08:00

198 lines
6.6 KiB
C#

// Copyright (c) Microsoft. All rights reserved.
using FunctionInvocationApproval.Options;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.SemanticKernel;
using Microsoft.SemanticKernel.Connectors.OpenAI;
namespace FunctionInvocationApproval;
internal sealed class Program
{
/// <summary>
/// This console application shows how to use function invocation filter to invoke function only if such operation was approved.
/// If function invocation was rejected, the result will contain an information about this, so LLM can react accordingly.
/// Application uses a plugin that allows to build a software by following main development stages:
/// Collection of requirements, design, implementation, testing and deployment.
/// Each step can be approved or rejected. Based on that, LLM will decide how to proceed.
/// </summary>
public static async Task Main()
{
var builder = Kernel.CreateBuilder();
// Add LLM configuration
AddChatCompletion(builder);
// Add function approval service and filter
builder.Services.AddSingleton<IFunctionApprovalService, ConsoleFunctionApprovalService>();
builder.Services.AddSingleton<IFunctionInvocationFilter, FunctionInvocationFilter>();
// Add software builder plugin
builder.Plugins.AddFromType<SoftwareBuilderPlugin>();
var kernel = builder.Build();
// Enable automatic function calling
var executionSettings = new OpenAIPromptExecutionSettings
{
Temperature = 0,
FunctionChoiceBehavior = FunctionChoiceBehavior.Auto()
};
// Initialize kernel arguments.
var arguments = new KernelArguments(executionSettings);
// Start execution
// Try to reject invocation at each stage to compare LLM results.
var result = await kernel.InvokePromptAsync("I want to build a software. Let's start from the first step.", arguments);
Console.WriteLine(result);
}
#region Plugins
public sealed class SoftwareBuilderPlugin
{
[KernelFunction]
public string CollectRequirements()
{
Console.WriteLine("Collecting requirements...");
return "Requirements";
}
[KernelFunction]
public string Design(string requirements)
{
Console.WriteLine($"Designing based on: {requirements}");
return "Design";
}
[KernelFunction]
public string Implement(string requirements, string design)
{
Console.WriteLine($"Implementing based on {requirements} and {design}");
return "Implementation";
}
[KernelFunction]
public string Test(string requirements, string design, string implementation)
{
Console.WriteLine($"Testing based on {requirements}, {design} and {implementation}");
return "Test Results";
}
[KernelFunction]
public string Deploy(string requirements, string design, string implementation, string testResults)
{
Console.WriteLine($"Deploying based on {requirements}, {design}, {implementation} and {testResults}");
return "Deployment";
}
}
#endregion
#region Approval
/// <summary>
/// Service that verifies if function invocation is approved.
/// </summary>
public interface IFunctionApprovalService
{
bool IsInvocationApproved(KernelFunction function, KernelArguments arguments);
}
/// <summary>
/// Service that verifies if function invocation is approved using console.
/// </summary>
public sealed class ConsoleFunctionApprovalService : IFunctionApprovalService
{
public bool IsInvocationApproved(KernelFunction function, KernelArguments arguments)
{
Console.WriteLine("====================");
Console.WriteLine($"Function name: {function.Name}");
Console.WriteLine($"Plugin name: {function.PluginName ?? "N/A"}");
if (arguments.Count == 0)
{
Console.WriteLine("\nArguments: N/A");
}
else
{
Console.WriteLine("\nArguments:");
foreach (var argument in arguments)
{
Console.WriteLine($"{argument.Key}: {argument.Value}");
}
}
Console.WriteLine("\nApprove invocation? (yes/no)");
var input = Console.ReadLine();
return input?.Equals("yes", StringComparison.OrdinalIgnoreCase) ?? false;
}
}
#endregion
#region Filter
/// <summary>
/// Filter to invoke function only if it's approved.
/// </summary>
public sealed class FunctionInvocationFilter(IFunctionApprovalService approvalService) : IFunctionInvocationFilter
{
private readonly IFunctionApprovalService _approvalService = approvalService;
public async Task OnFunctionInvocationAsync(FunctionInvocationContext context, Func<FunctionInvocationContext, Task> next)
{
// Invoke the function only if it's approved.
if (this._approvalService.IsInvocationApproved(context.Function, context.Arguments))
{
await next(context);
}
else
{
// Otherwise, return a result that operation was rejected.
context.Result = new FunctionResult(context.Result, "Operation was rejected.");
}
}
}
#endregion
#region Configuration
private static void AddChatCompletion(IKernelBuilder builder)
{
// Get configuration
var config = new ConfigurationBuilder()
.AddUserSecrets<Program>()
.AddEnvironmentVariables()
.Build();
var openAIOptions = config.GetSection(OpenAIOptions.SectionName).Get<OpenAIOptions>();
var azureOpenAIOptions = config.GetSection(AzureOpenAIOptions.SectionName).Get<AzureOpenAIOptions>();
if (openAIOptions is not null && openAIOptions.IsValid)
{
builder.AddOpenAIChatCompletion(openAIOptions.ChatModelId, openAIOptions.ApiKey);
}
else if (azureOpenAIOptions is not null && azureOpenAIOptions.IsValid)
{
builder.AddAzureOpenAIChatCompletion(
azureOpenAIOptions.ChatDeploymentName,
azureOpenAIOptions.Endpoint,
azureOpenAIOptions.ApiKey);
}
else
{
throw new Exception("OpenAI/Azure OpenAI configuration was not found.");
}
}
#endregion
}