squidex/tools/Migrate_01/MigrationPath.cs

// ==========================================================================
//  Squidex Headless CMS
// ==========================================================================
//  Copyright (c) Squidex UG (haftungsbeschraenkt)
//  All rights reserved. Licensed under the MIT license.
// ==========================================================================

using System;
using System.Collections.Generic;
using System.Linq;
using Microsoft.Extensions.DependencyInjection;
using Migrate_01.Migrations;
using Squidex.Infrastructure.Migrations;

namespace Migrate_01
{
    public sealed class MigrationPath : IMigrationPath
    {
        private const int CurrentVersion = 12;
        private readonly IServiceProvider serviceProvider;

        public MigrationPath(IServiceProvider serviceProvider)
        {
            this.serviceProvider = serviceProvider;
        }

        public (int Version, IEnumerable<IMigration> Migrations) GetNext(int version)
        {
            if (version == CurrentVersion)
            {
                return (CurrentVersion, null);
            }

            var migrations = ResolveMigrators(version).Where(x => x != null).ToList();

            return (CurrentVersion, migrations);
        }

        private IEnumerable<IMigration> ResolveMigrators(int version)
        {
            yield return serviceProvider.GetRequiredService<StopEventConsumers>();

            // Version 06: Convert Event store. Must always be executed first.
            if (version < 6)
            {
                yield return serviceProvider.GetRequiredService<ConvertEventStore>();
            }

            // Version 07: Introduces AppId for backups.
            else if (version < 7)
            {
                yield return serviceProvider.GetRequiredService<ConvertEventStoreAppId>();
            }

            // Version 05: Fixes the broken command architecture and requires a rebuild of all snapshots.
            if (version < 5)
            {
                yield return serviceProvider.GetRequiredService<RebuildSnapshots>();
            }

            // Version 12: Introduce roles.
            else if (version < 12)
            {
                yield return serviceProvider.GetRequiredService<RebuildApps>();
            }

            // Version 09: Grain indexes.
            if (version < 9)
            {
                yield return serviceProvider.GetService<ConvertOldSnapshotStores>();
                yield return serviceProvider.GetRequiredService<PopulateGrainIndexes>();
            }

            // Version 11: Introduce content drafts.
            if (version < 11)
            {
                yield return serviceProvider.GetService<DeleteContentCollections>();
                yield return serviceProvider.GetRequiredService<RebuildContents>();
            }

            // Version 01: Introduce app patterns.
            if (version < 1)
            {
                yield return serviceProvider.GetRequiredService<AddPatterns>();
            }

            yield return serviceProvider.GetRequiredService<StartEventConsumers>();
        }
    }
}