1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using System.Threading.Channels;

namespace VanDerHeijden.Logging.Sql;

/// <summary>
/// Extension methods for registering SQL Server-based logging via <see cref="ILoggingBuilder"/>.
/// </summary>
public static class SqlLoggingBuilderExtensions
{
	/// <summary>
	/// Adds a SQL Server logger that bulk-inserts log entries into the specified table using <c>SqlBulkCopy</c>.
	/// </summary>
	/// <param name="builder">The <see cref="ILoggingBuilder"/> to configure.</param>
	/// <param name="connectionString">The SQL Server connection string.</param>
	/// <param name="tableName">
	/// The destination table name. Defaults to <c>"Logs"</c>.
	/// See <see cref="SqlLogWriter"/> for the expected schema.
	/// </param>
	/// <returns>The <paramref name="builder"/> so that additional calls can be chained.</returns>
	public static ILoggingBuilder AddSqlLogger(
		this ILoggingBuilder builder,
		string connectionString,
		string tableName = "Logs")
	{
		builder.Services.AddSingleton<ILoggerProvider>(sp =>
		{
			var httpContextAccessor = sp.GetService<IHttpContextAccessor>();
			var logWriter = new SqlLogWriter(connectionString, tableName);
			var batchedLogger = new BatchedLogger<SqlLogEntry>(logWriter, batchSize: 200, maxIdleMs: 4000, fullMode: BoundedChannelFullMode.Wait);
			return new BatchedLoggerProvider<SqlLogEntry>(
				batchedLogger,
				entryFactory: (category, message, logLevel, exception, ctx) => new SqlLogEntry
				{
					Timestamp = DateTime.UtcNow,
					Level     = logLevel.ToString(),
					Category  = category,
					Message   = message,
					Exception = exception?.ToString(),
					Path      = ctx?.Path,
					Method    = ctx?.Method,
					ClientIp  = ctx?.ClientIp,
					Referer   = ctx?.Referer,
					UserAgent = ctx?.UserAgent
				},
				httpContextAccessor
			);
		});
		return builder;
	}
}