feat: add PublishAsync method for serialized messages

Author: Morten Laursen

src/Atc.Azure.Messaging/EventHub/EventHubPublisher.cs

@@ -26,6 +26,17 @@ public Task PublishAsync(
             cancellationToken);
     }
 
+    public Task PublishAsync(
+        string message,
+        IDictionary<string, string>? messageProperties = null,
+        CancellationToken cancellationToken = default)
+    {
+        return PerformPublishAsync(
+            message,
+            messageProperties,
+            cancellationToken);
+    }
+
     private Task PerformPublishAsync(
         string messageBody,
         IDictionary<string, string>? messageProperties = null,

src/Atc.Azure.Messaging/EventHub/IEventHubPublisher.cs

@@ -1,7 +1,7 @@
 namespace Atc.Azure.Messaging.EventHub;
 
-/// <summary>
-/// Publisher responsible for publishing objects with metadata to a specific EventHub.
+/// <summary>
+/// Publisher responsible for publishing objects with metadata to a specific EventHub.
 /// </summary>
 /// <remarks>
 /// Is safe to cache and use in singletons for the lifetime of the application.
@@ -12,4 +12,9 @@ Task PublishAsync(
         object message,
         IDictionary<string, string>? messageProperties = null,
         CancellationToken cancellationToken = default);
+
+    Task PublishAsync(
+        string message,
+        IDictionary<string, string>? messageProperties = null,
+        CancellationToken cancellationToken = default);
 }

test/Atc.Azure.Messaging.Tests/EventHub/EventHubPublisherTests.cs

@@ -29,13 +29,14 @@ internal async Task PublishAsync_Calls_Client_With_Correct_MessageBody(
         [Frozen, Substitute] EventHubProducerClient client,
         [Frozen] IMessagePayloadSerializer serializer,
         EventHubPublisher sut,
-        string messageBody,
+        object messageBody,
+        string serializedMessage,
         IDictionary<string, string> properties,
         CancellationToken cancellationToken)
     {
         serializer
-            .Serialize<object>(default!)
-            .ReturnsForAnyArgs(messageBody);
+            .Serialize(messageBody)
+            .ReturnsForAnyArgs(serializedMessage);
         await sut.PublishAsync(
             messageBody,
             properties,
@@ -49,7 +50,31 @@ await sut.PublishAsync(
             .Should()
             .BeEquivalentTo(
                 Encoding.UTF8.GetBytes(
-                    messageBody));
+                    serializedMessage));
+    }
+
+    [Theory, AutoNSubstituteData]
+    internal async Task PublishAsync_Calls_Client_With_Correct_Serialized_MessageBody(
+        [Frozen, Substitute] EventHubProducerClient client,
+        EventHubPublisher sut,
+        string serializedMessage,
+        IDictionary<string, string> properties,
+        CancellationToken cancellationToken)
+    {
+        await sut.PublishAsync(
+            serializedMessage,
+            properties,
+            cancellationToken);
+
+        var data = client
+            .ReceivedCallWithArgument<EventData[]>()
+            .Single();
+
+        data.Body.ToArray()
+            .Should()
+            .BeEquivalentTo(
+                Encoding.UTF8.GetBytes(
+                    serializedMessage));
     }
 
     [Theory, AutoNSubstituteData]