Adds Decorator, wip

Core/Database/DatabaseScope.cs

@@ -1,4 +1,5 @@
 using System.Data;
+using System.Diagnostics;
 using Microsoft.ApplicationInsights.DataContracts;
 using Microsoft.ApplicationInsights.Extensibility;
 
@@ -6,19 +7,24 @@ namespace PlanTempus.Core.Database;
 
 public class DatabaseScope : IDisposable
 {
-    private readonly IOperationHolder<DependencyTelemetry> _operation;
+    internal readonly IOperationHolder<DependencyTelemetry> _operation;
+    private readonly Stopwatch _stopwatch;
 
     public DatabaseScope(IDbConnection connection, IOperationHolder<DependencyTelemetry> operation)
     {
         Connection = connection;
         _operation = operation;
         _operation.Telemetry.Success = true;
+        _stopwatch = Stopwatch.StartNew();
     }
 
     public IDbConnection Connection { get; }
 
     public void Dispose()
     {
+        _stopwatch.Stop();
+        _operation.Telemetry.Duration = _stopwatch.Elapsed;
+
         _operation.Dispose();
         Connection.Dispose();
     }

Core/ModuleRegistry/SecurityModule.cs

@@ -0,0 +1,14 @@
+using Autofac;
+using PlanTempus.Core.SeqLogging;
+
+namespace PlanTempus.Core.ModuleRegistry
+{
+    public class SecurityModule : Module
+    {
+        protected override void Load(ContainerBuilder builder)
+        {
+            builder.RegisterType<SecureTokenizer>()
+                .As<ISecureTokenizer>();
+        }
+    }
+}

PlanTempus.Components/CommandHandler.cs

@@ -5,9 +5,9 @@ namespace PlanTempus.Components;
 
 public class CommandHandler(IComponentContext context) : ICommandHandler
 {
-    public Task<TCommandResult> Handle<TCommand, TCommandResult>(TCommand command)
+    public async Task<TCommandResult> Handle<TCommand, TCommandResult>(TCommand command)
     {
         var handler = context.Resolve<ICommandHandler<TCommand, TCommandResult>>();
-        return handler.Handle(command);
+        return await handler.Handle(command);
     }
 }

PlanTempus.Components/ICommandHandler.cs

@@ -0,0 +1,15 @@
+namespace PlanTempus.Components;
+
+public interface ICommandHandler
+{
+    Task<TCommandResult> Handle<TCommand, TCommandResult>(TCommand command);
+}
+
+public interface ICommandHandler<in T, TResult>
+{
+    Task<TResult> Handle(T input);
+}
+
+public interface ICommandHandlerDecorator
+{
+}

PlanTempus.Components/ModuleRegistry/CommandModule.cs

@@ -1,4 +1,5 @@
 using Autofac;
+using PlanTempus.Components.Users.Create;
 using PlanTempus.Core.SeqLogging;
 
 namespace PlanTempus.Components.ModuleRegistry
@@ -9,15 +10,34 @@ namespace PlanTempus.Components.ModuleRegistry
 
         protected override void Load(ContainerBuilder builder)
         {
-            // Registrer alle handlers
-            builder.RegisterAssemblyTypes()
-                .AsClosedTypesOf(typeof(ICommandHandler<>))
+
+            builder.RegisterType<PlanTempus.Components.CommandHandler>()
+                .As<PlanTempus.Components.ICommandHandler>()
                 .InstancePerLifetimeScope();
                 
+            builder.RegisterAssemblyTypes(ThisAssembly)
+                .Where(t => !typeof(ICommandHandlerDecorator).IsAssignableFrom(t))
+                .AsClosedTypesOf(typeof(ICommandHandler<,>))
+                .InstancePerLifetimeScope();
+            
+            
+            // Registrer alle handlers
+            // builder.RegisterAssemblyTypes(ThisAssembly)
+            //     .AsClosedTypesOf(typeof(ICommandHandler<,>))
+            //     .InstancePerLifetimeScope();
+
+            builder.RegisterAssemblyTypes(ThisAssembly)
+                 .As<ICommandHandlerDecorator>();
+            
+            
+            builder.RegisterDecorator(
+                typeof(CreateUserHandlerDecorator), 
+                typeof(ICommandHandler<CreateUserCommand, CreateUserResult>));
+            //     
             // Registrer en decorator for alle ICommandHandler<TCommand>
-            builder.RegisterGenericDecorator(
-                typeof(CreateUserHandlerDecorator<>), // Din decorator-klasse
-                typeof(ICommandHandler<>)); // Interface, der skal dekoreres
+            // builder.RegisterGenericDecorator(
+            //     typeof(CommandHandlerDecorator<,>), 
+            //     typeof(ICommandHandler<,>));
 
         }
     }

PlanTempus.Components/Users/Create/CreateUserHandler.cs

