Fix Bug - build MockRepositorySpecification without schema

Author: David Nierman

src/ReactiveDomain.Testing/Specifications/MockRepositorySpecification.cs

@@ -23,10 +23,10 @@ public class MockRepositorySpecification : DispatcherSpecification
         /// </summary>
         /// <param name="schema">Schema prefix for stream name.</param>
         /// <param name="dataStore">Stream store connection.</param>
-        public MockRepositorySpecification(string schema, IStreamStoreConnection dataStore)
+        private MockRepositorySpecification(string schema, IStreamStoreConnection dataStore)
         {
             _schema = schema;
-            StreamNameBuilder = new PrefixedCamelCaseStreamNameBuilder(schema);
+            StreamNameBuilder = string.IsNullOrEmpty(schema) ? new PrefixedCamelCaseStreamNameBuilder() : new PrefixedCamelCaseStreamNameBuilder(schema);
             StreamStoreConnection = dataStore;
             StreamStoreConnection.Connect();
             EventSerializer = new JsonMessageSerializer();
@@ -55,7 +55,7 @@ public MockRepositorySpecification(string schema, IStreamStoreConnection dataSto
         /// Creates a mock repository connected to a StreamStore. 
         /// </summary>
         /// <param name="dataStore">Stream store connection.</param>
-        public MockRepositorySpecification(IStreamStoreConnection dataStore) : this("", dataStore)
+        public MockRepositorySpecification(IStreamStoreConnection dataStore) : this(dataStore.ConnectionName, dataStore)
         {
         }
 

src/ReactiveDomain.Testing/Specifications/MockRepositoryTests.cs

@@ -1,6 +1,7 @@
 using System;
 using ReactiveDomain.Messaging;
 using ReactiveDomain.Messaging.Bus;
+using ReactiveDomain.Testing.EventStore;
 using Xunit;
 
 namespace ReactiveDomain.Testing
@@ -28,7 +29,7 @@ public void can_get_repository_events()
             var aggregate = new TestAggregate(id);
             _fixture.Repository.Save(aggregate);
             _fixture.RepositoryEvents.WaitFor<TestAggregateMessages.NewAggregate>(TimeSpan.FromMilliseconds(500));
-            
+
             _fixture
                 .RepositoryEvents
                 .AssertNext<TestAggregateMessages.NewAggregate>(e => e.AggregateId == id, "Aggregate Id Mismatch")
@@ -37,7 +38,7 @@ public void can_get_repository_events()
 
         [Fact]
         public void can_clear_queues()
-        {          
+        {
             var evt = new TestEvent();
             _fixture.Dispatcher.Publish(evt);
 
@@ -70,6 +71,28 @@ public void can_clear_queues()
                 .RepositoryEvents
                 .AssertEmpty();
         }
+
+        [Fact]
+        public void create_mock_repository_without_a_prefix()
+        {
+            var id = Guid.NewGuid();
+            var expectedStreamName = $"testAggregate-{id:n}";
+            var mockRepositoryWithoutPrefix = new MockRepositorySpecification(dataStore: new MockStreamStoreConnection(""));
+            var categoryStreamName = mockRepositoryWithoutPrefix.StreamNameBuilder.GenerateForAggregate(typeof(TestAggregate), id);
+            Assert.Equal(expectedStreamName, categoryStreamName);
+        }
+
+        [Fact]
+        public void create_mock_repository_with_a_prefix()
+        {
+            var prefix = "iamaprefix";
+            var id = Guid.NewGuid();
+            var expectedStreamName = $"{prefix}.testAggregate-{id:n}";
+            var mockRepositoryWithoutPrefix = new MockRepositorySpecification(dataStore: new MockStreamStoreConnection(prefix));
+            var categoryStreamName = mockRepositoryWithoutPrefix.StreamNameBuilder.GenerateForAggregate(typeof(TestAggregate), id);
+            Assert.Equal(expectedStreamName, categoryStreamName);
+        }
+
         public CommandResponse Handle(TestCommands.Command1 command)
         {
             return command.Succeed();