gistlyn · September 9, 2024 07:53
diff --git a/_init b/_init
 dotnet add package ServiceStack.Jobs
diff --git a/Configure.RequestLogs.cs b/Configure.RequestLogs.cs
 using ServiceStack.Jobs;
 using ServiceStack.Web;

 [assembly: HostingStartup(typeof(MyApp.ConfigureRequestLogs))]

 namespace MyApp;

 public class ConfigureRequestLogs : IHostingStartup
 {
    public void Configure(IWebHostBuilder builder) => builder
        .ConfigureServices((context, services) => {
            
            services.AddPlugin(new RequestLogsFeature {
                RequestLogger = new SqliteRequestLogger(),
                EnableResponseTracking = true,
                EnableRequestBodyTracking = true,
                EnableErrorTracking = true
            });
            services.AddHostedService<RequestLogsHostedService>();
        });
 }

 public class RequestLogsHostedService(ILogger<RequestLogsHostedService> log, IRequestLogger requestLogger) : BackgroundService
 {
    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        var dbRequestLogger = (SqliteRequestLogger)requestLogger;
        using var timer = new PeriodicTimer(TimeSpan.FromSeconds(3));
        while (!stoppingToken.IsCancellationRequested && await timer.WaitForNextTickAsync(stoppingToken))
        {
            dbRequestLogger.Tick(log);
        }
    }
 }
	using ServiceStack.Jobs;
	using ServiceStack.Web;

	[assembly: HostingStartup(typeof(MyApp.ConfigureRequestLogs))]

	namespace MyApp;

	public class ConfigureRequestLogs : IHostingStartup
	{
	public void Configure(IWebHostBuilder builder) => builder
	.ConfigureServices((context, services) => {

	services.AddPlugin(new RequestLogsFeature {
	RequestLogger = new SqliteRequestLogger(),
	EnableResponseTracking = true,
	EnableRequestBodyTracking = true,
	EnableErrorTracking = true
	});
	services.AddHostedService<RequestLogsHostedService>();
	});
	}

	public class RequestLogsHostedService(ILogger<RequestLogsHostedService> log, IRequestLogger requestLogger) : BackgroundService
	{
	protected override async Task ExecuteAsync(CancellationToken stoppingToken)
	{
	var dbRequestLogger = (SqliteRequestLogger)requestLogger;
	using var timer = new PeriodicTimer(TimeSpan.FromSeconds(3));
	while (!stoppingToken.IsCancellationRequested && await timer.WaitForNextTickAsync(stoppingToken))
	{
	dbRequestLogger.Tick(log);
	}
	}
	}