@@ -8,16 +8,6 @@ using PlanTempus.Core.Telemetry;
 
 namespace PlanTempus.Components.Users.Create
 {
-    public interface ICommandHandler
-    {
-        Task<TCommandResult> Handle<TCommand, TCommandResult>(TCommand command );
-    }
-    
-    public interface ICommandHandler<in T, TResult>
-    {
-        Task<TResult> Handle(T input);
-    }
-
     public class CreateUserHandler(
         TelemetryClient telemetryClient,
         IDatabaseOperations databaseOperations,
@@ -50,7 +40,6 @@ namespace PlanTempus.Components.Users.Create
 
                 var result = data.First();
 
-                telemetryClient.TrackTrace(GetType().Name, result.Format());
 
                 return result;
             }

PlanTempus.Components/Users/Create/CreateUserHandlerDecorator.cs

@@ -1,25 +1,41 @@
-using Microsoft.ApplicationInsights;
+using System.Diagnostics;
+using Microsoft.ApplicationInsights;
+using Microsoft.ApplicationInsights.DataContracts;
 
 namespace PlanTempus.Components.Users.Create;
 
-public class CreateUserHandlerDecorator : ICommandHandler<CreateUserCommand, CreateUserResult>
-{
-    private readonly ICommandHandler<CreateUserCommand, CreateUserResult> _decoratedHandler;
-    private readonly TelemetryClient _telemetryClient;
-
-    public CreateUserHandlerDecorator(
+public class CreateUserHandlerDecorator(
     ICommandHandler<CreateUserCommand, CreateUserResult> decoratedHandler,
     TelemetryClient telemetryClient)
+    : ICommandHandler<CreateUserCommand, CreateUserResult>, ICommandHandlerDecorator
 {
-        _decoratedHandler = decoratedHandler;
-        _telemetryClient = telemetryClient;
-    }
-
     public async Task<CreateUserResult> Handle(CreateUserCommand command)
     {
-        _telemetryClient.TrackTrace($"Before handling {nameof(CreateUserCommand)}");
-        var result = await _decoratedHandler.Handle(command);
-        _telemetryClient.TrackTrace($"After handling {nameof(CreateUserCommand)}");
+        // var correlationId = Activity.Current?.RootId ?? command.CorrelationId;
+
+        using (var operation =
+               telemetryClient.StartOperation<RequestTelemetry>($"Handle {nameof(CreateUserCommand)}",
+                   command.CorrelationId.ToString()))
+        {
+            try
+            {
+                operation.Telemetry.Properties["CorrelationId"] = command.CorrelationId.ToString();
+                var result = await decoratedHandler.Handle(command);
+
+                operation.Telemetry.Success = true;
+
                 return result;
             }
+            catch (Exception ex)
+            {
+                operation.Telemetry.Success = false;
+
+                telemetryClient.TrackException(ex, new Dictionary<string, string>
+                {
+                    ["CommandType"] = nameof(CreateUserCommand)
+                });
+                throw;
+            }
+        }
+    }
 }

Tests/CommandQueryHandlerTests/HandlerTest.cs

@@ -4,6 +4,7 @@ using PlanTempus.Components;
 using PlanTempus.Components.Users.Create;
 using PlanTempus.Core.Database;
 using PlanTempus.Core.Database.ConnectionFactory;
+using Shouldly;
 
 namespace PlanTempus.X.TDD.CommandQueryHandlerTests;
 
@@ -16,18 +17,21 @@ public class HandlerTest : TestFixture
     }
 
     [TestMethod]
-    public void TestDefaultConnection()
+    public async Task ShouldResolveCommandHandlerAndDispatchToGenericCommandHandler()
     {
-        var commandHandler = Container.Resolve<CommandHandler>();
+        var commandHandler = Container.Resolve<ICommandHandler>();
+        commandHandler.ShouldBeOfType<CommandHandler>();
 
         var command = new CreateUserCommand
         {
-            Email = "lloyd@dumbanddumber.com", // Lloyd Christmas
+            Email = "lloyd@dumbanddumber.com1", // Lloyd Christmas
             Password = "1234AceVentura#LOL", // Ace Ventura
             IsActive = true,
             CorrelationId = Guid.NewGuid()
         };
 
-        var result = commandHandler.Handle<CreateUserCommand, CreateUserResult>(command);
+        var result = await commandHandler.Handle<CreateUserCommand, CreateUserResult>(command);
+        
+        result.ShouldNotBeNull();
     }
 }

Tests/TestFixture.cs

@@ -2,6 +2,7 @@
 using Autofac;
 using Microsoft.ApplicationInsights;
 using Microsoft.Extensions.Logging;
+using PlanTempus.Components.ModuleRegistry;
 using PlanTempus.Core.Configurations;
 using PlanTempus.Core.Configurations.JsonConfigProvider;
 using PlanTempus.Core.ModuleRegistry;
@@ -67,6 +68,8 @@ public abstract class TestFixture
             SeqConfiguration = configuration.GetSection("SeqConfiguration").ToObject<SeqConfiguration>()
         });
 
+        builder.RegisterModule<CommandModule>();
+        builder.RegisterModule<SecurityModule>();
         
         ContainerBuilder = builder;
     }