Files
2025-02-12 20:59:38 +00:00

35 lines
1.3 KiB
C#

using Microsoft.Extensions.DependencyInjection;
namespace Toolkit.Foundation;
public class ScopedServiceFactory<TScopedService>(IServiceScopeFactory serviceScopeFactory,
ICache<TScopedService, IServiceProvider> cache) :
IScopedServiceFactory<TScopedService>
where TScopedService : notnull
{
public (IServiceProvider, TScopedService) Create(params object?[] parameters)
{
if (serviceScopeFactory.CreateScope() is IServiceScope serviceScope)
{
IServiceProvider serviceProvider = serviceScope.ServiceProvider;
if (serviceProvider.GetRequiredService<IServiceFactory>() is IServiceFactory factory)
{
if (factory.Create<TScopedService>(parameters) is TScopedService service)
{
serviceProvider.GetRequiredService<IScopedServiceDescriptor<TScopedService>>().Set(service);
cache.Add(service, serviceProvider);
foreach (IInitializationScoped initializationScoped in serviceProvider.GetServices<IInitializationScoped>())
{
initializationScoped.Initialize();
}
return (serviceProvider, service);
}
}
}
return default;
}
}