convert propagation test

Author: zeitlinger

smoke-tests/src/test/groovy/io/opentelemetry/smoketest/PropagationTest.groovy

@@ -0,0 +1,17 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.smoketest.propagation;
+
+import java.util.Map;
+import org.junit.jupiter.api.condition.DisabledIf;
+
+@DisabledIf("io.opentelemetry.smoketest.TestContainerManager#useWindowsContainers")
+class B3MultiPropagationTest extends PropagationTest {
+  @Override
+  protected Map<String, String> getExtraEnv() {
+    return Map.of("otel.propagators", "b3multi");
+  }
+}

smoke-tests/src/test/java/io/opentelemetry/smoketest/propagation/B3MultiPropagationTest.java

@@ -0,0 +1,17 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.smoketest.propagation;
+
+import java.util.Map;
+import org.junit.jupiter.api.condition.DisabledIf;
+
+@DisabledIf("io.opentelemetry.smoketest.TestContainerManager#useWindowsContainers")
+class B3PropagationTest extends PropagationTest {
+  @Override
+  protected Map<String, String> getExtraEnv() {
+    return Map.of("otel.propagators", "b3");
+  }
+}

smoke-tests/src/test/java/io/opentelemetry/smoketest/propagation/B3PropagationTest.java

@@ -0,0 +1,11 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.smoketest.propagation;
+
+import org.junit.jupiter.api.condition.DisabledIf;
+
+@DisabledIf("io.opentelemetry.smoketest.TestContainerManager#useWindowsContainers")
+class DefaultPropagationTest extends PropagationTest {}

smoke-tests/src/test/java/io/opentelemetry/smoketest/propagation/DefaultPropagationTest.java

@@ -0,0 +1,60 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.smoketest.propagation;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+import io.opentelemetry.sdk.trace.data.SpanData;
+import io.opentelemetry.smoketest.JavaSmokeTest;
+import io.opentelemetry.smoketest.TargetWaitStrategy;
+import io.opentelemetry.testing.internal.armeria.common.AggregatedHttpResponse;
+import java.time.Duration;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.stream.Collectors;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.condition.DisabledIf;
+
+@DisabledIf("io.opentelemetry.smoketest.TestContainerManager#useWindowsContainers")
+class OtTracePropagationTest extends JavaSmokeTest {
+  @Override
+  protected String getTargetImage(String jdk) {
+    return "ghcr.io/open-telemetry/opentelemetry-java-instrumentation/smoke-test-spring-boot:jdk"
+        + jdk
+        + "-20211213.1570880324";
+  }
+
+  @Override
+  protected TargetWaitStrategy getWaitStrategy() {
+    return new TargetWaitStrategy.Log(
+        Duration.ofMinutes(1), ".*Started SpringbootApplication in.*");
+  }
+
+  @Test
+  public void shouldPropagate() throws Exception {
+    runTarget(
+        11,
+        output -> {
+          AggregatedHttpResponse response = client().get("/front").aggregate().join();
+          List<SpanData> spanData = waitForTraces();
+
+          Set<String> ids =
+              spanData.stream().map(s -> s.getTraceId().substring(16)).collect(Collectors.toSet());
+          assertThat(ids).hasSize(1);
+
+          var traceId = ids.iterator().next();
+
+          assertThat(response.contentUtf8())
+              .matches("[0-9a-f]{16}" + traceId + ";[0]{16}" + traceId);
+        });
+  }
+
+  @Override
+  protected Map<String, String> getExtraEnv() {
+    return Map.of("otel.propagators", "ottrace");
+  }
+}

smoke-tests/src/test/java/io/opentelemetry/smoketest/propagation/OtTracePropagationTest.java

@@ -0,0 +1,48 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.smoketest.propagation;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+import io.opentelemetry.sdk.testing.assertj.TracesAssert;
+import io.opentelemetry.sdk.trace.data.SpanData;
+import io.opentelemetry.smoketest.JavaSmokeTest;
+import io.opentelemetry.smoketest.TargetWaitStrategy;
+import io.opentelemetry.testing.internal.armeria.common.AggregatedHttpResponse;
+import java.time.Duration;
+import java.util.List;
+import org.junit.jupiter.api.Test;
+
+public abstract class PropagationTest extends JavaSmokeTest {
+
+  @Override
+  protected String getTargetImage(String jdk) {
+    return "ghcr.io/open-telemetry/opentelemetry-java-instrumentation/smoke-test-spring-boot:jdk"
+        + jdk
+        + "-20211213.1570880324";
+  }
+
+  @Override
+  protected TargetWaitStrategy getWaitStrategy() {
+    return new TargetWaitStrategy.Log(
+        Duration.ofMinutes(1), ".*Started SpringbootApplication in.*");
+  }
+
+  @Test
+  public void shouldPropagate() throws Exception {
+    runTarget(
+        11,
+        output -> {
+          AggregatedHttpResponse response = client().get("/front").aggregate().join();
+          List<SpanData> traces = waitForTraces();
+
+          TracesAssert.assertThat(traces).hasTracesSatisfyingExactly(trace -> {});
+
+          var traceId = traces.get(0).getTraceId();
+          assertThat(response.contentUtf8()).isEqualTo(traceId + ";" + traceId);
+        });
+  }
+}

smoke-tests/src/test/java/io/opentelemetry/smoketest/propagation/PropagationTest.java

@@ -0,0 +1,17 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.smoketest.propagation;
+
+import java.util.Map;
+import org.junit.jupiter.api.condition.DisabledIf;
+
+@DisabledIf("io.opentelemetry.smoketest.TestContainerManager#useWindowsContainers")
+class W3CPropagationTest extends PropagationTest {
+  @Override
+  protected Map<String, String> getExtraEnv() {
+    return Map.of("otel.propagators", "tracecontext");
+  }
+}

smoke-tests/src/test/java/io/opentelemetry/smoketest/propagation/W3CPropagationTest.java

@@ -0,0 +1,17 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.smoketest.propagation;
+
+import java.util.Map;
+import org.junit.jupiter.api.condition.DisabledIf;
+
+@DisabledIf("io.opentelemetry.smoketest.TestContainerManager#useWindowsContainers")
+class XRayPropagationTest extends PropagationTest {
+  @Override
+  protected Map<String, String> getExtraEnv() {
+    return Map.of("otel.propagators", "xray");
+  }
+}