chore: check compatibility between reactor-core and lettuce

Change-Id: Id24535b21c004991b9bd6eec3c3f167903bc6ab0

Author: 123liuziming

instrumentation/lettuce/lettuce-5.1/javaagent/build.gradle.kts

@@ -41,3 +41,16 @@ tasks {
     dependsOn(testStableSemconv)
   }
 }
+
+testing {
+  suites {
+    val test_compatibility by registering(JvmTestSuite::class) {
+      dependencies {
+        implementation("io.lettuce:lettuce-core:5.2.0.RELEASE")
+        implementation("io.projectreactor:reactor-core:3.5.3")
+        implementation("org.testcontainers:testcontainers")
+        implementation(project(":instrumentation:lettuce:lettuce-5.1:testing"))
+      }
+    }
+  }
+}

instrumentation/lettuce/lettuce-5.1/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/lettuce/v5_1/CompatibilityChecker.java

@@ -0,0 +1,51 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.javaagent.instrumentation.lettuce.v5_1;
+
+import io.lettuce.core.tracing.TraceContext;
+import io.lettuce.core.tracing.TraceContextProvider;
+import io.lettuce.core.tracing.Tracing;
+import java.util.concurrent.locks.Lock;
+import java.util.concurrent.locks.ReentrantLock;
+import reactor.core.publisher.Mono;
+
+public class CompatibilityChecker {
+  private static Boolean isCompatible;
+  private static final Lock lock = new ReentrantLock();
+
+  // related to https://github.com/open-telemetry/opentelemetry-java-instrumentation/issues/10997
+  // if users are using  incompatible versions of reactor-core and lettuce
+  // then just disable the instrumentation
+  public static boolean checkCompatible() {
+    try {
+      lock.lock();
+      if (isCompatible != null) {
+        return isCompatible;
+      }
+      Tracing.withTraceContextProvider(
+          new TraceContextProvider() {
+            @Override
+            public TraceContext getTraceContext() {
+              return null;
+            }
+
+            @Override
+            public Mono<TraceContext> getTraceContextLater() {
+              return TraceContextProvider.super.getTraceContextLater();
+            }
+          });
+      Tracing.getContext();
+      Tracing.clearContext();
+      Tracing.disabled();
+      isCompatible = true;
+    } catch (Throwable t) {
+      isCompatible = false;
+    } finally {
+      lock.unlock();
+    }
+    return isCompatible;
+  }
+}

instrumentation/lettuce/lettuce-5.1/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/lettuce/v5_1/DefaultClientResourcesInstrumentation.java

@@ -35,7 +35,9 @@ public static class BuilderAdvice {
 
     @Advice.OnMethodExit(suppress = Throwable.class)
     public static void methodEnter(@Advice.Return DefaultClientResources.Builder builder) {
-      builder.tracing(TracingHolder.TRACING);
+      if (CompatibilityChecker.checkCompatible()) {
+        builder.tracing(TracingHolder.TRACING);
+      }
     }
   }
 }

instrumentation/lettuce/lettuce-5.1/javaagent/src/test_compatibility/java/io/opentelemetry/javaagent/instrumentation/lettuce/v5_1/DisableNoEntranceSpanAndMetricsTest.java

@@ -0,0 +1,71 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.javaagent.instrumentation.lettuce.v5_1;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+import io.lettuce.core.RedisClient;
+import io.lettuce.core.api.sync.RedisCommands;
+import io.opentelemetry.instrumentation.lettuce.v5_1.AbstractLettuceClientTest;
+import io.opentelemetry.instrumentation.testing.junit.AgentInstrumentationExtension;
+import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+import org.junit.jupiter.api.AfterAll;
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+public class DisableNoEntranceSpanAndMetricsTest extends AbstractLettuceClientTest {
+  @RegisterExtension
+  static final InstrumentationExtension testing = AgentInstrumentationExtension.create();
+
+  @Override
+  public InstrumentationExtension testing() {
+    return testing;
+  }
+
+  @Override
+  protected RedisClient createClient(String uri) {
+    return RedisClient.create(uri);
+  }
+
+  private static RedisCommands<String, String> syncCommands;
+
+  @BeforeAll
+  void setUp() throws UnknownHostException {
+    redisServer.start();
+
+    host = redisServer.getHost();
+    ip = InetAddress.getByName(host).getHostAddress();
+    port = redisServer.getMappedPort(6379);
+    embeddedDbUri = "redis://" + host + ":" + port + "/" + DB_INDEX;
+
+    redisClient = createClient(embeddedDbUri);
+
+    connection = redisClient.connect();
+    syncCommands = connection.sync();
+
+    syncCommands.set("TESTKEY", "TESTVAL");
+  }
+
+  @AfterAll
+  static void cleanUp() {
+    connection.close();
+    redisClient.shutdown();
+    redisServer.stop();
+  }
+
+  @Test
+  void testEmptyTrace() {
+    String res =
+        testing().runWithSpan("parent", () -> syncCommands.set("TESTSETKEY", "TESTSETVAL"));
+    assertThat(res).isEqualTo("OK");
+
+    assertThat(testing.spans().isEmpty());
+    assertThat(testing.metrics().isEmpty());
+  }
+}