chore: spotless

Author: dmarkwat

instrumentation/finagle-http-23.11/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/finaglehttp/v23_11/Helpers.java

@@ -35,10 +35,10 @@
 
 public class Helpers {
 
-  private static final VirtualField<FullHttpRequest, Context> FULL_HTTP_REQUEST_CONTEXT = VirtualField.find(
-      FullHttpRequest.class, Context.class);
-  private static final VirtualField<HttpRequest, Context> HTTP_REQUEST_CONTEXT = VirtualField.find(
-      HttpRequest.class, Context.class);
+  private static final VirtualField<FullHttpRequest, Context> FULL_HTTP_REQUEST_CONTEXT =
+      VirtualField.find(FullHttpRequest.class, Context.class);
+  private static final VirtualField<HttpRequest, Context> HTTP_REQUEST_CONTEXT =
+      VirtualField.find(HttpRequest.class, Context.class);
 
   public static final RecordSchema.Field<Context> OTEL_CONTEXT_KEY =
       Request$.MODULE$.Schema().newField();
@@ -135,10 +135,13 @@ public static void mutateHandlerPipeline(Channel ch) {
 
     // h1 server handler || h2 server handler;
     // private class on a semi-private type -- not bothering to extract that any other way
-    if (
-        h1Handler instanceof HttpServerCodec || (h2Handler != null && h2Handler.getClass().getName()
-            .equals(
-                "com.twitter.finagle.http2.transport.common.Http2StreamMessageHandler$ServerHttp2StreamMessageHandler"))) {
+    if (h1Handler instanceof HttpServerCodec
+        || (h2Handler != null
+            && h2Handler
+                .getClass()
+                .getName()
+                .equals(
+                    "com.twitter.finagle.http2.transport.common.Http2StreamMessageHandler$ServerHttp2StreamMessageHandler"))) {
       // ensure we capture the server context and assign it to the outgoing request before offering
       // to the AsyncQueue;
       // not applicable to clients

instrumentation/finagle-http-23.11/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/finaglehttp/v23_11/ServerH2Test.java

@@ -70,17 +70,20 @@ void h2ProtocolUpgrade() throws Exception {
     cleanup.deferCleanup(client::close);
 
     Response response =
-        testing.runWithSpan("h2-upgrade-client", () -> Await.result(
-            client.apply(
-                Utils.buildRequest(
-                    "GET",
-                    uri,
-                    ImmutableMap.of(
-                        HttpHeaderNames.USER_AGENT.toString(),
-                        TEST_USER_AGENT,
-                        HttpHeaderNames.X_FORWARDED_FOR.toString(),
-                        TEST_CLIENT_IP))),
-            Duration.fromSeconds(20)));
+        testing.runWithSpan(
+            "h2-upgrade-client",
+            () ->
+                Await.result(
+                    client.apply(
+                        Utils.buildRequest(
+                            "GET",
+                            uri,
+                            ImmutableMap.of(
+                                HttpHeaderNames.USER_AGENT.toString(),
+                                TEST_USER_AGENT,
+                                HttpHeaderNames.X_FORWARDED_FOR.toString(),
+                                TEST_CLIENT_IP))),
+                    Duration.fromSeconds(20)));
 
     assertThat(response.status().code()).isEqualTo(SUCCESS.getStatus());
     assertThat(response.contentString()).isEqualTo(SUCCESS.getBody());
@@ -96,13 +99,17 @@ void h2ProtocolUpgrade() throws Exception {
               s -> s.hasName("h2-upgrade-client").hasNoParent().hasKind(SpanKind.INTERNAL));
           // actual client netty span (including upgrade event)
           spanAssertions.add(
-              s -> s.hasKind(SpanKind.CLIENT).hasName(method).hasParent(trace.getSpan(0))
-                  .hasEventsSatisfyingExactly(ServerH2Test::assertSwitchingProtocolsEvent));
+              s ->
+                  s.hasKind(SpanKind.CLIENT)
+                      .hasName(method)
+                      .hasParent(trace.getSpan(0))
+                      .hasEventsSatisfyingExactly(ServerH2Test::assertSwitchingProtocolsEvent));
           // server netty span (including upgrade event)
           spanAssertions.add(
-              span -> assertServerSpan(span, method, endpoint, endpoint.getStatus())
-                  .hasParent(trace.getSpan(1))
-                  .hasEventsSatisfyingExactly(ServerH2Test::assertSwitchingProtocolsEvent));
+              span ->
+                  assertServerSpan(span, method, endpoint, endpoint.getStatus())
+                      .hasParent(trace.getSpan(1))
+                      .hasEventsSatisfyingExactly(ServerH2Test::assertSwitchingProtocolsEvent));
           // server controller span
           spanAssertions.add(
               span -> {