#15 starting to work with SignalR on Generic Host

Author: thangchung

README.md

@@ -1,12 +1,15 @@
-# Cloud Native .NET Core Kit
-[![Price](https://img.shields.io/badge/price-FREE-0098f7.svg?style=for-the-badge)](https://github.com/cloudnative-netcore/netcorekit/blob/master/LICENSE) [![version](https://img.shields.io/nuget/v/NetCoreKit.Domain.svg?label=version&style=for-the-badge)](https://www.nuget.org/packages?q=NetCoreKit)
-[![Build status](https://img.shields.io/appveyor/ci/thangchung/netcore-kit.svg?style=for-the-badge)](https://ci.appveyor.com/api/project/thangchung/netcore-kit)
+# Cloud-native .NET Core Kit
+[![Price](https://img.shields.io/badge/price-FREE-0098f7.svg)](https://github.com/cloudnative-netcore/netcorekit/blob/master/LICENSE)
+[![version](https://img.shields.io/nuget/v/NetCoreKit.Domain.svg?label=version)](https://www.nuget.org/packages?q=NetCoreKit)
+[![Build status](https://img.shields.io/appveyor/ci/thangchung/netcore-kit.svg)](https://ci.appveyor.com/api/project/thangchung/netcore-kit)
 
-A set of cloud native tools and utilities for .NET Core.
+A set of cloud-native tools and utilities for .NET Core.
+
+<details>
+  <summary>Features</summary>
 
-### Features
 - Simple libraries. No frameworks. Little abstraction.
-- Modular (Easy to swap out Utils, Domain, AspNetCore, Clean Architecture, Open API, Entity Framework Core...)
+- Modular (Easy to swap out Utils, Domain, AspNetCore, Clean Architecture, Open API, Entity Framework Core, Event Bus...)
 - Adhere to [twelve-factor app paradigm](https://12factor.net) and more.
 - Resilience and health check out of the box.
 - Easy for configuration management.
@@ -17,7 +20,9 @@ A set of cloud native tools and utilities for .NET Core.
 - Documentation template with OpenAPI documentation.
 - Work natively with Kubernetes or even with Service Mesh.
 
-### Get Starting
+</details>
+
+## Less Code to Get Starting
 
 Small, lightweight, cloud-native out of the box, and much more simple to get starting with miniservices approach. [Why miniservices?](https://thenewstack.io/miniservices-a-realistic-alternative-to-microservices)
 
@@ -42,19 +47,22 @@ public class Startup
 }
 ```
 
-- Read [Get starting](https://github.com/cloudnative-netcore/netcorekit/wiki/Get-Started) section and [Play with Kubernetes](https://github.com/cloudnative-netcore/netcorekit/wiki/Deploy-on-k8s-on-local) section to know more about this cloud-native toolkit.
+<details>
+  <summary>More types of equipment to get starting</summary>
 
+- Read [Get starting](https://github.com/cloudnative-netcore/netcorekit/wiki/Get-Started) section and [Play with Kubernetes](https://github.com/cloudnative-netcore/netcorekit/wiki/Deploy-on-k8s-on-local) section to know more about this cloud-native toolkit.
 - Basic usage can be found at [TodoApi Sample](https://github.com/cloudnative-netcore/netcorekit/tree/master/samples/TodoApi)
 - More advance usage is at [Coolstore Microservices](https://github.com/vietnam-devs/coolstore-microservices) project.
 
-### Contributing
+</details>
+
+<details>
+  <summary>Contributing</summary>
 
 1. Fork it!
 2. Create your feature branch: `git checkout -b my-new-feature`
 3. Commit your changes: `git commit -am 'Add some feature'`
 4. Push to the branch: `git push origin my-new-feature`
 5. Submit a pull request :p
 
-### Licence
-
-Code released under [the MIT license](https://github.com/cloudnative-netcore/netcorekit/blob/master/LICENSE).
+</details>

netcorekit.sln

@@ -52,6 +52,10 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "NetCoreKit.Infrastructure.B
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "NetCoreKit.Samples.Notifier", "samples\Notifier\NetCoreKit.Samples.Notifier.csproj", "{7AE8F281-2C86-4CF5-80CF-FCCE940E5DC3}"
 EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "NetCoreKit.Samples.SignalRNotifier", "samples\SignalRNotifier\NetCoreKit.Samples.SignalRNotifier.csproj", "{9894E768-600D-452E-9F9E-6612D7AA6421}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "NetCoreKit.Samples.Contracts", "samples\Contracts\NetCoreKit.Samples.Contracts.csproj", "{C7C5DA44-023A-4138-8F13-D7FA2EB58F74}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -172,6 +176,22 @@ Global
 		{7AE8F281-2C86-4CF5-80CF-FCCE940E5DC3}.Release|Any CPU.Build.0 = Release|Any CPU
 		{7AE8F281-2C86-4CF5-80CF-FCCE940E5DC3}.Release|x86.ActiveCfg = Release|Any CPU
 		{7AE8F281-2C86-4CF5-80CF-FCCE940E5DC3}.Release|x86.Build.0 = Release|Any CPU
+		{9894E768-600D-452E-9F9E-6612D7AA6421}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{9894E768-600D-452E-9F9E-6612D7AA6421}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{9894E768-600D-452E-9F9E-6612D7AA6421}.Debug|x86.ActiveCfg = Debug|Any CPU
+		{9894E768-600D-452E-9F9E-6612D7AA6421}.Debug|x86.Build.0 = Debug|Any CPU
+		{9894E768-600D-452E-9F9E-6612D7AA6421}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{9894E768-600D-452E-9F9E-6612D7AA6421}.Release|Any CPU.Build.0 = Release|Any CPU
+		{9894E768-600D-452E-9F9E-6612D7AA6421}.Release|x86.ActiveCfg = Release|Any CPU
+		{9894E768-600D-452E-9F9E-6612D7AA6421}.Release|x86.Build.0 = Release|Any CPU
+		{C7C5DA44-023A-4138-8F13-D7FA2EB58F74}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{C7C5DA44-023A-4138-8F13-D7FA2EB58F74}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{C7C5DA44-023A-4138-8F13-D7FA2EB58F74}.Debug|x86.ActiveCfg = Debug|Any CPU
+		{C7C5DA44-023A-4138-8F13-D7FA2EB58F74}.Debug|x86.Build.0 = Debug|Any CPU
+		{C7C5DA44-023A-4138-8F13-D7FA2EB58F74}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{C7C5DA44-023A-4138-8F13-D7FA2EB58F74}.Release|Any CPU.Build.0 = Release|Any CPU
+		{C7C5DA44-023A-4138-8F13-D7FA2EB58F74}.Release|x86.ActiveCfg = Release|Any CPU
+		{C7C5DA44-023A-4138-8F13-D7FA2EB58F74}.Release|x86.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -192,6 +212,8 @@ Global
 		{BEA4FAB4-1A38-4720-8CCB-D7074CF7596D} = {6CF50533-EBD6-47B1-9AD9-9EBBFF3AC887}
 		{4C788CCD-4695-4A1E-8F8D-AD1C864C7AFA} = {6CF50533-EBD6-47B1-9AD9-9EBBFF3AC887}
 		{7AE8F281-2C86-4CF5-80CF-FCCE940E5DC3} = {92D6FD73-B95C-4CBB-A48E-047672EB4E77}
+		{9894E768-600D-452E-9F9E-6612D7AA6421} = {92D6FD73-B95C-4CBB-A48E-047672EB4E77}
+		{C7C5DA44-023A-4138-8F13-D7FA2EB58F74} = {92D6FD73-B95C-4CBB-A48E-047672EB4E77}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {B9325AE8-21A8-4D46-9B04-38BD2BC35C0F}

samples/TodoApi/Domain/ProjectCreated.cs renamed to samples/Contracts/Events/ProjectCreated.cs

@@ -1,7 +1,7 @@
 using MediatR;
 using NetCoreKit.Domain;
 
-namespace NetCoreKit.Samples.TodoAPI.Domain
+namespace NetCoreKit.Samples.Contracts.Events
 {
   public class ProjectCreated : EventBase, INotification
   {
@@ -10,6 +10,6 @@ public ProjectCreated(string name)
       Name = name;
     }
 
-    public string Name { get; set; }
+    public string Name { get; }
   }
 }

samples/Contracts/Events/TaskCreated.cs

@@ -0,0 +1,14 @@
+using MediatR;
+using NetCoreKit.Domain;
+
+namespace NetCoreKit.Samples.Contracts.Events
+{
+  public class TaskCreated : EventBase, INotification
+  {
+    public TaskCreated(string title)
+    {
+      Title = title;
+    }
+    public string Title { get; }
+  }
+}

samples/TodoApi/Domain/TaskDeleted.cs renamed to samples/Contracts/Events/TaskDeleted.cs

@@ -1,6 +1,6 @@
 using NetCoreKit.Domain;
 
-namespace NetCoreKit.Samples.TodoAPI.Domain
+namespace NetCoreKit.Samples.Contracts.Events
 {
   public class TaskDeleted : EventBase
   {

samples/TodoApi/Domain/TaskUpdated.cs renamed to samples/Contracts/Events/TaskUpdated.cs

@@ -1,6 +1,6 @@
 using NetCoreKit.Domain;
 
-namespace NetCoreKit.Samples.TodoAPI.Domain
+namespace NetCoreKit.Samples.Contracts.Events
 {
   public class TaskUpdated : EventBase
   {

samples/Contracts/NetCoreKit.Samples.Contracts.csproj

@@ -0,0 +1,15 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>netcoreapp2.1</TargetFramework>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="MediatR" Version="5.1.0" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\..\src\NetCoreKit.Domain\NetCoreKit.Domain.csproj" />
+  </ItemGroup>
+
+</Project>

samples/Notifier/EventsHostedService.cs

@@ -1,12 +1,11 @@
 using System;
 using System.Threading;
 using System.Threading.Tasks;
-using AutoMapper;
 using MediatR;
 using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.Logging;
 using NetCoreKit.Domain;
-using NetCoreKit.Infrastructure.Mappers;
+using NetCoreKit.Samples.Contracts.Events;
 
 namespace NetCoreKit.Samples.Notifier
 {
@@ -44,7 +43,7 @@ private void OnStarted()
     {
       _logger.LogInformation("OnStarted has been called.");
 
-      _eventBus.Subscribe<ProjectCreated>().Wait();
+      _eventBus.Subscribe("project").Wait();
     }
 
     private void OnStopping()
@@ -61,24 +60,6 @@ private void OnStopped()
     }
   }
 
-  public class ProjectCreatedProfile : Profile
-  {
-    public ProjectCreatedProfile()
-    {
-      this.MapMySelf(typeof(ProjectCreated));
-    }
-  }
-
-  public class ProjectCreated : EventBase, INotification
-  {
-    public ProjectCreated(string name)
-    {
-      Name = name;
-    }
-
-    public string Name { get; set; }
-  }
-
   public class ProjectCreatedSubscriber : INotificationHandler<ProjectCreated>
   {
     private readonly ILogger _logger;
@@ -91,7 +72,6 @@ public ProjectCreatedSubscriber(ILogger<ProjectCreatedSubscriber> logger)
     public Task Handle(ProjectCreated @event, CancellationToken cancellationToken)
     {
       _logger.LogInformation($"@ Project Created Event -{@event.OccurredOn}-{@event.EventVersion}. Now I will do something cool in this worker...");
-
       return Task.FromResult(@event);
     }
   }

samples/Notifier/NetCoreKit.Samples.Notifier.csproj

@@ -25,21 +25,11 @@
     <Content Include="**\*.json" CopyToOutputDirectory="PreserveNewest" />
   </ItemGroup>
 
-  <ItemGroup>
-    <Compile Remove="bin\**" />
-    <Compile Remove="obj\**" />
-    <Content Remove="bin\**" />
-    <Content Remove="obj\**" />
-    <EmbeddedResource Remove="bin\**" />
-    <EmbeddedResource Remove="obj\**" />
-    <None Remove="bin\**" />
-    <None Remove="obj\**" />
-  </ItemGroup>
-
   <ItemGroup>
     <ProjectReference Include="..\..\src\NetCoreKit.Domain\NetCoreKit.Domain.csproj" />
     <ProjectReference Include="..\..\src\NetCoreKit.Infrastructure.Bus.Kafka\NetCoreKit.Infrastructure.Bus.Kafka.csproj" />
     <ProjectReference Include="..\..\src\NetCoreKit.Infrastructure\NetCoreKit.Infrastructure.csproj" />
+    <ProjectReference Include="..\Contracts\NetCoreKit.Samples.Contracts.csproj" />
   </ItemGroup>
 
   <ItemGroup>

samples/Notifier/Program.cs

@@ -21,14 +21,14 @@ public static async Task Main(string[] args)
         {
           configHost.SetBasePath(Directory.GetCurrentDirectory());
           configHost.AddJsonFile("hostsettings.json", optional: true);
-          configHost.AddEnvironmentVariables(prefix: "PREFIX_");
+          configHost.AddEnvironmentVariables();
           configHost.AddCommandLine(args);
         })
         .ConfigureAppConfiguration((hostContext, configApp) =>
         {
           configApp.AddJsonFile("appsettings.json", optional: true);
           configApp.AddJsonFile($"appsettings.{hostContext.HostingEnvironment.EnvironmentName}.json", optional: true);
-          configApp.AddEnvironmentVariables(prefix: "PREFIX_");
+          configApp.AddEnvironmentVariables();
           configApp.AddCommandLine(args);
         })
         .ConfigureServices((hostContext, services) =>