SeriLog

Bunt.Core/Bunt.Core.csproj

@@ -9,6 +9,8 @@
     <PackageReference Include="MediatR" Version="4.0.1" />
     <PackageReference Include="Microsoft.EntityFrameworkCore" Version="2.0.1" />
     <PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="2.0.1" />
+    <PackageReference Include="Serilog.Sinks.Debug" Version="1.0.0" />
+    <PackageReference Include="Serilog.Sinks.MSSqlServer" Version="5.1.0-dev-00174" />
   </ItemGroup>
 
 </Project>

Bunt.Core/Domain/Commands/SparaBuntladeStalle.cs

@@ -4,6 +4,7 @@
 using Bunt.Core.Domain.Model;
 using MediatR;
 using Microsoft.EntityFrameworkCore;
+using Serilog;
 
 namespace Bunt.Core.Domain.Commands
 {
@@ -19,10 +20,12 @@ public class Command : IRequest
         public class Handler : IRequestHandler<Command>
         {
             private readonly BuntDbContext _db;
+            private readonly ILogger _logger;
 
-            public Handler(BuntDbContext db)
+            public Handler(BuntDbContext db, ILogger logger)
             {
                 _db = db;
+                _logger = logger;
             }
 
             public async Task Handle(Command command, CancellationToken cancellationToken)
@@ -33,11 +36,13 @@ public async Task Handle(Command command, CancellationToken cancellationToken)
                 {
                     var lastIndex = await _db.BuntladeStallen.MaxAsync(b => b.Index, cancellationToken);
                     buntladeStalle = new BuntladeStalle(command.Id, command.Adress, command.Typ, lastIndex + 1);
+                    _logger.Information("Nytt buntlådeställe skapat med id: {Id}", buntladeStalle.Id);
                     _db.Add(buntladeStalle);
                 }
                 else
                 {
                     buntladeStalle.Redigera(command.Adress, command.Typ);
+                    _logger.Information("Uppdaterade befintligt buntådeställe med id: {Id}", buntladeStalle.Id);
                 }
 
                 await _db.SaveChangesAsync(cancellationToken);

Bunt.Core/Infrastructure/LoggingBehavior.cs

@@ -0,0 +1,36 @@
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+using MediatR;
+using Serilog;
+using Serilog.Context;
+
+namespace Bunt.Core.Infrastructure
+{
+    public class LoggingBehavior<TRequest, TResponse> : IPipelineBehavior<TRequest, TResponse>
+    {
+        private readonly ILogger _logger;
+
+        public LoggingBehavior(ILogger logger)
+        {
+            _logger = logger;
+        }
+        public async Task<TResponse> Handle(TRequest request, CancellationToken cancellationToken, RequestHandlerDelegate<TResponse> next)
+        {
+            using (LogContext.PushProperty("CorrelationId", Guid.NewGuid()))
+            using (LogContext.PushProperty("RequestName", typeof(TRequest).FullName))
+            {
+                try
+                {
+                    _logger.Information("Executing {@RequestName} with payload {@RequestPayload}", typeof(TRequest).FullName, request);
+                    return await next();
+                }
+                catch (Exception e)
+                {
+                    _logger.Error(e, e.Message);
+                    throw;
+                }
+            }
+        }
+    }
+}

Bunt.Migrations/201712061300_AddLogTable.cs

@@ -0,0 +1,29 @@
+using FluentMigrator;
+
+namespace Bunt.Migrations
+{
+    [Migration(201712061300)]
+    public class AddRequestLogTable : Migration
+    {   
+        public override void Up()
+        {
+            Execute.Sql(@"
+                CREATE TABLE [Log] (
+                   [Id] int IDENTITY(1,1) NOT NULL PRIMARY KEY,
+                   [Message] nvarchar(max) NULL,
+                   [MessageTemplate] nvarchar(max) NULL,
+                   [Level] nvarchar(128) NULL,
+                   [TimeStamp] datetimeoffset(7) NOT NULL,  -- use datetime for SQL Server pre-2008
+                   [Exception] nvarchar(max) NULL,
+                   [Properties] xml NULL,
+                   [LogEvent] nvarchar(max) NULL            
+                )
+            ");
+        }
+
+        public override void Down()
+        {
+            Delete.Table("Log");
+        }
+    }
+}

Bunt.Web/Startup.cs

@@ -12,6 +12,7 @@
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
+using Serilog;
 
 namespace Bunt.Web
 {
@@ -27,6 +28,13 @@ public Startup(IConfiguration configuration)
         // This method gets called by the runtime. Use this method to add services to the container.
         public void ConfigureServices(IServiceCollection services)
         {
+            var logger = new LoggerConfiguration()
+                .WriteTo.MSSqlServer(Configuration.GetConnectionString("BuntDb"), "Log")
+                .Enrich.FromLogContext()
+                .CreateLogger();
+
+            services.AddSingleton<ILogger>(logger);
+            services.AddTransient(typeof(IPipelineBehavior<,>), typeof(LoggingBehavior<,>));
             services.AddTransient<IConnectionFactory>(provider => new SqlConnectionFactory(Configuration.GetConnectionString("BuntDb")));
             services.AddDbContext<BuntDbContext>(options => options.UseSqlServer(Configuration.GetConnectionString("BuntDb")));
             services.AddMediatR(typeof(ListaBuntladeStallen.Handler));