Support transaction finishing automatically with 'idle timeout'

CHANGELOG.md

@@ -6,6 +6,7 @@
 
 - Symbolication for Single File Apps ([#2425](https://github.com/getsentry/sentry-dotnet/pull/2425))
 - Add binding to `SwiftAsyncStacktraces` on iOS ([#2436](https://github.com/getsentry/sentry-dotnet/pull/2436))
+- Support transaction finishing automatically with 'idle timeout' ([#2452](https://github.com/getsentry/sentry-dotnet/pull/2452))
 
 ### Fixes
 

src/Sentry/SentryOptions.cs

@@ -982,6 +982,11 @@ public bool JsonPreserveReferences
     /// </summary>
     internal bool InitNativeSdks { get; set; } = true;
 
+    /// <summary>
+    /// Idling transaction timeout after which transaction will be finished automatically.
+    /// </summary>
+    public TimeSpan? IdleTimeout { get; set; }
+
     /// <summary>
     /// Creates a new instance of <see cref="SentryOptions"/>
     /// </summary>

src/Sentry/TransactionTracer.cs

@@ -9,6 +9,8 @@ namespace Sentry;
 public class TransactionTracer : ITransaction, IHasDistribution, IHasTransactionNameSource, IHasMeasurements
 {
     private readonly IHub _hub;
+    private readonly Timer? _idleTimer;
+    private long _idleTimerStopped;
     private readonly SentryStopwatch _stopwatch = SentryStopwatch.StartNew();
 
     /// <inheritdoc />
@@ -174,6 +176,7 @@ public IReadOnlyList<string> Fingerprint
 
     internal ITransactionProfiler? TransactionProfiler { get; set; }
 
+    // TODO: mark as internal in version 4
     /// <summary>
     /// Initializes an instance of <see cref="Transaction"/>.
     /// </summary>
@@ -182,6 +185,7 @@ public TransactionTracer(IHub hub, string name, string operation)
     {
     }
 
+    // TODO: mark as internal in version 4
     /// <summary>
     /// Initializes an instance of <see cref="Transaction"/>.
     /// </summary>
@@ -201,6 +205,7 @@ public TransactionTracer(IHub hub, string name, string operation, TransactionNam
     public TransactionTracer(IHub hub, ITransactionContext context)
     {
         _hub = hub;
+        var idleTimeout = (hub as Hub)?.Options.IdleTimeout;
         Name = context.Name;
         NameSource = context is IHasTransactionNameSource c ? c.NameSource : TransactionNameSource.Custom;
         Operation = context.Operation;
@@ -210,6 +215,19 @@ public TransactionTracer(IHub hub, ITransactionContext context)
         Description = context.Description;
         Status = context.Status;
         IsSampled = context.IsSampled;
+
+        if (idleTimeout != null)
+        {
+            _idleTimer = new Timer(state =>
+            {
+                if (state is not TransactionTracer transactionTracer)
+                {
+                    return;
+                }
+
+                transactionTracer.Finish(Status ?? SpanStatus.Ok);
+            }, this, TimeSpan.Zero, idleTimeout.Value);
+        }
     }
 
     /// <inheritdoc />
@@ -260,6 +278,13 @@ public ISpan StartChild(string operation) =>
     /// <inheritdoc />
     public void Finish()
     {
+        if (Interlocked.Exchange(ref _idleTimerStopped, 1) == 0)
+        {
+            _idleTimer?.Change(Timeout.InfiniteTimeSpan, Timeout.InfiniteTimeSpan);
+
+            _idleTimer?.Dispose();
+        }
+
         TransactionProfiler?.Finish();
         Status ??= SpanStatus.Ok;
         EndTimestamp = _stopwatch.CurrentDateTimeOffset;

test/Sentry.Tests/ApiApprovalTests.Run.Core3_1.verified.txt

@@ -615,6 +615,7 @@ namespace Sentry
         public System.Collections.Generic.IList<Sentry.SubstringOrRegexPattern> FailedRequestTargets { get; set; }
         public System.TimeSpan FlushTimeout { get; set; }
         public System.Net.IWebProxy? HttpProxy { get; set; }
+        public System.TimeSpan? IdleTimeout { get; set; }
         public System.TimeSpan InitCacheFlushTimeout { get; set; }
         public bool IsEnvironmentUser { get; set; }
         public bool IsGlobalModeEnabled { get; set; }

test/Sentry.Tests/ApiApprovalTests.Run.DotNet6_0.verified.txt

@@ -616,6 +616,7 @@ namespace Sentry
         public System.Collections.Generic.IList<Sentry.SubstringOrRegexPattern> FailedRequestTargets { get; set; }
         public System.TimeSpan FlushTimeout { get; set; }
         public System.Net.IWebProxy? HttpProxy { get; set; }
+        public System.TimeSpan? IdleTimeout { get; set; }
         public System.TimeSpan InitCacheFlushTimeout { get; set; }
         public bool IsEnvironmentUser { get; set; }
         public bool IsGlobalModeEnabled { get; set; }

test/Sentry.Tests/ApiApprovalTests.Run.DotNet7_0.verified.txt

@@ -616,6 +616,7 @@ namespace Sentry
         public System.Collections.Generic.IList<Sentry.SubstringOrRegexPattern> FailedRequestTargets { get; set; }
         public System.TimeSpan FlushTimeout { get; set; }
         public System.Net.IWebProxy? HttpProxy { get; set; }
+        public System.TimeSpan? IdleTimeout { get; set; }
         public System.TimeSpan InitCacheFlushTimeout { get; set; }
         public bool IsEnvironmentUser { get; set; }
         public bool IsGlobalModeEnabled { get; set; }

test/Sentry.Tests/ApiApprovalTests.Run.Net4_8.verified.txt

@@ -614,6 +614,7 @@ namespace Sentry
         public System.Collections.Generic.IList<Sentry.SubstringOrRegexPattern> FailedRequestTargets { get; set; }
         public System.TimeSpan FlushTimeout { get; set; }
         public System.Net.IWebProxy? HttpProxy { get; set; }
+        public System.TimeSpan? IdleTimeout { get; set; }
         public System.TimeSpan InitCacheFlushTimeout { get; set; }
         public bool IsEnvironmentUser { get; set; }
         public bool IsGlobalModeEnabled { get; set; }

test/Sentry.Tests/HubTests.cs

@@ -1132,7 +1132,7 @@ public void CaptureTransaction_HubEnabled(bool enabled)
     [Fact]
     public void CaptureTransaction_Client_Gets_Hint()
     {
-        // Arrange        
+        // Arrange
         var hub = _fixture.GetSut();
 
         // Act
@@ -1146,7 +1146,7 @@ public void CaptureTransaction_Client_Gets_Hint()
     [Fact]
     public void CaptureTransaction_Client_Gets_ScopeAttachments()
     {
-        // Arrange        
+        // Arrange
         var hub = _fixture.GetSut();
         List<Attachment> attachments = new List<Attachment> {
             AttachmentHelper.FakeAttachment("foo"),
@@ -1336,4 +1336,32 @@ public async Task WithScopeAsyncT_Works()
     }
 
     private static Scope GetCurrentScope(Hub hub) => hub.ScopeManager.GetCurrent().Key;
+
+    [Fact]
+    public async Task IdleTimeout_auto_finishes_transaction()
+    {
+        // Arrange
+        _fixture.Options.IdleTimeout = TimeSpan.FromMilliseconds(2);
+        var hub = _fixture.GetSut();
+        var context = new TransactionContext(
+            SpanId.Create(),
+            SpanId.Create(),
+            SentryId.Create(),
+            "name",
+            "operation",
+            "description",
+            SpanStatus.Ok,
+            null,
+            true,
+            TransactionNameSource.Component
+        );
+
+        // Act
+        var transaction = hub.StartTransaction(context);
+
+        await Task.Delay(TimeSpan.FromMilliseconds(5));
+
+        // Assert
+        transaction.IsFinished.Should().BeTrue();
+    }
 }

test/Sentry.Tests/Protocol/TransactionTests.cs

@@ -504,4 +504,37 @@ public void ISpan_GetTransaction_FromSpan()
         // Assert
         Assert.Same(transaction, result);
     }
+
+    [Fact]
+    public async Task Idle_transaction_should_finish_with_idle_timeout_specified()
+    {
+        // Arrange
+        var client = Substitute.For<ISentryClient>();
+        var options = new SentryOptions
+        {
+            Dsn = ValidDsn,
+            IdleTimeout = TimeSpan.FromMilliseconds(2)
+        };
+        var hub = new Hub(options, client);
+        var context = new TransactionContext(
+            SpanId.Create(),
+            SpanId.Create(),
+            SentryId.Create(),
+            "my name",
+            "my operation",
+            "description",
+            SpanStatus.Ok,
+            null,
+            true,
+            TransactionNameSource.Component
+        );
+
+        var transaction = new TransactionTracer(hub, context);
+
+        // Act
+        await Task.Delay(5);
+
+        // Assert
+        transaction.IsFinished.Should().BeTrue();
+    }
 }

test/Sentry.Tests/SentryOptionsTests.cs

@@ -194,4 +194,11 @@ public void FailedRequestTargets_ByDefault_MatchesAnyUrl()
         var sut = new SentryOptions();
         Assert.Contains(".*", sut.FailedRequestTargets);
     }
+
+    [Fact]
+    public void IdleTimeout_ByDefault_IsNull()
+    {
+        var sut = new SentryOptions();
+        sut.IdleTimeout.IsNull();
+    }
 }