💾 Feat: The first time that dashboard invoke plugin function throw ne…

…twork connection.
Crequency · Feb 25, 2024 · eefe60f · eefe60f
1 parent 069443d
commit eefe60f
Show file tree

Hide file tree

Showing 6 changed files with 379 additions and 114 deletions.
diff --git a/KitX Dashboard/Converters/PluginInfoConverters.cs b/KitX Dashboard/Converters/PluginInfoConverters.cs
@@ -54,11 +54,11 @@ public class PluginInfoSelectedConverter : IMultiValueConverter
 {
     public object? Convert(IList<object?> values, Type targetType, object? parameter, CultureInfo culture)
     {
-        if (values.Count != 2) return false;
+        if (values.Count != 3) return false;
 
         if (values[0] is string id1)
             if (values[1] is string id2)
-                return id1.Equals(id2);
+                return id1.Equals(id2) && (bool)values[2]!;
 
         return false;
     }

diff --git a/KitX Dashboard/Network/PluginsNetwork/PluginConnector.cs b/KitX Dashboard/Network/PluginsNetwork/PluginConnector.cs
@@ -200,7 +200,7 @@ private void SendWorkingDetail()
         }
     }
 
-    private async void Request(Request request)
+    internal async void Request(Request request)
     {
         await _connection!.Send(JsonSerializer.Serialize(request, serializerOptions));
     }

diff --git a/KitX Dashboard/Network/PluginsNetwork/PluginsServer.cs b/KitX Dashboard/Network/PluginsNetwork/PluginsServer.cs
@@ -1,6 +1,7 @@
 using Fleck;
 using KitX.Dashboard.Configuration;
 using KitX.Dashboard.Services;
+using KitX.Shared.Plugin;
 using System.Collections.Generic;
 using System.Linq;
 using System.Reactive.Linq;
@@ -50,6 +51,18 @@ public PluginsServer Run()
         return this;
     }
 
+    public PluginConnector? FindConnector(PluginInfo info)
+    {
+        var query = PluginConnectors.Where(
+            x => x.PluginInfo.HasValue && x.PluginInfo.Value.Equals(info)
+        );
+
+        if (query.Any())
+            return query.First();
+        else
+            return null;
+    }
+
     public async Task<PluginsServer> Close()
     {
         await Task.Run(() =>