Skip to content

Commit 30b0291

Browse files
committed
fix(otel): Fix propagation tests
1 parent e56d51d commit 30b0291

File tree

3 files changed

+16
-36
lines changed

3 files changed

+16
-36
lines changed

dd-java-agent/instrumentation/opentelemetry/opentelemetry-1.4/src/test/groovy/opentelemetry14/context/propagation/W3cLastParentIdTest.groovy

Lines changed: 0 additions & 24 deletions
This file was deleted.

dd-java-agent/instrumentation/opentelemetry/opentelemetry-1.4/src/test/groovy/opentelemetry14/context/propagation/W3cPropagatorTest.groovy

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,5 @@ class W3cPropagatorTest extends AgentPropagatorTest {
2323
void assertInjectedHeaders(Map<String, String> headers, String traceId, String spanId, byte sampling) {
2424
def traceFlags = sampling == SAMPLER_KEEP ? '01' : '00'
2525
assert headers['traceparent'] == "00-$traceId-$spanId-$traceFlags"
26-
// 'p:' not expected in tracestate here because 'p' is not supplied in values()
27-
assert !headers['tracestate'].contains("p:")
2826
}
2927
}

dd-java-agent/instrumentation/opentelemetry/opentelemetry-1.4/src/test/groovy/opentelemetry14/context/propagation/W3cPropagatorTracestateTest.groovy

Lines changed: 16 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -2,9 +2,11 @@ package opentelemetry14.context.propagation
22

33
import datadog.trace.agent.test.AgentTestRunner
44
import io.opentelemetry.api.GlobalOpenTelemetry
5-
import io.opentelemetry.context.Context
65
import spock.lang.Subject
76

7+
import static io.opentelemetry.context.Context.current
8+
import static io.opentelemetry.context.Context.root
9+
810
class W3cPropagatorTracestateTest extends AgentTestRunner {
911
@Subject
1012
def tracer = GlobalOpenTelemetry.get().tracerProvider.get("tracecontext-propagator-tracestate")
@@ -33,18 +35,18 @@ class W3cPropagatorTracestateTest extends AgentTestRunner {
3335
}
3436

3537
when:
36-
def context = propagator.extract(Context.root(), headers, TextMap.INSTANCE)
38+
def context = propagator.extract(root(), headers, TextMap.INSTANCE)
3739

3840
then:
39-
context != Context.root()
41+
context != root()
4042

4143
when:
4244
def localSpan = tracer.spanBuilder("some-name")
4345
.setParent(context)
4446
.startSpan()
4547
def scope = localSpan.makeCurrent()
4648
Map<String, String> injectedHeaders = [:]
47-
propagator.inject(Context.current(), injectedHeaders, TextMap.INSTANCE)
49+
propagator.inject(current(), injectedHeaders, TextMap.INSTANCE)
4850
scope.close()
4951
localSpan.end()
5052

@@ -55,16 +57,20 @@ class W3cPropagatorTracestateTest extends AgentTestRunner {
5557
// Check tracestate contains extracted members plus the Datadog one in first position
5658
def injectedMembers = injectedTracestate.split(',')
5759
injectedMembers.length == Math.min(1 + members.length, 32)
58-
injectedMembers[0] == expect
60+
// Check datadog member (should be injected as first member)
61+
injectedMembers[0] == "dd=s:0;p:${localSpan.spanContext.spanId};t.tid:1111111111111111"
62+
// Check all other members
5963
for (int i = 0; i< Math.min(members.length, 31); i++) {
6064
assert injectedMembers[i+1] == members[i]
6165
}
6266

6367
where:
64-
tracestate |expect
65-
"foo=1,bar=2" |"dd=s:0;t.tid:1111111111111111"
66-
"dd=s:0,foo=1,bar=2" |"dd=s:0;t.tid:1111111111111111"
67-
"foo=1,dd=s:0,bar=2" |"dd=s:0;t.tid:1111111111111111"
68-
"dd=s:3" |"dd=s:0;t.tid:1111111111111111"
68+
// spotless:off
69+
tracestate << [
70+
"foo=1,bar=2",
71+
"dd=s:0,foo=1,bar=2",
72+
"foo=1,dd=s:0,bar=2",
73+
]
74+
// spotless:on
6975
}
7076
}

0 commit comments

Comments
 (0)