src/EventSubscriber/ExceptionListener.php line 42

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Slivki\EventSubscriber;
  7. use Psr\Log\LoggerInterface;
  8. use Slivki\Controller\Admin\BePaid\ValidateBePaidCredentialsAction;
  9. use Slivki\Controller\Api\GiftSubscription\CancelSubscriptionAction;
  10. use Slivki\Controller\Api\OnlineOrder\Vendor\GetNearestTimeAction;
  11. use Slivki\Controller\Api\Profile\Balance\BalanceTransferAction;
  12. use Slivki\Controller\Api\Profile\VirtualWallet\TransferSlivkiPayBalanceAction;
  13. use Slivki\Controller\Payment\Click\CompletePaymentAction;
  14. use Slivki\Controller\Payment\Click\PreparePaymentAction;
  15. use Slivki\Controller\Payment\Oplati\GetStatusOplatiTransactionAction;
  16. use Slivki\Controller\Subscription\GetChildSubscribersAction;
  17. use Slivki\Controller\Subscription\ShareSubscriptionAction;
  18. use Symfony\Component\HttpFoundation\JsonResponse;
  19. use Symfony\Component\HttpFoundation\Response;
  20. use Symfony\Component\HttpKernel\Event\ExceptionEvent;
  21. use Symfony\Component\HttpKernel\Exception\HttpExceptionInterface;
  22. use Symfony\Component\Messenger\Exception\HandlerFailedException;
  24. use Throwable;
  25. use function json_decode;
  26. use function array_filter;
  27. use function count;
  28. use function json_last_error;
  30. final class ExceptionListener
  31. {
  32.     private const API_NAMESPACES_START = [
  33.     ];
  35.     private LoggerInterface $logger;
  37.     public function __construct(LoggerInterface $logger)
  38.     {
  39.         $this->logger = $logger;
  40.     }
  42.     public function onKernelException(ExceptionEvent $event): void
  43.     {
  44.         $exception = $this->getException($event->getThrowable());
  45.         $exceptionMessage = $exception->getMessage();
  47.         $controller = $event->getRequest()->attributes->get('_controller');
  49.         if (null !== $controller && $this->isIncludedToRoute($controller)) {
  50.             json_decode($exceptionMessage, true);
  51.             $isJson = json_last_error() === JSON_ERROR_NONE;
  53.             $this->logger->error(
  54.                 'Exception occurred in controller',
  55.                 [
  56.                     'exception' => $exception,
  57.                     'isJson' => $isJson,
  58.                     'controller' => $controller,
  59.                 ]
  60.             );
  62.             $response = new JsonResponse(
  63.                 $isJson ? $exceptionMessage : ['error' => $exceptionMessage],
  64.                 $exception->getCode() !== 0 ? $exception->getCode() : Response::HTTP_INTERNAL_SERVER_ERROR,
  65.                 [],
  66.                 $isJson
  67.             );
  69.             if ($exception instanceof HttpExceptionInterface) {
  70.                 $response->setStatusCode($exception->getStatusCode());
  71.                 $response->headers->replace($exception->getHeaders());
  72.             }
  74.             $event->setResponse($response);
  75.         }
  76.     }
  78.     private function isIncludedToRoute(string $controller): bool
  79.     {
  80.         $matches = array_filter(
  81.             self::API_NAMESPACES_START,
  82.             static fn(string $needle): bool => strpos($controller, $needle) !== false,
  83.         );
  85.         return count($matches) > 0;
  86.     }
  88.     private function getException(Throwable $exception): Throwable
  89.     {
  90.         return $exception instanceof HandlerFailedException
  91.             ? $this->getException($exception->getPrevious())
  92.             : $exception;
  93.     }
  94. }