src/EventSubscriber/CrmAiExceptionSubscriber.php line 39

  1. <?php
  3. declare(strict_types=1);
  5. namespace App\EventSubscriber;
  7. use Psr\Log\LoggerInterface;
  8. use Symfony\Component\DependencyInjection\Attribute\Autowire;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use Symfony\Component\HttpFoundation\JsonResponse;
  11. use Symfony\Component\HttpFoundation\Request;
  12. use Symfony\Component\HttpFoundation\Response;
  13. use Symfony\Component\HttpKernel\Event\ExceptionEvent;
  14. use Symfony\Component\HttpKernel\Exception\HttpExceptionInterface;
  15. use Symfony\Component\HttpKernel\KernelEvents;
  16. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  17. use Symfony\Component\Security\Core\Exception\AccessDeniedException;
  18. use Symfony\Component\Security\Core\User\UserInterface;
  20. final class CrmAiExceptionSubscriber implements EventSubscriberInterface
  21. {
  22.     public function __construct(
  23.         #[Autowire(service: 'monolog.logger.crm_ai')]
  24.         private readonly LoggerInterface $crmAiLogger,
  25.         private readonly TokenStorageInterface $tokenStorage,
  26.     ) {
  27.     }
  29.     /**
  30.      * @return array<string, array{0: string, 1: int}>
  31.      */
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [
  35.             KernelEvents::EXCEPTION => ['onKernelException', 64],
  36.         ];
  37.     }
  39.     public function onKernelException(ExceptionEvent $event): void
  40.     {
  41.         $request = $event->getRequest();
  42.         if (!$this->isCrmAiRequest($request)) {
  43.             return;
  44.         }
  46.         $exception = $event->getThrowable();
  47.         $diagnosticId = $this->createDiagnosticId();
  48.         $statusCode = $this->resolveStatusCode($exception);
  50.         $this->logException($request, $exception, $diagnosticId, $statusCode);
  52.         $message = $statusCode === Response::HTTP_FORBIDDEN
  53.             ? 'Nie udało się uruchomić rozmowy z asystentem. Brak dostępu albo sesja/token bezpieczeństwa są nieaktualne.'
  54.             : 'Nie udało się wykonać akcji asystenta CRM.';
  56.         $event->setResponse(new JsonResponse([
  57.             'error' => $message . ' Kod diagnostyczny: ' . $diagnosticId . '.',
  58.             'diagnostic_id' => $diagnosticId,
  59.             'diagnostic_reason' => $statusCode === Response::HTTP_FORBIDDEN ? 'access_denied' : 'crm_ai_exception',
  60.             'support_message' => 'Podaj ten kod administratorowi CRM.',
  61.         ], $statusCode));
  62.     }
  64.     private function isCrmAiRequest(Request $request): bool
  65.     {
  66.         $path = $request->getPathInfo();
  68.         return str_starts_with($path, '/admin/ai/')
  69.             || str_starts_with($path, '/consultant/ai/');
  70.     }
  72.     private function resolveStatusCode(\Throwable $exception): int
  73.     {
  74.         if ($exception instanceof AccessDeniedException) {
  75.             return Response::HTTP_FORBIDDEN;
  76.         }
  78.         if ($exception instanceof HttpExceptionInterface) {
  79.             return $exception->getStatusCode();
  80.         }
  82.         return Response::HTTP_INTERNAL_SERVER_ERROR;
  83.     }
  85.     private function createDiagnosticId(): string
  86.     {
  87.         return 'crm-ai-exception-' . date('Ymd-His') . '-' . bin2hex(random_bytes(4));
  88.     }
  90.     private function logException(Request $request, \Throwable $exception, string $diagnosticId, int $statusCode): void
  91.     {
  92.         $user = $this->tokenStorage->getToken()?->getUser();
  93.         $roles = $user instanceof UserInterface ? $user->getRoles() : [];
  95.         $context = [
  96.             'diagnostic_id' => $diagnosticId,
  97.             'status_code' => $statusCode,
  98.             'path' => $request->getPathInfo(),
  99.             'route' => $request->attributes->get('_route'),
  100.             'method' => $request->getMethod(),
  101.             'user_id' => $user !== null && method_exists($user, 'getId') ? $user->getId() : null,
  102.             'user_identifier' => $user instanceof UserInterface ? $user->getUserIdentifier() : null,
  103.             'user_roles' => array_values(array_unique($roles)),
  104.             'csrf_header_present' => $request->headers->has('X-CSRF-TOKEN'),
  105.             'csrf_header_length' => strlen((string) $request->headers->get('X-CSRF-TOKEN', '')),
  106.             'ajax_header' => $request->headers->get('X-Requested-With'),
  107.             'client_ip' => $request->getClientIp(),
  108.             'user_agent' => $request->headers->get('User-Agent'),
  109.             'exception_class' => $exception::class,
  110.             'exception_message' => $exception->getMessage(),
  111.             'exception_file' => $exception->getFile(),
  112.             'exception_line' => $exception->getLine(),
  113.         ];
  115.         if ($statusCode >= Response::HTTP_INTERNAL_SERVER_ERROR) {
  116.             $this->crmAiLogger->error('CRM AI request failed before controller response.', $context);
  118.             return;
  119.         }
  121.         $this->crmAiLogger->warning('CRM AI request was blocked before controller response.', $context);
  122.     }
  123. }