Compression and JustSaying 8.0 Changes

src/JustSaying/AwsTools/MessageHandling/ReceivedMessageConverter.cs

@@ -47,7 +47,7 @@
             var decompressor = _compressionRegistry.GetCompression(contentEncoding.StringValue);
             if (decompressor is null)
             {
                 throw new InvalidOperationException($"Compression encoding '{contentEncoding.StringValue}' is not registered.");
             }
 
             body = decompressor.Decompress(body);
@@ -76,17 +76,31 @@
             var dataType = property.Value.GetProperty("Type").GetString();
             var dataValue = property.Value.GetProperty("Value").GetString();
 
-            attributes.Add(property.Name, MessageAttributeParser.Parse(dataType, dataValue));
+            attributes.Add(property.Name, ParseMessageAttribute(dataType, dataValue));
         }
 
         return new MessageAttributes(attributes);
     }
 
+    public static MessageAttributeValue ParseMessageAttribute(string dataType, string dataValue)
+    {
+        // Check for a prefix instead of an exact match as SQS supports custom-type labels, or example, "Binary.gif".
+        // See https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-message-metadata.html#sqs-message-attributes.
+        bool isBinary = dataType?.StartsWith("Binary", StringComparison.Ordinal) is true;
+
+        return new()
+        {
+            DataType = dataType,
+            StringValue = !isBinary ? dataValue : null,
+            BinaryValue = isBinary ? Convert.FromBase64String(dataValue) : null
+        };
+    }
+
     private static MessageAttributes GetRawMessageAttributes(Amazon.SQS.Model.Message message)
     {
         if (message.MessageAttributes is null)
         {
             return new MessageAttributes();
         }
 
         Dictionary<string, MessageAttributeValue> rawAttributes = new ();
@@ -95,7 +109,7 @@
         {
             var dataType = messageMessageAttribute.Value.DataType;
             var dataValue = messageMessageAttribute.Value.StringValue;
-            rawAttributes.Add(messageMessageAttribute.Key, MessageAttributeParser.Parse(dataType, dataValue));
+            rawAttributes.Add(messageMessageAttribute.Key, ParseMessageAttribute(dataType, dataValue));
         }
 
         return new MessageAttributes(rawAttributes);
@@ -113,7 +127,7 @@
             var utf8JsonReader = new Utf8JsonReader(Encoding.UTF8.GetBytes(body));
             if (!JsonDocument.TryParseValue(ref utf8JsonReader, out var jsonDocument))
             {
                 return false;
             }
 
             using (jsonDocument)

tests/JustSaying.Extensions.DependencyInjection.StructureMap.Tests/StructureMapTests.cs

@@ -12,7 +12,7 @@ namespace JustSaying;
 public class WhenUsingStructureMap(ITestOutputHelper outputHelper)
 {
     private ITestOutputHelper OutputHelper { get; } = outputHelper;
-    private InMemoryAwsBus InMemoryAwsBus { get; } = new ();
+    private InMemoryAwsBus InMemoryAwsBus { get; } = new();
 
     [AwsFact]
     public async Task Can_Create_Messaging_Bus_Fluently_For_A_Queue()