Convert camel-2-20 aws tests from groovy to java (open-telemetry#8906)

Author: jaydeluca

conventions/src/main/kotlin/otel.java-conventions.gradle.kts

@@ -286,7 +286,8 @@ tasks.withType<Test>().configureEach {
 
   val trustStore = project(":testing-common").file("src/misc/testing-keystore.p12")
   // Work around payara not working when this is set for some reason.
-  if (project.name != "jaxrs-2.0-payara-testing") {
+  // Don't set for camel as we have tests that interact with AWS and need normal trustStore
+  if (project.name != "jaxrs-2.0-payara-testing" && project.description != "camel-2-20") {
     jvmArgumentProviders.add(KeystoreArgumentsProvider(trustStore))
   }
 

instrumentation/camel-2.20/javaagent-unit-tests/src/test/groovy/io/opentelemetry/javaagent/instrumentation/apachecamel/decorators/SanitizationTest.groovy

@@ -0,0 +1,104 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.javaagent.instrumentation.apachecamel.decorators;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.when;
+
+import java.util.stream.Stream;
+import org.apache.camel.Exchange;
+import org.apache.camel.Message;
+import org.junit.jupiter.api.extension.ExtensionContext;
+import org.junit.jupiter.params.ParameterizedTest;
+import org.junit.jupiter.params.provider.Arguments;
+import org.junit.jupiter.params.provider.ArgumentsProvider;
+import org.junit.jupiter.params.provider.ArgumentsSource;
+
+class SanitizationTest {
+
+  @ParameterizedTest
+  @ArgumentsSource(CqlArgs.class)
+  void sanitizeCql(String original, String expected) {
+    DbSpanDecorator decorator = new DbSpanDecorator("cql", "");
+
+    Exchange exchange = mock(Exchange.class);
+    Message message = mock(Message.class);
+    when(message.getHeader("CamelCqlQuery")).thenReturn(original);
+    when(exchange.getIn()).thenReturn(message);
+
+    String actualSanitized = decorator.getStatement(exchange, null);
+    assertEquals(actualSanitized, expected);
+  }
+
+  @ParameterizedTest
+  @ArgumentsSource(JdbcArgs.class)
+  void sanitizeJdbc(String original, String expected) {
+    DbSpanDecorator decorator = new DbSpanDecorator("jdbc", "");
+
+    Exchange exchange = mock(Exchange.class);
+    Message message = mock(Message.class);
+    when(message.getBody()).thenReturn(original);
+    when(exchange.getIn()).thenReturn(message);
+
+    String actualSanitized = decorator.getStatement(exchange, null);
+    assertEquals(actualSanitized, expected);
+  }
+
+  @ParameterizedTest
+  @ArgumentsSource(SqlArgs.class)
+  void sanitizeSql(String original, String expected) {
+
+    DbSpanDecorator decorator = new DbSpanDecorator("sql", "");
+
+    Exchange exchange = mock(Exchange.class);
+    Message message = mock(Message.class);
+    when(message.getHeader("CamelSqlQuery")).thenReturn(original);
+    when(exchange.getIn()).thenReturn(message);
+
+    String actualSanitized = decorator.getStatement(exchange, null);
+    assertEquals(actualSanitized, expected);
+  }
+
+  static class SqlArgs implements ArgumentsProvider {
+    @Override
+    public Stream<? extends Arguments> provideArguments(ExtensionContext context) {
+      return Stream.of(
+          Arguments.of(
+              "SELECT * FROM table WHERE col1=1234 AND col2>3",
+              "SELECT * FROM table WHERE col1=? AND col2>?"),
+          Arguments.of("UPDATE table SET col=12", "UPDATE table SET col=?"),
+          Arguments.of("insert into table where col=321", "insert into table where col=?"));
+    }
+  }
+
+  static class CqlArgs implements ArgumentsProvider {
+    @Override
+    public Stream<? extends Arguments> provideArguments(ExtensionContext context) {
+      return Stream.of(
+          Arguments.of("FROM TABLE WHERE FIELD>=-1234", "FROM TABLE WHERE FIELD>=?"),
+          Arguments.of(
+              "SELECT Name, Phone.Number FROM Contact WHERE Address.State = 'NY'",
+              "SELECT Name, Phone.Number FROM Contact WHERE Address.State = ?"),
+          Arguments.of("FROM col WHERE @Tag='Something'", "FROM col WHERE @Tag=?"));
+    }
+  }
+
+  static class JdbcArgs implements ArgumentsProvider {
+    @Override
+    public Stream<? extends Arguments> provideArguments(ExtensionContext context) {
+      return Stream.of(
+          Arguments.of("SELECT 3", "SELECT ?"),
+          Arguments.of(
+              "SELECT * FROM TABLE WHERE FIELD = 1234", "SELECT * FROM TABLE WHERE FIELD = ?"),
+          Arguments.of(
+              "SELECT * FROM TABLE WHERE FIELD<-1234", "SELECT * FROM TABLE WHERE FIELD<?"),
+          Arguments.of(
+              "SELECT col1 AS col2 FROM users WHERE field=1234",
+              "SELECT col1 AS col2 FROM users WHERE field=?"));
+    }
+  }
+}

instrumentation/camel-2.20/javaagent-unit-tests/src/test/groovy/io/opentelemetry/javaagent/instrumentation/apachecamel/CamelPropagationUtilTest.java renamed to instrumentation/camel-2.20/javaagent-unit-tests/src/test/java/io/opentelemetry/javaagent/instrumentation/apachecamel/CamelPropagationUtilTest.java

@@ -13,6 +13,8 @@ muzzle {
 
 val camelversion = "2.20.1" // first version that the tests pass on
 
+description = "camel-2-20"
+
 dependencies {
   library("org.apache.camel:camel-core:$camelversion")
   implementation("io.opentelemetry.contrib:opentelemetry-aws-xray-propagator")
@@ -46,7 +48,6 @@ dependencies {
   testImplementation("javax.xml.bind:jaxb-api:2.3.1")
   testImplementation("org.elasticmq:elasticmq-rest-sqs_2.12:1.0.0")
 
-  testImplementation("org.testcontainers:localstack")
   testImplementation("org.testcontainers:cassandra")
   testImplementation("org.testcontainers:testcontainers")
   testImplementation("org.testcontainers:junit-jupiter")