- Register IAmazonS3 as a singleton instead of scoped: the AWS SDK client is thread-safe and manages its own connection pool, so one instance per DI scope (per request / per job iteration) was wasteful and risked socket exhaustion - AudioTranscoderService: start reading stdout/stderr before writing stdin to remove the latent pipe-buffer deadlock shape - Dispose the resized-picture MemoryStream in ResizePictureActivity - Background jobs use PeriodicTimer instead of while + Task.Delay Verified: Worker boots against RabbitMQ + Postgres in Docker with no captive- dependency error (dev scope validation) and both jobs start. Build: 0 warnings, 0 errors. Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
91 lines
4.1 KiB
C#
91 lines
4.1 KiB
C#
using Amazon.S3;
|
|
using Microsoft.Extensions.Configuration;
|
|
using Microsoft.Extensions.DependencyInjection;
|
|
using Microsoft.Extensions.Options;
|
|
using Musify.Application.Configuration;
|
|
using Musify.Infrastructure.Configuration;
|
|
using Musify.Infrastructure.Jobs;
|
|
using Musify.Application.Contracts;
|
|
|
|
namespace Musify.Infrastructure.Services
|
|
{
|
|
public static class ServicesDependencyInjection
|
|
{
|
|
public static IServiceCollection AddStorageService(this IServiceCollection serviceDescriptors, IConfiguration configuration)
|
|
{
|
|
serviceDescriptors
|
|
.AddOptionsWithValidateOnStart<InfrastructureStorageConfiguration>()
|
|
.Bind(configuration.GetRequiredSection(InfrastructureStorageConfiguration.SectionName))
|
|
.ValidateDataAnnotations();
|
|
|
|
serviceDescriptors.AddSingleton(serviceProvider =>
|
|
serviceProvider.GetRequiredService<IOptions<InfrastructureStorageConfiguration>>().Value);
|
|
|
|
serviceDescriptors.AddSingleton<IAmazonS3>(serviceProvider =>
|
|
{
|
|
var configuration = serviceProvider.GetRequiredService<InfrastructureStorageConfiguration>();
|
|
var s3Configuration = new AmazonS3Config
|
|
{
|
|
ServiceURL = configuration.Address,
|
|
ForcePathStyle = configuration.ForcePathStyle,
|
|
UseHttp = configuration.UseHttp,
|
|
};
|
|
return new AmazonS3Client(configuration.AccessKey, configuration.SecretAccessKey, s3Configuration);
|
|
} );
|
|
|
|
serviceDescriptors.AddScoped<IStorageService, StorageService>();
|
|
return serviceDescriptors;
|
|
}
|
|
|
|
public static IServiceCollection AddPictureService(this IServiceCollection serviceDescriptors, IConfiguration configuration)
|
|
{
|
|
serviceDescriptors.AddScoped<IPictureService, PictureService>();
|
|
return serviceDescriptors;
|
|
}
|
|
|
|
public static IServiceCollection AddUploadIntentConfiguration(this IServiceCollection serviceDescriptors, IConfiguration configuration)
|
|
{
|
|
serviceDescriptors.AddValidatedOptions<UploadIntentConfiguration>(configuration, UploadIntentConfiguration.SectionName);
|
|
|
|
return serviceDescriptors;
|
|
}
|
|
|
|
public static IServiceCollection AddUploadIntentJobs(this IServiceCollection serviceDescriptors, IConfiguration configuration)
|
|
{
|
|
serviceDescriptors.AddUploadIntentConfiguration(configuration);
|
|
|
|
serviceDescriptors.AddHostedService<UploadIntentExpirationJob>();
|
|
serviceDescriptors.AddHostedService<TemporalUploadsCleanUpJob>();
|
|
|
|
return serviceDescriptors;
|
|
}
|
|
|
|
public static IServiceCollection AddStreamTicketService(this IServiceCollection serviceDescriptors, IConfiguration configuration)
|
|
{
|
|
serviceDescriptors
|
|
.AddOptionsWithValidateOnStart<StreamTicketConfiguration>()
|
|
.Bind(configuration.GetRequiredSection(StreamTicketConfiguration.SectionName))
|
|
.ValidateDataAnnotations();
|
|
|
|
serviceDescriptors.AddSingleton(serviceProvider =>
|
|
serviceProvider.GetRequiredService<IOptions<StreamTicketConfiguration>>().Value);
|
|
|
|
serviceDescriptors.AddSingleton<IStreamTicketService, StreamTicketService>();
|
|
return serviceDescriptors;
|
|
}
|
|
|
|
public static IServiceCollection AddAudioTranscoder(this IServiceCollection serviceDescriptors, IConfiguration configuration)
|
|
{
|
|
serviceDescriptors
|
|
.AddOptionsWithValidateOnStart<AudioTranscoderConfiguration>()
|
|
.Bind(configuration.GetRequiredSection(AudioTranscoderConfiguration.SectionName))
|
|
.ValidateDataAnnotations();
|
|
|
|
serviceDescriptors.AddSingleton(serviceProvider =>
|
|
serviceProvider.GetRequiredService<IOptions<AudioTranscoderConfiguration>>().Value);
|
|
|
|
serviceDescriptors.AddScoped<IAudioTranscoderService, AudioTranscoderService>();
|
|
return serviceDescriptors;
|
|
}
|
|
}
|
|
} |