#15 fix build failed

Author: thangchung

build.cake

@@ -19,7 +19,6 @@ var libs = new List<string>{
     "./src/NetCoreKit.Infrastructure.EfCore.SqlServer/NetCoreKit.Infrastructure.EfCore.SqlServer.csproj",
     "./src/NetCoreKit.Infrastructure.EfCore.MySql/NetCoreKit.Infrastructure.EfCore.MySql.csproj",
     "./src/NetCoreKit.Infrastructure.Bus/NetCoreKit.Infrastructure.Bus.csproj",
-    "./src/NetCoreKit.Infrastructure.Bus.InProcessBus/NetCoreKit.Infrastructure.Bus.InProcessBus.csproj",
     "./src/NetCoreKit.Infrastructure.Bus.Kafka/NetCoreKit.Infrastructure.Bus.Kafka.csproj"
 };
 

samples/SignalRNotifier/Startup.cs

@@ -19,7 +19,7 @@ public IServiceProvider ConfigureServices(IServiceCollection services)
     {
       services.AddMediatR(
         typeof(Startup),
-        typeof(DomainDomainEventBus)
+        typeof(DomainEventBus)
         /*typeof(ProjectCreated)*/);
 
       Mapper.Initialize(cfg => cfg.AddProfiles(typeof(Startup)));

samples/TodoApi/Startup.cs

@@ -23,7 +23,6 @@ public void ConfigureServices(IServiceCollection services)
         },
         (svc, _) => { svc.AddScoped<IUserGateway, UserGateway>(); }
       );
-
     }
 
     public void Configure(IApplicationBuilder app)

samples/TodoApi/v1/Services/KafkaEnvelopeEventHandler.cs

@@ -2,8 +2,13 @@
 using System.Threading.Tasks;
 using MediatR;
 using NetCoreKit.Domain;
+using NetCoreKit.Infrastructure.Bus;
+using NetCoreKit.Infrastructure.Bus.Kafka;
+using NetCoreKit.Infrastructure.Mappers;
 using NetCoreKit.Samples.TodoAPI.Domain;
 using NetCoreKit.Samples.TodoAPI.Extensions;
+using Project.Proto;
+using Task = System.Threading.Tasks.Task;
 
 namespace NetCoreKit.Samples.TodoAPI.v1.UseCases.CreateProject
 {
@@ -27,6 +32,24 @@ public async Task<CreateProjectResponse> Handle(CreateProjectRequest request,
     }
   }
 
+  public class KafkaEnvelopeEventHandler : INotificationHandler<NotificationEnvelope>
+  {
+    private readonly IDispatchedEventBus _eventBus;
+
+    public KafkaEnvelopeEventHandler(IDispatchedEventBus eventBus)
+    {
+      _eventBus = eventBus;
+    }
+
+    public async Task Handle(NotificationEnvelope notify, CancellationToken cancellationToken)
+    {
+      if (!(notify.Event is ProjectCreated)) return;
+
+      var msg = notify.Event.MapTo<IEvent, ProjectCreatedMsg>();
+      await _eventBus.Publish(msg, "project");
+    }
+  }
+
   public class EventSubscriber : INotificationHandler<ProjectCreated>
   {
     public async System.Threading.Tasks.Task Handle(ProjectCreated @event, CancellationToken cancellationToken)

samples/TodoApi/v1/UseCases/CreateProject/RequestHandler.cs

@@ -5,11 +5,11 @@
 
 namespace NetCoreKit.Infrastructure.Bus
 {
-  public class DomainDomainEventBus : IDomainEventBus
+  public class DomainEventBus : IDomainEventBus
   {
     private readonly IMediator _mediator;
 
-    public DomainDomainEventBus(IMediator mediator)
+    public DomainEventBus(IMediator mediator)
     {
       _mediator = mediator;
     }

src/NetCoreKit.Infrastructure.Bus/DomainDomainEventBus.cs renamed to src/NetCoreKit.Infrastructure.Bus/DomainEventBus.cs

@@ -7,7 +7,7 @@ public static class ServiceCollectionExtensions
   {
     public static IServiceCollection AddDomainEventBus(this IServiceCollection services)
     {
-      services.AddSingleton<IDomainEventBus, DomainDomainEventBus>();
+      services.AddSingleton<IDomainEventBus, DomainEventBus>();
       return services;
     }
   }