Merge pull request #8 from OpenTagOS/feature/exception-listener

Feature: Exception listener

Author: allflame

src/Bridge/ExceptionListener.php

@@ -0,0 +1,43 @@
+<?php
+declare(strict_types=1);
+
+namespace Jaeger\Symfony\Bridge;
+
+use Jaeger\Log\ErrorLog;
+use Jaeger\Span\SpanAwareInterface;
+use Jaeger\Tag\ErrorTag;
+use Symfony\Component\EventDispatcher\EventSubscriberInterface;
+use Symfony\Component\HttpKernel\Event\ExceptionEvent;
+
+class ExceptionListener implements EventSubscriberInterface
+{
+    private $spanManager;
+
+    public function __construct(SpanAwareInterface $spanManager)
+    {
+        $this->spanManager = $spanManager;
+    }
+
+    public static function getSubscribedEvents(): array
+    {
+        return [
+            ExceptionEvent::class => ['onKernelException', 0],
+        ];
+    }
+
+    public function onKernelException(ExceptionEvent $event): void
+    {
+        $span = $this->spanManager->getSpan();
+
+        if (null === $span) {
+            return;
+        }
+
+        $exception = $event->getThrowable();
+
+        $span
+            ->addTag(new ErrorTag())
+            ->addLog(new ErrorLog($exception->getMessage(), $exception->getTraceAsString()))
+        ;
+    }
+}

src/Bridge/RequestSpanListener.php

@@ -6,12 +6,15 @@
 use Jaeger\Http\HttpCodeTag;
 use Jaeger\Http\HttpMethodTag;
 use Jaeger\Http\HttpUriTag;
+use Jaeger\Log\ErrorLog;
 use Jaeger\Symfony\Name\Generator\NameGeneratorInterface;
 use Jaeger\Symfony\Tag\SymfonyComponentTag;
 use Jaeger\Symfony\Tag\SymfonyVersionTag;
+use Jaeger\Tag\ErrorTag;
 use Jaeger\Tag\SpanKindServerTag;
 use Jaeger\Tracer\TracerInterface;
 use Symfony\Component\EventDispatcher\EventSubscriberInterface;
+use Symfony\Component\HttpKernel\Event\ExceptionEvent;
 use Symfony\Component\HttpKernel\Event\RequestEvent;
 use Symfony\Component\HttpKernel\Event\ResponseEvent;
 use Symfony\Component\HttpKernel\HttpKernelInterface;
@@ -36,6 +39,7 @@ public static function getSubscribedEvents(): array
         return [
             RequestEvent::class => ['onRequest', 29],
             ResponseEvent::class => ['onResponse', -1024],
+            ExceptionEvent::class => ['onKernelException', 0],
         ];
     }
 
@@ -69,4 +73,18 @@ public function onRequest(RequestEvent $event): void
             )
         );
     }
+
+    public function onKernelException(ExceptionEvent $event): void
+    {
+        if ($this->spans->isEmpty()) {
+            return;
+        }
+
+        $exception = $event->getThrowable();
+
+        $this->spans->current()
+            ->addTag(new ErrorTag())
+            ->addLog(new ErrorLog($exception->getMessage(), $exception->getTraceAsString()))
+        ;
+    }
 }

src/Resources/services.yml

@@ -189,3 +189,9 @@ services:
     arguments: ['@jaeger.span.handler.background', '@jaeger.span.handler.gloabal']
     tags:
       - {name: 'kernel.event_subscriber' }
+  jaeger.exception.listener:
+    class: Jaeger\Symfony\Bridge\ExceptionListener
+    arguments:
+      - '@jaeger.span.manager'
+    tags:
+      - {name: 'kernel.event_subscriber'}