Implement JSONRPC V2

Flow.Launcher.Core/ExternalPlugins/Environments/AbstractPluginEnvironment.cs

@@ -58,7 +58,7 @@ internal IEnumerable<PluginPair> Setup()
                     string.Empty, MessageBoxButtons.YesNo) == DialogResult.No)
             {
                 var msg = $"Please select the {EnvName} executable";
-                var selectedFile = string.Empty;
+                string selectedFile;
 
                 selectedFile = GetFileFromDialog(msg, FileDialogFilter);
 
@@ -131,14 +131,8 @@ private string GetFileFromDialog(string title, string filter = "")
             };
 
             var result = dlg.ShowDialog();
-            if (result == DialogResult.OK)
-            {
-                return dlg.FileName;
-            }
-            else
-            {
-                return string.Empty;
-            }
+            return result == DialogResult.OK ? dlg.FileName : string.Empty;
+
         }
 
         /// <summary>

Flow.Launcher.Core/ExternalPlugins/Environments/PythonV2Environment.cs

@@ -0,0 +1,23 @@
+using System.Collections.Generic;
+using Flow.Launcher.Core.Plugin;
+using Flow.Launcher.Infrastructure.UserSettings;
+using Flow.Launcher.Plugin;
+
+namespace Flow.Launcher.Core.ExternalPlugins.Environments
+{
+    internal class PythonV2Environment : PythonEnvironment
+    {
+        internal override string Language => AllowedLanguage.PythonV2;
+
+        internal override PluginPair CreatePluginPair(string filePath, PluginMetadata metadata)
+        {
+            return new PluginPair
+            {
+                Plugin = new PythonPluginV2(filePath),
+                Metadata = metadata
+            };
+        }
+
+        internal PythonV2Environment(List<PluginMetadata> pluginMetadataList, PluginsSettings pluginSettings) : base(pluginMetadataList, pluginSettings) { }
+    }
+}

Flow.Launcher.Core/ExternalPlugins/PluginsManifest.cs

@@ -1,4 +1,4 @@
-using Flow.Launcher.Infrastructure.Logger;
+using Flow.Launcher.Infrastructure.Logger;
 using System;
 using System.Collections.Generic;
 using System.Threading;

Flow.Launcher.Core/Flow.Launcher.Core.csproj

@@ -57,6 +57,7 @@
     <PackageReference Include="FSharp.Core" Version="7.0.300" />
     <PackageReference Include="Microsoft.IO.RecyclableMemoryStream" Version="2.3.2" />
     <PackageReference Include="squirrel.windows" Version="1.5.2" NoWarn="NU1701" />
+    <PackageReference Include="StreamJsonRpc" Version="2.15.29" />
   </ItemGroup>
 
   <ItemGroup>

Flow.Launcher.Core/Plugin/ExecutablePlugin.cs

@@ -1,5 +1,6 @@
 using System.Diagnostics;
 using System.IO;
+using System.Text.Json;
 using System.Threading;
 using System.Threading.Tasks;
 
@@ -27,14 +28,14 @@ public ExecutablePlugin(string filename)
         protected override Task<Stream> RequestAsync(JsonRPCRequestModel request, CancellationToken token = default)
         {
             // since this is not static, request strings will build up in ArgumentList if index is not specified
-            _startInfo.ArgumentList[0] = request.ToString();
+            _startInfo.ArgumentList[0] = JsonSerializer.Serialize(request, RequestSerializeOption);
             return ExecuteAsync(_startInfo, token);
         }
 
         protected override string Request(JsonRPCRequestModel rpcRequest, CancellationToken token = default)
         {
             // since this is not static, request strings will build up in ArgumentList if index is not specified
-            _startInfo.ArgumentList[0] = rpcRequest.ToString();
+            _startInfo.ArgumentList[0] = JsonSerializer.Serialize(rpcRequest, RequestSerializeOption);
             return Execute(_startInfo);
         }
     }

Flow.Launcher.Core/Plugin/ExecutablePluginV2.cs

@@ -0,0 +1,26 @@
+using System.Diagnostics;
+using System.IO;
+using System.Text.Json;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Flow.Launcher.Core.Plugin
+{
+    internal sealed class ExecutablePluginV2 : ProcessStreamPluginV2
+    {
+        protected override ProcessStartInfo StartInfo { get; set; }
+
+        public ExecutablePluginV2(string filename)
+        {
+            StartInfo = new ProcessStartInfo
+            {
+                FileName = filename,
+                UseShellExecute = false,
+                CreateNoWindow = true,
+                RedirectStandardOutput = true,
+                RedirectStandardError = true
+            };
+        }
+
+    }
+}

