feat(transaction-is-ended): add IsEnded() method (#995)

v3/newrelic/internal_txn.go

@@ -54,6 +54,14 @@ type thread struct {
 	thread *tracingThread
 }
 
+func (thd *thread) IsEnded() bool {
+	txn := thd.txn
+	txn.Lock()
+	defer txn.Unlock()
+
+	return txn.finished
+}
+
 func (txn *txn) markStart(now time.Time) {
 	txn.Start = now
 	// The mainThread is considered active now.

v3/newrelic/internal_txn_test.go

@@ -1018,3 +1018,32 @@ func TestPanicNilRecovery(t *testing.T) {
 		},
 	})
 }
+
+func TestIsEndedInternal(t *testing.T) {
+	tests := []struct {
+		name     string
+		txn      *txn
+		expected bool
+	}{
+		{
+			name:     "finished transaction",
+			txn:      &txn{finished: true},
+			expected: true,
+		},
+		{
+			name:     "unfinished transaction",
+			txn:      &txn{finished: false},
+			expected: false,
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			thread := &thread{txn: tt.txn}
+			result := thread.IsEnded()
+			if result != tt.expected {
+				t.Errorf("IsEnded() = %v; want %v", result, tt.expected)
+			}
+		})
+	}
+}

v3/newrelic/transaction.go

@@ -239,6 +239,16 @@ func (txn *Transaction) SetWebRequestHTTP(r *http.Request) {
 	txn.SetWebRequest(wr)
 }
 
+// IsEnded returns transaction end status.
+// If the transaction is nil, the thread is nil, or the transaction is finished, it returns true.
+// Otherwise, it returns thread.finished value.
+func (txn *Transaction) IsEnded() bool {
+	if nilTransaction(txn) {
+		return true
+	}
+	return txn.thread.IsEnded()
+}
+
 func transport(r *http.Request) TransportType {
 	if strings.HasPrefix(r.Proto, "HTTP") {
 		if r.TLS != nil {

v3/newrelic/transaction_test.go

@@ -6,6 +6,29 @@ import (
 	"testing"
 )
 
+func TestIsEnded(t *testing.T) {
+	tests := []struct {
+		name     string
+		txn      *Transaction
+		expected bool
+	}{
+		{"txn is nil", nil, true},
+		{"thread is nil", &Transaction{thread: nil}, true},
+		{"txn.thread.txn is nil", &Transaction{thread: &thread{}}, true},
+		{"txn.thread.txn.finished is true", &Transaction{thread: &thread{txn: &txn{finished: true}}}, true},
+		{"txn.thread.txn.finished is false", &Transaction{thread: &thread{txn: &txn{finished: false}}}, false},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			result := tt.txn.IsEnded()
+			if result != tt.expected {
+				t.Errorf("IsEnded() = %v; want %v", result, tt.expected)
+			}
+		})
+	}
+}
+
 func TestTransaction_MethodsWithNilTransaction(t *testing.T) {
 	var nilTxn *Transaction