feat: migrate load script runner plugins

Directory.Packages.props

@@ -11,6 +11,7 @@
         <PackageVersion Include="Microsoft.AspNetCore.Authentication.JwtBearer" Version="9.0.1"/>
         <PackageVersion Include="Microsoft.AspNetCore.SpaServices.Extensions" Version="9.0.1"/>
         <PackageVersion Include="Microsoft.AspNetCore.OpenApi" Version="9.0.1"/>
+        <PackageVersion Include="Microsoft.Extensions.DependencyInjection" Version="9.0.3"/>
         <PackageVersion Include="Microsoft.Extensions.Diagnostics.HealthChecks" Version="9.0.1"/>
         <PackageVersion Include="Microsoft.Extensions.Logging.Abstractions" Version="9.0.2"/>
         <PackageVersion Include="Microsoft.Extensions.Options.ConfigurationExtensions" Version="9.0.2"/>

ScriptBee.sln

@@ -53,6 +53,12 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Persistence.File", "src\Ada
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Persistence.File.Tests", "test\Adapters\Driven\Persistence.File.Tests\Persistence.File.Tests.csproj", "{86A8C10D-0701-4D44-BEAB-0982C0D733A2}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Ports.Plugins", "src\Application\Ports\Driven\Ports.Plugins\Ports.Plugins.csproj", "{FC474598-6399-46E2-8795-394E4F806052}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Persistence.InMemory", "src\Adapters\Driven\Persistence.InMemory\Persistence.InMemory.csproj", "{0426847C-4B33-434E-AC93-7C8C95AB5506}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Persistence.InMemory.Tests", "test\Adapters\Driven\Persistence.InMemory.Tests\Persistence.InMemory.Tests.csproj", "{348FE904-F636-4113-B63E-044B645F64C7}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -163,5 +169,17 @@ Global
 		{86A8C10D-0701-4D44-BEAB-0982C0D733A2}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{86A8C10D-0701-4D44-BEAB-0982C0D733A2}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{86A8C10D-0701-4D44-BEAB-0982C0D733A2}.Release|Any CPU.Build.0 = Release|Any CPU
+		{FC474598-6399-46E2-8795-394E4F806052}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{FC474598-6399-46E2-8795-394E4F806052}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{FC474598-6399-46E2-8795-394E4F806052}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{FC474598-6399-46E2-8795-394E4F806052}.Release|Any CPU.Build.0 = Release|Any CPU
+		{0426847C-4B33-434E-AC93-7C8C95AB5506}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{0426847C-4B33-434E-AC93-7C8C95AB5506}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{0426847C-4B33-434E-AC93-7C8C95AB5506}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{0426847C-4B33-434E-AC93-7C8C95AB5506}.Release|Any CPU.Build.0 = Release|Any CPU
+		{348FE904-F636-4113-B63E-044B645F64C7}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{348FE904-F636-4113-B63E-044B645F64C7}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{348FE904-F636-4113-B63E-044B645F64C7}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{348FE904-F636-4113-B63E-044B645F64C7}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 EndGlobal

calculation.Dockerfile

@@ -15,10 +15,12 @@ COPY src/Application/Domain/Service.Analysis src/Application/Domain/Service.Anal
 COPY src/Application/Ports/Driving/UseCases.Analysis src/Application/Ports/Driving/UseCases.Analysis
 COPY src/Application/Ports/Driven/Ports.Analysis src/Application/Ports/Driven/Ports.Analysis
 COPY src/Application/Ports/Driven/Ports.Files src/Application/Ports/Driven/Ports.Files
+COPY src/Application/Ports/Driven/Ports.Plugins src/Application/Ports/Driven/Ports.Plugins
 COPY src/Application/Ports/Driven/Ports.Project src/Application/Ports/Driven/Ports.Project
 
-COPY src/Adapters/Driven/Persistence.Mongodb src/Adapters/Driven/Persistence.Mongodb
 COPY src/Adapters/Driven/Persistence.File src/Adapters/Driven/Persistence.File
+COPY src/Adapters/Driven/Persistence.InMemory src/Adapters/Driven/Persistence.InMemory
+COPY src/Adapters/Driven/Persistence.Mongodb src/Adapters/Driven/Persistence.Mongodb
 
 COPY src/Adapters/Driving/Common.Web src/Adapters/Driving/Common.Web
 COPY src/Adapters/Driving/Calculation.Web src/Adapters/Driving/Calculation.Web

src/Adapters/Driven/Persistence.InMemory/Persistence.InMemory.csproj

