| | | 1 | | using ArturRios.Data.MongoDb.Configuration; |
| | | 2 | | using ArturRios.Data.MongoDb.Interfaces; |
| | | 3 | | using ArturRios.Data.MongoDb.Repositories; |
| | | 4 | | using ArturRios.Data.MongoDb.Transactions; |
| | | 5 | | using Microsoft.Extensions.Configuration; |
| | | 6 | | using Microsoft.Extensions.DependencyInjection; |
| | | 7 | | using MongoDB.Driver; |
| | | 8 | | |
| | | 9 | | namespace ArturRios.Data.MongoDb.DependencyInjection; |
| | | 10 | | |
| | | 11 | | /// <summary>Dependency-injection registration for the ArturRios.Data.MongoDb document store.</summary> |
| | | 12 | | public static class ServiceCollectionExtensions |
| | | 13 | | { |
| | | 14 | | /// <param name="services">The service collection.</param> |
| | | 15 | | extension(IServiceCollection services) |
| | | 16 | | { |
| | | 17 | | /// <summary>Registers the MongoDB document store, binding options from configuration.</summary> |
| | | 18 | | /// <param name="configuration">Application configuration.</param> |
| | | 19 | | /// <param name="sectionName">Configuration section holding the options. Defaults to "ArturRios.Data.MongoDb".</ |
| | | 20 | | public IServiceCollection AddMongoData(IConfiguration configuration, |
| | | 21 | | string sectionName = "ArturRios.Data.MongoDb") |
| | | 22 | | { |
| | 0 | 23 | | var options = configuration.GetSection(sectionName).Get<MongoOptions>() ?? new MongoOptions(); |
| | 0 | 24 | | return services.AddMongoData(options); |
| | | 25 | | } |
| | | 26 | | |
| | | 27 | | /// <summary> |
| | | 28 | | /// Registers the MongoDB document store from an explicit options instance. |
| | | 29 | | /// Failures are logged in full when logging is registered (<c>AddLogging</c>); without |
| | | 30 | | /// it the repositories still run and error envelopes carry no driver text. |
| | | 31 | | /// </summary> |
| | | 32 | | /// <param name="options">The Mongo options.</param> |
| | | 33 | | public IServiceCollection AddMongoData(MongoOptions options) |
| | | 34 | | { |
| | 8 | 35 | | services.AddSingleton<IMongoClient>(_ => new MongoClient(options.ConnectionString)); |
| | 4 | 36 | | services.AddScoped<IMongoDatabase>(sp => |
| | 8 | 37 | | sp.GetRequiredService<IMongoClient>().GetDatabase(options.DatabaseName)); |
| | 4 | 38 | | services.AddScoped<MongoContext>(); |
| | | 39 | | |
| | 4 | 40 | | services.AddScoped(typeof(IDocumentReadOnlyRepository<>), typeof(MongoDocumentRepository<>)); |
| | 4 | 41 | | services.AddScoped(typeof(IDocumentRepository<>), typeof(MongoDocumentRepository<>)); |
| | 4 | 42 | | services.AddScoped(typeof(IAsyncDocumentReadOnlyRepository<>), typeof(MongoDocumentRepository<>)); |
| | 4 | 43 | | services.AddScoped(typeof(IAsyncDocumentRepository<>), typeof(MongoDocumentRepository<>)); |
| | | 44 | | |
| | 4 | 45 | | services.AddScoped<IMongoUnitOfWork, MongoUnitOfWork>(); |
| | 4 | 46 | | services.AddScoped<IAsyncMongoUnitOfWork, MongoUnitOfWork>(); |
| | | 47 | | |
| | 4 | 48 | | return services; |
| | | 49 | | } |
| | | 50 | | } |
| | | 51 | | } |