Merge pull request #1 from XerProjects/feature-autofac

Feature autofac

Author: mvput

.gitattributes

@@ -0,0 +1,63 @@
+###############################################################################
+# Set default behavior to automatically normalize line endings.
+###############################################################################
+* text=auto
+
+###############################################################################
+# Set default behavior for command prompt diff.
+#
+# This is need for earlier builds of msysgit that does not have it on by
+# default for csharp files.
+# Note: This is only used by command line
+###############################################################################
+#*.cs     diff=csharp
+
+###############################################################################
+# Set the merge driver for project and solution files
+#
+# Merging from the command prompt will add diff markers to the files if there
+# are conflicts (Merging from VS is not affected by the settings below, in VS
+# the diff markers are never inserted). Diff markers may cause the following 
+# file extensions to fail to load in VS. An alternative would be to treat
+# these files as binary and thus will always conflict and require user
+# intervention with every merge. To do so, just uncomment the entries below
+###############################################################################
+#*.sln       merge=binary
+#*.csproj    merge=binary
+#*.vbproj    merge=binary
+#*.vcxproj   merge=binary
+#*.vcproj    merge=binary
+#*.dbproj    merge=binary
+#*.fsproj    merge=binary
+#*.lsproj    merge=binary
+#*.wixproj   merge=binary
+#*.modelproj merge=binary
+#*.sqlproj   merge=binary
+#*.wwaproj   merge=binary
+
+###############################################################################
+# behavior for image files
+#
+# image files are treated as binary by default.
+###############################################################################
+#*.jpg   binary
+#*.png   binary
+#*.gif   binary
+
+###############################################################################
+# diff behavior for common document formats
+# 
+# Convert binary document formats to text before diffing them. This feature
+# is only available from the command line. Turn it on by uncommenting the 
+# entries below.
+###############################################################################
+#*.doc   diff=astextplain
+#*.DOC   diff=astextplain
+#*.docx  diff=astextplain
+#*.DOCX  diff=astextplain
+#*.dot   diff=astextplain
+#*.DOT   diff=astextplain
+#*.pdf   diff=astextplain
+#*.PDF   diff=astextplain
+#*.rtf   diff=astextplain
+#*.RTF   diff=astextplain

.gitignore

@@ -1,7 +1,5 @@
 ## Ignore Visual Studio temporary files, build results, and
 ## files generated by popular Visual Studio add-ons.
-##
-## Get latest from https://github.com/github/gitignore/blob/master/VisualStudio.gitignore
 
 # User-specific files
 *.suo
@@ -42,11 +40,10 @@ TestResult.xml
 [Rr]eleasePS/
 dlldata.c
 
-# .NET Core
+# DNX
 project.lock.json
 project.fragment.lock.json
 artifacts/
-**/Properties/launchSettings.json
 
 *_i.c
 *_p.c
@@ -113,10 +110,6 @@ _TeamCity*
 # DotCover is a Code Coverage Tool
 *.dotCover
 
-# Visual Studio code coverage results
-*.coverage
-*.coveragexml
-
 # NCrunch
 _NCrunch_*
 .*crunch*.local.xml
@@ -150,7 +143,7 @@ publish/
 *.azurePubxml
 # TODO: Comment the next line if you want to checkin your web deploy settings
 # but database connection strings (with potential passwords) will be unencrypted
-*.pubxml
+#*.pubxml
 *.publishproj
 
 # Microsoft Azure Web App publish settings. Comment the next line if you want to
@@ -166,7 +159,7 @@ PublishScripts/
 !**/packages/build/
 # Uncomment if necessary however generally it will be regenerated when needed
 #!**/packages/repositories.config
-# NuGet v3's project.json files produces more ignorable files
+# NuGet v3's project.json files produces more ignoreable files
 *.nuget.props
 *.nuget.targets
 
@@ -199,6 +192,7 @@ ClientBin/
 *.jfm
 *.pfx
 *.publishsettings
+node_modules/
 orleans.codegen.cs
 
 # Since there are multiple workflows, uncomment next line to ignore bower_components
@@ -219,7 +213,6 @@ UpgradeLog*.htm
 # SQL Server files
 *.mdf
 *.ldf
-*.ndf
 
 # Business Intelligence projects
 *.rdl.data
@@ -234,20 +227,13 @@ FakesAssemblies/
 
 # Node.js Tools for Visual Studio
 .ntvs_analysis.dat
-node_modules/
-
-# Typescript v1 declaration files
-typings/
 
 # Visual Studio 6 build log
 *.plg
 
 # Visual Studio 6 workspace options file
 *.opt
 
-# Visual Studio 6 auto-generated workspace file (contains which files were open etc.)
-*.vbw
-
 # Visual Studio LightSwitch build output
 **/*.HTMLClient/GeneratedArtifacts
 **/*.DesktopClient/GeneratedArtifacts
@@ -274,15 +260,9 @@ paket-files/
 __pycache__/
 *.pyc
 
-# Cake - Uncomment if you are using it
-# tools/**
-# !tools/packages.config
-
-# Telerik's JustMock configuration file
-*.jmconfig
+# VS Code
+.vscode/
 
