Merge pull request #349 from Particular/better-installer-coverage-back

src/SharedAcceptanceTests.All/When_saga_table_doesnt_exist_and_installers_disabled.cs

@@ -0,0 +1,93 @@
+namespace NServiceBus.AcceptanceTests
+{
+    using System;
+    using System.Linq;
+    using System.Threading.Tasks;
+    using NServiceBus;
+    using AcceptanceTesting;
+    using Configuration.AdvancedExtensibility;
+    using NServiceBus.AcceptanceTesting.Support;
+    using Testing;
+    using EndpointTemplates;
+    using NUnit.Framework;
+
+    public partial class When_saga_table_doesnt_exist_and_installers_disabled : NServiceBusAcceptanceTest
+    {
+        private const string TableThatDoesntExist = "doesnotexist";
+
+        [SetUp]
+        public Task Setup()
+        {
+            return SetupFixture.TableClient.GetTableReference(TableThatDoesntExist).DeleteIfExistsAsync();
+        }
+
+        [Test]
+        public void Should_throw_not_supported()
+        {
+            var exception = Assert.ThrowsAsync<MessageFailedException>(async () =>
+                await Scenario.Define<Context>()
+                    .WithEndpoint<EndpointWithInstallersOff>(b => b.When(session => session.SendLocal(new StartSagaMessage
+                    {
+                        SomeId = Guid.NewGuid()
+                    })))
+                    .Done(c => c.FailedMessages.Any())
+                    .Run());
+
+            Assert.AreEqual(1, exception.ScenarioContext.FailedMessages.Count);
+            StringAssert.Contains(
+                ConnectionStringHelper.IsPremiumEndpoint(SetupFixture.TableClient)
+                    ? "The specified resource does not exist."
+                    : "Element 0 in the batch returned an unexpected response code.",
+                exception.FailedMessage.Exception.Message);
+        }
+
+        public class Context : ScenarioContext
+        {
+        }
+
+        public class EndpointWithInstallersOff : EndpointConfigurationBuilder
+        {
+            public EndpointWithInstallersOff()
+            {
+                EndpointSetup<DefaultServer>(c =>
+                {
+                    // so that we don't have to create a new endpoint template
+                    c.GetSettings().Set("Installers.Enable", false);
+
+                    var sagaPersistence = c.UsePersistence<AzureTablePersistence, StorageType.Sagas>();
+                    sagaPersistence.DefaultTable(TableThatDoesntExist);
+
+                    var subscriptionStorage = c.UsePersistence<AzureTablePersistence, StorageType.Subscriptions>();
+                });
+            }
+
+            public class SomeSaga : Saga<SomeSagaData>, IAmStartedByMessages<StartSagaMessage>
+            {
+                public Task Handle(StartSagaMessage message, IMessageHandlerContext context)
+                {
+                    Data.SomeId = message.SomeId;
+                    return Task.CompletedTask;
+                }
+
+                protected override void ConfigureHowToFindSaga(SagaPropertyMapper<SomeSagaData> mapper)
+                {
+                    mapper.ConfigureMapping<StartSagaMessage>(m => m.SomeId)
+                        .ToSaga(s => s.SomeId);
+                }
+            }
+
+            public class SomeSagaData : IContainSagaData
+            {
+                public Guid Id { get; set; }
+                public string Originator { get; set; }
+                public string OriginalMessageId { get; set; }
+                public Guid SomeId { get; set; }
+            }
+        }
+
+        public class StartSagaMessage : ICommand
+        {
+            public Guid SomeId { get; set; }
+        }
+    }
+}

src/SharedAcceptanceTests.All/When_saga_table_doesnt_exist_and_table_creation_disabled.cs

@@ -12,12 +12,20 @@ namespace NServiceBus.AcceptanceTests
 
     public partial class When_saga_table_doesnt_exist_and_table_creation_disabled : NServiceBusAcceptanceTest
     {
+        private const string TableThatDoesntExist = "doesnotexist";
+
+        [SetUp]
+        public Task Setup()
+        {
+            return SetupFixture.TableClient.GetTableReference(TableThatDoesntExist).DeleteIfExistsAsync();
+        }
+
         [Test]
         public void Should_throw_not_supported()
         {
             var exception = Assert.ThrowsAsync<MessageFailedException>(async () =>
                 await Scenario.Define<Context>()
-                    .WithEndpoint<EndpointWithSchemaCreationOff>(b => b.When(session => session.SendLocal(new StartSagaMessage
+                    .WithEndpoint<EndpointWithTableCreationDisabled>(b => b.When(session => session.SendLocal(new StartSagaMessage
                     {
                         SomeId = Guid.NewGuid()
                     })))
@@ -36,14 +44,14 @@ public class Context : ScenarioContext
         {
         }
 
-        public class EndpointWithSchemaCreationOff : EndpointConfigurationBuilder
+        public class EndpointWithTableCreationDisabled : EndpointConfigurationBuilder
         {
-            public EndpointWithSchemaCreationOff()
+            public EndpointWithTableCreationDisabled()
             {
                 EndpointSetup<DefaultServer>(c =>
                 {
                     var sagaPersistence = c.UsePersistence<AzureTablePersistence, StorageType.Sagas>();
-                    sagaPersistence.DefaultTable("doesnotexist");
+                    sagaPersistence.DefaultTable(TableThatDoesntExist);
                     sagaPersistence.DisableTableCreation();
 
                     var subscriptionStorage = c.UsePersistence<AzureTablePersistence, StorageType.Subscriptions>();