Refactor tool/plugin loading to use dynamic API data

- Replace static tool/plugin lists with dynamic loading from FlowSynx API
- Update SearchablePluginsList to use PluginsFullDetailsList*
- Make IToolRegistry.GetAll async and accept CancellationToken
- Refactor ToolRegistry to fetch and log plugin data from API
- Update WorkflowNodeProperties to load tools asynchronously
- Bump FlowSynx.Client.AspNetCore to v1.3.12

#97

Author: ziagham

src/Components/Pages/Workflows/SearchablePluginsList.razor

@@ -138,13 +138,13 @@
             FlowSynxClient.SetAuthenticationStrategy(
                 new FlowSynx.Client.Authentication.BearerTokenAuthStrategy(token));
 
-            var request = new FlowSynx.Client.Messages.Requests.Plugins.PluginsListRequest
+            var request = new FlowSynx.Client.Messages.Requests.Plugins.PluginsFullDetailsListRequest
             {
                 Page = 1,
                 PageSize = int.MaxValue
             };
 
-            var result = await FlowSynxClient.Plugins.ListAsync(request, cancellationToken);
+            var result = await FlowSynxClient.Plugins.PluginsFullDetailsListAsync(request, cancellationToken);
 
             if (result.StatusCode != 200 || !result.Payload.Succeeded)
             {
@@ -158,10 +158,11 @@
                 {
                     Type = g.Key,
                     Description = g.FirstOrDefault()?.Description,
-                    Versions = g.Select(x => x.Version)
-                                .Distinct()
-                                .OrderByDescending(v => v)
-                                .ToList()
+                    Versions = g
+                        .SelectMany(x => x.Versions)
+                        .Distinct()
+                        .OrderByDescending(v => v)
+                        .ToList()
                 })
                 .ToList();
         }

src/Components/Pages/Workflows/WorkflowNodeProperties.razor

@@ -1,4 +1,5 @@
-@using MudBlazor
+@using Console.Models
+@using MudBlazor
 @using System.Text.Json
 @inject IToolRegistry ToolRegistry
 
@@ -256,7 +257,7 @@
                                            Placeholder="Select allowed tools"
                                            HelperText="These tools are allowed"
                                            Variant="Variant.Filled">
-                                    @foreach (var tool in ToolRegistry.GetAll())
+                                    @foreach (var tool in AvailableTools)
                                     {
                                         <MudSelectItem Value="@tool.Name">
                                             <MudText Typo="Typo.body1">@tool.Name</MudText>
@@ -276,7 +277,7 @@
                                            Placeholder="Select denied tools"
                                            HelperText="These tools are denied"
                                            Variant="Variant.Filled">
-                                    @foreach (var tool in ToolRegistry.GetAll())
+                                    @foreach (var tool in AvailableTools)
                                     {
                                         <MudSelectItem Value="@tool.Name">
                                             <MudText Typo="Typo.body1">@tool.Name</MudText>
@@ -556,6 +557,7 @@
     private string _newParamKey;
     private string _newParamValue;
     private bool IsProcessing = false;
+    private List<ToolDescriptor> AvailableTools = new();
 
     private string Dependencies
     {
@@ -581,7 +583,7 @@
             RunOnFailure.Split(',', StringSplitOptions.RemoveEmptyEntries | StringSplitOptions.TrimEntries).ToList();
     }
 
-    protected override void OnInitialized()
+    protected override async Task OnInitializedAsync()
     {
         SelectedTask.Position ??= new WorkflowTaskPosition(0, 0);
 
@@ -630,6 +632,8 @@
         };
 
         Dependencies = SelectedTask != null ? string.Join(',', SelectedTask.FlowControl.Dependencies) : string.Empty;
+
+        AvailableTools = await GetAvailableToolsAsync();
     }
 
     private void Cancel()
@@ -703,7 +707,11 @@
         SelectedTask.FlowControl.ConditionalBranches.Remove(branch);
     }
 
