Add unit tests of CAP builder.

test/DotNetCore.CAP.EntityFrameworkCore.Test/DotNetCore.CAP.EntityFrameworkCore.Test.csproj

@@ -28,7 +28,7 @@
     <PackageReference Include="xunit" Version="2.2.0" />
     <PackageReference Include="Microsoft.AspNetCore.Http" Version="1.1.2" />
     <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="1.1.1" />
-    <PackageReference Include="Moq" Version="4.7.10" />
+    <PackageReference Include="Moq" Version="4.7.63" />
     <PackageReference Include="Microsoft.Extensions.Logging" Version="1.1.2" />
     <PackageReference Include="Microsoft.Extensions.Configuration.Abstractions" Version="1.1.2" />
     <PackageReference Include="Microsoft.Extensions.Configuration" Version="1.1.2" />

test/DotNetCore.CAP.Test/CAP.BuilderTest.cs

+using System;
+using System.Threading;
+using System.Threading.Tasks;
+using DotNetCore.CAP.Infrastructure;
+using DotNetCore.CAP.Job;
+using Microsoft.Extensions.DependencyInjection;
+using Xunit;
+
+namespace DotNetCore.CAP.Test
+{
+    public class CapBuilderTest
+    {
+        [Fact]
+        public void CanOverrideMessageStore()
+        {
+            var services = new ServiceCollection();
+            services.AddConsistency().AddMessageStore<MyMessageStore>();
+
+            var thingy = services.BuildServiceProvider()
+
+                .GetRequiredService<ICapMessageStore>() as MyMessageStore;
+
+            Assert.NotNull(thingy);
+        }
+
+        [Fact]
+        public void CanOverrideJobs()
+        {
+            var services = new ServiceCollection();
+            services.AddConsistency().AddJobs<MyJobTest>();
+
+            var thingy = services.BuildServiceProvider()
+                .GetRequiredService<IJob>() as MyJobTest;
+
+            Assert.NotNull(thingy);
+        }
+
+        [Fact]
+        public void CanOverrideProducerService()
+        {
+            var services = new ServiceCollection();
+            services.AddConsistency().AddProducerService<MyProducerService>();
+
+            var thingy = services.BuildServiceProvider()
+                .GetRequiredService<ICapProducerService>() as MyProducerService;
+
+            Assert.NotNull(thingy);
+        }
+
+
+        private class MyProducerService : ICapProducerService
+        {
+            public Task SendAsync(string topic, string content)
+            {
+                throw new NotImplementedException();
+            }
+        }
+
+
+        private class MyJobTest : IJob
+        {
+            public Task ExecuteAsync()
+            {
+                throw new NotImplementedException();
+            }
+        }
+
+        private class MyMessageStore : ICapMessageStore
+        {
+            public Task<OperateResult> CreateAsync(ConsistencyMessage message, CancellationToken cancellationToken)
+            {
+                throw new NotImplementedException();
+            }
+
+            public Task<OperateResult> DeleteAsync(ConsistencyMessage message, CancellationToken cancellationToken)
+            {
+                throw new NotImplementedException();
+            }
+
+            public Task<ConsistencyMessage> FindByIdAsync(string messageId, CancellationToken cancellationToken)
+            {
+                throw new NotImplementedException();
+            }
+
+            public Task<string> GeConsistencyMessageIdAsync(ConsistencyMessage message, CancellationToken cancellationToken)
+            {
+                throw new NotImplementedException();
+            }
+
+            public Task<ConsistencyMessage> GetFirstEnqueuedMessageAsync(CancellationToken cancellationToken)
+            {
+                throw new NotImplementedException();
+            }
+
+            public Task<OperateResult> UpdateAsync(ConsistencyMessage message, CancellationToken cancellationToken)
+            {
+                throw new NotImplementedException();
+            }
+        }
+    }
+}
\ No newline at end of file

test/DotNetCore.CAP.Test/ConsistencyBuilderTest.cs

