Replace IDataMigrationManager.UpdateAsync(string) with IDataMigrationManager.UpdateAsync(IEnumerable<string>)

src/OrchardCore/OrchardCore.Data.Abstractions/Extensions/DataMigrationManagerExtensions.cs

@@ -0,0 +1,25 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace OrchardCore.Data.Migration;
+
+/// <summary>
+/// Provides an extension methods for <see cref="IDataMigrationManager"/>.
+/// </summary>
+public static class DataMigrationManagerExtensions
+{
+ /// <summary>
+ /// Updates the database to the latest version for the specified features.
+ /// </summary>
+ /// <param name="dataMigrationManager">The <see cref="IDataMigrationManager"/>.</param>
+ /// <param name="features">The features to be updated.</param>
+ public static async Task UpdateAsync(this IDataMigrationManager dataMigrationManager, IEnumerable<string> features)
+ {
+ ArgumentNullException.ThrowIfNull(dataMigrationManager, nameof(dataMigrationManager));
+ ArgumentNullException.ThrowIfNull(features, nameof(features));
+
+ await Task.WhenAll(features.Select(dataMigrationManager.UpdateAsync));
+ }
+}

src/OrchardCore/OrchardCore.Data.Abstractions/IDataMigrationManager.cs

@@ -1,4 +1,6 @@
+using System;
 using System.Collections.Generic;
+using System.Linq;
 using System.Threading.Tasks;
 
 namespace OrchardCore.Data.Migration
@@ -28,7 +30,8 @@ public interface IDataMigrationManager
  /// Updates the database to the latest version for the specified features.
  /// </summary>
  /// <param name="features">The features to be updated.</param>
- Task UpdateAsync(IEnumerable<string> features);
+ [Obsolete("This method has been deprecated and moved into an extension method.")]
+ async Task UpdateAsync(IEnumerable<string> features) => await Task.WhenAll(features.Select(UpdateAsync));
 
  /// <summary>
  /// Execute a script to delete any information relative to the feature.

src/OrchardCore/OrchardCore.Data.YesSql/Migration/DataMigrationManager.cs

@@ -123,17 +123,6 @@ public async Task Uninstall(string feature)
  }
  }
 
- public async Task UpdateAsync(IEnumerable<string> featureIds)
- {
- foreach (var featureId in featureIds)
- {
- if (!_processedFeatures.Contains(featureId))
- {
- await UpdateAsync(featureId);
- }
- }
- }
-
  public async Task UpdateAsync(string featureId)
  {
  if (_processedFeatures.Contains(featureId))
@@ -152,7 +141,10 @@ public async Task UpdateAsync(string featureId)
  .Where(x => x.Id != featureId)
  .Select(x => x.Id);
 
- await UpdateAsync(dependencies);
+ foreach (var dependency in dependencies)
+ {
+ await UpdateAsync(dependency);
+ }
 
  var migrations = GetDataMigrations(featureId);