Add events before and after handling bulk imports

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

@@ -1,3 +1,4 @@
+using System.Collections.Generic;
 using System.Threading.Tasks;
 
 namespace OrchardCore.ContentManagement.Handlers

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

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

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

@@ -1,3 +1,4 @@
+using System.Collections.Generic;
 using System.Threading.Tasks;
 
 namespace OrchardCore.ContentManagement.Handlers

src/OrchardCore/OrchardCore.ContentManagement/DefaultContentManager.cs

@@ -35,6 +35,7 @@ public DefaultContentManager(
             IContentDefinitionManager contentDefinitionManager,
             IContentManagerSession contentManagerSession,
             IEnumerable<IContentHandler> handlers,
+            IEnumerable<IBulkContentHandler> bulkContentHandlers,
             ISession session,
             IContentItemIdGenerator idGenerator,
             ILogger<DefaultContentManager> logger,
@@ -43,13 +44,16 @@ public DefaultContentManager(
             _contentDefinitionManager = contentDefinitionManager;
             Handlers = handlers;
             ReversedHandlers = handlers.Reverse().ToArray();
+            BulkContentHandlers = bulkContentHandlers;
             _session = session;
             _idGenerator = idGenerator;
             _contentManagerSession = contentManagerSession;
             _logger = logger;
             _clock = clock;
         }
 
+        public IEnumerable<IBulkContentHandler> BulkContentHandlers { get; private set; }
+
         public IEnumerable<IContentHandler> Handlers { get; private set; }
         public IEnumerable<IContentHandler> ReversedHandlers { get; private set; }
 
@@ -647,6 +651,9 @@ public Task<ContentValidateResult> UpdateContentItemVersionAsync(ContentItem upd
 
         public async Task ImportAsync(IEnumerable<ContentItem> 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>();
@@ -775,6 +782,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)