Unwrap the OutboxMessage before publishing it

Libraries/CO.CDP.AwsServices.Tests/Sqs/SqsPublisherTest.cs

@@ -4,6 +4,7 @@
 using Amazon.SQS.Model;
 using CO.CDP.AwsServices.Sqs;
 using CO.CDP.MQ;
+using CO.CDP.MQ.Outbox;
 using CO.CDP.MQ.Tests;
 using FluentAssertions;
 using Microsoft.Extensions.Logging;
@@ -22,6 +23,22 @@ public SqsPublisherTest(LocalStackFixture localStack)
         _sqsClient = SqsClient();
     }
 
+    [Fact]
+    public async Task ItPublishesOutboxMessageToTheQueue()
+    {
+        var publisher = await CreatePublisher();
+
+        await publisher.Publish(new OutboxMessage
+        {
+            Type = "TestMessage",
+            Message = "{\"Id\":13,\"Name\":\"Hello!\"}"
+        });
+
+        var message = await waitForOneMessage<TestMessage>();
+
+        message.Should().Be(new TestMessage(13, "Hello!"));
+    }
+
     protected override async Task<T> waitForOneMessage<T>() where T : class
     {
         var queue = await _sqsClient.GetQueueUrlAsync(TestQueue);
@@ -34,6 +51,7 @@ protected override async Task<T> waitForOneMessage<T>() where T : class
         var message = messages.Messages.First<Message>();
         var type = message.MessageAttributes.GetValueOrDefault("Type")?.StringValue;
         type.Should().Be(typeof(T).Name);
+        await _sqsClient.DeleteMessageAsync(queue.QueueUrl, message.ReceiptHandle);
         return JsonSerializer.Deserialize<T>(message.Body) ??
                throw new Exception($"Unable to deserialize {message.Body} into {typeof(T).FullName}");
     }

Libraries/CO.CDP.AwsServices/Sqs/SqsPublisher.cs

@@ -2,20 +2,17 @@
 using Amazon.SQS;
 using Amazon.SQS.Model;
 using CO.CDP.MQ;
+using CO.CDP.MQ.Outbox;
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
 
 namespace CO.CDP.AwsServices.Sqs;
 
-public delegate string Serializer(object message);
-
-public delegate string TypeMapper(object message);
-
 public class SqsPublisher(
     IAmazonSQS sqsClient,
     SqsPublisherConfiguration configuration,
-    Serializer serializer,
-    TypeMapper typeMapper,
+    Func<object, string> serializer,
+    Func<object, string> typeMapper,
     ILogger<SqsPublisher> logger
 ) : IPublisher
 {
@@ -29,8 +26,8 @@ public SqsPublisher(IAmazonSQS sqsClient, IOptions<AwsConfiguration> configurati
     public SqsPublisher(IAmazonSQS sqsClient, SqsPublisherConfiguration configuration, ILogger<SqsPublisher> logger) : this(
         sqsClient,
         configuration,
-        o => JsonSerializer.Serialize(o),
-        o => o.GetType().Name,
+        OutboxMessageSerializerFactory.Create(o => JsonSerializer.Serialize(o)),
+        OutboxMessageTypeMapperFactory.Create(o => o.GetType().Name),
         logger)
     {
     }