Added the request body and response body to the tracer (#6793)

Author: jonas-elias

publish/opentracing.php

@@ -125,12 +125,14 @@
             'uri' => 'request.uri',
             'method' => 'request.method',
             'header' => 'request.header',
+            // 'body' => 'request.body',
         ],
         'coroutine' => [
             'id' => 'coroutine.id',
         ],
         'response' => [
             'status_code' => 'response.status_code',
+            // 'body' => 'response.body',
         ],
         'rpc' => [
             'path' => 'rpc.path',

src/Listener/RequestTraceListener.php

@@ -77,12 +77,18 @@ protected function handleRequestTerminated(RequestTerminated $event): void
         $tracer = TracerContext::getTracer();
         $span = TracerContext::getRoot();
         $span->setTag($this->spanTagManager->get('response', 'status_code'), (string) $response->getStatusCode());
+        if ($this->spanTagManager->has('response', 'body')) {
+            $span->setTag($this->spanTagManager->get('response', 'body'), (string) $response->getBody());
+        }
 
         if ($event->exception && $this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($event->exception)) {
             $this->appendExceptionToSpan($span, $exception = $event->exception);
 
             if ($exception instanceof HttpException) {
                 $span->setTag($this->spanTagManager->get('response', 'status_code'), $exception->getStatusCode());
+                if ($this->spanTagManager->has('response', 'body')) {
+                    $span->setTag($this->spanTagManager->get('response', 'body'), (string) $response->getBody());
+                }
             }
         }
 
@@ -107,6 +113,9 @@ protected function buildSpan(ServerRequestInterface $request): Span
         $span->setTag($this->spanTagManager->get('request', 'path'), (string) $uri->getPath());
         $span->setTag($this->spanTagManager->get('request', 'method'), $request->getMethod());
         $span->setTag($this->spanTagManager->get('request', 'uri'), (string) $uri);
+        if ($this->spanTagManager->has('request', 'body')) {
+            $span->setTag($this->spanTagManager->get('request', 'body'), (string) $request->getBody());
+        }
         foreach ($request->getHeaders() as $key => $value) {
             $span->setTag($this->spanTagManager->get('request', 'header') . '.' . $key, implode(', ', $value));
         }

src/Middleware/TraceMiddleware.php

@@ -58,6 +58,9 @@ public function process(ServerRequestInterface $request, RequestHandlerInterface
                 $response = $response->withHeader('Trace-Id', $traceId);
             }
             $span->setTag($this->spanTagManager->get('response', 'status_code'), (string) $response->getStatusCode());
+            if ($this->spanTagManager->has('response', 'body')) {
+                $span->setTag($this->spanTagManager->get('response', 'body'), (string) $response->getBody());
+            }
         } catch (Throwable $exception) {
             if ($this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($exception)) {
                 $this->appendExceptionToSpan($span, $exception);
@@ -90,6 +93,9 @@ protected function buildSpan(ServerRequestInterface $request): Span
         $span->setTag($this->spanTagManager->get('request', 'path'), (string) $uri->getPath());
         $span->setTag($this->spanTagManager->get('request', 'method'), $request->getMethod());
         $span->setTag($this->spanTagManager->get('request', 'uri'), (string) $uri);
+        if ($this->spanTagManager->has('request', 'body')) {
+            $span->setTag($this->spanTagManager->get('request', 'body'), (string) $request->getBody());
+        }
         foreach ($request->getHeaders() as $key => $value) {
             $span->setTag($this->spanTagManager->get('request', 'header') . '.' . $key, implode(', ', $value));
         }