Support Native AOT

Directory.Build.props

@@ -64,4 +64,10 @@
     <None Include="$(MSBuildThisFileDirectory)$(PackageIcon)" Pack="True" PackagePath="" />
     <None Include="$(MSBuildThisFileDirectory)$(PackageReadmeFile)" Pack="True" PackagePath="" />
   </ItemGroup>
+  <ItemGroup Condition="$([MSBuild]::IsTargetFrameworkCompatible('$(TargetFramework)','net8.0'))">
+    <Using Include="System.Diagnostics.CodeAnalysis" />
+  </ItemGroup>
+  <PropertyGroup Condition="$([MSBuild]::IsTargetFrameworkCompatible('$(TargetFramework)','net8.0'))">
+    <IsAotCompatible>true</IsAotCompatible>
+  </PropertyGroup>
 </Project>

Directory.Packages.props

@@ -1,14 +1,15 @@
 <Project>
   <ItemGroup Label="Libraries">
     <PackageVersion Include="AWSSDK.Extensions.NETCore.Setup" Version="3.7.300" />
-    <PackageVersion Include="AWSSDK.SimpleNotificationService" Version="3.7.0" />
-    <PackageVersion Include="AWSSDK.SQS" Version="3.7.0" />
+    <PackageVersion Include="AWSSDK.SimpleNotificationService" Version="3.7.300" />
+    <PackageVersion Include="AWSSDK.SQS" Version="3.7.300" />
     <PackageVersion Include="Microsoft.Bcl.AsyncInterfaces" Version="1.1.1" />
     <PackageVersion Include="Microsoft.Extensions.Configuration" Version="8.0.0" />
     <PackageVersion Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="1.1.0" Condition=" '$(TargetFramework)' == 'net461' " />
     <PackageVersion Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="2.0.0" Condition=" '$(TargetFramework)' == 'netstandard2.0' " />
     <PackageVersion Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="8.0.0" Condition=" '$(TargetFramework)' == 'net8.0' " />
     <PackageVersion Include="Microsoft.Extensions.Logging.Abstractions" Version="2.0.0" />
+    <PackageVersion Include="Microsoft.Extensions.Options" Version="8.0.0" Condition=" '$(TargetFramework)' == 'net8.0' " />
     <PackageVersion Include="Newtonsoft.Json" Version="13.0.1" />
     <PackageVersion Include="StructureMap" Version="4.6.0" />
     <PackageVersion Include="System.Text.Json" Version="4.6.0" />

samples/src/JustSaying.Sample.Restaurant.OrderingApi/ApplicationJsonContext.cs

@@ -0,0 +1,12 @@
+using System.Text.Json.Serialization;
+using JustSaying.Sample.Restaurant.Models;
+using JustSaying.Sample.Restaurant.OrderingApi.Models;
+
+namespace JustSaying.Sample.Restaurant.OrderingApi;
+
+[JsonSerializable(typeof(CustomerOrderModel))]
+[JsonSerializable(typeof(OrderPlacedEvent))]
+[JsonSerializable(typeof(OrderReadyEvent))]
+[JsonSerializable(typeof(OrderDeliveredEvent))]
+[JsonSerializable(typeof(OrderOnItsWayEvent))]
+public sealed partial class ApplicationJsonContext : JsonSerializerContext;

samples/src/JustSaying.Sample.Restaurant.OrderingApi/JustSaying.Sample.Restaurant.OrderingApi.csproj

@@ -21,7 +21,11 @@
   </ItemGroup>
 
   <ItemGroup>
-    <Content Update="appsettings.json" CopyToOutputDirectory="PreserveNewest" />
+    <Content Update="appsettings.json" CopyToOutputDirectory="PreserveNewest" CopyToPublishDirectory="PreserveNewest" />
   </ItemGroup>
 
+  <PropertyGroup>
+    <PublishAot>true</PublishAot>
+  </PropertyGroup>
+
 </Project>

samples/src/JustSaying.Sample.Restaurant.OrderingApi/OrderingApi.http

