Change bulk operations implementation to use internal operations that…

… do not trigger pipeline requests, these will be moved to the plugings project and pipeline simulation to make sure they trigger in the same order as the platform. DynamicsValue/fake-xrm-easy#122
DynamicsValue · May 24, 2024 · d879715 · d879715
1 parent bc67cdd
commit d879715
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 4 deletions.
diff --git a/src/FakeXrmEasy.Core/Middleware/Crud/FakeMessageExecutors/CreateMultipleRequestExecutor.cs b/src/FakeXrmEasy.Core/Middleware/Crud/FakeMessageExecutors/CreateMultipleRequestExecutor.cs
@@ -43,7 +43,7 @@ public OrganizationResponse Execute(OrganizationRequest request, IXrmFakedContex
 
             foreach (var record in records)
             {
-                var id = service.Create(record);
+                var id = ctx.CreateEntity(record);
                 createdIds.Add(id);
             }
 

diff --git a/src/FakeXrmEasy.Core/Middleware/Crud/FakeMessageExecutors/UpdateMultipleRequestExecutor.cs b/src/FakeXrmEasy.Core/Middleware/Crud/FakeMessageExecutors/UpdateMultipleRequestExecutor.cs
@@ -42,7 +42,7 @@ public OrganizationResponse Execute(OrganizationRequest request, IXrmFakedContex
 
             foreach (var record in records)
             {
-                service.Update(record);
+                ctx.UpdateEntity(record);
             }
 
             return new UpdateMultipleResponse()

diff --git a/src/FakeXrmEasy.Core/Middleware/Crud/FakeMessageExecutors/UpsertMultipleRequestExecutor.cs b/src/FakeXrmEasy.Core/Middleware/Crud/FakeMessageExecutors/UpsertMultipleRequestExecutor.cs
@@ -41,9 +41,23 @@ public OrganizationResponse Execute(OrganizationRequest request, IXrmFakedContex
 
             var service = ctx.GetOrganizationService();
 
-            foreach (var record in records)
+            foreach (var record in records) 
             {
-                var response = service.Execute(new UpsertRequest() { Target = record }) as UpsertResponse;
+                UpsertResponse response = null; 
+                if (ctx.ContainsEntity(record.LogicalName, record.Id))
+                {
+                    ctx.UpdateEntity(record);
+                    response = new UpsertResponse();
+                    response.Results.Add("RecordCreated", false);
+                    response.Results.Add("Target", new EntityReference(record.LogicalName, record.Id));
+                }
+                else
+                {
+                    var id = ctx.CreateEntity(record);
+                    response = new UpsertResponse();
+                    response.Results.Add("RecordCreated", true);
+                    response.Results.Add("Target", new EntityReference(record.LogicalName, id));
+                }
                 results.Add(response);
             }