@@ -0,0 +1,13 @@
+<Project Sdk="Microsoft.NET.Sdk">
+    <PropertyGroup>
+        <RootNamespace>ScriptBee.Persistence.InMemory</RootNamespace>
+    </PropertyGroup>
+
+    <ItemGroup>
+        <ProjectReference Include="..\..\..\Application\Ports\Driven\Ports.Plugins\Ports.Plugins.csproj" />
+    </ItemGroup>
+
+    <ItemGroup>
+        <PackageReference Include="Microsoft.Extensions.DependencyInjection" />
+    </ItemGroup>
+</Project>

src/Adapters/Driven/Persistence.InMemory/PluginRepository.cs

@@ -0,0 +1,91 @@
+using System.Collections.Concurrent;
+using DxWorks.ScriptBee.Plugin.Api;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.DependencyInjection.Extensions;
+using ScriptBee.Domain.Model.Plugin;
+using ScriptBee.Domain.Model.Plugin.Manifest;
+using ScriptBee.Ports.Plugins;
+
+namespace ScriptBee.Persistence.InMemory;
+
+public class PluginRepository : IPluginRepository
+{
+    private readonly ConcurrentDictionary<string, Plugin> _plugins = new();
+    private readonly ConcurrentBag<ServiceDescriptor> _pluginServiceCollection = [];
+
+    public void UnRegisterPlugin(string pluginId, string pluginVersion)
+    {
+        _plugins.Remove(pluginId, out _);
+    }
+
+    public void RegisterPlugin(Plugin plugin, Type @interface, Type concrete)
+    {
+        RegisterPlugin(plugin);
+
+        _pluginServiceCollection.Add(
+            new ServiceDescriptor(@interface, concrete, ServiceLifetime.Singleton)
+        );
+    }
+
+    public void RegisterPlugin(Plugin plugin)
+    {
+        _plugins.AddOrUpdate(
+            plugin.Id,
+            plugin,
+            (_, manifest) => manifest.Version < plugin.Version ? plugin : manifest
+        );
+    }
+
+    public TService? GetPlugin<TService>(
+        Func<TService, bool> filter,
+        IEnumerable<(Type @interface, object instance)>? services = null
+    )
+        where TService : IPlugin
+    {
+        return GetPlugins<TService>().FirstOrDefault(filter);
+    }
+
+    public IEnumerable<TService> GetPlugins<TService>(
+        IEnumerable<(Type @interface, object instance)>? services = null
+    )
+        where TService : IPlugin
+    {
+        var serviceCollection = new ServiceCollection { _pluginServiceCollection };
+
+        if (services is not null)
+            serviceCollection.Add(
+                services.Select(s => new ServiceDescriptor(s.@interface, s.instance))
+            );
+
+        return serviceCollection.BuildServiceProvider().GetServices<TService>();
+    }
+
+    public IEnumerable<PluginManifest> GetLoadedPluginsManifests()
+    {
+        return GetLoadedPlugins().Select(plugin => plugin.Manifest);
+    }
+
+    public IEnumerable<Plugin> GetLoadedPlugins(string kind)
+    {
+        return GetLoadedPlugins()
+            .Where(plugin =>
+                plugin.Manifest.ExtensionPoints.Any(extensionPoint => extensionPoint.Kind == kind)
+            );
+    }
+
+    public IEnumerable<T> GetLoadedPluginExtensionPoints<T>()
+        where T : PluginExtensionPoint
+    {
+        return GetLoadedPlugins().SelectMany(p => p.Manifest.ExtensionPoints).OfType<T>();
+    }
+
+    public Version? GetInstalledPluginVersion(string pluginId)
+    {
+        return _plugins.TryGetValue(pluginId, out var plugin) ? plugin.Version : null;
+    }
+
+    private IEnumerable<Plugin> GetLoadedPlugins()
+    {
+        return _plugins.Values;
+    }
+}

src/Adapters/Driving/Analysis.Web/Analysis.Web.csproj

@@ -10,6 +10,7 @@
 
     <ItemGroup>
         <ProjectReference Include="..\..\..\Common\Common.csproj" />
+        <ProjectReference Include="..\..\Driven\Persistence.InMemory\Persistence.InMemory.csproj" />
         <ProjectReference Include="..\Common.Web\Common.Web.csproj"/>
         <ProjectReference Include="..\..\..\Application\Domain\Service.Analysis\Service.Analysis.csproj" />
         <ProjectReference Include="..\..\..\Application\Ports\Driving\UseCases.Analysis\UseCases.Analysis.csproj"/>

