#15 continue to work on realtime notification

Author: thangchung

.gitignore

@@ -52,7 +52,7 @@ BenchmarkDotNet.Artifacts/
 project.lock.json
 project.fragment.lock.json
 artifacts/
-**/Properties/launchSettings.json
+#**/Properties/launchSettings.json
 
 # StyleCop
 StyleCopReport.xml

samples/Contracts/Events/ProjectCreated.cs

@@ -1,9 +1,8 @@
-using MediatR;
 using NetCoreKit.Domain;
 
 namespace NetCoreKit.Samples.Contracts.Events
 {
-  public class ProjectCreated : EventBase, INotification
+  public class ProjectCreated : EventBase
   {
     public ProjectCreated(string name)
     {

samples/Contracts/Events/TaskCreated.cs

@@ -1,9 +1,8 @@
-using MediatR;
 using NetCoreKit.Domain;
 
 namespace NetCoreKit.Samples.Contracts.Events
 {
-  public class TaskCreated : EventBase, INotification
+  public class TaskCreated : EventBase
   {
     public TaskCreated(string title)
     {

samples/Contracts/NetCoreKit.Samples.Contracts.csproj

@@ -2,12 +2,11 @@
 
   <PropertyGroup>
     <TargetFramework>netstandard2.0</TargetFramework>
+    <OutputType>Library</OutputType>
+    <BlazorLinkOnBuild>false</BlazorLinkOnBuild>
+    <LangVersion>latest</LangVersion>
   </PropertyGroup>
 
-  <ItemGroup>
-    <PackageReference Include="MediatR" Version="5.1.0" />
-  </ItemGroup>
-
   <ItemGroup>
     <ProjectReference Include="..\..\src\NetCoreKit.Domain\NetCoreKit.Domain.csproj" />
   </ItemGroup>

samples/Notifier/EventsHostedService.cs

@@ -42,7 +42,6 @@ public Task StopAsync(CancellationToken cancellationToken)
     private void OnStarted()
     {
       _logger.LogInformation("OnStarted has been called.");
-
       _eventBus.Subscribe("project").Wait();
     }
 
@@ -60,7 +59,7 @@ private void OnStopped()
     }
   }
 
-  public class ProjectCreatedSubscriber : INotificationHandler<ProjectCreated>
+  /*public class ProjectCreatedSubscriber : INotificationHandler<ProjectCreated>
   {
     private readonly ILogger _logger;
 
@@ -74,5 +73,5 @@ 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/SignalRNotifier/Properties/launchSettings.json

@@ -0,0 +1,27 @@
+{
+  "iisSettings": {
+    "windowsAuthentication": false,
+    "anonymousAuthentication": true,
+    "iisExpress": {
+      "applicationUrl": "http://localhost:5002",
+      "sslPort": 0
+    }
+  },
+  "profiles": {
+    "IIS Express": {
+      "commandName": "IISExpress",
+      "launchBrowser": true,
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "webnotifier": {
+      "commandName": "Project",
+      "launchBrowser": true,
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      },
+      "applicationUrl": "http://localhost:5002"
+    }
+  }
+}

samples/SignalRNotifier/Services/Hubs/ProjectHub.cs

@@ -1,10 +1,8 @@
-using System;
 using System.Threading;
 using System.Threading.Tasks;
 using MediatR;
 using Microsoft.AspNetCore.SignalR;
 using NetCoreKit.Domain;
-using NetCoreKit.Samples.Contracts.Events;
 
 namespace NetCoreKit.Samples.SignalRNotifier.Services.Hubs
 {
@@ -13,34 +11,32 @@ public class ProjectHub : Hub
   }
 
   public class ProjectHostService : HostedService,
-    INotificationHandler<ProjectCreated>,
-    INotificationHandler<TaskCreated>
+    INotificationHandler<Notifications.ProjectCreated>,
+    INotificationHandler<Notifications.TaskCreated>
   {
     private readonly IEventBus _eventBus;
-    private readonly IServiceProvider _resolver;
 
-    public ProjectHostService(IHubContext<ProjectHub> context, IServiceProvider resolver, IEventBus eventBus)
+    public ProjectHostService(IHubContext<ProjectHub> context, IEventBus eventBus)
     {
-      _resolver = resolver;
       _eventBus = eventBus;
       Clients = context.Clients;
     }
 
     private IHubClients Clients { get; }
 
-    public async Task Handle(ProjectCreated @event, CancellationToken cancellationToken)
+    public async Task Handle(Notifications.ProjectCreated notification, CancellationToken cancellationToken)
     {
-      await Clients.All.SendAsync("projectCreatedNotify", @event, cancellationToken);
+      await Clients.All.SendAsync("projectCreatedNotify", notification, cancellationToken);
     }
 
-    public async Task Handle(TaskCreated @event, CancellationToken cancellationToken)
+    public async Task Handle(Notifications.TaskCreated notification, CancellationToken cancellationToken)
     {
-      await Clients.All.SendAsync("taskAddedToProjectNotify", @event, cancellationToken);
+      await Clients.All.SendAsync("taskAddedToProjectNotify", notification, cancellationToken);
     }
 
     protected override Task ExecuteAsync(CancellationToken cancellationToken)
     {
-      _eventBus.Subscribe("project");
+      _eventBus.Subscribe("project").Wait(cancellationToken);
       return Task.CompletedTask;
     }
   }

samples/SignalRNotifier/Services/Notifications/ProjectCreated.cs

@@ -0,0 +1,11 @@
+using System;
+using MediatR;
+
+namespace NetCoreKit.Samples.SignalRNotifier.Services.Notifications
+{
+  public class ProjectCreated : INotification
+  {
+    public string Name { get; set; }
+    public DateTime OccurredOn { get; set; }
+  }
+}

samples/SignalRNotifier/Services/Notifications/TaskCreated.cs

@@ -0,0 +1,11 @@
+using System;
+using MediatR;
+
+namespace NetCoreKit.Samples.SignalRNotifier.Services.Notifications
+{
+  public class TaskCreated : INotification
+  {
+    public string Title { get; set; }
+    public DateTime OccurredOn { get; set; }
+  }
+}

samples/SignalRNotifier/Services/Profiles/ProjectProfile.cs

@@ -8,8 +8,8 @@ public class ProjectProfile : Profile
   {
     public ProjectProfile()
     {
-      this.MapMySelf<ProjectCreated>();
-      this.MapMySelf<TaskCreated>();
+      this.MapToNotification<ProjectCreated, Notifications.ProjectCreated>();
+      this.MapToNotification<TaskCreated, Notifications.TaskCreated>();
     }
   }
 }