open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

convert gwt tests from groovy to java (#8201) 

Related to #7195
This commit is contained in:
Nitesh S 2023-04-04 00:00:33 +05:30 committed by GitHub
parent 1393604118
commit f7d74f5daa
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 195 additions and 174 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

174
instrumentation/gwt-2.0/javaagent/src/test/groovy/GwtTest.groovy
View File

@ -1,174 +0,0 @@
/*
* Copyright The OpenTelemetry Authors
* SPDX-License-Identifier: Apache-2.0
*/
import io.opentelemetry.api.trace.SpanKind
import io.opentelemetry.instrumentation.test.AgentInstrumentationSpecification
import io.opentelemetry.instrumentation.test.asserts.TraceAssert
import io.opentelemetry.instrumentation.test.base.HttpServerTestTrait
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes
import org.eclipse.jetty.server.Server
import org.eclipse.jetty.util.resource.Resource
import org.eclipse.jetty.webapp.WebAppContext
import org.openqa.selenium.chrome.ChromeOptions
import org.slf4j.Logger
import org.slf4j.LoggerFactory
import org.testcontainers.Testcontainers
import org.testcontainers.containers.BrowserWebDriverContainer
import org.testcontainers.containers.output.Slf4jLogConsumer
import spock.lang.Shared
import java.util.concurrent.TimeUnit
class GwtTest extends AgentInstrumentationSpecification implements HttpServerTestTrait<Server> {
private static final Logger logger = LoggerFactory.getLogger(GwtTest)
@Shared
BrowserWebDriverContainer<?> browser
@Override
Server startServer(int port) {
WebAppContext webAppContext = new WebAppContext()
webAppContext.setContextPath(getContextPath())
webAppContext.setBaseResource(Resource.newResource(new File("build/testapp/web")))
def jettyServer = new Server(port)
jettyServer.connectors.each {
it.setHost('localhost')
}
jettyServer.setHandler(webAppContext)
jettyServer.start()
return jettyServer
}
@Override
void stopServer(Server server) {
server.stop()
server.destroy()
}
def setupSpec() {
setupServer()
Testcontainers.exposeHostPorts(port)
browser = new BrowserWebDriverContainer<>()
.withCapabilities(new ChromeOptions())
.withLogConsumer(new Slf4jLogConsumer(logger))
browser.start()
address = new URI("http://host.testcontainers.internal:$port" + getContextPath() + "/")
}
def cleanupSpec() {
cleanupServer()
browser?.stop()
}
@Override
String getContextPath() {
return "/xyz"
}
def getDriver() {
def driver = browser.getWebDriver()
driver.manage().timeouts().implicitlyWait(30, TimeUnit.SECONDS)
return driver
}
def "test gwt"() {
setup:
def driver = getDriver()
// fetch the test page
driver.get(address.resolve("greeting.html").toString())
expect:
// wait for page to load
driver.findElementByClassName("greeting.button")
assertTraces(4) {
traces.sort(orderByRootSpanName("GET " + getContextPath() + "/*", "GET"))
// /xyz/greeting.html
trace(0, 1) {
serverSpan(it, 0, "GET " + getContextPath() + "/*")
}
// /xyz/greeting/greeting.nocache.js
trace(1, 1) {
serverSpan(it, 0, "GET " + getContextPath() + "/*")
}
// /xyz/greeting/1B105441581A8F41E49D5DF3FB5B55BA.cache.html
trace(2, 1) {
serverSpan(it, 0, "GET " + getContextPath() + "/*")
}
// /favicon.ico
trace(3, 1) {
serverSpan(it, 0, "GET")
}
}
clearExportedData()
when:
// click a button to trigger calling java code
driver.findElementByClassName("greeting.button").click()
then:
// wait for response
"Hello, Otel" == driver.findElementByClassName("message.received").getText()
assertTraces(1) {
trace(0, 2) {
serverSpan(it, 0, "POST " + getContextPath() + "/greeting/greet")
span(1) {
name "test.gwt.shared.MessageService/sendMessage"
kind SpanKind.SERVER
childOf(span(0))
attributes {
"$SemanticAttributes.RPC_SYSTEM" "gwt"
"$SemanticAttributes.RPC_SERVICE" "test.gwt.shared.MessageService"
"$SemanticAttributes.RPC_METHOD" "sendMessage"
}
}
}
}
clearExportedData()
when:
// click a button to trigger calling java code
driver.findElementByClassName("error.button").click()
then:
// wait for response
"Error" == driver.findElementByClassName("error.received").getText()
assertTraces(1) {
trace(0, 2) {
serverSpan(it, 0, "POST " + getContextPath() + "/greeting/greet")
span(1) {
name "test.gwt.shared.MessageService/sendMessage"
kind SpanKind.SERVER
childOf(span(0))
errorEvent(IOException)
attributes {
"$SemanticAttributes.RPC_SYSTEM" "gwt"
"$SemanticAttributes.RPC_SERVICE" "test.gwt.shared.MessageService"
"$SemanticAttributes.RPC_METHOD" "sendMessage"
}
}
}
}
cleanup:
driver.close()
}
static serverSpan(TraceAssert trace, int index, String spanName) {
trace.span(index) {
hasNoParent()
name spanName
kind SpanKind.SERVER
}
}
}

195
instrumentation/gwt-2.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/gwt/GwtTest.java Normal file
View File

@ -0,0 +1,195 @@
/*
* Copyright The OpenTelemetry Authors
* SPDX-License-Identifier: Apache-2.0
*/
package io.opentelemetry.javaagent.instrumentation.gwt;
import static io.opentelemetry.instrumentation.testing.util.TelemetryDataUtil.orderByRootSpanName;
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.equalTo;
import static org.junit.jupiter.api.Assertions.assertEquals;
import io.opentelemetry.api.trace.SpanKind;
import io.opentelemetry.instrumentation.test.utils.PortUtils;
import io.opentelemetry.instrumentation.testing.junit.AgentInstrumentationExtension;
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
import java.io.File;
import java.io.IOException;
import java.net.URI;
import java.util.concurrent.TimeUnit;
import org.eclipse.jetty.server.Connector;
import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.server.ServerConnector;
import org.eclipse.jetty.util.resource.Resource;
import org.eclipse.jetty.webapp.WebAppContext;
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;
import org.openqa.selenium.chrome.ChromeOptions;
import org.openqa.selenium.remote.RemoteWebDriver;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.testcontainers.Testcontainers;
import org.testcontainers.containers.BrowserWebDriverContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
class GwtTest {
@RegisterExtension
private static final InstrumentationExtension testing = AgentInstrumentationExtension.create();
private static final Logger logger = LoggerFactory.getLogger(GwtTest.class);
static int port;
static Server server;
static BrowserWebDriverContainer<?> browser;
static URI address;
static void startServer() throws Exception {
port = PortUtils.findOpenPort();
server = new Server(port);
for (Connector connector : server.getConnectors()) {
((ServerConnector) connector).setHost("localhost");
}
WebAppContext webAppContext = new WebAppContext();
webAppContext.setContextPath(getContextPath());
webAppContext.setBaseResource(Resource.newResource(new File("build/testapp/web")));
server.setHandler(webAppContext);
server.start();
}
static void stopServer() throws Exception {
server.stop();
server.destroy();
}
@BeforeAll
static void setup() throws Exception {
startServer();
Testcontainers.exposeHostPorts(port);
browser =
new BrowserWebDriverContainer<>()
.withCapabilities(new ChromeOptions())
.withLogConsumer(new Slf4jLogConsumer(logger));
browser.start();
address = new URI("http://host.testcontainers.internal:" + port + getContextPath() + "/");
}
@AfterAll
static void cleanup() throws Exception {
stopServer();
browser.stop();
}
static final String getContextPath() {
return "/xyz";
}
RemoteWebDriver getDriver() {
RemoteWebDriver driver = browser.getWebDriver();
driver.manage().timeouts().implicitlyWait(30, TimeUnit.SECONDS);
return driver;
}
@Test
void testGwt() {
RemoteWebDriver driver = getDriver();
// fetch the test page
driver.get(address.resolve("greeting.html").toString());
driver.findElementByClassName("greeting.button");
testing.waitAndAssertSortedTraces(
orderByRootSpanName("GET " + getContextPath() + "/*", "GET"),
trace -> {
// /xyz/greeting.html
trace.hasSpansSatisfyingExactly(
span ->
span.hasName("GET " + getContextPath() + "/*")
.hasKind(SpanKind.SERVER)
.hasNoParent());
},
trace -> {
// /xyz/greeting/greeting.nocache.js
trace.hasSpansSatisfyingExactly(
span ->
span.hasName("GET " + getContextPath() + "/*")
.hasKind(SpanKind.SERVER)
.hasNoParent());
},
trace -> {
// /xyz/greeting/1B105441581A8F41E49D5DF3FB5B55BA.cache.html
trace.hasSpansSatisfyingExactly(
span ->
span.hasName("GET " + getContextPath() + "/*")
.hasKind(SpanKind.SERVER)
.hasNoParent());
},
trace -> {
// /favicon.ico
trace.hasSpansSatisfyingExactly(
span -> span.hasName("GET").hasKind(SpanKind.SERVER).hasNoParent());
});
testing.clearData();
// click a button to trigger calling java code
driver.findElementByClassName("greeting.button").click();
assertEquals(driver.findElementByClassName("message.received").getText(), "Hello, Otel");
testing.waitAndAssertTraces(
trace ->
trace
.hasSize(2)
.hasSpansSatisfyingExactly(
span ->
span.hasName("POST " + getContextPath() + "/greeting/greet")
.hasKind(SpanKind.SERVER)
.hasNoParent(),
span ->
span.hasName("test.gwt.shared.MessageService/sendMessage")
.hasKind(SpanKind.SERVER)
.hasParent(trace.getSpan(0))
.hasAttributesSatisfyingExactly(
equalTo(SemanticAttributes.RPC_SYSTEM, "gwt"),
equalTo(
SemanticAttributes.RPC_SERVICE,
"test.gwt.shared.MessageService"),
equalTo(SemanticAttributes.RPC_METHOD, "sendMessage"))));
testing.clearData();
// click a button to trigger calling java code
driver.findElementByClassName("error.button").click();
assertEquals(driver.findElementByClassName("error.received").getText(), "Error");
testing.waitAndAssertTraces(
trace ->
trace
.hasSize(2)
.hasSpansSatisfyingExactly(
span ->
span.hasName("POST " + getContextPath() + "/greeting/greet")
.hasKind(SpanKind.SERVER)
.hasNoParent(),
span ->
span.hasName("test.gwt.shared.MessageService/sendMessage")
.hasKind(SpanKind.SERVER)
.hasParent(trace.getSpan(0))
.hasException(new IOException())
.hasAttributesSatisfyingExactly(
equalTo(SemanticAttributes.RPC_SYSTEM, "gwt"),
equalTo(
SemanticAttributes.RPC_SERVICE,
"test.gwt.shared.MessageService"),
equalTo(SemanticAttributes.RPC_METHOD, "sendMessage"))));
driver.close();
}
}