Flow.Launcher.Core/Plugin/JsonPRCModel.cs

@@ -19,67 +19,35 @@
 
 namespace Flow.Launcher.Core.Plugin
 {
-    public class JsonRPCErrorModel
-    {
-        public int Code { get; set; }
-
-        public string Message { get; set; }
-
-        public string Data { get; set; }
-    }
-
-
-    public class JsonRPCResponseModel
-    {
-        public string Result { get; set; }
+    public record JsonRPCBase(int Id, JsonRPCErrorModel Error = default);
+    public record JsonRPCErrorModel(int Code, string Message, string Data);
 
-        public JsonRPCErrorModel Error { get; set; }
-    }
-
-    public class JsonRPCQueryResponseModel : JsonRPCResponseModel
-    {
-        [JsonPropertyName("result")]
-        public new List<JsonRPCResult> Result { get; set; }
+    public record JsonRPCResponseModel(int Id, JsonRPCErrorModel Error = default) : JsonRPCBase(Id, Error);
+    public record JsonRPCQueryResponseModel(int Id,
+        [property: JsonPropertyName("result")] List<JsonRPCResult> Result,
+        IReadOnlyDictionary<string, object> SettingsChanges = null,
+        string DebugMessage = "",
+        JsonRPCErrorModel Error = default) : JsonRPCResponseModel(Id, Error);
 
-        public Dictionary<string, object> SettingsChange { get; set; }
+    public record JsonRPCRequestModel(int Id,
+        string Method,
+        object[] Parameters,
+        IReadOnlyDictionary<string, object> Settings = default,
+        JsonRPCErrorModel Error = default) : JsonRPCBase(Id, Error);
 
-        public string DebugMessage { get; set; }
-    }
-
-    public class JsonRPCRequestModel
-    {
-        public string Method { get; set; }
-
-        public object[] Parameters { get; set; }
-
-        public Dictionary<string, object> Settings { get; set; }
-
-        private static readonly JsonSerializerOptions options = new()
-        {
-            PropertyNamingPolicy = JsonNamingPolicy.CamelCase
-        };
-        public override string ToString()
-        {
-            return JsonSerializer.Serialize(this, options);
-        }
-    }
-
-    /// <summary>
-    /// Json RPC Request that Flow Launcher sent to client
-    /// </summary>
-    public class JsonRPCServerRequestModel : JsonRPCRequestModel
-    {
-
-    }
 
     /// <summary>
     /// Json RPC Request(in query response) that client sent to Flow Launcher
     /// </summary>
-    public class JsonRPCClientRequestModel : JsonRPCRequestModel
-    {
-        public bool DontHideAfterAction { get; set; }
-    }
-
+    public record JsonRPCClientRequestModel(
+        int Id,
+        string Method,
+        object[] Parameters,
+        IReadOnlyDictionary<string, object> Settings,
+        bool DontHideAfterAction = false,
+        JsonRPCErrorModel Error = default) : JsonRPCRequestModel(Id, Method, Parameters, Settings, Error);
+
+
     /// <summary>
     /// Represent the json-rpc result item that client send to Flow Launcher
     /// Typically, we will send back this request model to client after user select the result item

Flow.Launcher.Core/Plugin/JsonRPCModelContext.cs

@@ -0,0 +1,21 @@
+using System.Text.Json.Serialization;
+
+namespace Flow.Launcher.Core.Plugin
+{
+    // TODO: After Upgrading to .Net 7, adding Source Generating Context for IAsyncEnumerable JsonRPCMessage
+
+    [JsonSerializable(typeof(JsonRPCQueryResponseModel))]
+    public partial class JsonRPCQueryResponseModelContext : JsonSerializerContext
+    {
+    }
+
+    [JsonSerializable(typeof(JsonRPCRequestModel))]
+    public partial class JsonRPCRequestModelContext : JsonSerializerContext
+    {
+    }
+
+    [JsonSerializable(typeof(JsonRPCClientRequestModel))]
+    public partial class JsonRPCClientRequestModelContext : JsonSerializerContext
+    {
+    }
+}