inject the widget assembly into the IoC as we are going to need it further in

2024-01-27 16:21:53 +00:00
parent 48925b89ff
commit 640b3292b2
16 changed files with 105 additions and 64 deletions
@@ -0,0 +1,41 @@
+using Microsoft.Extensions.Hosting;
+using System.Reflection;
+using System.Runtime.Loader;
+
+namespace Hyperbar.Widget;
+
+public class WidgetExtensionEnumerator(IFactory<Type, IWidget> factory,
+    IHostEnvironment hostEnvironment, 
+    IMediator mediator) :
+    INotificationHandler<Enumerate<WidgetExtension>>
+{
+    public Task Handle(Enumerate<WidgetExtension> notification, 
+        CancellationToken cancellationToken)
+    {
+        string extensionsDirectory = Path.Combine(hostEnvironment.ContentRootPath, "Extensions");
+        if (Directory.Exists(extensionsDirectory))
+        {
+            List<string> assemblyPaths =
+            [
+                .. Directory.GetDirectories(extensionsDirectory)
+                                .AsParallel()
+                                .SelectMany(assemblyDirectory => Directory.GetFiles(assemblyDirectory, "*.dll"))
+            ];
+
+            Parallel.ForEach(assemblyPaths, async (string assemblyPath) =>
+            {
+                Assembly assembly = AssemblyLoadContext.Default.LoadFromAssemblyPath(assemblyPath);
+                foreach (Type widgetType in assembly.GetTypes().Where(x => typeof(IWidget).IsAssignableFrom(x)))
+                {
+                    if (factory.Create(widgetType) is IWidget widget)
+                    {
+                        await mediator.PublishAsync(new Created<WidgetExtension>(new WidgetExtension(widget, 
+                            new WidgetAssembly(assembly))), cancellationToken);
+                    }
+                }
+            });
+        }
+
+        return Task.CompletedTask;
+    }
+}