fix: include null validation in request.Statement

simaoribeiro · simaoribeiro · commit f5585cd62101 · 2024-09-13T16:14:14.000+01:00
diff --git a/src/Extensions/Cassandra.OpenTelemetry/OpenTelemetryRequestTracker.cs b/src/Extensions/Cassandra.OpenTelemetry/OpenTelemetryRequestTracker.cs
@@ -74,7 +74,7 @@ public virtual Task OnStartAsync(RequestTrackingInfo request)
                     activity.AddTag("db.name", request.Statement.Keyspace);
                 }
 
-                if (_instrumentationOptions.IncludeDatabaseStatement)
+                if (_instrumentationOptions.IncludeDatabaseStatement && request.Statement != null)
                 {
                     activity.AddTag("db.statement", request.Statement.ToString());
                 }
@@ -227,7 +227,7 @@ public virtual Task OnNodeStart(RequestTrackingInfo request, HostTrackingInfo ho
                     activity.AddTag("db.name", request.Statement.Keyspace);
                 }
 
-                if (_instrumentationOptions.IncludeDatabaseStatement)
+                if (_instrumentationOptions.IncludeDatabaseStatement && request.Statement != null)
                 {
                     activity.AddTag("db.statement", request.Statement.ToString());
                 }

Original file line number	Diff line number	Diff line change
`@@ -74,7 +74,7 @@ public virtual Task OnStartAsync(RequestTrackingInfo request)`
`74`	`74`	`activity.AddTag("db.name", request.Statement.Keyspace);`
`75`	`75`	`}`
`76`	`76`
`77`		`- if (_instrumentationOptions.IncludeDatabaseStatement)`
	`77`	`+ if (_instrumentationOptions.IncludeDatabaseStatement && request.Statement != null)`
`78`	`78`	`{`
`79`	`79`	`activity.AddTag("db.statement", request.Statement.ToString());`
`80`	`80`	`}`
`@@ -227,7 +227,7 @@ public virtual Task OnNodeStart(RequestTrackingInfo request, HostTrackingInfo ho`
`227`	`227`	`activity.AddTag("db.name", request.Statement.Keyspace);`
`228`	`228`	`}`
`229`	`229`
`230`		`- if (_instrumentationOptions.IncludeDatabaseStatement)`
	`230`	`+ if (_instrumentationOptions.IncludeDatabaseStatement && request.Statement != null)`
`231`	`231`	`{`
`232`	`232`	`activity.AddTag("db.statement", request.Statement.ToString());`
`233`	`233`	`}`