add possibility to register ipc service using custom implementation factory

Author: Jacques Kang

README.md

@@ -65,15 +65,16 @@ IpcServiceFramework is available via NuGet:
 
         private static IServiceCollection ConfigureServices(IServiceCollection services)
         {
-            services
-                .AddIpc()
-                .AddNamedPipe(options =>
+            return services
+                .AddIpc(builder =>
                 {
-                    options.ThreadCount = 2;
+                    builder
+                        .AddNamedPipe(options =>
+                        {
+                            options.ThreadCount = 2;
+                        })
+                        .AddService<IComputingService, ComputingService>();
                 });
-            
-            return services
-                .AddService<IComputingService, ComputingService>();
         }
     }
 ```

src/IpcServiceSample.ConsoleServer/Program.cs

@@ -33,23 +33,22 @@ static void Main(string[] args)
 
         private static IServiceCollection ConfigureServices(IServiceCollection services)
         {
-            services
+            return services
                 .AddLogging(builder =>
                 {
                     builder.AddConsole();
                     builder.SetMinimumLevel(LogLevel.Debug);
-                });
-
-            services
-                .AddIpc()
-                .AddNamedPipe(options =>
-                {
-                    options.ThreadCount = 2;
                 })
-                .AddService<IComputingService, ComputingService>()
-                .AddService<ISystemService, SystemService>();
-
-            return services;
+                .AddIpc(builder =>
+                {
+                    builder
+                        .AddNamedPipe(options =>
+                        {
+                            options.ThreadCount = 2;
+                        })
+                        .AddService<IComputingService, ComputingService>()
+                        .AddService<ISystemService, SystemService>();
+                });
         }
     }
 }

src/IpcServiceSample.WebServer/Startup.cs

@@ -13,10 +13,13 @@ public class Startup
         public void ConfigureServices(IServiceCollection services)
         {
             services
-                .AddIpc()
-                .AddNamedPipe()
-                .AddService<IComputingService, ComputingService>()
-                .AddService<ISystemService, SystemService>();
+                .AddIpc(builder =>
+                {
+                    builder
+                        .AddNamedPipe()
+                        .AddService<IComputingService, ComputingService>()
+                        .AddService<ISystemService, SystemService>();
+                });
         }
 
         public void Configure(IApplicationBuilder app, IHostingEnvironment env)

src/JKang.IpcServiceFramework.Server/IIpcServiceBuilder.cs

@@ -1,4 +1,5 @@
 using Microsoft.Extensions.DependencyInjection;
+using System;
 
 namespace JKang.IpcServiceFramework
 {
@@ -9,5 +10,9 @@ public interface IIpcServiceBuilder
         IIpcServiceBuilder AddService<TInterface, TImplementation>()
             where TInterface: class
             where TImplementation: class, TInterface;
+
+        IIpcServiceBuilder AddService<TInterface, TImplementation>(Func<IServiceProvider, TImplementation> implementationFactory)
+            where TInterface : class
+            where TImplementation : class, TInterface;
     }
 }

src/JKang.IpcServiceFramework.Server/IpcServiceBuilder.cs

@@ -1,4 +1,5 @@
 using Microsoft.Extensions.DependencyInjection;
+using System;
 
 namespace JKang.IpcServiceFramework
 {
@@ -11,10 +12,20 @@ public IpcServiceBuilder(IServiceCollection services)
 
         public IServiceCollection Services { get; }
 
-        IIpcServiceBuilder IIpcServiceBuilder.AddService<TInterface, TImplementation>()
+        public IIpcServiceBuilder AddService<TInterface, TImplementation>()
+            where TInterface : class
+            where TImplementation : class, TInterface
         {
             Services.AddScoped<TInterface, TImplementation>();
             return this;
         }
+
+        public IIpcServiceBuilder AddService<TInterface, TImplementation>(Func<IServiceProvider, TImplementation> implementationFactory)
+            where TInterface : class
+            where TImplementation : class, TInterface
+        {
+            Services.AddScoped<TInterface, TImplementation>(implementationFactory);
+            return this;
+        }
     }
 }

src/JKang.IpcServiceFramework.Server/IpcServiceServiceCollectionExtensions.cs

@@ -1,18 +1,29 @@
 using JKang.IpcServiceFramework.Services;
 using Microsoft.Extensions.DependencyInjection;
+using System;
 
 namespace JKang.IpcServiceFramework
 {
     public static class IpcServiceServiceCollectionExtensions
     {
+        [Obsolete("Use services.AddIpc(builder => { ... }) instead.")]
         public static IIpcServiceBuilder AddIpc(this IServiceCollection services)
+        {
+            IIpcServiceBuilder builder = null;
+            services.AddIpc(x => builder = x);
+            return builder;
+        }
+
+        public static IServiceCollection AddIpc(this IServiceCollection services, Action<IIpcServiceBuilder> configAction)
         {
             services
                 .AddLogging()
                 .AddScoped<IValueConverter, DefaultValueConverter>()
                 .AddScoped<IIpcMessageSerializer, DefaultIpcMessageSerializer>();
 
-            return new IpcServiceBuilder(services);
+            var builder = new IpcServiceBuilder(services);
+            configAction?.Invoke(builder);
+            return services;
         }
     }
 }