-    private List<string> AvailableTools => ToolRegistry.GetAll().Select(t => t.Name).OrderBy(x => x).ToList();
+    private async Task<List<ToolDescriptor>> GetAvailableToolsAsync()
+    {
+        var result = await ToolRegistry.GetAll(CancellationToken.None);
+        return result.OrderBy(x => x.Name).ToList();
+    }
 
     public enum ErrorStrategy
     {

src/Console.csproj

@@ -21,7 +21,7 @@
 
 	<ItemGroup>
 		<PackageReference Include="Blazored.LocalStorage" Version="4.5.0" />
-		<PackageReference Include="FlowSynx.Client.AspNetCore" Version="1.3.11" />
+		<PackageReference Include="FlowSynx.Client.AspNetCore" Version="1.3.12" />
 		<PackageReference Include="Microsoft.AspNetCore.Authentication.OpenIdConnect" Version="10.0.1" />
 		<PackageReference Include="Microsoft.AspNetCore.SignalR.Client" Version="10.0.1" />
 		<PackageReference Include="Microsoft.IdentityModel.Protocols.OpenIdConnect" Version="8.15.0" />

src/Services/IToolRegistry.cs

@@ -4,5 +4,5 @@ namespace Console.Services;
 
 public interface IToolRegistry
 {
-    IReadOnlyCollection<ToolDescriptor> GetAll();
+    Task<IReadOnlyCollection<ToolDescriptor>> GetAll(CancellationToken cancellationToken);
 }

src/Services/ToolRegistry.cs

@@ -1,24 +1,55 @@
 using Console.Models;
+using FlowSynx.Client;
 
 namespace Console.Services;
 
 public class ToolRegistry : IToolRegistry
 {
-    private readonly List<ToolDescriptor> _tools = new()
+    private readonly IFlowSynxClient _flowSynxClient;
+    private readonly IAccessTokenProvider _tokenProvider;
+    private readonly ILogger<ToolRegistry> _logger;
+
+    public ToolRegistry(
+        IFlowSynxClient flowSynxClient, 
+        IAccessTokenProvider tokenProvider,
+        ILogger<ToolRegistry> logger)
+    {
+        _flowSynxClient = flowSynxClient;
+        _tokenProvider = tokenProvider;
+        _logger = logger;
+    }
+
+    public async Task<IReadOnlyCollection<ToolDescriptor>> GetAll(CancellationToken cancellationToken)
     {
-        new ToolDescriptor(
-            Name: "FlowSynx.Storage.Local",
-            Description: "Reads and writes files to local or mounted file systems. Supports directory traversal, file watching, and bulk file operations."
-        ),
-        new ToolDescriptor(
-            Name: "FlowSynx.Data.Json",
-            Description: "Loads and parses local JSON files. Supports transformation, extraction, and mapping of hierarchical data structures in workflows."
-        ),
-        new ToolDescriptor(
-            Name: "FlowSynx.Data.Csv",
-            Description: "Reads and writes CSV files, enabling easy batch data import/export operations and integration with spreadsheet-based data workflows."
-        )
-    };
-
-    public IReadOnlyCollection<ToolDescriptor> GetAll() => _tools.AsReadOnly();
+        try
+        {
+            var token = await _tokenProvider.GetAccessTokenAsync();
+            _flowSynxClient.SetAuthenticationStrategy(
+                new FlowSynx.Client.Authentication.BearerTokenAuthStrategy(token));
+
+            var request = new FlowSynx.Client.Messages.Requests.Plugins.PluginsFullDetailsListRequest
+            {
+                Page = 1,
+                PageSize = int.MaxValue
+            };
+
+            var result = await _flowSynxClient.Plugins.PluginsFullDetailsListAsync(request, cancellationToken);
+
+            if (result.StatusCode != 200 || !result.Payload.Succeeded)
+            {
+                _logger.LogError("Failed to load plugins");
+                return new List<ToolDescriptor>();
+            }
+
+            return result.Payload.Data
+                .GroupBy(p => p.Type)
+                .Select(g => new ToolDescriptor(g.Key, g.FirstOrDefault()?.Description))
+                .ToList();
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, ex.Message);
+            return new List<ToolDescriptor>();
+        }
+    }
 }