Webiant Logo Webiant Logo
☌

  1. No results found.

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

NopGeneratorAccessor.cs

using FluentMigrator;
using FluentMigrator.Runner.Generators;

namespace Nop.Data.Migrations;

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

    public NopGeneratorAccessor(IEnumerable generators)
    {
        ConfigureGenerator(generators.ToList());
    }

    #endregion

    #region Utilities

    /// 
    /// Configure generator
    /// 
    /// Collection of migration generators
    protected virtual void ConfigureGenerator(IList generators)
    {
        var dataSettings = DataSettingsManager.LoadSettings();

        if (!generators.Any())
            throw new InvalidOperationException("No migration generator registered.");

        Generator = dataSettings is null ? generators.FirstOrDefault() : dataSettings.DataProvider switch
        {
            DataProviderType.SqlServer => FindGenerator(generators, GeneratorIdConstants.SqlServer),
            DataProviderType.MySql => FindGenerator(generators, GeneratorIdConstants.MySql5),
            DataProviderType.PostgreSQL => FindGenerator(generators, GeneratorIdConstants.PostgreSQL9_2),
            _ => throw new InvalidOperationException(
                $@"A migration generator for Data provider type {dataSettings.DataProvider} couldn't be found.")
        };
    }

    /// 
    /// Gets single processor by DatabaseType or DatabaseTypeAlias
    /// 
    /// Collection of migration generators
    /// The ID of the generator
    /// 
    protected IMigrationGenerator FindGenerator(IList generators,
        string generatorId)
    {
        if (generators.FirstOrDefault(p =>
                p.GeneratorId.Equals(generatorId, StringComparison.OrdinalIgnoreCase) ||
                p.GeneratorIdAliases.Any(a => a.Equals(generatorId, StringComparison.OrdinalIgnoreCase))) is
            IMigrationGenerator processor)
        {
            return processor;
        }

        var generatorNames = string.Join(", ",
            generators.Select(p => p.GeneratorId).Union(generators.SelectMany(p => p.GeneratorIdAliases)));

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

    #endregion

    #region  Properties

    public IMigrationGenerator Generator { get; protected set; }

    #endregion
}