Added unit tests for DomainService.

src/ReliableUnitOfWork.SqlAzure.UnitTests/DomainServiceFacts.cs

@@ -0,0 +1,22 @@
+using ReliableUnitOfWork.SqlAzure.Interfaces;
+using Xunit;
+
+namespace ReliableUnitOfWork.SqlAzure.UnitTests
+{
+    public class DomainServiceFacts
+    {
+        private readonly IUnitOfWorkFactory<TestContext> unitOfWorkFactory = new UnitOfWorkFactory<TestContext>();
+        private readonly TestPlayer1 player = new TestPlayer1();
+
+        [Fact]
+        public void ShouldCreateUnitOfWorkPerMethodAndJoinPlayersAccordingly()
+        {
+            var service = new TestService(unitOfWorkFactory, player);
+
+            Assert.True(service.FirstCall());
+            Assert.True(service.AnothertCall());
+            Assert.True(service.FirstCall());
+            Assert.True(service.AnothertCall());
+        }
+    }
+}

src/ReliableUnitOfWork.SqlAzure.UnitTests/ReliableUnitOfWork.SqlAzure.UnitTests.csproj

@@ -49,6 +49,7 @@
     </Reference>
   </ItemGroup>
   <ItemGroup>
+    <Compile Include="DomainServiceFacts.cs" />
     <Compile Include="UnitOfWorkFactoryFacts.cs" />
     <Compile Include="UnitOfWorkFacts.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />

src/ReliableUnitOfWork.SqlAzure.UnitTests/TestObjects.cs

@@ -1,4 +1,5 @@
 using System;
+using ReliableUnitOfWork.SqlAzure.Interfaces;
 
 namespace ReliableUnitOfWork.SqlAzure.UnitTests
 {
@@ -27,4 +28,31 @@ protected override void HandlePlayerJoinedUnit(object sender, EventArgs e)
             TestPlayer1.Join(UnitOfWork);
         }
     }
+
+    public class TestService : DomainService<TestContext>
+    {
+        private readonly TestPlayer1 player;
+
+        public TestService(IUnitOfWorkFactory<TestContext> unitOfWorkFactory, TestPlayer1 testPlayer1)
+            : base(unitOfWorkFactory, testPlayer1)
+        {
+            player = testPlayer1;
+        }
+
+        public bool FirstCall()
+        {
+            using (var uow = StartNewUnit())
+            {
+                return uow.UniqueId == player.UnitOfWork.UniqueId;
+            }
+        }
+
+        public bool AnothertCall()
+        {
+            using (var uow = StartNewUnit())
+            {
+                return uow.UniqueId == player.UnitOfWork.UniqueId;
+            }
+        }
+    }
 }