Add support for transport mode validation and update durable mode enforcement

Author: carcer

src/Transports/SignalR/Wolverine.SignalR.Tests/Internals/SignalRTransportModeTests.cs

@@ -0,0 +1,34 @@
+using Shouldly;
+using Wolverine.Configuration;
+using Wolverine.SignalR.Internals;
+
+namespace Wolverine.SignalR.Tests.Internals;
+
+public class SignalRTransportModeTests
+{
+    private readonly SignalRTransport _transport = new();
+
+    [Fact]
+    public void does_not_support_durable_mode()
+    {
+        _transport.SupportsMode(EndpointMode.Durable).ShouldBeFalse();
+    }
+
+    [Fact]
+    public void supports_inline_mode()
+    {
+        _transport.SupportsMode(EndpointMode.Inline).ShouldBeTrue();
+    }
+
+    [Fact]
+    public void supports_buffered_in_memory_mode()
+    {
+        _transport.SupportsMode(EndpointMode.BufferedInMemory).ShouldBeTrue();
+    }
+
+    [Fact]
+    public void setting_durable_mode_throws_exception()
+    {
+        Should.Throw<InvalidOperationException>(() => _transport.Mode = EndpointMode.Durable);
+    }
+}

src/Wolverine/Configuration/Endpoint.cs

@@ -442,7 +442,15 @@ protected virtual bool supportsMode(EndpointMode mode)
     {
         return true;
     }
-    
+
+    /// <summary>
+    /// Check if this endpoint supports the specified mode
+    /// </summary>
+    public bool SupportsMode(EndpointMode mode)
+    {
+        return supportsMode(mode);
+    }
+
     // Is this endpoint part of a sharded messaging topology?
     // If so, this should be "auto-started"
     internal bool UsedInShardedTopology { get; set; }

src/Wolverine/Configuration/ISubscriberConfiguration.cs

@@ -70,6 +70,8 @@ public interface ISubscriberConfiguration<T> : IEndpointConfiguration<T> where T
     /// </summary>
     /// <returns></returns>
     public T GlobalSender();
+
+    public Endpoint Endpoint { get; }
 }
 
 public interface ISubscriberConfiguration : ISubscriberConfiguration<ISubscriberConfiguration>;

src/Wolverine/WolverineOptions.Policies.cs

@@ -72,7 +72,13 @@ void IPolicies.Add(IWolverinePolicy policy)
 
     void IPolicies.UseDurableInboxOnAllListeners()
     {
-        this.As<IPolicies>().AllListeners(x => x.UseDurableInbox());
+        this.As<IPolicies>().AllListeners(x =>
+        {
+            if (x.Endpoint.SupportsMode(EndpointMode.Durable))
+            {
+                x.UseDurableInbox();
+            }
+        });
     }
 
     internal readonly List<IHandledTypeRule> HandledTypeRules = [new AgentCommandHandledTypeRule()];
@@ -94,7 +100,13 @@ void IPolicies.UseDurableLocalQueues()
 
     void IPolicies.UseDurableOutboxOnAllSendingEndpoints()
     {
-        this.As<IPolicies>().AllSenders(x => x.UseDurableOutbox());
+        this.As<IPolicies>().AllSenders(x =>
+        {
+            if (x.Endpoint.SupportsMode(EndpointMode.Durable))
+            {
+                x.UseDurableOutbox();
+            }
+        });
     }
 
     void IPolicies.AllListeners(Action<ListenerConfiguration> configure)