remove new http test

Author: pjfanning

instrumentation/pekko/pekko-http-1.0/javaagent/src/test/scala/io/opentelemetry/javaagent/instrumentation/pekkohttp/v1_0/PekkoHttpServerInstrumentationTestAsync.scala

@@ -6,17 +6,10 @@
 package io.opentelemetry.javaagent.instrumentation.pekkohttp.v1_0
 
 import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension
-import io.opentelemetry.instrumentation.testing.junit.http.ServerEndpoint.SUCCESS
 import io.opentelemetry.instrumentation.testing.junit.http.{
   HttpServerInstrumentationExtension,
   HttpServerTestOptions
 }
-import io.opentelemetry.testing.internal.armeria.common.{
-  AggregatedHttpRequest,
-  AggregatedHttpResponse
-}
-import org.assertj.core.api.Assertions.assertThat
-import org.junit.jupiter.api.Test
 import org.junit.jupiter.api.extension.RegisterExtension
 
 class PekkoHttpServerInstrumentationTestAsync
@@ -39,23 +32,4 @@ class PekkoHttpServerInstrumentationTestAsync
     super.configure(options)
     options.setTestHttpPipelining(false)
   }
-
-  @Test
-  def successfulPostRequestWithParent(): Unit = {
-    val method = "POST"
-    val traceId = "00000000000000000000000000000123"
-    val parentId = "0000000000000456"
-    val aggregatedHttpRequest = AggregatedHttpRequest
-      .of( // intentionally sending mixed-case "tracePARENT" to make sure that TextMapGetters are
-        // not case-sensitive
-        request(SUCCESS, method).headers.toBuilder
-          .set("tracePARENT", "00-" + traceId + "-" + parentId + "-01")
-          .build
-      )
-    val response = client.execute(aggregatedHttpRequest).aggregate.join
-    assertThat(response.status.code).isEqualTo(SUCCESS.getStatus)
-    assertThat(response.contentUtf8).isEqualTo(SUCCESS.getBody)
-    val spanId = assertResponseHasCustomizedHeaders(response, SUCCESS, traceId)
-    assertTheTraces(1, traceId, parentId, spanId, "POST", SUCCESS)
-  }
 }

instrumentation/pekko/pekko-http-1.0/javaagent/src/test/scala/io/opentelemetry/javaagent/instrumentation/pekkohttp/v1_0/PekkoHttpTestAsyncWebServer.scala

@@ -5,23 +5,19 @@
 
 package io.opentelemetry.javaagent.instrumentation.pekkohttp.v1_0
 
-import io.opentelemetry.api.trace.Span
-import io.opentelemetry.instrumentation.testing.junit.http.ServerEndpoint._
-import io.opentelemetry.instrumentation.testing.junit.http.{
-  AbstractHttpServerTest,
-  ServerEndpoint
-}
 import org.apache.pekko.actor.ActorSystem
 import org.apache.pekko.http.scaladsl.Http
 import org.apache.pekko.http.scaladsl.Http.ServerBinding
-import org.apache.pekko.http.scaladsl.model.HttpMethods.{GET, POST}
-import org.apache.pekko.http.scaladsl.model.StatusCodes.OK
+import org.apache.pekko.http.scaladsl.model.HttpMethods.GET
 import org.apache.pekko.http.scaladsl.model._
-import org.apache.pekko.pattern.after
 import org.apache.pekko.stream.ActorMaterializer
+import io.opentelemetry.instrumentation.testing.junit.http.{
+  AbstractHttpServerTest,
+  ServerEndpoint
+}
+import io.opentelemetry.instrumentation.testing.junit.http.ServerEndpoint._
 
 import java.util.function.Supplier
-import scala.concurrent.duration.DurationInt
 import scala.concurrent.{Await, ExecutionContextExecutor, Future}
 
 object PekkoHttpTestAsyncWebServer {
@@ -61,26 +57,6 @@ object PekkoHttpTestAsyncWebServer {
           }
         )
       }
-    case HttpRequest(POST, uri: Uri, _, _, _) =>
-      val endpoint = ServerEndpoint.forPath(uri.path.toString())
-      AbstractHttpServerTest.controller(
-        endpoint,
-        () =>
-          for {
-            _ <- Future.successful(2)
-            firstSpanContext = Span.current().getSpanContext()
-            _ <- after(1.second, system.scheduler)(Future.successful(1))
-            secondSpanContext = Span.current().getSpanContext()
-            _ = require(
-              firstSpanContext.getTraceId() == secondSpanContext.getTraceId(),
-              s"TraceId ${firstSpanContext.getTraceId()} did not match ${secondSpanContext.getTraceId()}"
-            )
-            _ = require(
-              firstSpanContext.getSpanId() == secondSpanContext.getSpanId(),
-              s"SpanId ${firstSpanContext.getSpanId()} did not match ${secondSpanContext.getSpanId()}"
-            )
-          } yield HttpResponse(status = OK, entity = endpoint.getBody)
-      )
   }
 
   private var binding: ServerBinding = _