@@ -0,0 +1,11 @@
+@HostAddress = http://localhost:5001
+
+POST {{HostAddress}}/api/orders
+Content-Type: application/json
+Accept: application/json
+
+{
+  "description": "A cool description"
+}
+
+###

samples/src/JustSaying.Sample.Restaurant.OrderingApi/Program.cs

@@ -1,8 +1,11 @@
+using System.Text.Json;
 using JustSaying.Messaging;
+using JustSaying.Messaging.MessageSerialization;
 using JustSaying.Sample.Restaurant.Models;
 using JustSaying.Sample.Restaurant.OrderingApi;
 using JustSaying.Sample.Restaurant.OrderingApi.Handlers;
 using JustSaying.Sample.Restaurant.OrderingApi.Models;
+using Microsoft.Extensions.Options;
 using Microsoft.OpenApi.Models;
 using Serilog;
 using Serilog.Events;
@@ -23,6 +26,16 @@
     var builder = WebApplication.CreateBuilder(args);
     var configuration = builder.Configuration;
     builder.Host.UseSerilog();
+    builder.Services.ConfigureHttpJsonOptions(cfg =>
+    {
+        cfg.SerializerOptions.TypeInfoResolverChain.Insert(0, ApplicationJsonContext.Default);
+    });
+
+    builder.Services.Configure<JustSayingJsonSerializerOptions>(cfg =>
+    {
+        cfg.SerializerOptions.TypeInfoResolverChain.Insert(0, ApplicationJsonContext.Default);
+    });
+
     builder.Services.AddJustSaying(config =>
     {
         config.Client(x =>

samples/src/JustSaying.Sample.Restaurant.OrderingApi/appsettings.json

@@ -1,5 +1,5 @@
 {
   "AWSRegion": "eu-west-1",
-  "AWSServiceUrl": "http://localhost:4100",
+  "AWSServiceUrl": "http://localhost:4566",
   "AllowedHosts": "*"
 }

src/JustSaying.Extensions.DependencyInjection.Microsoft/IServiceCollectionExtensions.cs

@@ -12,6 +12,11 @@
 using JustSaying.Models;
 using JustSaying.Naming;
 using Microsoft.Extensions.DependencyInjection.Extensions;
+#if NET8_0_OR_GREATER
+using System.Text.Json;
+using Microsoft.Extensions.Options;
+using System.Diagnostics.CodeAnalysis;
+#endif
 
 namespace Microsoft.Extensions.DependencyInjection;
 
@@ -61,7 +66,7 @@ public static IServiceCollection AddJustSaying(this IServiceCollection services,
 
         if (string.IsNullOrWhiteSpace(region))
         {
-            throw new ArgumentException("region must not be null or empty" ,nameof(region));
+            throw new ArgumentException("region must not be null or empty", nameof(region));
         }
 
         return services.AddJustSaying(
@@ -135,7 +140,11 @@ public static IServiceCollection AddJustSaying(this IServiceCollection services,
         services.TryAddSingleton<IMessageContextAccessor>(serviceProvider => serviceProvider.GetRequiredService<MessageContextAccessor>());
         services.TryAddSingleton<IMessageContextReader>(serviceProvider => serviceProvider.GetRequiredService<MessageContextAccessor>());
 
+#if NET8_0_OR_GREATER
+        services.TryAddSingleton<IMessageSerializationFactory>(sp => new TypedSystemTextJsonSerializationFactory(sp.GetRequiredService<IOptions<JustSayingJsonSerializerOptions>>().Value));
+#else
         services.TryAddSingleton<IMessageSerializationFactory, NewtonsoftSerializationFactory>();
+#endif
         services.TryAddSingleton<IMessageSubjectProvider, GenericMessageSubjectProvider>();
         services.TryAddSingleton<IVerifyAmazonQueues, AmazonQueueCreator>();
         services.TryAddSingleton<IMessageSerializationRegister>(
@@ -199,7 +208,11 @@ public static IServiceCollection AddJustSaying(this IServiceCollection services,
     /// <exception cref="ArgumentNullException">
     /// <paramref name="services"/> is <see langword="null"/>.
     /// </exception>
+#if NET8_0_OR_GREATER
+    public static IServiceCollection AddJustSayingHandler<TMessage, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] THandler>(this IServiceCollection services)
+#else
     public static IServiceCollection AddJustSayingHandler<TMessage, THandler>(this IServiceCollection services)
+#endif
         where TMessage : Message
         where THandler : class, IHandlerAsync<TMessage>
     {

src/JustSaying.Extensions.DependencyInjection.Microsoft/JustSaying.Extensions.DependencyInjection.Microsoft.csproj

@@ -11,8 +11,12 @@
   </ItemGroup>
   <ItemGroup>
     <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" />
+    <PackageReference Include="Microsoft.Extensions.Options" Condition="$([MSBuild]::IsTargetFrameworkCompatible('$(TargetFramework)','net8.0'))" />
   </ItemGroup>
   <ItemGroup>
     <Using Remove="System.Net.Http" />
   </ItemGroup>
+  <PropertyGroup Condition="$([MSBuild]::IsTargetFrameworkCompatible('$(TargetFramework)','net8.0'))">
+    <IsAotCompatible>true</IsAotCompatible>
+  </PropertyGroup>
 </Project>

src/JustSaying/AwsTools/MessageHandling/SnsPolicyBuilder.cs

@@ -1,5 +1,6 @@
 using System.Text.Json;
 using Amazon;
+using JustSaying.Messaging.MessageSerialization;
 
 namespace JustSaying.AwsTools.MessageHandling;
 
@@ -42,7 +43,7 @@ internal static string BuildPolicyJson(SnsPolicyDetails policyDetails)
                              "Sid" : "{{Guid.NewGuid().ToString().Replace("-", "")}}",
                              "Effect" : "Allow",
                              "Principal" : {
-                                 "AWS" : {{JsonSerializer.Serialize(policyDetails.AccountIds)}}
+                                 "AWS" : {{SerializeAccountIds(policyDetails.AccountIds)}}
                              },
                              "Action"    : "sns:Subscribe",
                              "Resource"  : "{{policyDetails.SourceArn}}"
@@ -51,4 +52,13 @@ internal static string BuildPolicyJson(SnsPolicyDetails policyDetails)
                  }
                  """;
     }
+
+    private static string SerializeAccountIds(IReadOnlyCollection<string> accountIds)
+    {
+#if NET8_0_OR_GREATER
+        return JsonSerializer.Serialize(accountIds, JustSayingSerializationContext.Default.IReadOnlyCollectionString);
+#else
+        return JsonSerializer.Serialize(accountIds);
+#endif
+    }
 }

src/JustSaying/AwsTools/QueueCreation/RedrivePolicy.cs

@@ -13,6 +13,9 @@ public class RedrivePolicy
     [JsonPropertyName("deadLetterTargetArn")]
     public string DeadLetterQueue { get; set; }
 
+#if NET8_0_OR_GREATER
+    [System.Text.Json.Serialization.JsonConstructor]
+#endif
     public RedrivePolicy(int maximumReceives, string deadLetterQueue)
     {
         MaximumReceives = maximumReceives;
@@ -23,11 +26,17 @@ protected RedrivePolicy()
     {
     }
 
-    // Cannot use System.Text.Json below as no public parameterless constructor. Change for v7?
-
     public override string ToString()
+#if NET8_0_OR_GREATER
+        => System.Text.Json.JsonSerializer.Serialize(this, JustSayingSerializationContext.Default.RedrivePolicy);
+#else
         => JsonConvert.SerializeObject(this);
+#endif
 
     public static RedrivePolicy ConvertFromString(string policy)
+#if NET8_0_OR_GREATER
+        => System.Text.Json.JsonSerializer.Deserialize(policy, JustSayingSerializationContext.Default.RedrivePolicy);
+#else
         => JsonConvert.DeserializeObject<RedrivePolicy>(policy);
-}
+#endif
+}

src/JustSaying/Constants.cs

@@ -0,0 +1,7 @@
+namespace JustSaying;
+
+internal static class Constants
+{
+    internal const string SerializationUnreferencedCodeMessage = "JSON serialization and deserialization might require types that cannot be statically analyzed. Use the overload that takes a JsonTypeInfo or JsonSerializerContext, or make sure all of the required types are preserved.";
+    internal const string SerializationDynamicCodeMessage = "JSON serialization and deserialization might require types that cannot be statically analyzed. Use the overload that takes a JsonTypeInfo or JsonSerializerContext.";
+}

src/JustSaying/Extensions/JsonSerializerOptionsExtensions.cs

@@ -0,0 +1,26 @@
+#if NET8_0_OR_GREATER
+using System.Text.Json;
+using System.Text.Json.Serialization.Metadata;
+
+namespace JustSaying.Extensions;
+
+
+internal static class JsonSerializerOptionsExtensions
+{
+    public static JsonTypeInfo<T> GetTypeInfo<T>(this JsonSerializerOptions options)
+    {
+        foreach (var info in options.TypeInfoResolverChain)
+        {
+            Console.WriteLine(info);
+        }
+
+        var typeInfo = options.GetTypeInfo(typeof(T));
+        if (typeInfo is not JsonTypeInfo<T> genericTypeInfo)
+        {
+            throw new JsonException($"Could not find type info for the specified type {typeof(T).Name}");
+        }
+
+        return genericTypeInfo;
+    }
+}
+#endif

src/JustSaying/Fluent/AccountAddressProvider.cs

@@ -106,10 +106,12 @@ public Uri GetQueueUriByConvention<T>()
     /// <returns>The <see cref="Uri"/> for this queue.</returns>
     public Uri GetQueueUri(string queueName)
     {
+#pragma warning disable CS0618 // Type or member is obsolete
         var hostname = _regionEndpoint.GetEndpointForService("sqs").Hostname;
+#pragma warning restore CS0618 // Type or member is obsolete
         return new UriBuilder("https", hostname)
         {
             Path = $"{_accountId}/{queueName}"
         }.Uri;
     }
-}
+}

src/JustSaying/Fluent/QueueAddress.cs

@@ -79,9 +79,11 @@ public static QueueAddress FromArn(string queueArn)
         if (!Arn.TryParse(queueArn, out var arn)) throw new ArgumentException("Must be a valid ARN.", nameof(queueArn));
         if (!string.Equals(arn.Service, "sqs", StringComparison.OrdinalIgnoreCase)) throw new ArgumentException("Must be an ARN for an SQS queue.", nameof(queueArn));
 
+#pragma warning disable CS0618 // Type or member is obsolete
         var hostname = RegionEndpoint.GetBySystemName(arn.Region)
             .GetEndpointForService("sqs")
             .Hostname;
+#pragma warning restore CS0618 // Type or member is obsolete
 
         var queueUrl = new UriBuilder("https", hostname)
         {
@@ -94,4 +96,4 @@ public static QueueAddress FromArn(string queueArn)
             RegionName = arn.Region
         };
     }
-}
+}

src/JustSaying/Fluent/ServiceResolver/DefaultServiceResolver.cs

@@ -1,3 +1,4 @@
+using System.Runtime.CompilerServices;
 using JustSaying.AwsTools;
 using JustSaying.Messaging.MessageSerialization;
 using JustSaying.Messaging.Monitoring;
@@ -44,7 +45,22 @@ private object TryResolveService(Type desiredType)
         }
         else if (desiredType == typeof(IMessageSerializationFactory))
         {
+
+#if NET8_0_OR_GREATER
+            if (RuntimeFeature.IsDynamicCodeSupported)
+            {
+                #pragma warning disable IL2026
+                #pragma warning disable IL3050
+                return new NewtonsoftSerializationFactory();
+                #pragma warning restore
+            }
+            else
+            {
+                throw new NotSupportedException($"Newtonsoft.Json is not supported when compiled with the 'PublishTrimmed' option. Use {nameof(TypedSystemTextJsonSerializationFactory)} instead.");
+            }
+#else
             return new NewtonsoftSerializationFactory();
+#endif
         }
         else if (desiredType == typeof(IMessageSerializationRegister))
         {
@@ -63,4 +79,4 @@ private object TryResolveService(Type desiredType)
 
         return null;
     }
-}
+}

src/JustSaying/JustSayingBus.cs

@@ -200,7 +200,7 @@ public async Task PublishAsync(
     {
         if (!_busStarted && _startupTasks.Count > 0)
         {
-            throw new InvalidOperationException("There are pending startup tasks that must be executed by calling StartAsync before messages may be published.");
+            throw new InvalidOperationException($"There are pending startup tasks that must be executed by calling StartAsync before messages may be published. Bus started {_busStarted}, Count {_startupTasks.Count}");
         }
 
         IMessagePublisher publisher = GetPublisherForMessage(message);

src/JustSaying/JustSayingSerializationContext.cs

@@ -0,0 +1,12 @@
+#if NET8_0_OR_GREATER
+using System.Text.Json.Serialization;
+using JustSaying.AwsTools.QueueCreation;
+using JustSaying.Messaging.MessageSerialization;
+
+namespace JustSaying;
+
+[JsonSerializable(typeof(SqsMessageEnvelope))]
+[JsonSerializable(typeof(IReadOnlyCollection<string>))]
+[JsonSerializable(typeof(RedrivePolicy))]
+internal sealed partial class JustSayingSerializationContext : JsonSerializerContext;
+#endif

src/JustSaying/Messaging/MessageSerialization/JustSayingJsonSerializerOptions.cs

@@ -0,0 +1,10 @@
+#if NET8_0_OR_GREATER
+using System.Text.Json;
+
+namespace JustSaying.Messaging.MessageSerialization;
+
+public class JustSayingJsonSerializerOptions
+{
+    public JsonSerializerOptions SerializerOptions { get; } = new();
+}
+#endif

src/JustSaying/Messaging/MessageSerialization/MessageFormatNotSupportedException.cs

@@ -19,7 +19,8 @@
 
     public MessageFormatNotSupportedException(string message, Exception innerException) : base(message, innerException)
     {
     }
+#if !NET8_0_OR_GREATER
 
 #if !NET8_0_OR_GREATER
     protected MessageFormatNotSupportedException(SerializationInfo info, StreamingContext context) : base(info, context)
@@ -27,3 +28,3 @@
     }
 #endif
 }

src/JustSaying/Messaging/MessageSerialization/NewtonsoftSerializationFactory.cs

@@ -3,6 +3,10 @@
 
 namespace JustSaying.Messaging.MessageSerialization;
 
+#if NET8_0_OR_GREATER
+[RequiresUnreferencedCode(Constants.SerializationUnreferencedCodeMessage)]
+[RequiresDynamicCode(Constants.SerializationDynamicCodeMessage)]
+#endif
 public class NewtonsoftSerializationFactory(JsonSerializerSettings settings) : IMessageSerializationFactory
 {
     private readonly NewtonsoftSerializer _serializer = new(settings);

src/JustSaying/Messaging/MessageSerialization/NewtonsoftSerializer.cs

@@ -5,6 +5,10 @@
 
 namespace JustSaying.Messaging.MessageSerialization;
 
+#if NET8_0_OR_GREATER
+[RequiresUnreferencedCode(Constants.SerializationUnreferencedCodeMessage)]
+[RequiresDynamicCode(Constants.SerializationDynamicCodeMessage)]
+#endif
 public class NewtonsoftSerializer : IMessageSerializer
 {
     private readonly JsonSerializerSettings _settings;

src/JustSaying/Messaging/MessageSerialization/SqsMessageEnvelope.cs

@@ -0,0 +1,8 @@
+namespace JustSaying.Messaging.MessageSerialization;
+
+internal sealed class SqsMessageEnvelope
+{
+    public string Subject { get; set; }
+
+    public string Message { get; set; }
+}