aspnetcore query support.

PoweredSoft.CQRS.AspNetCore/Mvc/QueryController.cs

@@ -0,0 +1,21 @@
+using Microsoft.AspNetCore.Mvc;
+using PoweredSoft.CQRS.Abstractions;
+using System;
+using System.Collections.Generic;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace PoweredSoft.CQRS.AspNetCore.Mvc
+{
+    [ApiController, Route("api/query/[controller]")]
+    public class QueryController<TQuery, TQueryResult> : Controller
+        where TQuery : class
+    {
+        [HttpPost]
+        public Task<TQueryResult> Handle([FromServices] IQueryHandler<TQuery, TQueryResult> handler, 
+            [FromBody] TQuery query)
+        {
+            return handler.HandleAsync(query, this.Request.HttpContext.RequestAborted);
+        }
+    }
+}

PoweredSoft.CQRS.AspNetCore/Mvc/QueryControllerConvention.cs

@@ -0,0 +1,28 @@
+using Microsoft.AspNetCore.Mvc.ApplicationModels;
+using Microsoft.Extensions.DependencyInjection;
+using PoweredSoft.CQRS.Abstractions.Discovery;
+using System;
+
+namespace PoweredSoft.CQRS.AspNetCore.Mvc
+{
+    public class QueryControllerConvention : IControllerModelConvention
+    {
+        private readonly IServiceProvider serviceProvider;
+
+        public QueryControllerConvention(IServiceProvider serviceProvider)
+        {
+            this.serviceProvider = serviceProvider;
+        }
+
+        public void Apply(ControllerModel controller)
+        {
+            if (controller.ControllerType.IsGenericType && controller.ControllerType.Name.Contains("QueryController") && controller.ControllerType.Assembly == typeof(QueryControllerConvention).Assembly)
+            {
+                var genericType = controller.ControllerType.GenericTypeArguments[0];
+                var queryDiscovery = this.serviceProvider.GetRequiredService<IQueryDiscovery>();
+                var query = queryDiscovery.FindQuery(genericType);
+                controller.ControllerName = query.Name;
+            }
+        }
+    }
+}

PoweredSoft.CQRS.AspNetCore/Mvc/QueryControllerFeatureProvider.cs

@@ -0,0 +1,32 @@
+using Microsoft.AspNetCore.Mvc.ApplicationParts;
+using Microsoft.AspNetCore.Mvc.Controllers;
+using Microsoft.Extensions.DependencyInjection;
+using PoweredSoft.CQRS.Abstractions.Discovery;
+using System;
+using System.Collections.Generic;
+using System.Reflection;
+using System.Text;
+
+namespace PoweredSoft.CQRS.AspNetCore.Mvc
+{
+    public class QueryControllerFeatureProvider : IApplicationFeatureProvider<ControllerFeature>
+    {
+        private readonly ServiceProvider serviceProvider;
+
+        public QueryControllerFeatureProvider(ServiceProvider serviceProvider)
+        {
+            this.serviceProvider = serviceProvider;
+        }
+
+        public void PopulateFeature(IEnumerable<ApplicationPart> parts, ControllerFeature feature)
+        {
+            var queryDiscovery = this.serviceProvider.GetRequiredService<IQueryDiscovery>();
+            foreach (var f in queryDiscovery.GetQueries())
+            {
+                var controllerType = typeof(QueryController<,>).MakeGenericType(f.QueryType, f.QueryResultType);
+                var controllerTypeInfo = controllerType.GetTypeInfo();
+                feature.Controllers.Add(controllerTypeInfo);
+            }
+        }
+    }
+}

PoweredSoft.CQRS.AspNetCore/Mvc/QueryControllerOptions.cs

@@ -0,0 +1,11 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace PoweredSoft.CQRS.AspNetCore.Mvc
+{
+    public class QueryControllerOptions
+    {
+
+    }
+}