Added unit testst for audit sink Emit() and sink EmitBatch() methods.

Author: ckadluba

test/Serilog.Sinks.MSSqlServer.Tests/Sinks/MSSqlServer/MSSqlServerAuditSinkTests.cs

@@ -1,6 +1,9 @@
 using System;
+using System.Collections.Generic;
 using System.Data;
 using Moq;
+using Serilog.Events;
+using Serilog.Parsing;
 using Serilog.Sinks.MSSqlServer.Platform;
 using Serilog.Sinks.MSSqlServer.Sinks.MSSqlServer.Dependencies;
 using Serilog.Sinks.MSSqlServer.Sinks.MSSqlServer.Options;
@@ -153,6 +156,25 @@ public void InitializeWithoutAutoCreateSqlTableDoesNotCallSqlTableCreator()
             _sqlTableCreatorMock.Verify(c => c.CreateTable(It.IsAny<DataTable>()), Times.Never);
         }
 
+        [Fact]
+        public void EmitCallsSqlLogEventWriter()
+        {
+            // Arrange
+            SetupSut();
+            var logEvent = new Events.LogEvent(
+                new DateTimeOffset(2020, 1, 1, 0, 0, 0, TimeSpan.Zero),
+                Events.LogEventLevel.Information,
+                null,
+                new Events.MessageTemplate("", new List<MessageTemplateToken>()),
+                new List<LogEventProperty>());
+
+            // Act
+            _sut.Emit(logEvent);
+
+            // Assert
+            _sqlLogEventWriter.Verify(w => w.WriteEvent(logEvent), Times.Once);
+        }
+
         private void SetupSut(bool autoCreateSqlTable = false)
         {
             _sinkOptions.AutoCreateSqlTable = autoCreateSqlTable;

test/Serilog.Sinks.MSSqlServer.Tests/Sinks/MSSqlServer/MSSqlServerSinkTests.cs

@@ -1,6 +1,9 @@
 using System;
+using System.Collections.Generic;
 using System.Data;
+using System.Linq;
 using Moq;
+using Serilog.Events;
 using Serilog.Sinks.MSSqlServer.Platform;
 using Serilog.Sinks.MSSqlServer.Sinks.MSSqlServer.Dependencies;
 using Serilog.Sinks.MSSqlServer.Sinks.MSSqlServer.Options;
@@ -125,6 +128,31 @@ public void InitializeWithoutAutoCreateSqlTableDoesNotCallSqlTableCreator()
             _sqlTableCreatorMock.Verify(c => c.CreateTable(It.IsAny<DataTable>()), Times.Never);
         }
 
+        [Fact]
+        public void EmitCallsSqlLogEventWriter()
+        {
+            // Arrange
+            const string messageTemplate = "Message Template";
+            SetupSut();
+            _sqlBulkBatchWriter.Setup(w => w.WriteBatch(It.IsAny<IEnumerable<LogEvent>>(), _dataTable))
+                .Callback<IEnumerable<LogEvent>, DataTable>((e, d) =>
+                 {
+                     Assert.Single(e);
+                     Assert.Equal(messageTemplate, e.First().MessageTemplate.Text);
+                 });
+            Log.Logger = new LoggerConfiguration()
+                .WriteTo
+                .Sink(_sut, LogEventLevel.Debug)
+                .CreateLogger();
+
+            // Act
+            Log.Logger.Information(messageTemplate);
+            Log.CloseAndFlush();
+
+            // Assert
+            _sqlBulkBatchWriter.Verify(w => w.WriteBatch(It.IsAny<IEnumerable<LogEvent>>(), _dataTable), Times.Once);
+        }
+
         private void SetupSut(bool autoCreateSqlTable = false)
         {
             _sinkOptions.AutoCreateSqlTable = autoCreateSqlTable;