dan/Toolkit2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Stuff for tunesync

Browse Source
This commit is contained in:
Dan Clark
2024-11-16 19:46:25 +00:00
parent 0865e7da89
commit b5bf17821c
27 changed files with 562 additions and 58 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Toolkit.Foundation/HandlerInitialization.cs
+9 -1
View File
@@ -11,7 +11,15 @@ public class HandlerInitialization<TMessage, TResponse, THandler>(IServiceProvid
(provider, args) => args.Reply(provider.GetRequiredService<THandler>().Handle(args.Message)));
}
public class HandlerInitialization<TMessage, THandler>(string key, IServiceProvider provider) :
public class HandlerInitialization<TMessage, THandler>(IServiceProvider provider) :
IInitialization where THandler : class, IHandler<TMessage>
where TMessage : class
{
public void Initialize() => WeakReferenceMessenger.Default.Register<IServiceProvider, TMessage>(provider,
(provider, args) => provider.GetRequiredService<THandler>().Handle(args));
}
public class HandlerKeyedInitialization<TMessage, THandler>(string key, IServiceProvider provider) :
IInitialization where THandler : class, IHandler<TMessage>
where TMessage : class
{
Toolkit.Foundation/IServiceCollectionExtensions.cs
+35 -23
View File
@@ -4,6 +4,28 @@ namespace Toolkit.Foundation;
public static class IServiceCollectionExtensions
{
public static IServiceCollection AddAsyncHandler<TMessage, TResponse, THandler>(this IServiceCollection services,
ServiceLifetime lifetime = ServiceLifetime.Transient)
where THandler : class, IAsyncHandler<TMessage, TResponse>
where TMessage : class
{
services.Add(new ServiceDescriptor(typeof(THandler), typeof(THandler), lifetime));
services.AddInitialization<AsyncHandlerInitialization<TMessage, TResponse, THandler>>();
return services;
}
public static IServiceCollection AddAsyncHandler<TMessage, THandler>(this IServiceCollection services,
ServiceLifetime lifetime = ServiceLifetime.Transient)
where THandler : class, IAsyncHandler<TMessage>
where TMessage : class
{
services.Add(new ServiceDescriptor(typeof(THandler), typeof(THandler), lifetime));
services.AddInitialization<AsyncHandlerInitialization<TMessage, THandler>>();
return services;
}
public static IServiceCollection AddAsyncInitialization<TInitialization>(this IServiceCollection services)
where TInitialization : class,
IAsyncInitialization
@@ -49,28 +71,6 @@ public static class IServiceCollectionExtensions
return services;
}
public static IServiceCollection AddAsyncHandler<TMessage, TResponse, THandler>(this IServiceCollection services,
ServiceLifetime lifetime = ServiceLifetime.Transient)
where THandler : class, IAsyncHandler<TMessage, TResponse>
where TMessage : class
{
services.Add(new ServiceDescriptor(typeof(THandler), typeof(THandler), lifetime));
services.AddInitialization<AsyncHandlerInitialization<TMessage, TResponse, THandler>>();
return services;
}
public static IServiceCollection AddAsyncHandler<TMessage, THandler>(this IServiceCollection services,
ServiceLifetime lifetime = ServiceLifetime.Transient)
where THandler : class, IAsyncHandler<TMessage>
where TMessage : class
{
services.Add(new ServiceDescriptor(typeof(THandler), typeof(THandler), lifetime));
services.AddInitialization<AsyncHandlerInitialization<TMessage, THandler>>();
return services;
}
public static IServiceCollection AddHandler<TMessage, THandler>(this IServiceCollection services,
string key)
where THandler : class, IHandler<TMessage>
@@ -85,7 +85,7 @@ public static class IServiceCollectionExtensions
if (key is { Length: > 0})
{
services.Add(new ServiceDescriptor(typeof(THandler), key, typeof(THandler), lifetime));
services.AddInitialization<HandlerInitialization<TMessage, THandler>>(key);
services.AddInitialization<HandlerKeyedInitialization<TMessage, THandler>>(key);
}
else
{
@@ -96,6 +96,18 @@ public static class IServiceCollectionExtensions
return services;
}
public static IServiceCollection AddInitialization<TInitialization, TInitializationImplementation>(this IServiceCollection services,
ServiceLifetime lifetime = ServiceLifetime.Transient)
where TInitialization : class,
IInitialization
where TInitializationImplementation : class,
TInitialization
{
services.Add(new ServiceDescriptor(typeof(TInitialization), typeof(TInitializationImplementation), lifetime));
services.AddTransient<IInitialization>(provider => provider.GetRequiredService<TInitialization>());
return services;
}
public static IServiceCollection AddInitialization<TInitialization>(this IServiceCollection services)
where TInitialization : class,
IInitialization
Toolkit.Foundation/ResponseEventArgs.cs
+1 -1
View File
@@ -5,5 +5,5 @@ namespace Toolkit.Foundation;
public class ResponseEventArgs<TMessage, TResponse> :
RequestMessage<TResponse>
{
public TMessage? Message { get; set; }
public required TMessage Message { get; set; }
}