Add events before and after handling bulk imports

src/OrchardCore/OrchardCore.ContentManagement.Abstractions/Handlers/IBulkContentEventHandler.cs

@@ -0,0 +1,10 @@
+using System.Collections.Generic;
+using System.Threading.Tasks;
+
+namespace OrchardCore.ContentManagement.Handlers;
+
+public interface IBulkContentEventHandler
+{
+    Task ImportingAsync(IEnumerable<ImportContentContext> contexts);
+    Task ImportedAsync(IEnumerable<ImportContentContext> contexts);
+}

src/OrchardCore/OrchardCore.ContentManagement/DefaultContentManager.cs

@@ -33,21 +33,24 @@ public class DefaultContentManager : IContentManager
     public DefaultContentManager(
         IContentDefinitionManager contentDefinitionManager,
         IContentManagerSession contentManagerSession,
-        IEnumerable<IContentHandler> handlers,
+        IEnumerable<IContentHandler> handlers, 
+        IEnumerable<IBulkContentEventHandler> bulkContentEventHandlers,
         ISession session,
         IContentItemIdGenerator idGenerator,
         ILogger<DefaultContentManager> logger,
         IClock clock)
     {
         _contentDefinitionManager = contentDefinitionManager;
         Handlers = handlers;
+        BulkContentHandlers = bulkContentEventHandlers;
         _session = session;
         _idGenerator = idGenerator;
         _contentManagerSession = contentManagerSession;
         _logger = logger;
         _clock = clock;
     }
 
+    public IEnumerable<IBulkContentEventHandler> BulkContentHandlers { get; private set; }
     public IEnumerable<IContentHandler> Handlers { get; private set; }
 
     public IEnumerable<IContentHandler> _reversedHandlers;
@@ -609,6 +612,9 @@ public async Task ImportAsync(IEnumerable<ContentItem> contentItems)
     {
         ArgumentNullException.ThrowIfNull(contentItems);
 
+        var contentList = contentItems.Select(x => new ImportContentContext(x)).ToList();
+        await BulkContentHandlers.InvokeAsync((handler, list) => handler.ImportingAsync(list), contentList, _logger);
+
         var skip = 0;
 
         var importedVersionIds = new HashSet<string>();
@@ -737,6 +743,8 @@ public async Task ImportAsync(IEnumerable<ContentItem> contentItems)
             skip += _importBatchSize;
             batchedContentItems = contentItems.Skip(skip).Take(_importBatchSize);
         }
+
+        await BulkContentHandlers.InvokeAsync((handler, list) => handler.ImportedAsync(list), contentList, _logger);
     }
 
     public async Task UpdateAsync(ContentItem contentItem)

src/OrchardCore/OrchardCore.ContentManagement/Handlers/DefaultBulkContentEventHandlerBase.cs

@@ -0,0 +1,9 @@
+using System.Collections.Generic;
+using System.Threading.Tasks;
+
+namespace OrchardCore.ContentManagement.Handlers;
+public class DefaultBulkContentEventHandlerBase : IBulkContentEventHandler
+{
+    public virtual Task ImportingAsync(IEnumerable<ImportContentContext> contexts) => Task.CompletedTask;
+    public virtual Task ImportedAsync(IEnumerable<ImportContentContext> contexts) => Task.CompletedTask;
+}

src/docs/releases/2.0.0.md

@@ -234,6 +234,8 @@ Additionally, the `GetContentItemByHandleAsync(string handle, bool latest = fals
 
 Lastly, we dropped support for AllVersions option in `VersionOptions`. Instead, you can use the new `GetAllVersionsAsync(string contentItemId)` method on `IContentManager`.
 
+We added `IBulkContentEventHandler` , which contains two handlers, `ImportingAsync` and `ImportedAsync` , that allow developers to get a collection of all the imported items at once during the import process and add custom processing logic.
+
 ### Media Indexing
 
 Previously, `.pdf` files were automatically indexed in the search providers (Elasticsearch, Lucene or Azure AI Search). Now, if you want to continue to index `.PDF` file you'll need to enable the `OrchardCore.Media.Indexing.Pdf` feature.