src/EventSubscriber/ResponseEncryptingSubscriber.php line 70

Open in your IDE?
  1. <?php
  2. /**
  3.  * @license SILK SOFTWARE HOUSE SP Z O O
  4.  */
  6. namespace App\EventSubscriber;
  8. use App\Decoder\Interfaces\DecoderInterface;
  9. use App\Entity\DeviceCommand;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Symfony\Component\HttpFoundation\Response;
  12. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  13. use Symfony\Component\HttpKernel\Exception\AccessDeniedHttpException;
  14. use Symfony\Component\HttpKernel\KernelEvents;
  16. /**
  17.  * Class ResponseEncryptingSubscriber.
  18.  */
  19. class ResponseEncryptingSubscriber implements EventSubscriberInterface
  20. {
  21.     const MAX_BUFFER_SIZE = 400;
  23.     /**
  24.      * Decoder.
  25.      *
  26.      * @var DecoderInterface
  27.      */
  28.     private $decoder;
  30.     /**
  31.      * Device ping path.
  32.      *
  33.      * @var string[]
  34.      */
  35.     private $encryptedPaths;
  37.     /**
  38.      * ResponseEncryptingSubscriber constructor.
  39.      *
  40.      * @param DecoderInterface $decoder
  41.      * @param string[]         $encryptedPaths Array of encrypted paths.
  42.      */
  43.     public function __construct(DecoderInterface $decoder, array $encryptedPaths)
  44.     {
  45.         $this->decoder = $decoder;
  46.         $this->encryptedPaths = $encryptedPaths;
  47.     }
  49.     /**
  50.      * Get subscribed events.
  51.      *
  52.      * @return array
  53.      */
  54.     public static function getSubscribedEvents(): array
  55.     {
  56.         return [
  57.             KernelEvents::RESPONSE => [
  58.                 ['onKernelResponse', -9999],
  59.             ],
  60.         ];
  61.     }
  63.     /**
  64.      * On kernel response.
  65.      *
  66.      * @param ResponseEvent $event
  67.      *
  68.      * @throws AccessDeniedHttpException
  69.      */
  70.     public function onKernelResponse(ResponseEvent $event)
  71.     {
  72.         if (!$event->isMasterRequest() || !in_array($event->getRequest()->getPathInfo(), $this->encryptedPaths)) {
  73.             return;
  74.         }
  75.         $serial = $event->getResponse()->headers->get('serial');
  77.         if ($serial) {
  78.             $event->getResponse()->headers->remove('serial');
  79.         }
  81.         $encrypted = $this->decoder->encrypt($event->getResponse()->getContent(), $serial);
  82.         $response = $event->getResponse();
  83.         $response->setContent($encrypted);
  85.         $response->headers->remove('Content-Type');
  86.         $response->headers->add(['Content-Type' => 'text/plain']);
  88.         if (strlen($encrypted) > self::MAX_BUFFER_SIZE) {
  89.             $response->setStatusCode(Response::HTTP_REQUEST_ENTITY_TOO_LARGE);
  90.             $contentWhereSizeFailed = json_encode(['cmd' => DeviceCommand::NO_COMMAND]);
  91.             $response->setContent($this->decoder->encrypt($contentWhereSizeFailed, $serial));
  92.         }
  94.         $event->setResponse($response);
  95.     }
  96. }