Merge pull request #373 from iggsn/ExtendBulkDeleteRequest

Extend bulk delete request

FakeXrmEasy.Shared/FakeMessageExecutors/BulkDeleteRequestExecutor.cs

@@ -2,6 +2,7 @@
 using System.ServiceModel;
 using Microsoft.Crm.Sdk.Messages;
 using Microsoft.Xrm.Sdk;
+using Microsoft.Xrm.Sdk.Query;
 
 namespace FakeXrmEasy.FakeMessageExecutors
 {
@@ -32,13 +33,38 @@ public OrganizationResponse Execute(OrganizationRequest request, XrmFakedContext
             {
                 throw new FaultException<OrganizationServiceFault>(new OrganizationServiceFault(), "Can not Bulk delete without ToRecipients");
             }
-
-            return new BulkDeleteResponse()
+
+            var service = ctx.GetOrganizationService();
+
+            // generate JobId
+            var jobId = Guid.NewGuid();
+
+            // create related asyncOperation
+            Entity asyncOpertation = new Entity("asyncoperation")
             {
-                ResponseName = "BulkDeleteResponse"
+                Id = jobId
             };
-        }
 
+            service.Create(asyncOpertation);
+
+            // delete all records from all queries
+            foreach (QueryExpression queryExpression in bulkDeleteRequest.QuerySet)
+            {
+                EntityCollection recordsToDelete = service.RetrieveMultiple(queryExpression);
+                foreach (Entity record in recordsToDelete.Entities)
+                {
+                    service.Delete(record.LogicalName, record.Id);
+                }
+            }
+
+            // set ayncoperation to completed
+            asyncOpertation["statecode"] = new OptionSetValue(3);
+            service.Update(asyncOpertation);
+
+            // return result
+            return new BulkDeleteResponse { ResponseName = "BulkDeleteResponse", ["JobId"] = jobId};
+        }
+
         public Type GetResponsibleRequestType()
         {
             return typeof(BulkDeleteRequest);

FakeXrmEasy.Tests.Shared/FakeContextTests/BulkDeleteRequestTests/BulkDeleteRequestTests.cs

@@ -0,0 +1,177 @@
+using System;
+using System.Reflection;
+using System.ServiceModel;
+using Crm;
+using FakeXrmEasy.FakeMessageExecutors;
+using Microsoft.Crm.Sdk.Messages;
+using Microsoft.Xrm.Sdk;
+using Microsoft.Xrm.Sdk.Messages;
+using Microsoft.Xrm.Sdk.Query;
+using System.Linq;
+using Xunit;
+
+namespace FakeXrmEasy.Tests.FakeContextTests.BulkDeleteRequestTests
+{
+    public class BulkDeleteRequestTests
+    {
+        [Fact]
+        public void When_can_execute_is_called_with_an_invalid_request_result_is_false()
+        {
+            var executor = new BulkDeleteRequestExecutor();
+            var anotherRequest = new RetrieveMultipleRequest();
+            Assert.False(executor.CanExecute(anotherRequest));
+        }
+
+        [Fact]
+        public void When_execute_is_called_with_a_null_jobname_exception_is_thrown()
+        {
+            var context = new XrmFakedContext();
+            var executor = new BulkDeleteRequestExecutor();
+            BulkDeleteRequest req = new BulkDeleteRequest
+            {
+                JobName = null
+            };
+            Assert.Throws<FaultException<OrganizationServiceFault>>(() => executor.Execute(req, context));
+        }
+
+        [Fact]
+        public void When_execute_is_called_with_a_null_queryset_exception_is_thrown()
+        {
+            var context = new XrmFakedContext();
+            var executor = new BulkDeleteRequestExecutor();
+            BulkDeleteRequest req = new BulkDeleteRequest
+            {
+                JobName = "Dummy Job",
+                QuerySet = null
+            };
+            Assert.Throws<FaultException<OrganizationServiceFault>>(() => executor.Execute(req, context));
+        }
+
+        [Fact]
+        public void When_execute_is_called_with_a_null_ccrecipients_exception_is_thrown()
+        {
+            var context = new XrmFakedContext();
+            var executor = new BulkDeleteRequestExecutor();
+            BulkDeleteRequest req = new BulkDeleteRequest
+            {
+                JobName = "Dummy Job",
+                QuerySet = new[]
+                {
+                    new QueryExpression("account"),
+                },
+                CCRecipients = null
+            };
+            Assert.Throws<FaultException<OrganizationServiceFault>>(() => executor.Execute(req, context));
+        }
+
+        [Fact]
+        public void When_execute_is_called_with_a_null_torecipients_exception_is_thrown()
+        {
+            var context = new XrmFakedContext();
+            var executor = new BulkDeleteRequestExecutor();
+            BulkDeleteRequest req = new BulkDeleteRequest
+            {
+                JobName = "Dummy Job",
+                QuerySet = new[]
+                {
+                    new QueryExpression("account"),
+                },
+                CCRecipients = new[]
+                {
+                    Guid.NewGuid(),
+                    Guid.NewGuid()
+                },
+                ToRecipients = null
+            };
+            Assert.Throws<FaultException<OrganizationServiceFault>>(() => executor.Execute(req, context));
+        }
+
+        [Fact]
+        public void Check_if_contacts_have_been_deleted_after_sending_request()
+        {
+            var context = new XrmFakedContext();
+            context.ProxyTypesAssembly = Assembly.GetExecutingAssembly();
+            var service = context.GetFakedOrganizationService();
+
+            // initialize data
+            var parentAccountId = Guid.NewGuid();
+            var keepName = "Keep";
+
+            var contactA = new Contact
+            {
+                Id = Guid.NewGuid(),
+                FirstName = "Delete",
+                LastName = "Me1",
+                ParentCustomerId = new EntityReference(Account.EntityLogicalName, parentAccountId)
+            };
+
+            var contactB = new Contact
+            {
+                Id = Guid.NewGuid(),
+                FirstName = "Delete",
+                LastName = "Me2",
+                ParentCustomerId = new EntityReference(Account.EntityLogicalName, parentAccountId)
+            };
+
+            var contactC = new Contact
+            {
+                Id = Guid.NewGuid(),
+                FirstName = keepName,
+                LastName = "Me",
+                ParentCustomerId = new EntityReference(Account.EntityLogicalName, Guid.NewGuid())
+            };
+
+            context.Initialize(new[] { contactA, contactB, contactC });
+
+            var query = new QueryExpression
+            {
+                EntityName = Contact.EntityLogicalName,
+                Distinct = false,
+                Criteria = new FilterExpression
+                {
+                    Conditions =
+                    {
+                        new ConditionExpression("parentcustomerid", ConditionOperator.Equal, parentAccountId )
+                    }
+                }
+            };
+
+            // execute
+            var request = new BulkDeleteRequest
+            {
+                JobName = $"Delete Contacts of Account '{parentAccountId}'",
+                QuerySet = new[]
+                {
+                    query
+                },
+                ToRecipients = new[] { Guid.NewGuid() },
+                CCRecipients = new Guid[] { },
+                SendEmailNotification = false,
+                RecurrencePattern = string.Empty
+            };
+
+            var response = (BulkDeleteResponse)service.Execute(request);
+
+            // validate
+            var deletedContacts = (from c in context.CreateQuery<Contact>()
+                                   where Equals(c.ParentCustomerId, new EntityReference(Account.EntityLogicalName, parentAccountId))
+                                   select c);
+            var allContacts = (from c in context.CreateQuery<Contact>()
+                               select c);
+
+            var asyncOperation = (from a in context.CreateQuery<AsyncOperation>()
+                                  where a.AsyncOperationId == response.JobId
+                                  select a);
+
+            Assert.NotNull(response);
+            Assert.IsType<BulkDeleteResponse>(response);
+            Assert.NotNull(response.JobId);
+            Assert.NotEqual(Guid.Empty, response.JobId);
+            Assert.Equal(0, deletedContacts.Count());
+            Assert.Equal(1, allContacts.Count());
+            Assert.Equal(keepName, allContacts.First().FirstName);
+            Assert.Equal(1, asyncOperation.Count());
+            Assert.Equal(AsyncOperationState.Completed, asyncOperation.First().StateCode);
+        }
+    }
+}

FakeXrmEasy.Tests.Shared/FakeXrmEasy.Tests.Shared.projitems

@@ -19,6 +19,7 @@
     <Compile Include="$(MSBuildThisFileDirectory)Extensions\QueryExpressionExtensionsTests.cs" />
     <Compile Include="$(MSBuildThisFileDirectory)FakeContextTests\AddListMembersListRequestTests\Tests.cs" />
     <Compile Include="$(MSBuildThisFileDirectory)FakeContextTests\AddMemberListRequestTests\Tests.cs" />
+    <Compile Include="$(MSBuildThisFileDirectory)FakeContextTests\BulkDeleteRequestTests\BulkDeleteRequestTests.cs" />
     <Compile Include="$(MSBuildThisFileDirectory)FakeContextTests\RemoveUserFromRecordTeamRequestTests\RemoveUserFromRecordTeamRequestTests.cs" />
     <Compile Include="$(MSBuildThisFileDirectory)FakeContextTests\AddUserToRecordTeamRequestTests\AddUserToRecordTeamRequestTests.cs" />
     <Compile Include="$(MSBuildThisFileDirectory)FakeContextTests\AddMembersTeamRequestTests\Tests.cs" />