-# BizTalk build output
-*.btp.cs
-*.btm.cs
-*.odx.cs
-*.xsd.cs
+tools/**
+!tools/packages.config
+BuildArtifacts/**

Src/Xer.Cqrs.Extensions.Autofac/AssemblyInfo.cs

@@ -0,0 +1,2 @@
+// Allow test project to access internal classes.
+[assembly: System.Runtime.CompilerServices.InternalsVisibleTo("Xer.Cqrs.Extensions.Autofac.Tests")]

Src/Xer.Cqrs.Extensions.Autofac/CommandHandlerDelegateResolver.cs

@@ -0,0 +1,17 @@
+using System;
+using Xer.Delegator;
+
+namespace Xer.Cqrs.Extensions.Autofac
+{
+    internal class CommandHandlerDelegateResolver : IMessageHandlerResolver
+    {
+        private readonly IMessageHandlerResolver _messageHandlerResolver;
+
+        internal CommandHandlerDelegateResolver(IMessageHandlerResolver messageHandlerResolver)
+        {
+            _messageHandlerResolver = messageHandlerResolver;
+        }
+
+        public MessageHandlerDelegate ResolveMessageHandler(Type messageType) => _messageHandlerResolver.ResolveMessageHandler(messageType);
+    }
+}

Src/Xer.Cqrs.Extensions.Autofac/ComponentContextAdapter.cs

@@ -0,0 +1,23 @@
+using Autofac;
+using System.Collections.Generic;
+
+namespace Xer.Cqrs.Extensions.Autofac
+{
+    /// <summary>
+    /// Represents an adapter to <see cref="IComponentContext"/>.
+    /// </summary>
+    public class ComponentContextAdapter : CommandStack.Resolvers.IContainerAdapter,
+                                           EventStack.Resolvers.IContainerAdapter
+    {
+        private readonly IComponentContext _context;
+
+        public ComponentContextAdapter(IComponentContext context)
+        {
+            _context = context;
+        }
+
+        public T Resolve<T>() where T : class => _context.Resolve<T>();
+
+        public IEnumerable<T> ResolveMultiple<T>() where T : class => _context.Resolve<IEnumerable<T>>();
+    }
+}

Src/Xer.Cqrs.Extensions.Autofac/ContainerBuilderExtensions.cs

@@ -0,0 +1,26 @@
+using System.Reflection;
+using Xer.Cqrs.Extensions.Autofac;
+
+namespace Autofac
+{
+    public static class ContainerBuilderExtensions
+    {
+        public static ContainerBuilder RegisterCqrs(this ContainerBuilder builder, params Assembly[] assemblies)
+        {
+            builder.RegisterCqrsCore()
+                .RegisterEventHandlers(select => 
+                    select.ByInterface(assemblies)
+                          .ByAttribute(assemblies))
+                .RegisterCommandHandlers(select => 
+                    select.ByInterface(assemblies)
+                          .ByAttribute(assemblies));
+                
+            return builder;
+        }
+
+        public static ICqrsBuilder RegisterCqrsCore(this ContainerBuilder builder)
+        {
+            return new CqrsBuilder(builder);
+        }
+    }
+}

Src/Xer.Cqrs.Extensions.Autofac/CqrsBuilder.cs

@@ -0,0 +1,80 @@
+using Autofac;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using Xer.Cqrs.CommandStack;
+using Xer.Cqrs.EventStack;
+using Xer.Delegator;
+using Xer.Delegator.Registrations;
+using Xer.Delegator.Resolvers;
+
+namespace Xer.Cqrs.Extensions.Autofac
+{
+    internal class CqrsBuilder : ICqrsBuilder
+    {
+        private readonly ContainerBuilder _builder;
+        private readonly CqrsCommandHandlerSelector _commandHandlerSelector;
+        private readonly CqrsEventHandlerSelector _eventHandlerSelector;
+
+        internal CqrsBuilder(ContainerBuilder builder)
+        {
+            _builder = builder;
+            _commandHandlerSelector = new CqrsCommandHandlerSelector(_builder);
+            _eventHandlerSelector = new CqrsEventHandlerSelector(_builder);
+        }
+
+        public ICqrsBuilder RegisterCommandHandlers(Action<ICqrsCommandHandlerSelector> selector)
+        {
+            if (selector == null)
+            {
+                throw new ArgumentNullException(nameof(selector));
+            }
+
+            // Select command handlers to register.
+            selector(_commandHandlerSelector);
+
+            _builder.Register(context =>
+            {
+                IMessageHandlerResolver[] handlers = context.Resolve<IEnumerable<CommandHandlerDelegateResolver>>().ToArray();
+
+                if (handlers.Any())
+                {
+                    return handlers.Length > 1
+                        ? new CommandDelegator(CompositeMessageHandlerResolver.Compose(handlers))
+                        : new CommandDelegator(handlers[0]);
+                }
+
+                return new CommandDelegator(new SingleMessageHandlerRegistration().BuildMessageHandlerResolver());
+            }).As<CommandDelegator>().SingleInstance();
+
+            return this;
+        }
+
+        public ICqrsBuilder RegisterEventHandlers(Action<ICqrsEventHandlerSelector> selector)
+        {
+            if (selector == null)
+            {
+                throw new ArgumentNullException(nameof(selector));
+            }
+
+            // Select event handlers to register.
+            selector(_eventHandlerSelector);
+            
+            _builder.Register(context =>
+            {
+                IMessageHandlerResolver[] handlers = context.Resolve<IEnumerable<EventHandlerDelegateResolver>>().ToArray();
+
+                if (handlers.Any())
+                {
+                    return handlers.Length > 1
+                        ? new EventDelegator(CompositeMessageHandlerResolver.Compose(handlers))
+                        : new EventDelegator(handlers[0]);
+                }
+
+                return new EventDelegator(new MultiMessageHandlerRegistration().BuildMessageHandlerResolver());
+            }).As<EventDelegator>().SingleInstance();
+
+            return this;
+        }
+    }
+}