TEAMModelOS/TEAMModelOS.SDK/DI/Multiple/MultipleAzureCosmosFactoryExtensions.cs

using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.DependencyInjection.Extensions;
using Microsoft.Extensions.Options;
using System;
using System.Collections.Generic;
using System.Text;
using TEAMModelOS.SDK.DI;

namespace TEAMModelOS.SDK.DI.Multiple
{
    public static class MultipleAzureCosmosFactoryExtensions
    {
        /// <summary>
        /// cosmosDB注入
        /// </summary>
        /// <param name="services"></param>
        /// <param name="connectionInfo"></param>
        /// <returns></returns>
        /// <exception cref="ArgumentNullException"></exception>
        public static IServiceCollection AddMultipleAzureCosmos(this IServiceCollection services, List<(string name, string connectionString)> connectionInfo)
        {
            if (services == null) throw new ArgumentNullException(nameof(services));
            if (connectionInfo == null) throw new ArgumentNullException(nameof(connectionInfo));
          
            connectionInfo.ForEach(connection =>
            {
                services.Configure<AzureCosmosFactoryOptions>(connection.name, o => { o.Name = connection.name; o.CosmosConnectionString = connection.connectionString; });
               
            });
            services.AddSingleton<IOptionsMonitor<AzureCosmosFactoryOptions>, OptionsMonitor<AzureCosmosFactoryOptions>>();
            services.TryAddSingleton<AzureCosmosFactory>();
           
            //多个数据库注入
           
            return services;
        }
    }
}