src/EventSubscriber/ApiSubscriber.php line 66

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Utils\ApiResponse;
  6. use App\Exceptions\Api\ApiException;
  7. use App\Controller\Api\BaseApiController;
  8. use App\Utils\Constants\ApiResponseMessages;
  9. use App\Exceptions\Api\ApiValidationException;
  10. use Symfony\Component\HttpKernel\KernelEvents;
  11. use Symfony\Component\HttpKernel\Event\ExceptionEvent;
  12. use Symfony\Component\HttpKernel\Event\ControllerEvent;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
  15. use Symfony\Component\HttpFoundation\File\Exception\FileException;
  16. use Symfony\Component\HttpKernel\Event\GetResponseForExceptionEvent;
  18. class ApiSubscriber implements EventSubscriberInterface {
  20.     /**
  21.      * Returns an array of event names this subscriber wants to listen to.
  22.      *
  23.      * The array keys are event names and the value can be:
  24.      *
  25.      *  * The method name to call (priority defaults to 0)
  26.      *  * An array composed of the method name to call and the priority
  27.      *  * An array of arrays composed of the method names to call and respective
  28.      *    priorities, or 0 if unset
  29.      *
  30.      * For instance:
  31.      *
  32.      *  * ['eventName' => 'methodName']
  33.      *  * ['eventName' => ['methodName', $priority]]
  34.      *  * ['eventName' => [['methodName1', $priority], ['methodName2']]]
  35.      *
  36.      * @return array The event names to listen to
  37.      */
  38.     public static function getSubscribedEvents(): array {
  39.         return [
  40.             KernelEvents::CONTROLLER => 'onKernelController',
  41.             KernelEvents::EXCEPTION => 'onKernelException'
  42.         ];
  43.     }
  45.     /**
  46.      * @param \Symfony\Component\HttpKernel\Event\ControllerEvent $event
  47.      */
  48.     public function onKernelController(ControllerEvent $event){
  49.         $request = $event->getRequest();
  51.         if ($request->getContentType() != 'json' || !$request->getContent()) {
  52.             return;
  53.         }
  55.         $data = json_decode($request->getContent(), true);
  56.         if (json_last_error() !== JSON_ERROR_NONE) {
  57.             throw new ApiException(ApiResponse::HTTP_BAD_REQUEST, ApiResponseMessages::MSG_INVALID_JSON);
  58.         }
  60.         $request->request->replace(is_array($data) ? $data : array());
  61.     }
  63.     /**
  64.      * @param \Symfony\Component\HttpKernel\Event\ExceptionEvent $event
  65.      */
  66.     public function onKernelException(ExceptionEvent  $event){
  67.         $fromApi = false;
  68.         $ex = $event->getThrowable();
  70.         $traces = $ex->getTrace();
  72.         foreach($traces as $trace){
  73.             if (!array_key_exists('class', $trace))
  74.                 continue;
  76.             if (strpos($trace['class'], "App\\Controller\\Api\\") === 0) {
  77.                 $fromApi = true;
  78.             }
  79.         }
  81.         if ($ex instanceof ApiValidationException) {
  82.             $code = method_exists($ex, "getStatusCode") ? $ex->getStatusCode() : 500;
  83.             $response = new ApiResponse(
  84.                 [
  85.                     "message" => $ex->getMessage(),
  86.                     "fields" => $ex->getFields()
  87.                 ],
  88.                 $code
  89.             );
  90.             $event->setResponse($response);
  91.         
  92.         } elseif ($_ENV['APP_ENV'] !== 'dev' && $ex instanceof NotFoundHttpException) {
  93.             $code = method_exists($ex, "getStatusCode") ? $ex->getStatusCode() : 404;
  94.             $response = new ApiResponse(
  95.                 [
  96.                     "message" => "Requested object is not found."
  97.                 ],
  98.                 $code
  99.             );
  100.             $event->setResponse($response);
  101.         
  102.         } elseif ($_ENV['APP_ENV'] !== 'dev' && ($fromApi || $ex instanceof ApiException)) {           
  103.             if (($ex instanceof FileException)
  104.                 && strpos($ex->file, 'FileService.php') !== false
  105.                 && is_array($ex->trace) 
  106.                 && strpos($ex->trace[1]['file'], 'src/Entity/News.php') !== false
  107.                 && $ex->trace[1]['function'] === 'upload') {
  108.                 // skip exception response; handle exception from controller to return custom response
  109.             
  110.             } else {
  111.                 $code = method_exists($ex, "getStatusCode") ? $ex->getStatusCode() : 500;
  112.                 $errType = method_exists($ex, "getErrType") ? $ex->getErrType() : '';
  113.                 $response = new ApiResponse(
  114.                     [
  115.                         "message" => $ex->getMessage(),
  116.                         "code" => $code,
  117.                         "type" => $errType
  118.                     ],
  119.                     $code
  120.                 );
  121.                 $event->setResponse($response);
  122.             }
  123.         }
  124.     }
  125. }