Merge branch 'master' of https://github.com/evan-cao-wb/BotSharp

Author: Wenbo Cao

src/Infrastructure/BotSharp.MCP/BotSharpMCPExtensions.cs

@@ -0,0 +1,68 @@
+using BotSharp.Abstraction.Agents;
+using BotSharp.Abstraction.Functions;
+using BotSharp.Core.Mcp.Functions;
+using BotSharp.Core.Mcp.Settings;
+using BotSharp.Core.Mcp;
+using BotSharp.MCP.Hooks;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
+using ModelContextProtocol.Configuration;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using ModelContextProtocol.Client;
+
+namespace BotSharp.MCP;
+
+public static class BotSharpMCPExtensions
+{
+    /// <summary>
+    /// Add mcp 
+    /// </summary>
+    /// <param name="services"></param>
+    /// <param name="config"></param>
+    /// <returns></returns>
+    public static IServiceCollection AddBotSharpMCP(this IServiceCollection services,
+        IConfiguration config)
+    {
+        var settings = config.GetSection("MCPSettings").Get<MCPSettings>();
+        services.AddScoped<MCPSettings>(provider => { return settings; });
+        if (settings != null)
+        {
+
+            var clientManager = new MCPClientManager(settings);
+            services.AddSingleton(clientManager);
+
+            foreach (var server in settings.McpServerConfigs)
+            {
+                RegisterFunctionCall(services, server, clientManager)
+                    .ConfigureAwait(false)
+                    .GetAwaiter()
+                    .GetResult();
+            }
+            // Register hooks
+            services.AddScoped<IAgentHook, MCPToolAgentHook>();
+        }
+        return services;
+    }
+
+    private static async Task RegisterFunctionCall(IServiceCollection services, McpServerConfig server, MCPClientManager clientManager)
+    {
+        var client = await clientManager.GetMcpClientAsync(server.Id);
+        var tools = await client.ListToolsAsync();
+
+        foreach (var tool in tools)
+        {
+            services.AddScoped(provider => { return tool; });
+
+            services.AddScoped<IFunctionCallback>(provider =>
+            {
+                var funcTool = new McpToolAdapter(provider, tool, clientManager);
+                return funcTool;
+            });
+        }
+    }
+}

src/Infrastructure/BotSharp.MCP/McpPlugin.cs

@@ -8,6 +8,6 @@ public class MCPSettings
 {
     public McpClientOptions McpClientOptions { get; set; }
 
-    public List<McpServerConfig> McpServerConfigs { get; set; }
+    public List<McpServerConfig> McpServerConfigs { get; set; } = new();
 
 }

src/Infrastructure/BotSharp.MCP/Settings/MCPSettings.cs

@@ -1,7 +1,6 @@
 using BotSharp.Abstraction.Agents.Models;
-using BotSharp.Core.Mcp;
-using ModelContextProtocol.Client;
-using ModelContextProtocol.Protocol.Types;
+ 
+ 
 
 namespace BotSharp.OpenAPI.Controllers;
 
@@ -12,20 +11,17 @@ public class AgentController : ControllerBase
     private readonly IAgentService _agentService;
     private readonly IUserIdentity _user;
     private readonly IServiceProvider _services;
-    private readonly MCPClientManager _clientManager;
-
+ 
     public AgentController(
         IAgentService agentService,
         IUserIdentity user,
-        IServiceProvider services,
-        MCPClientManager mCPClientManager
+        IServiceProvider services  
         )
     {
         _agentService = agentService;
         _user = user;
         _services = services;
-        _clientManager = mCPClientManager;
-    }
+     }
 
     [HttpGet("/agent/settings")]
     public AgentSettings GetSettings()
@@ -173,17 +169,7 @@ public IEnumerable<AgentUtility> GetAgentUtilityOptions()
         }
         return utilities.Where(x => !string.IsNullOrWhiteSpace(x.Name)).OrderBy(x => x.Name).ToList();
     }
-
-    [HttpGet("/agent/mcp/tools")]
-    public async Task<IEnumerable<McpClientTool>> GetMCPTools(string serverId)
-    {
-        var client = await _clientManager.GetMcpClientAsync(serverId);
-        var tools = await client.ListToolsAsync();
-         
-        return tools.Where(x => !string.IsNullOrWhiteSpace(x.Name))
-            .OrderBy(x => x.Name).ToList();
-    }
-
+ 
     [HttpGet("/agent/labels")]
     public async Task<IEnumerable<string>> GetAgentLabels()
     {

src/Infrastructure/BotSharp.OpenAPI/Controllers/AgentController.cs

@@ -5,6 +5,7 @@
 using Serilog;
 using BotSharp.Abstraction.Messaging.JsonConverters;
 using StackExchange.Redis;
+using BotSharp.MCP;
 
 var builder = WebApplication.CreateBuilder(args);
 
@@ -23,6 +24,7 @@
      options.JsonSerializerOptions.Converters.Add(new RichContentJsonConverter());
      options.JsonSerializerOptions.Converters.Add(new TemplateMessageJsonConverter());
  }).AddBotSharpOpenAPI(builder.Configuration, allowedOrigins, builder.Environment, true)
+   .AddBotSharpMCP(builder.Configuration)
    .AddBotSharpLogger(builder.Configuration);
 
 // Add service defaults & Aspire components.

src/WebStarter/Program.cs

@@ -171,23 +171,23 @@
       "Model": "gpt-4o-mini"
     }
   },
-  "MCPSettings": {
-    "McpClientOptions": {
-      "ClientInfo": {
-        "Name": "SimpleToolsBotsharp",
-        "Version": "1.0.0"
-      }
-    },
-    "McpServerConfigs": [
-      {
-        "Id": "PizzaServer",
-        "Name": "PizzaServer",
-        "TransportType": "sse",
-        "TransportOptions": [],
-        "Location": "http://localhost:58905/sse"
-      }
-    ]
-  },
+  //"MCPSettings": {
+  //  "McpClientOptions": {
+  //    "ClientInfo": {
+  //      "Name": "SimpleToolsBotsharp",
+  //      "Version": "1.0.0"
+  //    }
+  //  },
+  //  "McpServerConfigs": [
+  //    {
+  //      "Id": "PizzaServer",
+  //      "Name": "PizzaServer",
+  //      "TransportType": "sse",
+  //      "TransportOptions": [],
+  //      "Location": "http://localhost:58905/sse"
+  //    }
+  //  ]
+  //},
   "Conversation": {
     "DataDir": "conversations",
     "ShowVerboseLog": false,
@@ -413,7 +413,6 @@
       "BotSharp.Core.Crontab",
       "BotSharp.Core.Realtime",
       "BotSharp.Logger",
-      "BotSharp.MCP",
       "BotSharp.Plugin.MongoStorage",
       "BotSharp.Plugin.Dashboard",
       "BotSharp.Plugin.OpenAI",