jellyfin/Jellyfin.Server/Migrations/MigrationRunner.cs

84 lines
3.7 KiB
C#
Raw Normal View History

2020-03-05 17:09:33 +00:00
using System;
using System.Linq;
using MediaBrowser.Common.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
namespace Jellyfin.Server.Migrations
{
/// <summary>
2020-03-07 19:18:45 +00:00
/// The class that knows which migrations to apply and how to apply them.
/// </summary>
2020-03-05 17:09:33 +00:00
public sealed class MigrationRunner
{
2020-03-05 17:09:33 +00:00
/// <summary>
/// The list of known migrations, in order of applicability.
/// </summary>
private static readonly Type[] _migrationTypes =
{
typeof(Routines.DisableTranscodingThrottling),
2020-05-14 23:30:28 +00:00
typeof(Routines.CreateUserLoggingConfigFile),
typeof(Routines.MigrateActivityLogDb),
typeof(Routines.RemoveDuplicateExtras),
2020-06-16 17:16:17 +00:00
typeof(Routines.AddDefaultPluginRepository),
2020-07-01 01:44:41 +00:00
typeof(Routines.MigrateUserDb),
typeof(Routines.ReaddDefaultPluginRepository),
2020-07-01 01:44:41 +00:00
typeof(Routines.MigrateDisplayPreferencesDb)
};
/// <summary>
/// Run all needed migrations.
/// </summary>
/// <param name="host">CoreAppHost that hosts current version.</param>
2020-03-05 17:09:33 +00:00
/// <param name="loggerFactory">Factory for making the logger.</param>
public static void Run(CoreAppHost host, ILoggerFactory loggerFactory)
{
2020-03-05 17:09:33 +00:00
var logger = loggerFactory.CreateLogger<MigrationRunner>();
var migrations = _migrationTypes
.Select(m => ActivatorUtilities.CreateInstance(host.ServiceProvider, m))
.OfType<IMigrationRoutine>()
.ToArray();
var migrationOptions = ((IConfigurationManager)host.ServerConfigurationManager).GetConfiguration<MigrationOptions>(MigrationsListStore.StoreKey);
if (!host.ServerConfigurationManager.Configuration.IsStartupWizardCompleted && migrationOptions.Applied.Count == 0)
{
// If startup wizard is not finished, this is a fresh install.
// Don't run any migrations, just mark all of them as applied.
logger.LogInformation("Marking all known migrations as applied because this is a fresh install");
migrationOptions.Applied.AddRange(migrations.Where(m => !m.PerformOnNewInstall).Select(m => (m.Id, m.Name)));
host.ServerConfigurationManager.SaveConfiguration(MigrationsListStore.StoreKey, migrationOptions);
}
var appliedMigrationIds = migrationOptions.Applied.Select(m => m.Id).ToHashSet();
for (var i = 0; i < migrations.Length; i++)
{
var migrationRoutine = migrations[i];
if (appliedMigrationIds.Contains(migrationRoutine.Id))
{
2020-03-08 14:02:59 +00:00
logger.LogDebug("Skipping migration '{Name}' since it is already applied", migrationRoutine.Name);
continue;
}
2020-03-08 14:02:59 +00:00
logger.LogInformation("Applying migration '{Name}'", migrationRoutine.Name);
2020-03-05 17:09:33 +00:00
try
{
migrationRoutine.Perform();
2020-03-05 17:09:33 +00:00
}
catch (Exception ex)
{
2020-03-08 14:02:59 +00:00
logger.LogError(ex, "Could not apply migration '{Name}'", migrationRoutine.Name);
throw;
}
// Mark the migration as completed
2020-03-08 14:02:59 +00:00
logger.LogInformation("Migration '{Name}' applied successfully", migrationRoutine.Name);
migrationOptions.Applied.Add((migrationRoutine.Id, migrationRoutine.Name));
host.ServerConfigurationManager.SaveConfiguration(MigrationsListStore.StoreKey, migrationOptions);
2020-03-08 14:02:59 +00:00
logger.LogDebug("Migration '{Name}' marked as applied in configuration.", migrationRoutine.Name);
2020-03-05 17:09:33 +00:00
}
}
}
}