memory provider idempotency updates

src/providers/WorkflowCore.Persistence.EntityFramework/Exceptions/WorkflowExistsException.cs → src/WorkflowCore/Exceptions/WorkflowExistsException.cs

@@ -1,7 +1,7 @@
 using System;
 using System.Runtime.Serialization;
 
-namespace WorkflowCore.Persistence.EntityFramework.Exceptions
+namespace WorkflowCore.Exceptions
 {
     public class WorkflowExistsException : Exception
     {

src/WorkflowCore/Services/DefaultProviders/MemoryPersistenceProvider.cs

@@ -3,6 +3,7 @@
 using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
+using WorkflowCore.Exceptions;
 using WorkflowCore.Interface;
 using WorkflowCore.Models;
 
@@ -30,6 +31,11 @@ public async Task<string> CreateNewWorkflow(WorkflowInstance workflow, Cancellat
         {
             lock (_instances)
             {
+                if (workflow.Reference != null && _instances.Any(x => x.Reference == workflow.Reference))
+                {
+                    throw new WorkflowExistsException();
+                }
+
                 workflow.Id = Guid.NewGuid().ToString();
                 _instances.Add(workflow);
                 return workflow.Id;

src/providers/WorkflowCore.Persistence.PostgreSQL/PostgresContext.cs

@@ -4,7 +4,7 @@
 using System;
 using System.Threading;
 using System.Threading.Tasks;
-using WorkflowCore.Persistence.EntityFramework.Exceptions;
+using WorkflowCore.Exceptions;
 using WorkflowCore.Persistence.EntityFramework.Models;
 using WorkflowCore.Persistence.EntityFramework.Services;
 

test/WorkflowCore.Tests.PostgreSQL/Scenarios/PostgresIdempotentReferenceScenario.cs

@@ -2,10 +2,10 @@
 using Microsoft.Extensions.DependencyInjection;
 using System;
 using System.Threading.Tasks;
+using WorkflowCore.Exceptions;
 using WorkflowCore.IntegrationTests.Scenarios;
 using WorkflowCore.Interface;
 using WorkflowCore.Models;
-using WorkflowCore.Persistence.EntityFramework.Exceptions;
 using WorkflowCore.Persistence.EntityFramework.Interfaces;
 using WorkflowCore.Testing;
 using Xunit;