Add configuration transaction scheduled

engineering87 · Nov 5, 2024 · d8c896f · d8c896f
1 parent fb225fe
commit d8c896f
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 3 deletions.
diff --git a/src/OpenSharpTrace.TestApi/appsettings.json b/src/OpenSharpTrace.TestApi/appsettings.json
@@ -1,4 +1,7 @@
 {
+  "ScheduledSharpTrace": {
+    "TimerIntervalSeconds": 30
+  },
   "ConnectionStrings": {
     "TraceDb": "Server=(***;Database=***;Trusted_Connection=True;MultipleActiveResultSets=true"
   },

diff --git a/src/OpenSharpTrace/OpenSharpTrace.csproj b/src/OpenSharpTrace/OpenSharpTrace.csproj
@@ -8,7 +8,7 @@
     <PackageProjectUrl>https://github.com/engineering87/OpenSharpTrace</PackageProjectUrl>
     <RepositoryUrl>https://github.com/engineering87/OpenSharpTrace</RepositoryUrl>
     <PackageLicenseFile>LICENSE.txt</PackageLicenseFile>
-    <Version>4.1.0</Version>
+    <Version>4.2.0</Version>
     <PackageReadmeFile>README.md</PackageReadmeFile>
   </PropertyGroup>
 

diff --git a/src/OpenSharpTrace/TransactionScheduler/ScheduledServiceTransaction.cs b/src/OpenSharpTrace/TransactionScheduler/ScheduledServiceTransaction.cs
@@ -1,5 +1,6 @@
 // (c) 2022 Francesco Del Re <francesco.delre.87@gmail.com>
 // This code is licensed under MIT license (see LICENSE.txt for details)
+using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 using System;
@@ -11,18 +12,22 @@ namespace OpenSharpTrace.TransactionScheduler
     public class ScheduledServiceTransaction : IHostedService
     {
         private readonly IServiceProvider _services;
+        private readonly TimeSpan _timerInterval;
 
         private Timer _timer;
 
         public ScheduledServiceTransaction(
-            IServiceProvider services)
+            IServiceProvider services,
+            IConfiguration configuration)
         {
             _services = services;
+            var intervalInSeconds = configuration.GetValue<int?>("ScheduledSharpTrace:TimerIntervalSeconds") ?? 60;
+            _timerInterval = TimeSpan.FromSeconds(intervalInSeconds);
         }
 
         public Task StartAsync(CancellationToken cancellationToken)
         {
-            _timer = new Timer(DoWork, null, TimeSpan.Zero, TimeSpan.FromMinutes(1));
+            _timer = new Timer(DoWork, null, TimeSpan.Zero, _timerInterval);
             return Task.CompletedTask;
         }