From 7399f59a9d7909fb7409787df1b81d406e3b3f87 Mon Sep 17 00:00:00 2001
From: Oliver Cooper <oliver.d.cooper@gmail.com>
Date: Thu, 28 Jan 2021 11:41:44 +0000
Subject: [PATCH] Add RepositoryExtensions.HardDeleteAsync for IEnumerables

---
 .../Repositories/RepositoryExtensions.cs      | 33 +++++++++++++++++++
 .../Abp/TestApp/Testing/HardDelete_Tests.cs   | 13 ++++++++
 2 files changed, 46 insertions(+)

diff --git a/framework/src/Volo.Abp.Ddd.Domain/Volo/Abp/Domain/Repositories/RepositoryExtensions.cs b/framework/src/Volo.Abp.Ddd.Domain/Volo/Abp/Domain/Repositories/RepositoryExtensions.cs
index 206204372f..264630c117 100644
--- a/framework/src/Volo.Abp.Ddd.Domain/Volo/Abp/Domain/Repositories/RepositoryExtensions.cs
+++ b/framework/src/Volo.Abp.Ddd.Domain/Volo/Abp/Domain/Repositories/RepositoryExtensions.cs
@@ -79,6 +79,39 @@ namespace Volo.Abp.Domain.Repositories
             }
         }
 
+        public static async Task HardDeleteAsync<TEntity>(
+            this IBasicRepository<TEntity> repository,
+            IEnumerable<TEntity> entities,
+            bool autoSave = false,
+            CancellationToken cancellationToken = default
+        )
+            where TEntity : class, IEntity, ISoftDelete
+        {
+            if (!(ProxyHelper.UnProxy(repository) is IUnitOfWorkManagerAccessor unitOfWorkManagerAccessor))
+            {
+                throw new AbpException($"The given repository (of type {repository.GetType().AssemblyQualifiedName}) should implement the {typeof(IUnitOfWorkManagerAccessor).AssemblyQualifiedName} interface in order to invoke the {nameof(HardDeleteAsync)} method!");
+            }
+
+            var uowManager = unitOfWorkManagerAccessor.UnitOfWorkManager;
+            if (uowManager == null)
+            {
+                throw new AbpException($"{nameof(unitOfWorkManagerAccessor.UnitOfWorkManager)} property of the given {nameof(repository)} object is null!");
+            }
+
+            if (uowManager.Current == null)
+            {
+                using (var uow = uowManager.Begin())
+                {
+                    await HardDeleteWithUnitOfWorkAsync(repository, entities, autoSave, cancellationToken, uowManager.Current);
+                    await uow.CompleteAsync(cancellationToken);
+                }
+            }
+            else
+            {
+                await HardDeleteWithUnitOfWorkAsync(repository, entities, autoSave, cancellationToken, uowManager.Current);
+            }
+        }
+
         public static async Task HardDeleteAsync<TEntity>(
             this IBasicRepository<TEntity> repository,
             TEntity entity,
diff --git a/framework/test/Volo.Abp.TestApp/Volo/Abp/TestApp/Testing/HardDelete_Tests.cs b/framework/test/Volo.Abp.TestApp/Volo/Abp/TestApp/Testing/HardDelete_Tests.cs
index e31b64f6e4..a2085a9a67 100644
--- a/framework/test/Volo.Abp.TestApp/Volo/Abp/TestApp/Testing/HardDelete_Tests.cs
+++ b/framework/test/Volo.Abp.TestApp/Volo/Abp/TestApp/Testing/HardDelete_Tests.cs
@@ -54,6 +54,19 @@ namespace Volo.Abp.TestApp.Testing
             }
         }
 
+        [Fact]
+        public async Task Should_HardDelete_Entities_With_IEnumerable()
+        {
+            using (DataFilter.Disable<ISoftDelete>())
+            {
+                var persons = await PersonRepository.GetListAsync();
+                await PersonRepository.HardDeleteAsync(persons);
+
+                var personCount = await PersonRepository.GetCountAsync();
+                personCount.ShouldBe(0);
+            }
+        }
+
         [Fact]
         public async Task Should_HardDelete_Soft_Deleted_Entities()
         {