Added CORS support

src/Infrastructure.Common/Recording/RecorderOptions.cs

@@ -150,7 +150,6 @@ public enum MetricReporterOption
 {
     None = 0,
     Cloud = 1,
-    ForwardToAncillaryApi = 3
 }
 
 /// <summary>
@@ -160,5 +159,4 @@ public enum UsageReporterOption
 {
     None = 0,
     ReliableQueue = 1,
-    ForwardToAncillaryApi = 2
 }

src/Infrastructure.Hosting.Common/Recording/HostRecorder.cs

@@ -67,9 +67,23 @@ private void Dispose(bool disposing)
             (_crashReporter as IDisposable)?.Dispose();
             // ReSharper disable once SuspiciousTypeConversion.Global
             (_metricsReporter as IDisposable)?.Dispose();
+            // ReSharper disable once SuspiciousTypeConversion.Global
+            (_usageReporter as IDisposable)?.Dispose();
         }
     }
 
+    public override string ToString()
+    {
+        var builder = new StringBuilder();
+        builder.AppendFormat("{0}: ", GetType().Name);
+        builder.AppendFormat("Crashes-> {0}, ", _crashReporter.GetType().Name);
+        builder.AppendFormat("Audits -> {0}, ", _auditReporter.GetType().Name);
+        builder.AppendFormat("Usages -> {0}, ", _usageReporter.GetType().Name);
+        builder.AppendFormat("Metrics -> {0}", _metricsReporter.GetType().Name);
+
+        return builder.ToString();
+    }
+
     public void TraceDebug(ICallContext? context, string messageTemplate, params object[] templateArgs)
     {
         var (augmentedMessageTemplate, augmentedArguments) =
@@ -243,7 +257,6 @@ private static IMetricReporter GetMetricReporter(IDependencyContainer container,
 #elif HOSTEDONAWS
                     new NullMetricReporter(),
 #endif
-            MetricReporterOption.ForwardToAncillaryApi => new ForwardToAncillaryApiMetrics(container),
             _ => throw new ArgumentOutOfRangeException(nameof(options.MetricReporting))
         };
     }
@@ -256,7 +269,6 @@ private static IUsageReporter GetUsageReporter(IDependencyContainer container,
             UsageReporterOption.None => new NullUsageReporter(),
             UsageReporterOption.ReliableQueue => new QueuedUsageReporter(container,
                 container.Resolve<IConfigurationSettings>().Platform),
-            UsageReporterOption.ForwardToAncillaryApi => new ForwardToAncillaryApiUsages(container),
             _ => throw new ArgumentOutOfRangeException(nameof(options.MetricReporting))
         };
     }

src/Infrastructure.Persistence.Common/ApplicationServices/InProcessInMemStore.cs

@@ -1,6 +1,6 @@
 #if TESTINGONLY
 using System.Diagnostics.CodeAnalysis;
-using Common;
+using Common.Extensions;
 using Domain.Interfaces;
 using Infrastructure.Persistence.Interfaces;
 using Infrastructure.Persistence.Interfaces.ApplicationServices;
