Title

/* * Copyright The OpenTelemetry Authors * SPDX-License-Identifier: Apache-2.0 */ import io.opentelemetry.instrumentation.test.AgentTestTrait import io.opentelemetry.instrumentation.test.asserts.TraceAssert import io.opentelemetry.instrumentation.test.base.HttpServerTest import io.opentelemetry.instrumentation.testing.junit.http.ServerEndpoint import io.opentelemetry.javaagent.bootstrap.servlet.ExperimentalSnippetHolder import io.opentelemetry.testing.internal.armeria.common.AggregatedHttpRequest import javax.servlet.Servlet import static io.opentelemetry.instrumentation.testing.junit.http.ServerEndpoint.AUTH_REQUIRED import static io.opentelemetry.instrumentation.testing.junit.http.ServerEndpoint.CAPTURE_HEADERS import static io.opentelemetry.instrumentation.testing.junit.http.ServerEndpoint.CAPTURE_PARAMETERS import static io.opentelemetry.instrumentation.testing.junit.http.ServerEndpoint.ERROR import static io.opentelemetry.instrumentation.testing.junit.http.ServerEndpoint.EXCEPTION import static io.opentelemetry.instrumentation.testing.junit.http.ServerEndpoint.INDEXED_CHILD import static io.opentelemetry.instrumentation.testing.junit.http.ServerEndpoint.NOT_FOUND import static io.opentelemetry.instrumentation.testing.junit.http.ServerEndpoint.QUERY_PARAM import static io.opentelemetry.instrumentation.testing.junit.http.ServerEndpoint.REDIRECT import static io.opentelemetry.instrumentation.testing.junit.http.ServerEndpoint.SUCCESS abstract class AbstractServlet3Test extends HttpServerTest implements AgentTestTrait { @Override URI buildAddress() { return new URI("http://localhost:$port$contextPath/") } // FIXME: Add authentication tests back in... // @Shared // protected String user = "user" // @Shared // protected String pass = "password" abstract Class servlet() abstract void addServlet(CONTEXT context, String path, Class servlet) public static final ServerEndpoint HTML_PRINT_WRITER = new ServerEndpoint("HTML_PRINT_WRITER", "htmlPrintWriter", 200, "\n" + "\n" + "\n" + " \n" + " Title\n" + "\n" + "\n" + "

test works

\n" + "\n" + "") public static final ServerEndpoint HTML_SERVLET_OUTPUT_STREAM = new ServerEndpoint("HTML_SERVLET_OUTPUT_STREAM", "htmlServletOutputStream", 200, "\n" + "\n" + "\n" + " \n" + " Title\n" + "\n" + "\n" + "

test works

\n" + "\n" + "") protected void setupServlets(CONTEXT context) { def servlet = servlet() addServlet(context, SUCCESS.path, servlet) addServlet(context, QUERY_PARAM.path, servlet) addServlet(context, ERROR.path, servlet) addServlet(context, EXCEPTION.path, servlet) addServlet(context, REDIRECT.path, servlet) addServlet(context, AUTH_REQUIRED.path, servlet) addServlet(context, INDEXED_CHILD.path, servlet) addServlet(context, CAPTURE_HEADERS.path, servlet) addServlet(context, CAPTURE_PARAMETERS.path, servlet) addServlet(context, HTML_PRINT_WRITER.path, servlet) addServlet(context, HTML_SERVLET_OUTPUT_STREAM.path, servlet) } protected ServerEndpoint lastRequest @Override AggregatedHttpRequest request(ServerEndpoint uri, String method) { lastRequest = uri super.request(uri, method) } @Override String expectedHttpRoute(ServerEndpoint endpoint) { switch (endpoint) { case NOT_FOUND: return getContextPath() + "/*" default: return super.expectedHttpRoute(endpoint) } } @Override boolean testCapturedRequestParameters() { true } boolean errorEndpointUsesSendError() { true } @Override boolean hasResponseCustomizer(ServerEndpoint endpoint) { true } @Override boolean hasResponseSpan(ServerEndpoint endpoint) { endpoint == REDIRECT || (endpoint == ERROR && errorEndpointUsesSendError()) } @Override void responseSpan(TraceAssert trace, int index, Object parent, String method, ServerEndpoint endpoint) { switch (endpoint) { case REDIRECT: redirectSpan(trace, index, parent) break case ERROR: sendErrorSpan(trace, index, parent) break } } def "snippet injection with ServletOutputStream"() { setup: ExperimentalSnippetHolder.setSnippet("\n ") def request = request(HTML_SERVLET_OUTPUT_STREAM, "GET") def response = client.execute(request).aggregate().join() expect: response.status().code() == HTML_SERVLET_OUTPUT_STREAM.status String result = "\n" + "\n" + "\n" + " \n" + " \n" + " Title\n" + "\n" + "\n" + "

test works

\n" + "\n" + "" response.contentUtf8() == result response.headers().contentLength() == result.length() } def "snippet injection with PrintWriter"() { setup: ExperimentalSnippetHolder.setSnippet("\n ") def request = request(HTML_PRINT_WRITER, "GET") def response = client.execute(request).aggregate().join() expect: response.status().code() == HTML_PRINT_WRITER.status String result = "\n" + "\n" + "\n" + " \n" + " \n" + " Title\n" + "\n" + "\n" + "

test works

\n" + "\n" + "" response.contentUtf8() == result response.headers().contentLength() == result.length() } }