Commit: b427e425b57b6484ff1ae9a445582d1eb8c6172c - CleanAuLait48 (git)

Commit MetaInfo

• Revisión: b427e425b57b6484ff1ae9a445582d1eb8c6172c (tree)
• Tiempo: 2022-06-04 21:24:52
• Autor: yoshy <yoshy.org.bitbucket@gz.j...>
• Commiter: yoshy

Log Message

[ADD] WindowController の抽象実装および単純実装をフレームワーク側に追加

Cambiar Resumen

• add: Adaptor/Controller/AbstractAsyncWindowController.cs
• add: Adaptor/Controller/AbstractWindowController.cs
• add: Adaptor/Controller/AsyncSimpleWindowController.cs
• add: Adaptor/Controller/SimpleWindowController.cs
• modified: CleanAuLait48.csproj

Diferencia incremental

--- /dev/null
+++ b/Adaptor/Controller/AbstractAsyncWindowController.cs
@@ -0,0 +1,39 @@
+using CleanAuLait48.Adaptor.Boundary.Controller;
+using CleanAuLait48.Core.DI;
+using CleanAuLait48.UseCase.Request;
+using CleanAuLait48.UseCase.Response;
+using System.Threading.Tasks;
+
+namespace CleanAuLait48.Adaptor.Controller
+{
+    public abstract class AbstractAsyncWindowController : IAsyncWindowController
+    {
+        public static readonly string DEFAULT_HANDLER_QUEUE = "defaultHandlerQueue";
+
+        private readonly IRequestScopeGenerator scopedGenerator;
+        private readonly IAsyncHandlerContextFactory contextFactory;
+
+        public AbstractAsyncWindowController(
+                IRequestScopeGenerator scopedGenerator,
+                IAsyncHandlerContextFactory contextFactory)
+        {
+            this.scopedGenerator = scopedGenerator;
+            this.contextFactory = contextFactory;
+        }
+
+        public virtual async Task<UseCaseResponse> ExecuteAsync(UseCaseRequest req)
+        {
+            return await ExecuteAsync(DEFAULT_HANDLER_QUEUE, req);
+        }
+
+        protected async Task<UseCaseResponse> ExecuteAsync(string handlerQueueName, UseCaseRequest req)
+        {
+            using (IScopedComponentProvider scope = scopedGenerator.CreateScope())
+            {
+                IAsyncHandlerContext context = contextFactory.Create(handlerQueueName, scope);
+
+                return await context.HandleNextAsync(req, context);
+            }
+        }
+    }
+}

--- /dev/null
+++ b/Adaptor/Controller/AbstractWindowController.cs
@@ -0,0 +1,43 @@
+using CleanAuLait48.Adaptor.Boundary.Controller;
+using CleanAuLait48.Core.DI;
+using CleanAuLait48.UseCase.Request;
+using CleanAuLait48.UseCase.Response;
+
+namespace CleanAuLait48.Adaptor.Controller
+{
+    public abstract class AbstractWindowController : IWindowController
+    {
+        public static readonly string DEFAULT_HANDLER_QUEUE = "defaultHandlerQueue";
+
+        protected readonly IRequestScopeGenerator scopedGenerator;
+        protected readonly IHandlerContextFactory contextFactory;
+
+        protected readonly object lockExecute = new object();
+
+        public AbstractWindowController(
+                IRequestScopeGenerator scopedGenerator,
+                IHandlerContextFactory contextFactory)
+        {
+            this.scopedGenerator = scopedGenerator;
+            this.contextFactory = contextFactory;
+        }
+
+        public virtual UseCaseResponse Execute(UseCaseRequest req)
+        {
+            return Execute(DEFAULT_HANDLER_QUEUE, req);
+        }
+
+        protected UseCaseResponse Execute(string handlerQueueName, UseCaseRequest req)
+        {
+            lock (lockExecute)
+            {
+                using (IScopedComponentProvider scope = this.scopedGenerator.CreateScope())
+                {
+                    IHandlerContext context = this.contextFactory.Create(handlerQueueName, scope);
+
+                    return context.HandleNext(req, context);
+                }
+            }
+        }
+    }
+}

--- /dev/null
+++ b/Adaptor/Controller/AsyncSimpleWindowController.cs
@@ -0,0 +1,15 @@
+using CleanAuLait48.Adaptor.Boundary.Controller;
+using CleanAuLait48.Core.DI;
+
+namespace CleanAuLait48.Adaptor.Controller
+{
+    internal class AsyncSimpleWindowController : AbstractAsyncWindowController
+    {
+        public AsyncSimpleWindowController(
+                IRequestScopeGenerator scopedGenerator,
+                IAsyncHandlerContextFactory contextFactory) :
+                        base(scopedGenerator, contextFactory)
+        {
+        }
+    }
+}

--- /dev/null
+++ b/Adaptor/Controller/SimpleWindowController.cs
@@ -0,0 +1,15 @@
+using CleanAuLait48.Adaptor.Boundary.Controller;
+using CleanAuLait48.Core.DI;
+
+namespace CleanAuLait48.Adaptor.Controller
+{
+    public class SimpleWindowController : AbstractWindowController
+    {
+        public SimpleWindowController(
+                IRequestScopeGenerator scopedGenerator,
+                IHandlerContextFactory contextFactory) :
+                        base(scopedGenerator, contextFactory)
+        {
+        }
+    }
+}

--- a/CleanAuLait48.csproj
+++ b/CleanAuLait48.csproj
@@ -55,9 +55,13 @@
   </ItemGroup>
   <ItemGroup>
     <Compile Include="Adaptor\Boundary\Controller\IAttachHandlerQueueMap.cs" />
+    <Compile Include="Adaptor\Controller\AbstractAsyncWindowController.cs" />
     <Compile Include="Adaptor\Controller\AbstractHandlerContextFactoryRegistrar.cs" />
+    <Compile Include="Adaptor\Controller\AbstractWindowController.cs" />
     <Compile Include="Adaptor\Controller\AsyncHandlerContextFactoryRegistrar.cs" />
+    <Compile Include="Adaptor\Controller\AsyncSimpleWindowController.cs" />
     <Compile Include="Adaptor\Controller\HandlerContextFactoryRegistrar.cs" />
+    <Compile Include="Adaptor\Controller\SimpleWindowController.cs" />
     <Compile Include="CleanAuLait48ComponentRegisterer.cs" />
     <Compile Include="Adaptor\Boundary\Controller\Handler\IAsyncRequestHandler.cs" />
     <Compile Include="Adaptor\Boundary\Controller\Handler\IRequestHandler.cs" />