src/Adapters/Driving/Analysis.Web/Extensions/PluginsConfigExtensions.cs

@@ -0,0 +1,12 @@
+using ScriptBee.Persistence.InMemory;
+using ScriptBee.Ports.Plugins;
+
+namespace ScriptBee.Analysis.Web.Extensions;
+
+public static class PluginsConfigExtensions
+{
+    public static IServiceCollection AddPluginsConfig(this IServiceCollection services)
+    {
+        return services.AddSingleton<IPluginRepository, PluginRepository>();
+    }
+}

src/Adapters/Driving/Analysis.Web/Program.cs

@@ -20,7 +20,8 @@
     .AddProblemDetailsDefaults()
     .AddMongoDb(mongoConnectionString)
     .AddCommonServices()
-    .AddFileConfig(userFolderConfigurationSection);
+    .AddFileConfig(userFolderConfigurationSection)
+    .AddPluginsConfig();
 
 builder.Services.AddEndpointDefinitions(
     typeof(IEndpointDefinition),

ScriptBee/Plugin/Manifest/HelperFunctionsPluginExtensionPoint.cs → src/Application/Domain/Model/Plugin/Manifest/HelperFunctionsPluginExtensionPoint.cs

@@ -1,5 +1,3 @@
-namespace ScriptBee.Plugin.Manifest;
+namespace ScriptBee.Domain.Model.Plugin.Manifest;
 
-public class HelperFunctionsPluginExtensionPoint : PluginExtensionPoint
-{
-}
+public class HelperFunctionsPluginExtensionPoint : PluginExtensionPoint { }

src/Application/Domain/Model/Plugin/Manifest/LinkerPluginExtensionPoint.cs

@@ -0,0 +1,3 @@
+namespace ScriptBee.Domain.Model.Plugin.Manifest;
+
+public class LinkerPluginExtensionPoint : PluginExtensionPoint { }

src/Application/Domain/Model/Plugin/Manifest/LoaderPluginExtensionPoint.cs

@@ -0,0 +1,3 @@
+namespace ScriptBee.Domain.Model.Plugin.Manifest;
+
+public class LoaderPluginExtensionPoint : PluginExtensionPoint { }

src/Application/Domain/Model/Plugin/Manifest/PluginBundleExtensionPoint.cs

@@ -0,0 +1,3 @@
+namespace ScriptBee.Domain.Model.Plugin.Manifest;
+
+public class PluginBundleExtensionPoint : PluginExtensionPoint { }

ScriptBee/Plugin/Manifest/PluginExtensionPoint.cs → src/Application/Domain/Model/Plugin/Manifest/PluginExtensionPoint.cs

@@ -1,4 +1,4 @@
-namespace ScriptBee.Plugin.Manifest;
+namespace ScriptBee.Domain.Model.Plugin.Manifest;
 
 public abstract class PluginExtensionPoint
 {

ScriptBee/Plugin/Manifest/PluginKind.cs → src/Application/Domain/Model/Plugin/Manifest/PluginKind.cs

@@ -1,4 +1,4 @@
-namespace ScriptBee.Plugin.Manifest;
+namespace ScriptBee.Domain.Model.Plugin.Manifest;
 
 public static class PluginKind
 {

ScriptBee/Plugin/Manifest/PluginManifest.cs → src/Application/Domain/Model/Plugin/Manifest/PluginManifest.cs

@@ -1,6 +1,4 @@
-using System.Collections.Generic;
-
-namespace ScriptBee.Plugin.Manifest;
+namespace ScriptBee.Domain.Model.Plugin.Manifest;
 
 public class PluginManifest
 {

ScriptBee/Plugin/Manifest/ScriptGeneratorPluginExtensionPoint.cs → src/Application/Domain/Model/Plugin/Manifest/ScriptGeneratorPluginExtensionPoint.cs

@@ -1,4 +1,4 @@
-namespace ScriptBee.Plugin.Manifest;
+namespace ScriptBee.Domain.Model.Plugin.Manifest;
 
 public class ScriptGeneratorPluginExtensionPoint : PluginExtensionPoint
 {

ScriptBee/Plugin/Manifest/ScriptRunnerPluginExtensionPoint.cs → src/Application/Domain/Model/Plugin/Manifest/ScriptRunnerPluginExtensionPoint.cs

@@ -1,4 +1,4 @@
-namespace ScriptBee.Plugin.Manifest;
+namespace ScriptBee.Domain.Model.Plugin.Manifest;
 
 public class ScriptRunnerPluginExtensionPoint : PluginExtensionPoint
 {