tests

Author: danielgerlag

test/WorkflowCore.IntegrationTests/Scenarios/ExternalEvents.cs

@@ -64,6 +64,7 @@ protected override void ConfigureWorkflow(IServiceCollection services)
                 counter++;                
             }
 
+            Host.PublishEvent("MyEvent", "1", "Fail");
             Host.PublishEvent("MyEvent", "0", "Pass");
 
             Instance = PersistenceProvider.GetWorkflowInstance(WorkflowId).Result;

test/WorkflowCore.TestAssets/LockProvider/DistributedLockProviderTests.cs

@@ -0,0 +1,65 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+using WorkflowCore.Interface;
+using NUnit;
+using FluentAssertions;
+using NUnit.Framework;
+
+namespace WorkflowCore.TestAssets.LockProvider
+{    
+    public abstract class DistributedLockProviderTests
+    {
+        protected IDistributedLockProvider Subject;
+
+        [SetUp]
+        public void Setup()
+        {
+            Subject = CreateProvider();
+            Subject.Start();
+        }
+
+        protected abstract IDistributedLockProvider CreateProvider();        
+
+        [Test]
+        public async void AcquiresLock()
+        {
+            const string lock1 = "lock1";
+            const string lock2 = "lock2";
+            await Subject.AcquireLock(lock2);
+
+            var acquired = await Subject.AcquireLock(lock1);
+
+            acquired.Should().Be(true);
+        }
+
+        [Test]
+        public async void DoesNotAcquireWhenLocked()
+        {
+            const string lock1 = "lock1";
+            await Subject.AcquireLock(lock1);
+
+            var acquired = await Subject.AcquireLock(lock1);
+
+            acquired.Should().Be(false);
+        }
+
+        [Test]
+        public async void ReleasesLock()
+        {
+            const string lock1 = "lock1";
+            await Subject.AcquireLock(lock1);
+
+            await Subject.ReleaseLock(lock1);
+
+            var available = await Subject.AcquireLock(lock1);
+            available.Should().Be(true);
+        }
+
+        [TearDown]
+        public virtual void TearDown()
+        {
+            Subject.Stop();
+        }
+    }
+}

test/WorkflowCore.TestAssets/WorkflowCore.TestAssets.csproj

@@ -17,12 +17,13 @@
 
   <ItemGroup>
     <PackageReference Include="FluentAssertions" Version="4.19.0" />
-    <PackageReference Include="Machine.Fakes" Version="2.8.0-beta3" />
-    <PackageReference Include="Machine.Fakes.Moq" Version="2.8.0-beta3" />
+    <PackageReference Include="Machine.Fakes" Version="2.8.0" />
+    <PackageReference Include="Machine.Fakes.Moq" Version="2.8.0" />
     <PackageReference Include="Machine.Specifications" Version="0.11.0" />
     <PackageReference Include="Machine.Specifications.Should" Version="0.11.0" />
     <PackageReference Include="Moq" Version="4.7.1" />
     <PackageReference Include="Newtonsoft.Json" Version="9.0.1" />
+    <PackageReference Include="NUnit" Version="3.6.1" />
   </ItemGroup>
 
 </Project>

test/WorkflowCore.UnitTests/SingleNodeLockProviderTests/SingleNodeLockProviderTests.cs

@@ -0,0 +1,20 @@
+using FluentAssertions;
+using NUnit.Framework;
+using System;
+using System.Collections.Generic;
+using System.Text;
+using WorkflowCore.Interface;
+using WorkflowCore.Services;
+using WorkflowCore.TestAssets.LockProvider;
+
+namespace WorkflowCore.UnitTests.SingleNodeLockProviderTests
+{
+    [TestFixture]
+    public class SingleNodeLockProviderTests : DistributedLockProviderTests
+    {
+        protected override IDistributedLockProvider CreateProvider()
+        {
+            return new SingleNodeLockProvider();
+        }
+    }
+}

test/WorkflowCore.UnitTests/WorkflowCore.UnitTests.csproj

@@ -30,6 +30,11 @@
     <PackageReference Include="Microsoft.Extensions.Logging.Console" Version="1.1.1" />
     <PackageReference Include="Microsoft.Extensions.Logging.Debug" Version="1.1.1" />
     <PackageReference Include="Moq" Version="4.7.1" />
+    <PackageReference Include="NUnit" Version="3.6.1" />
+    <PackageReference Include="NUnit.ConsoleRunner" Version="3.6.1" />
+    <PackageReference Include="NUnit3TestAdapter" Version="3.7.0" />
+    <PackageReference Include="System.Runtime.InteropServices" Version="4.3.0" />
+    <DotNetCliToolReference Include="dotnet-xunit" Version="2.3.0-beta1-build3642" />
   </ItemGroup>
 
 </Project>