Add some resources to the server

Author: CapulusCodeNinja

mcp_nexus/Models/McpModels.cs

@@ -110,6 +110,53 @@ public class McpToolsListResult
         public McpToolSchema[] Tools { get; set; } = Array.Empty<McpToolSchema>();
     }
 
+    // ===== MCP RESOURCE MODELS =====
+
+    public class McpResource
+    {
+        [JsonPropertyName("uri")]
+        public string Uri { get; set; } = string.Empty;
+
+        [JsonPropertyName("name")]
+        public string Name { get; set; } = string.Empty;
+
+        [JsonPropertyName("description")]
+        public string Description { get; set; } = string.Empty;
+
+        [JsonPropertyName("mimeType")]
+        public string? MimeType { get; set; }
+
+        [JsonPropertyName("expiresAt")]
+        public DateTime? ExpiresAt { get; set; }
+    }
+
+    public class McpResourcesListResult
+    {
+        [JsonPropertyName("resources")]
+        public McpResource[] Resources { get; set; } = Array.Empty<McpResource>();
+    }
+
+    public class McpResourceContent
+    {
+        [JsonPropertyName("uri")]
+        public string Uri { get; set; } = string.Empty;
+
+        [JsonPropertyName("mimeType")]
+        public string MimeType { get; set; } = "text/plain";
+
+        [JsonPropertyName("text")]
+        public string? Text { get; set; }
+
+        [JsonPropertyName("blob")]
+        public string? Blob { get; set; }
+    }
+
+    public class McpResourceReadResult
+    {
+        [JsonPropertyName("contents")]
+        public McpResourceContent[] Contents { get; set; } = Array.Empty<McpResourceContent>();
+    }
+
     public class McpServerInfoResponse
     {
         [JsonPropertyName("jsonrpc")]
@@ -132,11 +179,20 @@ public class McpCapabilities
     {
         [JsonPropertyName("tools")]
         public object Tools { get; set; } = new { listChanged = true };
+        
+        [JsonPropertyName("resources")]
+        public object Resources { get; set; } = new 
+        { 
+            subscribe = true, 
+            listChanged = true 
+        };
+        
         [JsonPropertyName("notifications")]
         public object Notifications { get; set; } = new
         {
             // Standard MCP notifications
             tools = new { listChanged = true },
+            resources = new { listChanged = true },
             // Custom MCP Nexus notifications  
             commandStatus = true,
             sessionRecovery = true,

mcp_nexus/Program.cs

@@ -697,6 +697,10 @@ private static void RegisterServices(IServiceCollection services, IConfiguration
             // Register MCP notification service for both HTTP and stdio modes
             services.AddSingleton<IMcpNotificationService, McpNotificationService>();
             Console.Error.WriteLine("Registered McpNotificationService for server-initiated notifications");
+
+            // Register MCP resource service for context and data resources
+            services.AddSingleton<McpResourceService>();
+            Console.Error.WriteLine("Registered McpResourceService for MCP resources support");
         }
 
         private static void ConfigureHttpServices(IServiceCollection services)

mcp_nexus/Protocol/McpProtocolService.cs

@@ -8,6 +8,7 @@ namespace mcp_nexus.Protocol
     public class McpProtocolService(
         McpToolDefinitionService m_toolDefinitionService,
         McpToolExecutionService m_toolExecutionService,
+        McpResourceService m_resourceService,
         ILogger<McpProtocolService> m_logger)
     {
         public async Task<object> ProcessRequest(JsonElement requestElement)
@@ -75,6 +76,8 @@ private async Task<object> ExecuteMethod(McpRequest request)
                 "notifications/initialized" => HandleNotificationInitialized(),
                 "tools/list" => HandleToolsList(),
                 "tools/call" => await HandleToolsCall(request.Params),
+                "resources/list" => HandleResourcesList(),
+                "resources/read" => await HandleResourcesRead(request.Params),
                 "notifications/cancelled" => HandleNotificationCancelled(request.Params),
                 _ => throw new McpToolException(-32601, $"Method not found: {request.Method}")
             };
@@ -125,6 +128,28 @@ private object HandleToolsList()
             return new McpToolsListResult { Tools = tools };
         }
 
+        private object HandleResourcesList()
+        {
+            var resources = m_resourceService.GetAllResources();
+            return new McpResourcesListResult { Resources = resources };
+        }
+
+        private async Task<object> HandleResourcesRead(JsonElement? paramsElement)
+        {
+            if (paramsElement == null || !paramsElement.Value.TryGetProperty("uri", out var uriProperty))
+            {
+                throw new McpToolException(-32602, "Missing required parameter: uri");
+            }
+
+            var uri = uriProperty.GetString();
+            if (string.IsNullOrEmpty(uri))
+            {
+                throw new McpToolException(-32602, "Invalid uri parameter");
+            }
+
+            return await m_resourceService.ReadResource(uri);
+        }
+
         private async Task<object> HandleToolsCall(JsonElement? paramsElement)
         {
             if (paramsElement == null)