Convert restlet 1.1 tests from groovy to java (#12337)

Author: laurit

instrumentation/restlet/restlet-1.1/javaagent/src/test/groovy/io/opentelemetry/javaagent/instrumentation/restlet/v1_1/RestletServerTest.groovy

@@ -0,0 +1,29 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.javaagent.instrumentation.restlet.v1_1;
+
+import io.opentelemetry.instrumentation.restlet.v1_1.AbstractRestletServerTest;
+import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
+import io.opentelemetry.instrumentation.testing.junit.http.HttpServerInstrumentationExtension;
+import io.opentelemetry.instrumentation.testing.junit.http.HttpServerTestOptions;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+class RestletServerTest extends AbstractRestletServerTest {
+
+  @RegisterExtension
+  static final InstrumentationExtension testing = HttpServerInstrumentationExtension.forAgent();
+
+  @Override
+  protected void configure(HttpServerTestOptions options) {
+    super.configure(options);
+    options.setHasResponseCustomizer((endpoint) -> true);
+  }
+
+  @Override
+  protected String notFoundRoute() {
+    return "/";
+  }
+}

instrumentation/restlet/restlet-1.1/javaagent/src/test/groovy/io/opentelemetry/javaagent/instrumentation/restlet/v1_1/ServletServerTest.groovy

@@ -0,0 +1,24 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.javaagent.instrumentation.restlet.v1_1;
+
+import io.opentelemetry.instrumentation.restlet.v1_1.AbstractServletServerTest;
+import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
+import io.opentelemetry.instrumentation.testing.junit.http.HttpServerInstrumentationExtension;
+import io.opentelemetry.instrumentation.testing.junit.http.HttpServerTestOptions;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+class ServletServerTest extends AbstractServletServerTest {
+
+  @RegisterExtension
+  static final InstrumentationExtension testing = HttpServerInstrumentationExtension.forAgent();
+
+  @Override
+  protected void configure(HttpServerTestOptions options) {
+    super.configure(options);
+    options.setHasResponseCustomizer((endpoint) -> true);
+  }
+}

instrumentation/restlet/restlet-1.1/javaagent/src/test/groovy/io/opentelemetry/javaagent/instrumentation/restlet/v1_1/spring/SpringBeanRouterTest.groovy

@@ -0,0 +1,29 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.javaagent.instrumentation.restlet.v1_1.spring;
+
+import io.opentelemetry.instrumentation.restlet.v1_1.spring.AbstractSpringServerTest;
+import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
+import io.opentelemetry.instrumentation.testing.junit.http.HttpServerInstrumentationExtension;
+import io.opentelemetry.instrumentation.testing.junit.http.HttpServerTestOptions;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+class SpringBeanRouterTest extends AbstractSpringServerTest {
+
+  @RegisterExtension
+  static final InstrumentationExtension testing = HttpServerInstrumentationExtension.forAgent();
+
+  @Override
+  protected void configure(HttpServerTestOptions options) {
+    super.configure(options);
+    options.setHasResponseCustomizer((endpoint) -> true);
+  }
+
+  @Override
+  protected String getConfigurationName() {
+    return "springBeanRouterConf.xml";
+  }
+}

instrumentation/restlet/restlet-1.1/javaagent/src/test/groovy/io/opentelemetry/javaagent/instrumentation/restlet/v1_1/spring/SpringRouterTest.groovy

@@ -0,0 +1,29 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.javaagent.instrumentation.restlet.v1_1.spring;
+
+import io.opentelemetry.instrumentation.restlet.v1_1.spring.AbstractSpringServerTest;
+import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
+import io.opentelemetry.instrumentation.testing.junit.http.HttpServerInstrumentationExtension;
+import io.opentelemetry.instrumentation.testing.junit.http.HttpServerTestOptions;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+class SpringRouterTest extends AbstractSpringServerTest {
+
+  @RegisterExtension
+  static final InstrumentationExtension testing = HttpServerInstrumentationExtension.forAgent();
+
+  @Override
+  protected void configure(HttpServerTestOptions options) {
+    super.configure(options);
+    options.setHasResponseCustomizer((endpoint) -> true);
+  }
+
+  @Override
+  protected String getConfigurationName() {
+    return "springRouterConf.xml";
+  }
+}

instrumentation/restlet/restlet-1.1/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/restlet/v1_1/RestletServerTest.java

@@ -0,0 +1,41 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opententelemetry.instrumentation.restlet.v1_1;
+
+import static java.util.Collections.singletonList;
+
+import com.noelios.restlet.StatusFilter;
+import io.opentelemetry.instrumentation.restlet.v1_1.AbstractRestletServerTest;
+import io.opentelemetry.instrumentation.restlet.v1_1.RestletTelemetry;
+import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
+import io.opentelemetry.instrumentation.testing.junit.http.AbstractHttpServerTest;
+import io.opentelemetry.instrumentation.testing.junit.http.HttpServerInstrumentationExtension;
+import org.junit.jupiter.api.extension.RegisterExtension;
+import org.restlet.Filter;
+import org.restlet.Restlet;
+
+class RestletServerTest extends AbstractRestletServerTest {
+
+  @RegisterExtension
+  static final InstrumentationExtension testing = HttpServerInstrumentationExtension.forLibrary();
+
+  @Override
+  protected Restlet wrapRestlet(Restlet restlet, String path) {
+    RestletTelemetry telemetry =
+        RestletTelemetry.builder(testing.getOpenTelemetry())
+            .setCapturedRequestHeaders(singletonList(AbstractHttpServerTest.TEST_REQUEST_HEADER))
+            .setCapturedResponseHeaders(singletonList(AbstractHttpServerTest.TEST_RESPONSE_HEADER))
+            .build();
+
+    Filter tracingFilter = telemetry.newFilter(path);
+    Filter statusFilter = new StatusFilter(component.getContext(), false, null, null);
+
+    tracingFilter.setNext(statusFilter);
+    statusFilter.setNext(restlet);
+
+    return tracingFilter;
+  }
+}

instrumentation/restlet/restlet-1.1/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/restlet/v1_1/ServletServerTest.java

@@ -0,0 +1,59 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opententelemetry.instrumentation.restlet.v1_1.spring;
+
+import static java.util.Collections.singletonList;
+
+import com.noelios.restlet.StatusFilter;
+import io.opentelemetry.instrumentation.restlet.v1_1.RestletTelemetry;
+import io.opentelemetry.instrumentation.restlet.v1_1.spring.AbstractSpringServerTest;
+import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
+import io.opentelemetry.instrumentation.testing.junit.http.AbstractHttpServerTest;
+import io.opentelemetry.instrumentation.testing.junit.http.HttpServerInstrumentationExtension;
+import java.util.ArrayList;
+import java.util.List;
+import org.junit.jupiter.api.extension.RegisterExtension;
+import org.restlet.Filter;
+import org.restlet.Restlet;
+import org.restlet.Route;
+import org.restlet.Router;
+import org.restlet.util.RouteList;
+
+abstract class AbstractSpringServerLibraryTest extends AbstractSpringServerTest {
+
+  @RegisterExtension
+  static final InstrumentationExtension testing = HttpServerInstrumentationExtension.forLibrary();
+
+  @Override
+  protected Restlet wrapRestlet(Restlet restlet, String path) {
+    RestletTelemetry telemetry =
+        RestletTelemetry.builder(testing.getOpenTelemetry())
+            .setCapturedRequestHeaders(singletonList(AbstractHttpServerTest.TEST_REQUEST_HEADER))
+            .setCapturedResponseHeaders(singletonList(AbstractHttpServerTest.TEST_RESPONSE_HEADER))
+            .build();
+
+    Filter tracingFilter = telemetry.newFilter(path);
+    Filter statusFilter = new StatusFilter(component.getContext(), false, null, null);
+
+    tracingFilter.setNext(statusFilter);
+    statusFilter.setNext(restlet);
+
+    return tracingFilter;
+  }
+
+  @Override
+  protected void setupRouting() {
+    List<Route> routes = new ArrayList<>();
+    for (Route route : router.getRoutes()) {
+      String pattern = route.getTemplate().getPattern();
+      routes.add(new Route(router, pattern, wrapRestlet(route.getNext(), pattern)));
+    }
+    router.setRoutes(new RouteList(routes));
+    router.setDefaultRoute(
+        new Route(router, "/", wrapRestlet(new Router(host.getContext()), "/*")));
+    host.attach(router);
+  }
+}