format

Author: zeitlinger

smoke-tests/src/test/java/io/opentelemetry/smoketest/JavaTelemetryRetriever.java

@@ -56,11 +56,11 @@ public Collection<MetricData> waitForMetrics() {
 
   public Collection<LogRecordData> waitForLogs() {
     Collection<ExportLogsServiceRequest> requests =
-           waitForTelemetry("get-logs", () -> ExportLogsServiceRequest.newBuilder());
-       return TelemetryConverter.getLogRecordData(
-           requests.stream()
-               .flatMap(r -> r.getResourceLogsList().stream())
-               .collect(Collectors.toList()));
+        waitForTelemetry("get-logs", () -> ExportLogsServiceRequest.newBuilder());
+    return TelemetryConverter.getLogRecordData(
+        requests.stream()
+            .flatMap(r -> r.getResourceLogsList().stream())
+            .collect(Collectors.toList()));
   }
 
   @SuppressWarnings({"unchecked", "rawtypes"})
@@ -103,9 +103,6 @@ private String waitForContent(String path) throws InterruptedException {
       TimeUnit.MILLISECONDS.sleep(500);
     }
 
-    // todo remove debug
-    //    System.out.println(new String(content, StandardCharsets.UTF_8));
-
     return content;
   }
 

smoke-tests/src/test/java/io/opentelemetry/smoketest/LogsSmokeTest.java

@@ -2,13 +2,14 @@
  * Copyright The OpenTelemetry Authors
  * SPDX-License-Identifier: Apache-2.0
  */
+
 package io.opentelemetry.smoketest;
 
 import static org.assertj.core.api.Assertions.assertThat;
 
+import io.opentelemetry.sdk.logs.data.LogRecordData;
 import java.time.Duration;
 import java.util.Collection;
-import io.opentelemetry.sdk.logs.data.LogRecordData;
 import org.junit.jupiter.api.condition.DisabledIf;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.ValueSource;

smoke-tests/src/test/java/io/opentelemetry/smoketest/QuarkusSmokeTest.java

@@ -5,17 +5,17 @@
 
 package io.opentelemetry.smoketest;
 
+import static io.opentelemetry.sdk.testing.assertj.TracesAssert.assertThat;
+
 import io.opentelemetry.semconv.ServiceAttributes;
+import io.opentelemetry.semconv.incubating.TelemetryIncubatingAttributes;
 import java.time.Duration;
 import java.util.jar.Attributes;
 import java.util.jar.JarFile;
-import io.opentelemetry.semconv.incubating.TelemetryIncubatingAttributes;
 import org.junit.jupiter.api.condition.DisabledIf;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.ValueSource;
 
-import static io.opentelemetry.sdk.testing.assertj.TracesAssert.assertThat;
-
 @DisabledIf("io.opentelemetry.smoketest.TestContainerManager#useWindowsContainers")
 class QuarkusSmokeTest extends JavaSmokeTest {
   @Override

testing-common/src/main/java/io/opentelemetry/instrumentation/testing/internal/TelemetryConverter.java

@@ -1,3 +1,8 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
 package io.opentelemetry.instrumentation.testing.internal;
 
 import static io.opentelemetry.api.common.AttributeKey.booleanArrayKey;
@@ -73,8 +78,8 @@
 import java.util.stream.Collectors;
 
 /**
- * This class is internal and is hence not for public use. Its APIs are unstable and can change
- * at any time.
+ * This class is internal and is hence not for public use. Its APIs are unstable and can change at
+ * any time.
  */
 public class TelemetryConverter {
   private static final char TRACESTATE_KEY_VALUE_DELIMITER = '=';

testing-common/src/main/java/io/opentelemetry/javaagent/testing/common/AgentTestingExporterAccess.java

@@ -106,17 +106,18 @@ public static List<SpanData> getExportedSpans() {
   public static List<MetricData> getExportedMetrics() {
     try {
       return TelemetryConverter.getMetricsData(
-          ((List<byte[]>) getMetricExportRequests.invokeExact()).stream()
-              .map(
-                  serialized -> {
-                    try {
-                      return ExportMetricsServiceRequest.parseFrom(serialized);
-                    } catch (InvalidProtocolBufferException e) {
-                      throw new AssertionError(e);
-                    }
-                  })
-              .flatMap(request -> request.getResourceMetricsList().stream())
-              .collect(toList()));
+          ((List<byte[]>) getMetricExportRequests.invokeExact())
+              .stream()
+                  .map(
+                      serialized -> {
+                        try {
+                          return ExportMetricsServiceRequest.parseFrom(serialized);
+                        } catch (InvalidProtocolBufferException e) {
+                          throw new AssertionError(e);
+                        }
+                      })
+                  .flatMap(request -> request.getResourceMetricsList().stream())
+                  .collect(toList()));
     } catch (Throwable t) {
       throw new AssertionError("Could not invoke getSpanExportRequests", t);
     }
@@ -125,17 +126,19 @@ public static List<MetricData> getExportedMetrics() {
   @SuppressWarnings("unchecked")
   public static List<LogRecordData> getExportedLogRecords() {
     try {
-      return TelemetryConverter.getLogRecordData(((List<byte[]>) getLogExportRequests.invokeExact()).stream()
-          .map(
-              serialized -> {
-                try {
-                  return ExportLogsServiceRequest.parseFrom(serialized);
-                } catch (InvalidProtocolBufferException e) {
-                  throw new AssertionError(e);
-                }
-              })
-          .flatMap(request -> request.getResourceLogsList().stream())
-          .collect(toList()));
+      return TelemetryConverter.getLogRecordData(
+          ((List<byte[]>) getLogExportRequests.invokeExact())
+              .stream()
+                  .map(
+                      serialized -> {
+                        try {
+                          return ExportLogsServiceRequest.parseFrom(serialized);
+                        } catch (InvalidProtocolBufferException e) {
+                          throw new AssertionError(e);
+                        }
+                      })
+                  .flatMap(request -> request.getResourceLogsList().stream())
+                  .collect(toList()));
     } catch (Throwable t) {
       throw new AssertionError("Could not invoke getLogExportRequests", t);
     }