Webiant Logo Webiant Logo
☌

  1. No results found.

    Try your search with a different keyword or use * as a wildcard.

NopProcessorAccessor.cs

using FluentMigrator;
using FluentMigrator.Exceptions;
using FluentMigrator.Runner.Processors;

namespace Nop.Data.Migrations;

/// 
/// An  implementation that selects one generator by data settings
/// 
public class NopProcessorAccessor : IProcessorAccessor
{
    #region Ctor

    public NopProcessorAccessor(IEnumerable processors)
    {
        ConfigureProcessor(processors.ToList());
    }

    #endregion

    #region Utilities

    /// 
    /// Configure processor
    /// 
    /// Collection of migration processors
    protected virtual void ConfigureProcessor(IList processors)
    {
        var dataSettings = DataSettingsManager.LoadSettings();

        if (!processors.Any())
            throw new ProcessorFactoryNotFoundException("No migration processor registered.");

        if (dataSettings is null)
            Processor = processors.FirstOrDefault();
        else
            Processor = dataSettings.DataProvider switch
            {
                DataProviderType.SqlServer => FindGenerator(processors, "SqlServer"),
                DataProviderType.MySql => FindGenerator(processors, "MySQL"),
                DataProviderType.PostgreSQL => FindGenerator(processors, "Postgres"),
                _ => throw new ProcessorFactoryNotFoundException(
                    $@"A migration generator for Data provider type {dataSettings.DataProvider} couldn't be found.")
            };
    }

    /// 
    /// Gets single processor by DatabaseType or DatabaseTypeAlias
    /// 
    /// Collection of migration processors
    /// DatabaseType or DatabaseTypeAlias
    /// 
    protected IMigrationProcessor FindGenerator(IList processors,
        string processorsId)
    {
        if (processors.FirstOrDefault(p =>
                p.DatabaseType.Equals(processorsId, StringComparison.OrdinalIgnoreCase) ||
                p.DatabaseTypeAliases.Any(a => a.Equals(processorsId, StringComparison.OrdinalIgnoreCase))) is
            IMigrationProcessor processor)
            return processor;

        var generatorNames = string.Join(", ",
            processors.Select(p => p.DatabaseType).Union(processors.SelectMany(p => p.DatabaseTypeAliases)));

        throw new ProcessorFactoryNotFoundException(
            $@"A migration generator with the ID {processorsId} couldn't be found. Available generators are: {generatorNames}");
    }

    #endregion

    #region  Properties

    public IMigrationProcessor Processor { get; protected set; }

    #endregion
}