-//using System;
-//using System.Threading;
-//using System.Threading.Tasks;
-//using DotNetCore.CAP.Infrastructure;
-//using DotNetCore.CAP.Store;
-//using Microsoft.Extensions.DependencyInjection;
-//using Xunit;
-
-//namespace DotNetCore.CAP.Test
-//{
-//    public class ConsistencyBuilderTest
-//    {
-//        [Fact]
-//        public void CanOverrideMessageStore() {
-//            var services = new ServiceCollection();
-//            services.AddConsistency().AddMessageStore<MyUberThingy>();
-//            var thingy = services.BuildServiceProvider().GetRequiredService<IConsistencyMessageStore>() as MyUberThingy;
-//            Assert.NotNull(thingy);
-//        }
-
-//        private class MyUberThingy : IConsistencyMessageStore
-//        {
-//            public Task<OperateResult> CreateAsync(ConsistencyMessage message, CancellationToken cancellationToken) {
-//                throw new NotImplementedException();
-//            }
-
-//            public Task<OperateResult> DeleteAsync(ConsistencyMessage message, CancellationToken cancellationToken) {
-//                throw new NotImplementedException();
-//            }
-
-//            public void Dispose() {
-//                throw new NotImplementedException();
-//            }
-
-//            public Task<ConsistencyMessage> FindByIdAsync(string messageId, CancellationToken cancellationToken) {
-//                throw new NotImplementedException();
-//            }
-
-//            public Task<string> GeConsistencyMessageIdAsync(ConsistencyMessage message, CancellationToken cancellationToken) {
-//                throw new NotImplementedException();
-//            }
-
-//            public Task<string> GetMessageIdAsync(ConsistencyMessage message, CancellationToken cancellationToken) {
-//                throw new NotImplementedException();
-//            }
-
-//            public Task<OperateResult> UpdateAsync(ConsistencyMessage message, CancellationToken cancellationToken) {
-//                throw new NotImplementedException();
-//            }
-//        }
-//    }
-//}
\ No newline at end of file

test/DotNetCore.CAP.Test/ConsistencyMessageManagerTest.cs

-//using System;
-//using System.Threading;
-//using System.Threading.Tasks;
-//using DotNetCore.CAP.Infrastructure;
-//using DotNetCore.CAP.Store;
-//using Microsoft.AspNetCore.Http;
-//using Microsoft.Extensions.DependencyInjection;
-//using Microsoft.Extensions.Logging;
-//using Moq;
-//using Xunit;
-
-//namespace DotNetCore.CAP.Test
-//{
-//    public class ConsistencyMessageManagerTest
-//    {
-//        [Fact]
-//        public void EnsureDefaultServicesDefaultsWithStoreWorks() {
-//            var services = new ServiceCollection()
-//                .AddTransient<IConsistencyMessageStore, NoopMessageStore>();
-//            services.AddConsistency();
-//            services.AddSingleton<IHttpContextAccessor, HttpContextAccessor>();
-//            services.AddLogging();
-
-//            var manager = services.BuildServiceProvider()
-//                .GetRequiredService<IConsistencyMessageStore >();
-
-//            Assert.NotNull(manager);
-//        }
-
-//        [Fact]
-//        public void AddMessageManagerWithCustomerMannagerReturnsSameInstance() {
-//            var services = new ServiceCollection()
-//                .AddTransient<IConsistencyMessageStore, NoopMessageStore>()
-//                .AddSingleton<IHttpContextAccessor, HttpContextAccessor>();
-
-//            services.AddLogging();
-
-//            //services.AddConsistency()
-//            //    .AddConsistencyMessageManager<CustomMessageManager>();
-
-//            var provider = services.BuildServiceProvider();
-
-//            Assert.Same(provider.GetRequiredService<IConsistencyMessageStore >(),
-//                provider.GetRequiredService<CustomMessageManager>());
-//        }
-
-//        public class CustomMessageManager : IConsistencyMessageStore 
-//        {
-//            public CustomMessageManager()
-//                : base(new Mock<IConsistencyMessageStore>().Object, null, null) {
-//            }
-//        }
-
-//        [Fact]
-//        public async Task CreateCallsStore() {
-//            var store = new Mock<IConsistencyMessageStore>();
-//            var message = new ConsistencyMessage { SendTime = DateTime.Now };
-//            store.Setup(x => x.CreateAsync(message, CancellationToken.None)).ReturnsAsync(OperateResult.Success).Verifiable();
-//            var messageManager = TestConsistencyMessageManager(store.Object);
-
-//            var result = await messageManager.CreateAsync(message);
-
-//            Assert.True(result.Succeeded);
-//            store.VerifyAll();
-//        }
-
-//        public IConsistencyMessageStore  TestConsistencyMessageManager(IConsistencyMessageStore store = null) {
-//            store = store ?? new Mock<IConsistencyMessageStore>().Object;
-//            var mockLogger = new Mock<ILogger<IConsistencyMessageStore >>().Object;
-//            var manager = new IConsistencyMessageStore (store, null, mockLogger);
-//            return manager;
-//        }
-//    }
-//}
\ No newline at end of file

