commandbus-stuff.cs

    interface ICommand
    {
    }

    interface ICommandBus
    {
        Task Send<TCommand>(TCommand command) where TCommand : ICommand;
    }

    interface ICommandHandler<TCommand> where TCommand : ICommand
    {
        Task Handle(TCommand command);
    }

    class MyCommand : ICommand
    {
    }

    class MyCommandHandler : ICommandHandler<MyCommand>
    {
        private readonly IHttpContextAccessor _context;

        public MyCommandHandler(IHttpContextAccessor context)
        {
            _context = context;
        }

        public async Task Handle(MyCommand command)
        {
            await _context.HttpContext.Response.WriteAsync("Hej fra mig!");
        }
    }

    class CommandBus : ICommandBus
    {
        private readonly IServiceProvider _services;

        public CommandBus(IServiceProvider services)
        {
            _services = services;
        }

        public async Task Send<TCommand>(TCommand command) where TCommand : ICommand
        {
            var handler = _services.GetService<ICommandHandler<TCommand>>();
            await handler.Handle(command);
        }
    }

    class CommandHandlerMiddleware
    {
        public CommandHandlerMiddleware(RequestDelegate next)
        {
        }

        public async Task InvokeAsync(HttpContext context, ICommandBus bus)
        {
            await bus.Send(new MyCommand());
        }
    }

    class Startup
    {
        public void ConfigureServices(IServiceCollection services)
        {
            services.AddScoped<ICommandBus, CommandBus>();
            services.AddScoped<ICommandHandler<MyCommand>, MyCommandHandler>();
        }

        public void Configure(IApplicationBuilder app, IHostingEnvironment env)
        {
            app.UseDeveloperExceptionPage();
            app.UseMiddleware<CommandHandlerMiddleware>();
        }
    }