Add custom CQRS with dependency injection

NewTests/CQRS/GetUpperValueQuery.cs

@@ -0,0 +1,20 @@
+using NewTests.DependencyInjection;
+
+namespace NewTests.CQRS;
+
+public class GetUpperValueQuery : IQueryHandler<string>
+{
+    private readonly string _value;
+
+    [Inject] public IStringFormatter Formatter { get; set; }
+
+    public GetUpperValueQuery(string value)
+    {
+        _value = value;
+    }
+
+    public string Handle()
+    {
+        return Formatter.Format(_value);
+    }
+}

NewTests/CQRS/GetUpperValueQuerySpecs.cs

@@ -0,0 +1,20 @@
+using Autofac;
+using NewTests.DependencyInjection;
+
+namespace NewTests.CQRS;
+
+public class GetUpperValueQuerySpecs
+{
+    [Test]
+    public void It_get_upper_value()
+    {
+        var container = new AppContainer();
+        container.RegisterDependencies(builder => builder.RegisterType<UpperStringFormatter>().As<IStringFormatter>());
+
+        var query = new GetUpperValueQuery("Hello");
+
+        var result = Messages.Dispatch(query);
+
+        Assert.That(result, Is.EqualTo("HELLO"));
+    }
+}

NewTests/CQRS/ICommandHandler.cs

@@ -0,0 +1,6 @@
+namespace NewTests.CQRS;
+
+public interface ICommandHandler
+{
+    void Handle();
+}

NewTests/CQRS/IQueryHandler.cs

@@ -0,0 +1,6 @@
+namespace NewTests.CQRS;
+
+public interface IQueryHandler<T>
+{
+    T Handle();
+}

NewTests/CQRS/InjectAttribute.cs

@@ -0,0 +1,6 @@
+namespace NewTests.CQRS;
+
+[AttributeUsage(AttributeTargets.Property)]
+public class InjectAttribute : Attribute
+{
+}

NewTests/CQRS/Messages.cs

@@ -0,0 +1,27 @@
+using NewTests.DependencyInjection;
+using System.Reflection;
+
+namespace NewTests.CQRS;
+
+public static class Messages
+{
+    public static T Dispatch<T>(IQueryHandler<T> query)
+    {
+        DependencyInjection(query);
+        return query.Handle();
+    }
+
+    public static void Dispatch(ICommandHandler command)
+    {
+        DependencyInjection(command);
+        command.Handle();
+    }
+
+    private static void DependencyInjection(object obj)
+    {
+        foreach (var property in obj.GetType().GetProperties().Where(p => p.GetCustomAttribute(typeof(InjectAttribute)) != null))
+        {
+            property.SetValue(obj, AppContainer.Resolve(property.PropertyType));
+        }
+    }
+}

NewTests/DependencyInjection/AppContainer.cs

@@ -4,7 +4,7 @@ namespace NewTests.DependencyInjection;
 
 public class AppContainer
 {
-    private IContainer _container;
+    private static IContainer _container;
 
     public void RegisterDependencies(Action<ContainerBuilder> action)
     {
@@ -13,7 +13,7 @@ public void RegisterDependencies(Action<ContainerBuilder> action)
         _container = builder.Build();
     }
 
-    public object Resolve(Type type) => _container.Resolve(type);
+    public static object Resolve(Type type) => _container.Resolve(type);
 
-    public T Resolve<T>() => _container.Resolve<T>();
+    public static T Resolve<T>() => _container.Resolve<T>();
 }

NewTests/DependencyInjection/DependencyInjectionSpecs.cs

@@ -14,7 +14,7 @@ public void It_resolves_lower_formatter(Type type, string result)
             builder.RegisterType(type).As<IStringFormatter>();
         });
 
-        var formatter = container.Resolve<IStringFormatter>();
+        var formatter = AppContainer.Resolve<IStringFormatter>();
 
         Assert.That(formatter.Format("Hello"), Is.EqualTo(result));
     }