test/DotNetCore.CAP.Test/ConsistencyOptionsTest.cs

@@ -2,5 +2,6 @@
 {
     public class ConsistencyOptionsTest
     {
+
     }
 }
\ No newline at end of file

test/DotNetCore.CAP.Test/DotNetCore.CAP.Test.csproj

@@ -24,7 +24,7 @@
     <PackageReference Include="xunit" Version="2.2.0" />
     <PackageReference Include="Microsoft.AspNetCore.Http" Version="1.1.2" />
     <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="1.1.1" />
-    <PackageReference Include="Moq" Version="4.7.10" />
+    <PackageReference Include="Moq" Version="4.7.63" />
     <PackageReference Include="Microsoft.Extensions.Logging" Version="1.1.2" />
   </ItemGroup>
 
@@ -32,4 +32,8 @@
     <Service Include="{82a7f48d-3b50-4b1e-b82e-3ada8210c358}" />
   </ItemGroup>
 
+  <ItemGroup>
+    <Folder Include="Job\" />
+  </ItemGroup>
+
 </Project>

test/DotNetCore.CAP.Test/NoopMessageStore.cs

-//using System;
-//using System.Threading;
-//using System.Threading.Tasks;
-//using DotNetCore.CAP.Infrastructure;
-//using DotNetCore.CAP.Store;
-
-//namespace DotNetCore.CAP.Test
-//{
-//    public class NoopMessageStore : IConsistencyMessageStore
-//    {
-//        public Task<OperateResult> CreateAsync(ConsistencyMessage message, CancellationToken cancellationToken) {
-//            throw new NotImplementedException();
-//        }
-
-//        public Task<OperateResult> DeleteAsync(ConsistencyMessage message, CancellationToken cancellationToken) {
-//            throw new NotImplementedException();
-//        }
-
-//        public void Dispose() {
-//            throw new NotImplementedException();
-//        }
-
-//        public Task<ConsistencyMessage> FindByIdAsync(string messageId, CancellationToken cancellationToken) {
-//            throw new NotImplementedException();
-//        }
-
-//        public Task<string> GeConsistencyMessageIdAsync(ConsistencyMessage message, CancellationToken cancellationToken) {
-//            throw new NotImplementedException();
-//        }
-
-//        public Task<string> GetMessageIdAsync(ConsistencyMessage message, CancellationToken cancellationToken) {
-//            throw new NotImplementedException();
-//        }
-
-//        public Task<OperateResult> UpdateAsync(ConsistencyMessage message, CancellationToken cancellationToken) {
-//            throw new NotImplementedException();
-//        }
-//    }
-//}
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+using DotNetCore.CAP.Infrastructure;
+
+namespace DotNetCore.CAP.Test
+{
+    public class NoopMessageStore : ICapMessageStore
+    {
+        public Task<OperateResult> CreateAsync(ConsistencyMessage message, CancellationToken cancellationToken)
+        {
+            throw new NotImplementedException();
+        }
+
+        public Task<OperateResult> DeleteAsync(ConsistencyMessage message, CancellationToken cancellationToken)
+        {
+            throw new NotImplementedException();
+        }
+
+        public void Dispose()
+        {
+            throw new NotImplementedException();
+        }
+
+        public Task<ConsistencyMessage> FindByIdAsync(string messageId, CancellationToken cancellationToken)
+        {
+            throw new NotImplementedException();
+        }
+
+        public Task<string> GeConsistencyMessageIdAsync(ConsistencyMessage message, CancellationToken cancellationToken)
+        {
+            throw new NotImplementedException();
+        }
+
+        public Task<ConsistencyMessage> GetFirstEnqueuedMessageAsync(CancellationToken cancellationToken)
+        {
+            throw new NotImplementedException();
+        }
+
\ No newline at end of file
+        public Task<string> GetMessageIdAsync(ConsistencyMessage message, CancellationToken cancellationToken)
+        {
+            throw new NotImplementedException();
+        }
+
+        public Task<OperateResult> UpdateAsync(ConsistencyMessage message, CancellationToken cancellationToken)
+        {
+            throw new NotImplementedException();
+        }
+    }
+}
\ No newline at end of file