Improve loading of widgets

This commit is contained in:
TheXamlGuy
2024-01-21 19:59:32 +00:00
parent 45070dc560
commit c07eafc9cf
49 changed files with 471 additions and 254 deletions
+3 -4
View File
@@ -10,14 +10,13 @@ public class PrimaryWidget :
{
args.Id = Guid.Parse("cfdfe07c-d9d6-4174-ae41-988ca24d2e10");
args.Name = "Primary commands";
}).ConfigureServices(args =>
}).ConfigureServices(services =>
{
args.AddCache<(Guid ParentId, Guid Id), PrimaryCommandConfiguration>()
services.AddCache<(Guid ParentId, Guid Id), PrimaryCommandConfiguration>()
.AddCache<Guid, IWidgetComponentViewModel>()
.AddTransient<IProvider<PrimaryCommandConfiguration, IWidgetComponentViewModel?>, WidgetComponentProvider>()
.AddTransient<IFactory<PrimaryCommandConfiguration, IWidgetComponentViewModel?>, WidgetComponentFactory>()
.AddTransient<IEnumerator<IWidgetComponentViewModel>, WidgetComponentEnumerator>()
.AddTransient<IEnumerator<IWidgetComponentViewModel>, WidgetComponentEnumerationHandler>()
.AddWidgetTemplate<PrimaryWidgetViewModel>()
.AddHandler<PrimaryWidgetConfigurationHandler>();
});
@@ -20,66 +20,70 @@ public class PrimaryWidgetConfigurationHandler(IMediator mediator,
(Guid currentParentId, List<PrimaryCommandConfiguration> currentConfigurations) = stack.Pop();
foreach (PrimaryCommandConfiguration configuration in currentConfigurations)
{
items.Add(new KeyValuePair<(Guid ParentId, Guid Id), PrimaryCommandConfiguration>((currentParentId, configuration.Id), configuration));
if (configuration.Commands is not null && configuration.Commands.Count > 0)
var key = (currentParentId, configuration.Id);
items.Add(new KeyValuePair<(Guid ParentId, Guid Id), PrimaryCommandConfiguration>(key, configuration));
if (configuration.Commands?.Count > 0)
{
stack.Push((configuration.Id, configuration.Commands));
}
}
}
foreach (KeyValuePair<(Guid ParentId, Guid Id), PrimaryCommandConfiguration> moved in
items.ExceptBy(cache.Select(x => new { x.Value.Order, x.Value.Id }), x => new { x.Value.Order, x.Value.Id }))
HashSet<Guid> cacheIds = new(cache.Select(x => x.Key.Id));
HashSet<Guid> itemIds = new(items.Select(x => x.Key.Id));
List<KeyValuePair<(Guid ParentId, Guid Id), PrimaryCommandConfiguration>> movedItems =
items.ExceptBy(cache.Select(x => new { x.Value.Order, x.Value.Id }), x =>
new { x.Value.Order, x.Value.Id }).ToList();
foreach (KeyValuePair<(Guid ParentId, Guid Id), PrimaryCommandConfiguration> moved in movedItems)
{
if (moved.Value is PrimaryCommandConfiguration configuration)
if (moved.Value is PrimaryCommandConfiguration configuration &&
provider.Get(configuration) is IWidgetComponentViewModel viewModel)
{
if (provider.Get(configuration) is IWidgetComponentViewModel viewModel)
{
await mediator.PublishAsync(new Moved<IWidgetComponentViewModel>(configuration.Order, viewModel),
moved.Key.ParentId == Guid.Empty ? nameof(PrimaryWidgetViewModel) : moved.Key.ParentId,
cancellationToken);
await mediator.PublishAsync(
new Moved<IWidgetComponentViewModel>(configuration.Order, viewModel),
moved.Key.ParentId == Guid.Empty ? nameof(PrimaryWidgetViewModel) : moved.Key.ParentId,
cancellationToken
);
cache.Remove(moved.Key);
cache.Add(moved.Key, moved.Value);
}
cache.Remove(moved.Key);
cache.Add(moved.Key, moved.Value);
}
// // cache.Add(added.Key, added.Value);
//}
}
foreach (KeyValuePair<(Guid ParentId, Guid Id), PrimaryCommandConfiguration> added in
items.ExceptBy(cache.Select(x => x.Key.Id), x => x.Key.Id))
List<KeyValuePair<(Guid ParentId, Guid Id), PrimaryCommandConfiguration>> addedItems =
items.ExceptBy(cacheIds.Select(x => x), x => x.Key.Id).ToList();
foreach (KeyValuePair<(Guid ParentId, Guid Id), PrimaryCommandConfiguration> added in addedItems)
{
if (added.Value is PrimaryCommandConfiguration configuration)
if (added.Value is PrimaryCommandConfiguration configuration &&
factory.Create(configuration) is IWidgetComponentViewModel viewModel)
{
if (factory.Create(configuration) is IWidgetComponentViewModel viewModel)
{
await mediator.PublishAsync(new Inserted<IWidgetComponentViewModel>(configuration.Order, viewModel),
added.Key.ParentId == Guid.Empty ? nameof(PrimaryWidgetViewModel) : added.Key.ParentId,
cancellationToken);
}
await mediator.PublishAsync(
new Inserted<IWidgetComponentViewModel>(configuration.Order, viewModel),
added.Key.ParentId == Guid.Empty ? nameof(PrimaryWidgetViewModel) : added.Key.ParentId,
cancellationToken);
cache.Add(added.Key, added.Value);
}
}
foreach (KeyValuePair<(Guid ParentId, Guid Id), PrimaryCommandConfiguration> removed in
cache.ExceptBy(items.Select(x => x.Key.Id), x => x.Key.Id))
{
if (removed.Value is PrimaryCommandConfiguration configuration)
{
if (provider.Get(configuration) is IWidgetComponentViewModel viewModel)
{
await mediator.PublishAsync(new Removed<IWidgetComponentViewModel>(viewModel),
removed.Key.ParentId == Guid.Empty ? nameof(PrimaryWidgetViewModel) : removed.Key.ParentId,
cancellationToken);
List<KeyValuePair<(Guid ParentId, Guid Id), PrimaryCommandConfiguration>> removedItems =
cache.ExceptBy(itemIds.Select(x => x), x => x.Key.Id).ToList();
cache.Remove(removed.Key);
}
foreach (KeyValuePair<(Guid ParentId, Guid Id), PrimaryCommandConfiguration> removed in removedItems)
{
if (removed.Value is PrimaryCommandConfiguration configuration &&
provider.Get(configuration) is IWidgetComponentViewModel viewModel)
{
await mediator.PublishAsync(
new Removed<IWidgetComponentViewModel>(viewModel),
removed.Key.ParentId == Guid.Empty ? nameof(PrimaryWidgetViewModel) : removed.Key.ParentId,
cancellationToken);
cache.Remove(removed.Key);
}
}
}
@@ -1,11 +1,11 @@
namespace Hyperbar.Windows.Primary;
public class WidgetComponentEnumerator(PrimaryWidgetConfiguration configuration,
public class WidgetComponentEnumerationHandler(PrimaryWidgetConfiguration configuration,
IFactory<PrimaryCommandConfiguration, IWidgetComponentViewModel?> factory,
ICache<(Guid ParentId, Guid Id), PrimaryCommandConfiguration> cache) :
IEnumerator<IWidgetComponentViewModel>
{
public IEnumerable<IWidgetComponentViewModel?> Next()
public IEnumerable<IWidgetComponentViewModel?> Get()
{
Stack<(Guid, List<PrimaryCommandConfiguration>)> stack = new();
stack.Push((Guid.Empty, configuration.Commands));
+30 -12
View File
@@ -1,10 +1,12 @@
using Hyperbar.Windows.Controls;
using Hyperbar.Windows.Interop;
using Hyperbar.Windows.UI;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Configuration.Json;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Microsoft.UI.Xaml;
using System;
using System.Reflection;
namespace Hyperbar.Windows;
@@ -27,24 +29,40 @@ public partial class App :
})
.ConfigureServices((context, services) =>
{
services.AddSingleton<IServiceFactory>(provider =>
new ServiceFactory((type, parameters) => ActivatorUtilities.CreateInstance(provider, type, parameters!)));
services.AddSingleton<IMediator, Mediator>();
services.AddSingleton<IDisposer, Disposer>();
services.AddSingleton<IDispatcher, Dispatcher>();
services.AddDefault();
services.AddHostedService<AppService>();
services.AddConfiguration<AppConfiguration>(args => { args.Placement = DesktopBarPlacemenet.Top; });
services.AddTransient<IInitializer, AppInitializer>();
services.AddSingleton<IDispatcher, Dispatcher>();
services.AddTransient<ITemplateFactory, TemplateFactory>();
services.AddSingleton<DesktopBar>();
services.AddContentTemplate<WidgetBarViewModel, WidgetBarView>();
services.AddTransient<IInitializer, AppInitializer>();
services.AddHandler<AppConfigurationChangedHandler>();
services.AddConfiguration<AppConfiguration>(args =>
{
args.Placement = DesktopBarPlacemenet.Top;
});
services.AddSingleton<DesktopBar>();
services.AddContentTemplate<WidgetBarViewModel, WidgetBarView>();
services.AddTransient<IWidgetServiceCollection>(provider =>
new WidgetServiceCollection(services =>
{
services.AddSingleton<IDispatcher, Dispatcher>();
services.AddTransient<ITemplateFactory, TemplateFactory>();
services.AddScoped<IVirtualKeyboard, VirtualKeyboard>();
services.AddHandler<KeyAcceleratorHandler>();
services.AddHandler<StartProcessHandler>();
services.AddTransient<IWidgetView, WidgetView>();
services.AddContentTemplate<WidgetContainerViewModel, WidgetContainerView>();
services.AddContentTemplate<WidgetButtonViewModel, WidgetButtonView>();
services.AddContentTemplate<WidgetSplitButtonViewModel, WidgetSplitButtonView>();
}));
//services.AddWidget<MediaControllerWidgetBuilder>();
//services.AddWidget<PrimaryWidget>();
@@ -3,59 +3,57 @@ using Hyperbar.Windows.UI;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Microsoft.UI.Dispatching;
namespace Hyperbar.Windows
{
public static class IServiceCollectionExtensions
{
public static IServiceCollection AddWidget<TWidget>(this IServiceCollection services)
where TWidget :
IWidget,
new()
{
IHost? host = new HostBuilder()
.UseContentRoot(AppContext.BaseDirectory)
.ConfigureAppConfiguration(config =>
{
config.SetBasePath(AppContext.BaseDirectory);
config.AddJsonFile("Settings.json", true, true);
//public static class IServiceCollectionExtensions
//{
// public static IServiceCollection AddWidget<TWidget>(this IServiceCollection services)
// where TWidget :
// IWidget,
// new()
// {
// IHost? host = new HostBuilder()
// .UseContentRoot(AppContext.BaseDirectory)
// .ConfigureAppConfiguration(config =>
// {
// config.SetBasePath(AppContext.BaseDirectory);
// config.AddJsonFile("Settings.json", true, true);
// })
// .ConfigureServices((context, isolatedServices) =>
// {
// isolatedServices.AddScoped<IServiceFactory>(provider =>
// new ServiceFactory((type, parameters) => ActivatorUtilities.CreateInstance(provider, type, parameters!)));
config.Build();
})
.ConfigureServices((context, isolatedServices) =>
{
isolatedServices.AddScoped<IServiceFactory>(provider =>
new ServiceFactory((type, parameters) => ActivatorUtilities.CreateInstance(provider, type, parameters!)));
// isolatedServices.AddHostedService<WidgetService>();
// isolatedServices.AddTransient<ITemplateFactory, TemplateFactory>();
isolatedServices.AddHostedService<WidgetService>();
isolatedServices.AddTransient<ITemplateFactory, TemplateFactory>();
// isolatedServices.AddScoped<IMediator, Mediator>();
// isolatedServices.AddScoped<IDisposer, Disposer>();
// isolatedServices.AddSingleton<IDispatcher, Dispatcher>();
isolatedServices.AddScoped<IMediator, Mediator>();
isolatedServices.AddScoped<IDisposer, Disposer>();
isolatedServices.AddSingleton<IDispatcher, Dispatcher>();
// isolatedServices.AddScoped<IVirtualKeyboard, VirtualKeyboard>();
isolatedServices.AddScoped<IVirtualKeyboard, VirtualKeyboard>();
// isolatedServices.AddHandler<KeyAcceleratorHandler>();
// isolatedServices.AddHandler<StartProcessHandler>();
isolatedServices.AddHandler<KeyAcceleratorHandler>();
isolatedServices.AddHandler<StartProcessHandler>();
// isolatedServices.AddTransient<IWidgetView, WidgetView>();
isolatedServices.AddTransient<IWidgetView, WidgetView>();
// isolatedServices.AddContentTemplate<WidgetContainerViewModel, WidgetContainerView>();
// isolatedServices.AddContentTemplate<WidgetButtonViewModel, WidgetButtonView>();
// isolatedServices.AddContentTemplate<WidgetSplitButtonViewModel, WidgetSplitButtonView>();
isolatedServices.AddContentTemplate<WidgetContainerViewModel, WidgetContainerView>();
isolatedServices.AddContentTemplate<WidgetButtonViewModel, WidgetButtonView>();
isolatedServices.AddContentTemplate<WidgetSplitButtonViewModel, WidgetSplitButtonView>();
// TWidget widget = new();
// IWidgetBuilder builder = widget.Create();
TWidget widget = new();
IWidgetBuilder builder = widget.Create();
isolatedServices.AddRange(builder.Services);
// isolatedServices.AddRange(builder.Services);
}).Build();
// }).Build();
services.AddTransient(provider => new WidgetContext(host.Services));
// services.AddTransient(provider => new WidgetContext(host.Services));
host.Start();
return services;
}
}
// host.Start();
// return services;
// }
//}
}
+1 -1
View File
@@ -3,7 +3,7 @@
public class Configuration<TConfiguration>(IConfigurationReader<TConfiguration> reader) :
IConfiguration<TConfiguration>
where TConfiguration :
class, new()
class
{
public TConfiguration Value => reader.Read();
}
@@ -0,0 +1,9 @@
namespace Hyperbar;
public class ConfigurationFactory<TConfiguration>(Func<TConfiguration> factory) :
IConfigurationFactory<TConfiguration>
where TConfiguration :
class
{
public TConfiguration Create() => factory.Invoke();
}
@@ -0,0 +1,11 @@
using Microsoft.Extensions.FileProviders;
namespace Hyperbar;
public class ConfigurationFile<TConfiguration>(IFileInfo fileInfo) :
IConfigurationFile<TConfiguration>
where TConfiguration :
class
{
public IFileInfo FileInfo => fileInfo;
}
@@ -1,23 +1,13 @@
namespace Hyperbar;
public class ConfigurationInitializer<TConfiguration>(DefaultConfiguration<TConfiguration> defaults,
IConfigurationReader<TConfiguration> reader,
IConfigurationWriter<TConfiguration> writer) :
public class ConfigurationInitializer<TConfiguration>(IConfigurationReader<TConfiguration> reader) :
IInitializer
where TConfiguration :
class,
new()
class
{
public Task InitializeAsync()
{
if (!reader.TryRead(out TConfiguration? _))
{
if (defaults.Configuration is not null)
{
writer.Write(defaults.Configuration);
}
}
reader.Read();
return Task.CompletedTask;
}
}
@@ -4,7 +4,7 @@ public class ConfigurationMonitor<TConfiguration>(IConfigurationFile<TConfigurat
IConfigurationReader<TConfiguration> reader,
IMediator mediator) : IInitializer
where TConfiguration :
class, new()
class
{
private FileSystemWatcher? watcher;
@@ -1,19 +1,19 @@
namespace Hyperbar;
public class ConfigurationReader<TConfiguration>(IConfigurationSource<TConfiguration> source) :
public class ConfigurationReader<TConfiguration>(IConfigurationSource<TConfiguration> source,
IConfigurationFactory<TConfiguration> factory) :
IConfigurationReader<TConfiguration>
where TConfiguration :
class, new()
class
{
public TConfiguration Read()
{
if ((source.TryGet(out TConfiguration? value) ? value :
new TConfiguration()) is TConfiguration configuration)
if ((source.TryGet(out TConfiguration? value) ? value : factory.Create()) is TConfiguration configuration)
{
return configuration;
}
return new TConfiguration();
return factory.Create();
}
public bool TryRead(out TConfiguration? configuration)
@@ -1,13 +1,15 @@
namespace Hyperbar;
public class ConfigurationWriter<TConfiguration>(IConfigurationSource<TConfiguration> source) :
public class ConfigurationWriter<TConfiguration>(IConfigurationSource<TConfiguration> source,
IConfigurationFactory<TConfiguration> factory) :
IConfigurationWriter<TConfiguration>
where TConfiguration :
class, new()
class
{
public void Write(Action<TConfiguration> updateDelegate)
{
if ((source.TryGet(out TConfiguration? value) ? value : new TConfiguration()) is TConfiguration updatedValue)
if ((source.TryGet(out TConfiguration? value) ? value :
factory.Create()) is TConfiguration updatedValue)
{
updateDelegate?.Invoke(updatedValue);
Write(updatedValue);
@@ -1,8 +0,0 @@
namespace Hyperbar;
public class DefaultConfiguration<TConfiguration>(TConfiguration? configuration = null)
where TConfiguration :
class
{
public TConfiguration? Configuration => configuration;
}
+1 -1
View File
@@ -2,7 +2,7 @@
public interface IConfiguration<out TConfiguration>
where TConfiguration :
class, new()
class
{
TConfiguration Value { get; }
}
@@ -0,0 +1,7 @@
namespace Hyperbar
{
public interface IConfigurationFactory<TConfiguration> where TConfiguration : class
{
TConfiguration Create();
}
}
@@ -0,0 +1,10 @@
using Microsoft.Extensions.FileProviders;
namespace Hyperbar;
public interface IConfigurationFile<TConfiguration>
where TConfiguration :
class
{
IFileInfo FileInfo { get; }
}
@@ -2,7 +2,7 @@
public interface IConfigurationReader<TConfiguration>
where TConfiguration :
class, new()
class
{
bool TryRead(out TConfiguration? configuration);
@@ -1,6 +1,4 @@
using Microsoft.Extensions.FileProviders;
namespace Hyperbar;
namespace Hyperbar;
public interface IConfigurationSource<TConfiguration>
where TConfiguration :
@@ -2,7 +2,7 @@
public interface IConfigurationWriter<TConfiguration>
where TConfiguration :
class, new()
class
{
void Write(Action<TConfiguration> updateDelegate);
@@ -2,7 +2,7 @@
public interface IWritableConfiguration<out TConfiguration>
where TConfiguration :
class, new()
class
{
void Write(Action<TConfiguration> updateDelegate);
}
@@ -3,7 +3,7 @@
public class WritableConfiguration<TConfiguration>(IConfigurationWriter<TConfiguration> writer) :
IWritableConfiguration<TConfiguration>
where TConfiguration :
class, new()
class
{
public void Write(Action<TConfiguration> updateDelegate) => writer.Write(updateDelegate);
}
@@ -7,23 +7,26 @@ using System.Text.Json;
namespace Hyperbar;
public interface IConfigurationFile<TConfiguration>
where TConfiguration :
class
{
IFileInfo FileInfo { get; }
}
public class ConfigurationFile<TConfiguration>(IFileInfo fileInfo) :
IConfigurationFile<TConfiguration>
where TConfiguration :
class
{
public IFileInfo FileInfo => fileInfo;
}
public static class IServiceCollectionExtensions
{
public static IServiceCollection AddDefault(this IServiceCollection services)
{
services.AddSingleton<IServiceFactory>(provider =>
new ServiceFactory((type, parameters) => ActivatorUtilities.CreateInstance(provider, type, parameters!)));
services.AddSingleton<IMediator, Mediator>();
services.AddSingleton<IDisposer, Disposer>();
services.AddTransient<IInitializer, WidgetInitializer>();
services.AddTransient<IFactory<Type, IWidget>, WidgetFactory>();
services.AddHandler<WidgetEnumerationHandler>();
services.AddHandler<WidgetAssemblyHandler>();
services.AddHandler<WidgetHandler>();
return services;
}
public static IServiceCollection AddCache<TKey, TValue>(this IServiceCollection services)
where TKey :
notnull
@@ -46,38 +49,45 @@ public static class IServiceCollectionExtensions
public static IServiceCollection AddConfiguration<TConfiguration>(this IServiceCollection services)
where TConfiguration :
class, new()
{
return services.AddConfiguration<TConfiguration>(typeof(TConfiguration).Name, "Settings.json", null);
}
class => services.AddConfiguration<TConfiguration>(typeof(TConfiguration).Name,
"Settings.json",
null);
public static IServiceCollection AddConfiguration<TConfiguration>(this IServiceCollection services,
Action<TConfiguration> configurationDelegate)
where TConfiguration :
class, new()
class,
new()
{
TConfiguration configuration = new();
configurationDelegate.Invoke(configuration);
return services.AddConfiguration<TConfiguration>(typeof(TConfiguration).Name, "Settings.json",
return services.AddConfiguration<TConfiguration>(typeof(TConfiguration).Name,
"Settings.json",
configuration);
}
public static IServiceCollection AddConfiguration<TConfiguration>(this IServiceCollection services,
TConfiguration? defaults = null)
TConfiguration configuration)
where TConfiguration :
class, new()
{
return services.AddConfiguration(typeof(TConfiguration).Name, "Settings.json", defaults);
}
class => services.AddConfiguration<TConfiguration>(configuration.GetType().Name,
"Settings.json",
configuration);
public static IServiceCollection AddConfiguration<TConfiguration>(this IServiceCollection services,
object configuration)
where TConfiguration :
class => services.AddConfiguration<TConfiguration>(configuration.GetType().Name,
"Settings.json",
(TConfiguration?)configuration);
public static IServiceCollection AddConfiguration<TConfiguration>(this IServiceCollection services,
string section,
string path = "Settings.json",
TConfiguration? defaults = null,
object? configuration = null,
Action<JsonSerializerOptions>? serializerDelegate = null)
where TConfiguration :
class, new()
class
{
services.AddSingleton<IConfigurationSource<TConfiguration>>(provider =>
{
@@ -109,7 +119,17 @@ public static class IServiceCollectionExtensions
services.AddSingleton<IConfigurationReader<TConfiguration>, ConfigurationReader<TConfiguration>>();
services.AddSingleton<IConfigurationWriter<TConfiguration>, ConfigurationWriter<TConfiguration>>();
services.AddTransient(provider => new DefaultConfiguration<TConfiguration>(defaults));
if (configuration is not null)
{
services.AddTransient(typeof(TConfiguration), provider => configuration);
}
services.AddTransient<IConfigurationFactory<TConfiguration>>(provider => new ConfigurationFactory<TConfiguration>(() =>
{
var fo = configuration ?? provider.GetRequiredService<TConfiguration>();
return (TConfiguration)fo;
}));
services.AddTransient<IInitializer, ConfigurationInitializer<TConfiguration>>();
services.AddTransient<IWritableConfiguration<TConfiguration>, WritableConfiguration<TConfiguration>>();
@@ -134,7 +154,12 @@ public static class IServiceCollectionExtensions
services.AddKeyedTransient(contentType, key);
services.AddKeyedTransient(templateType, key);
services.AddTransient<IContentTemplateDescriptor>(provider => new ContentTemplateDescriptor { ContentType = contentType, TemplateType = templateType, Key = key });
services.AddTransient<IContentTemplateDescriptor>(provider => new ContentTemplateDescriptor
{
ContentType = contentType,
TemplateType = templateType,
Key = key
});
return services;
}
@@ -1,4 +1,3 @@
namespace Hyperbar;
public record Changed<TValue>(TValue? Value = default) : INotification;
public record Changed<TValue>(TValue? Value = default) : INotification;
+3
View File
@@ -0,0 +1,3 @@
namespace Hyperbar;
public record Created<TValue>(TValue Value, object? Target = null) : INotification;
+3
View File
@@ -0,0 +1,3 @@
namespace Hyperbar;
public record Enumerate<TValue> : INotification;
-9
View File
@@ -1,9 +0,0 @@
namespace Hyperbar;
public record Created<TValue>(TValue Value, object Target) : INotification
{
public static Created<TValue> For<TTarget>(TValue value)
{
return new Created<TValue>(value, typeof(TTarget).Name);
}
}
+1 -1
View File
@@ -2,5 +2,5 @@
public interface IEnumerator<TItem>
{
IEnumerable<TItem?> Next();
IEnumerable<TItem?> Get();
}
@@ -50,7 +50,7 @@ public partial class ObservableCollectionViewModel<TItem> :
if (enumerator is not null)
{
foreach (TItem? item in enumerator.Next())
foreach (TItem? item in enumerator.Get())
{
if (item is not null)
{
@@ -1,6 +0,0 @@
namespace Hyperbar
{
public interface IWidgetAssemblyLoader
{
}
}
+2 -2
View File
@@ -4,7 +4,7 @@ namespace Hyperbar;
public interface IWidgetBuilder
{
WidgetConfiguration Configuration { get; }
IWidgetBuilder ConfigureServices(Action<IServiceCollection> configureDelegate);
IServiceCollection Services { get; }
IWidgetHost Build();
}
+6 -28
View File
@@ -1,35 +1,13 @@
using Microsoft.Extensions.DependencyInjection;
using System.Reflection;
using System.Runtime.Loader;
namespace Hyperbar;
public class AssemblyProvider
{
public static void Load()
{
string extensionsPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Extensions");
Directory.CreateDirectory(extensionsPath);
}
public static IEnumerable<Assembly> Get(string path)
{
string extensionsPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Extensions");
Directory.CreateDirectory(extensionsPath);
foreach (string assemblyPath in Directory.GetFiles(extensionsPath, "*.dll", SearchOption.AllDirectories))
{
yield return AssemblyLoadContext.Default.LoadFromAssemblyPath(assemblyPath);
}
}
}
public static class IWidgetBuilderExtensions
{
public static IWidgetBuilder ConfigureServices(this IWidgetBuilder builder,
Action<IServiceCollection> servicesDelegate)
{
servicesDelegate(builder.Services);
return builder;
}
//public static IWidgetBuilder ConfigureServices(this IWidgetBuilder builder,
// Action<IServiceCollection> servicesDelegate)
//{
// servicesDelegate(builder.Services);
// return builder;
//}
}
+6
View File
@@ -0,0 +1,6 @@
namespace Hyperbar;
public interface IWidgetHost
{
}
@@ -0,0 +1,6 @@
namespace Hyperbar;
public interface IWidgetServiceBuilder
{
void ConfigureWidgetServices(IWidgetServiceCollection widgetServices);
}
@@ -0,0 +1,8 @@
using Microsoft.Extensions.DependencyInjection;
namespace Hyperbar;
public interface IWidgetServiceCollection
{
IServiceCollection Services { get; }
}
+6
View File
@@ -0,0 +1,6 @@
using System.Reflection;
namespace Hyperbar;
public record WidgetAssembly(Assembly? Assembly = default) :
INotification;
+23
View File
@@ -0,0 +1,23 @@
using System.Reflection;
namespace Hyperbar;
public class WidgetAssemblyHandler(IMediator mediator,
IFactory<Type, IWidget> factory) :
INotificationHandler<Created<Assembly>>
{
public Task Handle(Created<Assembly> notification,
CancellationToken cancellationToken)
{
if (notification.Value?.GetTypes().FirstOrDefault(x => typeof(IWidget).IsAssignableFrom(x)) is Type widgetType)
{
if (factory.Create(widgetType) is IWidget widget)
{
mediator.PublishAsync(new Created<IWidget>(widget),
cancellationToken);
}
}
return Task.CompletedTask;
}
}
+46 -6
View File
@@ -1,17 +1,42 @@
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using System.Reflection;
namespace Hyperbar;
public class WidgetBuilder(WidgetConfiguration configuration) :
IWidgetBuilder
public class WidgetBuilder :
IWidgetBuilder,
IWidgetServiceBuilder
{
public IServiceCollection Services => new ServiceCollection();
private readonly IHostBuilder hostBuilder;
public WidgetConfiguration Configuration => configuration;
public WidgetBuilder(IWidgetConfiguration configuration)
{
hostBuilder = new HostBuilder()
.UseContentRoot(Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.LocalApplicationData),
Assembly.GetEntryAssembly()?.GetName().Name!), true)
.ConfigureAppConfiguration(config =>
{
config.AddJsonFile("Settings.json", true, true);
})
.ConfigureServices((context, services) =>
{
services.AddScoped<IServiceFactory>(provider =>
new ServiceFactory((type, parameters) =>
ActivatorUtilities.CreateInstance(provider, type, parameters!)));
services.AddHostedService<WidgetService>();
services.AddScoped<IMediator, Mediator>();
services.AddScoped<IDisposer, Disposer>();
services.AddConfiguration<IWidgetConfiguration>(configuration);
});
}
public static IWidgetBuilder Configure<TWidgetConfiguration>(Action<TWidgetConfiguration> configurationDelegate)
where TWidgetConfiguration :
WidgetConfiguration,
IWidgetConfiguration,
new()
{
TWidgetConfiguration configuration = new();
@@ -19,4 +44,19 @@ public class WidgetBuilder(WidgetConfiguration configuration) :
return new WidgetBuilder(configuration);
}
public IWidgetHost Build()
{
IHost host = hostBuilder.Build();
return new WidgetHost(host);
}
public IWidgetBuilder ConfigureServices(Action<IServiceCollection> configureDelegate)
{
hostBuilder.ConfigureServices(configureDelegate.Invoke);
return this;
}
public void ConfigureWidgetServices(IWidgetServiceCollection widgetServices) =>
hostBuilder.ConfigureServices(services => services.AddRange(widgetServices.Services));
}
+11 -1
View File
@@ -1,6 +1,16 @@
namespace Hyperbar;
public abstract class WidgetConfiguration
public interface IWidgetConfiguration
{
Guid Id { get; set; }
string? Name { get; set; }
string? Description { get; set; }
}
public abstract class WidgetConfiguration :
IWidgetConfiguration
{
public Guid Id { get; set; } = Guid.NewGuid();
+10 -19
View File
@@ -1,30 +1,21 @@
namespace Hyperbar;
using Microsoft.Extensions.Hosting;
public class WidgetContext(IServiceProvider serviceProvider) :
IInitializer
namespace Hyperbar;
public class WidgetHost :
IWidgetHost
{
public IServiceProvider ServiceProvider => serviceProvider;
public Task InitializeAsync()
public WidgetHost(IHost host)
{
throw new NotImplementedException();
}
}
public class WidgetMonitor :
IInitializer
{
public Task InitializeAsync()
public void Start()
{
throw new NotImplementedException();
}
}
public class WidgetManager :
IInitializer
{
public Task InitializeAsync()
public void Stop()
{
throw new NotImplementedException();
}
}
@@ -0,0 +1,33 @@
using Microsoft.Extensions.Hosting;
using System.Reflection;
using System.Runtime.Loader;
namespace Hyperbar;
public class WidgetEnumerationHandler(IHostEnvironment hostEnvironment,
IMediator mediator) :
INotificationHandler<Enumerate<IWidget>>
{
public Task Handle(Enumerate<IWidget> 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, (string assemblyPath) =>
{
Assembly assembly = AssemblyLoadContext.Default.LoadFromAssemblyPath(assemblyPath);
mediator.PublishAsync(new Created<Assembly>(assembly));
});
}
return Task.CompletedTask;
}
}
-11
View File
@@ -1,11 +0,0 @@
namespace Hyperbar;
public class WidgetEnumerator() :
IEnumerator<IWidgetComponentViewModel>
{
public IEnumerable<IWidgetComponentViewModel?> Next()
{
return null;
}
}
+15
View File
@@ -0,0 +1,15 @@
namespace Hyperbar;
public class WidgetFactory :
IFactory<Type, IWidget>
{
public IWidget? Create(Type value)
{
if (Activator.CreateInstance(value) is IWidget widget)
{
return widget;
}
return default;
}
}
+23
View File
@@ -0,0 +1,23 @@
namespace Hyperbar;
public class WidgetHandler(IWidgetServiceCollection serviceCollection,
IMediator mediator) :
INotificationHandler<Created<IWidget>>
{
public Task Handle(Created<IWidget> notification,
CancellationToken cancellationToken)
{
if(notification.Value is IWidget widget)
{
IWidgetBuilder widgetBuilder = widget.Create();
if (widgetBuilder is IWidgetServiceBuilder serviceBuilder)
{
serviceBuilder.ConfigureWidgetServices(serviceCollection);
}
widgetBuilder.Build();
}
return Task.CompletedTask;
}
}
+11
View File
@@ -0,0 +1,11 @@
namespace Hyperbar;
public class WidgetInitializer(IMediator mediator) :
IInitializer
{
public Task InitializeAsync()
{
mediator.PublishAsync<Enumerate<IWidget>>();
return Task.CompletedTask;
}
}
+10
View File
@@ -0,0 +1,10 @@
namespace Hyperbar;
public class WidgetMonitor :
IInitializer
{
public Task InitializeAsync()
{
throw new NotImplementedException();
}
}
@@ -0,0 +1,15 @@
using Microsoft.Extensions.DependencyInjection;
namespace Hyperbar;
public class WidgetServiceCollection :
IWidgetServiceCollection
{
public WidgetServiceCollection(Action<IServiceCollection> configureDelegate)
{
Services = new ServiceCollection();
configureDelegate.Invoke(Services);
}
public IServiceCollection Services { get; private set; }
}