Support Native AOT

Directory.Packages.props

@@ -1,13 +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<JsonSerializerOptions>(cfg =>
+    {
+        cfg.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 @@
 
         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 @@
         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<JsonSerializerOptions>>().Value));
+#else
         services.TryAddSingleton<IMessageSerializationFactory, NewtonsoftSerializationFactory>();
+#endif
         services.TryAddSingleton<IMessageSubjectProvider, GenericMessageSubjectProvider>();
         services.TryAddSingleton<IVerifyAmazonQueues, AmazonQueueCreator>();
         services.TryAddSingleton<IMessageSerializationRegister>(
@@ -199,7 +208,11 @@
     /// <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

@@ -4,15 +4,19 @@
     <GenerateDocumentationFile>true</GenerateDocumentationFile>
     <IsShipping>true</IsShipping>
     <RootNamespace>Microsoft.Extensions.DependencyInjection</RootNamespace>
-    <TargetFrameworks>netstandard2.0;net461</TargetFrameworks>
+    <TargetFrameworks>netstandard2.0;net461;net8.0</TargetFrameworks>
   </PropertyGroup>
   <ItemGroup>
     <ProjectReference Include="..\JustSaying\JustSaying.csproj" />
   </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.Extensions.DependencyInjection.Microsoft/PublicAPI/net8.0/PublicAPI.Shipped.txt

@@ -0,0 +1,8 @@
+Microsoft.Extensions.DependencyInjection.IServiceCollectionExtensions
+static Microsoft.Extensions.DependencyInjection.IServiceCollectionExtensions.AddJustSaying(this Microsoft.Extensions.DependencyInjection.IServiceCollection services) -> Microsoft.Extensions.DependencyInjection.IServiceCollection
+static Microsoft.Extensions.DependencyInjection.IServiceCollectionExtensions.AddJustSaying(this Microsoft.Extensions.DependencyInjection.IServiceCollection services, string region) -> Microsoft.Extensions.DependencyInjection.IServiceCollection
+static Microsoft.Extensions.DependencyInjection.IServiceCollectionExtensions.AddJustSaying(this Microsoft.Extensions.DependencyInjection.IServiceCollection services, System.Action<JustSaying.MessagingBusBuilder, System.IServiceProvider> configure) -> Microsoft.Extensions.DependencyInjection.IServiceCollection
+static Microsoft.Extensions.DependencyInjection.IServiceCollectionExtensions.AddJustSaying(this Microsoft.Extensions.DependencyInjection.IServiceCollection services, System.Action<JustSaying.MessagingBusBuilder> configure) -> Microsoft.Extensions.DependencyInjection.IServiceCollection
+static Microsoft.Extensions.DependencyInjection.IServiceCollectionExtensions.AddJustSayingHandler<TMessage, THandler>(this Microsoft.Extensions.DependencyInjection.IServiceCollection services) -> Microsoft.Extensions.DependencyInjection.IServiceCollection
+static Microsoft.Extensions.DependencyInjection.IServiceCollectionExtensions.AddJustSayingHandlers<TMessage>(this Microsoft.Extensions.DependencyInjection.IServiceCollection services, System.Collections.Generic.IEnumerable<JustSaying.Messaging.MessageHandling.IHandlerAsync<TMessage>> handlers) -> Microsoft.Extensions.DependencyInjection.IServiceCollection
+static Microsoft.Extensions.DependencyInjection.IServiceCollectionExtensions.ConfigureJustSaying(this Microsoft.Extensions.DependencyInjection.IServiceCollection services, System.Action<JustSaying.MessagingBusBuilder> configure) -> Microsoft.Extensions.DependencyInjection.IServiceCollection

src/JustSaying.Models/JustSaying.Models.csproj

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
   <PropertyGroup>
     <IsShipping>true</IsShipping>
-    <TargetFrameworks>netstandard2.0;net461</TargetFrameworks>
+    <TargetFrameworks>netstandard2.0;net461;net8.0</TargetFrameworks>
   </PropertyGroup>
   <ItemGroup>
     <Using Remove="System.Net.Http" />

src/JustSaying.Models/PublicAPI/net8.0/PublicAPI.Shipped.txt

@@ -0,0 +1,15 @@
+JustSaying.Models.Message
+JustSaying.Models.Message.Conversation.get -> string
+JustSaying.Models.Message.Conversation.set -> void
+JustSaying.Models.Message.Id.get -> System.Guid
+JustSaying.Models.Message.Id.set -> void
+JustSaying.Models.Message.Message() -> void
+JustSaying.Models.Message.RaisingComponent.get -> string
+JustSaying.Models.Message.RaisingComponent.set -> void
+JustSaying.Models.Message.SourceIp.get -> string
+JustSaying.Models.Message.Tenant.get -> string
+JustSaying.Models.Message.Tenant.set -> void
+JustSaying.Models.Message.TimeStamp.get -> System.DateTime
+JustSaying.Models.Message.TimeStamp.set -> void
+JustSaying.Models.Message.Version.get -> string
+virtual JustSaying.Models.Message.UniqueKey() -> string

src/JustSaying/AwsTools/MessageHandling/PublishException.cs

@@ -17,7 +17,9 @@ public PublishException(string message, Exception inner) : base(message, inner)
     {
     }
 
+#if !NET8_0_OR_GREATER
     protected PublishException(SerializationInfo info, StreamingContext context) : base(info, context)
     {
     }
-}
+#endif
+}

src/JustSaying/AwsTools/MessageHandling/SnsPolicyBuilder.cs

@@ -1,5 +1,6 @@
 using System.Text.Json;
 using Amazon;
+using JustSaying.Messaging.MessageSerialization;
 
 namespace JustSaying.AwsTools.MessageHandling;
 
@@ -41,12 +42,21 @@ 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}""
         }}
     ]
 }}";
     }
+
+    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/ConfigurationErrorsException.cs

@@ -17,7 +17,9 @@ public ConfigurationErrorsException(string message, Exception inner) : base(mess
     {
     }
 
+#if !NET8_0_OR_GREATER
     protected ConfigurationErrorsException(SerializationInfo info, StreamingContext context) : base(info, context)
     {
     }
-}
+#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 @@
         }
         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 @@
 
         return null;
     }
-}
+}

src/JustSaying/HandlerNotRegisteredWithContainerException.cs

@@ -17,7 +17,9 @@ public HandlerNotRegisteredWithContainerException(string message, Exception inne
     {
     }
 
+#if !NET8_0_OR_GREATER
     protected HandlerNotRegisteredWithContainerException(SerializationInfo info, StreamingContext context) : base(info, context)
     {
     }
+#endif
 }