@@ -13,13 +13,18 @@ namespace Infrastructure.Persistence.Common.ApplicationServices;
 [ExcludeFromCodeCoverage]
 public sealed partial class InProcessInMemStore
 {
-    public InProcessInMemStore(Optional<IQueueStoreNotificationHandler> handler = default)
+    public static InProcessInMemStore Create(IQueueStoreNotificationHandler? handler = default)
     {
-        if (handler.HasValue)
+        return new InProcessInMemStore(handler);
+    }
+
+    private InProcessInMemStore(IQueueStoreNotificationHandler? handler = default)
+    {
+        if (handler.Exists())
         {
             FireMessageQueueUpdated += (_, args) =>
             {
-                handler.Value.HandleMessagesQueueUpdated(args.QueueName, args.MessageCount);
+                handler.HandleMessagesQueueUpdated(args.QueueName, args.MessageCount);
             };
             NotifyAllQueuedMessages();
         }

src/Infrastructure.Persistence.Common/ApplicationServices/LocalMachineJsonFileStore.cs

@@ -22,7 +22,7 @@ public partial class LocalMachineJsonFileStore
     private readonly string _rootPath;
 
     public static LocalMachineJsonFileStore Create(ISettings settings,
-        Optional<IQueueStoreNotificationHandler> handler = default)
+        IQueueStoreNotificationHandler? handler = default)
     {
         var configPath = settings.GetString(PathSettingName);
         var basePath = Environment.GetFolderPath(Environment.SpecialFolder.LocalApplicationData);
@@ -32,7 +32,7 @@ public static LocalMachineJsonFileStore Create(ISettings settings,
         return new LocalMachineJsonFileStore(path, handler);
     }
 
-    private LocalMachineJsonFileStore(string rootPath, Optional<IQueueStoreNotificationHandler> handler = default)
+    private LocalMachineJsonFileStore(string rootPath, IQueueStoreNotificationHandler? handler = default)
     {
         rootPath.ThrowIfNotValuedParameter(nameof(rootPath));
         if (rootPath.IsInvalidParameter(ValidateRootPath, nameof(rootPath),
@@ -43,11 +43,11 @@ private LocalMachineJsonFileStore(string rootPath, Optional<IQueueStoreNotificat
 
         _rootPath = rootPath;
 
-        if (handler.HasValue)
+        if (handler.Exists())
         {
             FireMessageQueueUpdated += (_, args) =>
             {
-                handler.Value.HandleMessagesQueueUpdated(args.QueueName, args.MessageCount);
+                handler.HandleMessagesQueueUpdated(args.QueueName, args.MessageCount);
             };
             NotifyAllQueuedMessages();
         }

src/Infrastructure.Persistence.Shared.IntegrationTests/InProcessInMemStoreSpec.cs

@@ -14,13 +14,15 @@ public class AllInProcessInMemStoreSpecs : ICollectionFixture<InProcessInMemStor
 [UsedImplicitly]
 public class InProcessInMemStoreSpecSetup : StoreSpecSetupBase
 {
-    public IBlobStore BlobStore { get; } = new InProcessInMemStore();
+    private readonly InProcessInMemStore _store = InProcessInMemStore.Create();
 
-    public IDataStore DataStore { get; } = new InProcessInMemStore();
+    public IBlobStore BlobStore => _store;
 
-    public IEventStore EventStore { get; } = new InProcessInMemStore();
+    public IDataStore DataStore => _store;
 
-    public IQueueStore QueueStore { get; } = new InProcessInMemStore();
+    public IEventStore EventStore => _store;
+
+    public IQueueStore QueueStore => _store;
 }
 
 [Trait("Category", "Integration.Storage")]

src/Infrastructure.Persistence.Shared.IntegrationTests/LocalMachineJsonFileStoreSpec.cs

@@ -14,21 +14,20 @@ public class AllLocalMachineJsonFileStoreSpecs : ICollectionFixture<LocalMachine
 [UsedImplicitly]
 public class LocalMachineJsonFileStoreSpecSetup : StoreSpecSetupBase
 {
+    private readonly LocalMachineJsonFileStore _store;
+
     public LocalMachineJsonFileStoreSpecSetup()
     {
-        DataStore = LocalMachineJsonFileStore.Create(Settings);
-        BlobStore = LocalMachineJsonFileStore.Create(Settings);
-        QueueStore = LocalMachineJsonFileStore.Create(Settings);
-        EventStore = LocalMachineJsonFileStore.Create(Settings);
+        _store = LocalMachineJsonFileStore.Create(Settings);
     }
 
-    public IBlobStore BlobStore { get; }
+    public IBlobStore BlobStore => _store;
 
-    public IDataStore DataStore { get; }
+    public IDataStore DataStore => _store;
 
-    public IEventStore EventStore { get; }
+    public IEventStore EventStore => _store;
 
-    public IQueueStore QueueStore { get; }
+    public IQueueStore QueueStore => _store;
 }
 
 [Trait("Category", "Integration.Storage")]

src/Infrastructure.Web.Api.Common/HttpConstants.cs

@@ -24,6 +24,7 @@ public static class HttpHeaders
 {
     public const string Accept = "Accept";
     public const string Authorization = "Authorization";
+    public const string ContentType = "Content-Type";
     public const string HmacSignature = "X-Hub-Signature";
     public const string RequestId = "Request-ID";
 }

src/Infrastructure.Web.Api.Common/Resources.resx

@@ -27,7 +27,4 @@
     <data name="RequestExtensions_MissingRouteAttribute" xml:space="preserve">
         <value>The request DTO type '{0}' is missing a '{1}' declared on the class</value>
     </data>
-    <data name="WebApplicationExtensions_AddExceptionShielding_UnexpectedExceptionMessage" xml:space="preserve">
-        <value>An unexpected error occurred</value>
-    </data>
 </root>

src/Infrastructure.Web.Hosting.Common/ApplicationServices/StubQueueDrainingService.cs

@@ -56,6 +56,8 @@ public override void Dispose()
         GC.SuppressFinalize(this);
     }
 
+    public IEnumerable<string> MonitoredQueues => _monitorQueueMappings.Select(mqm => mqm.Key);
+
     protected override async Task ExecuteAsync(CancellationToken cancellationToken)
     {
         await Task.Delay(StartInterval, cancellationToken);