src/EventSubscriber/ResponseEncryptingSubscriber.php line 91

Open in your IDE?
  1. <?php
  2. /**
  3.  * @license Silk Software House Sp. Z O. O.
  4.  */
  6. declare(strict_types=1);
  8. namespace App\EventSubscriber;
  10. use App\Decoder\Interfaces\DecoderInterface;
  11. use App\Entity\DeviceCommand;
  12. use App\Repository\RecipeToSyncRepository;
  13. use Psr\Log\LoggerInterface;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use Symfony\Component\HttpFoundation\Response;
  16. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  17. use Symfony\Component\HttpKernel\Exception\AccessDeniedHttpException;
  18. use Symfony\Component\HttpKernel\KernelEvents;
  20. /**
  21.  * Class ResponseEncryptingSubscriber.
  22.  */
  23. class ResponseEncryptingSubscriber implements EventSubscriberInterface
  24. {
  25.     const MAX_BUFFER_SIZE = 400;
  27.     /**
  28.      * Decoder.
  29.      *
  30.      * @var DecoderInterface
  31.      */
  32.     private $decoder;
  34.     /**
  35.      * Device ping path.
  36.      *
  37.      * @var string[]
  38.      */
  39.     private $encryptedPaths;
  41.     /**
  42.      * @var RecipeToSyncRepository
  43.      */
  44.     private $recipeToSyncRepository;
  46.     /**
  47.      * @var LoggerInterface
  48.      */
  49.     private $logger;
  51.     /**
  52.      * ResponseEncryptingSubscriber constructor.
  53.      *
  54.      * @param DecoderInterface $decoder
  55.      * @param string[]         $encryptedPaths Array of encrypted paths.
  56.      */
  57.     public function __construct(
  58.         DecoderInterface $decoder,
  59.         array $encryptedPaths,
  60.         RecipeToSyncRepository $recipeToSyncRepository,
  61.         LoggerInterface $logger
  62.     )
  63.     {
  64.         $this->decoder = $decoder;
  65.         $this->encryptedPaths = $encryptedPaths;
  66.         $this->recipeToSyncRepository = $recipeToSyncRepository;
  67.         $this->logger = $logger;
  68.     }
  70.     /**
  71.      * Get subscribed events.
  72.      *
  73.      * @return array
  74.      */
  75.     public static function getSubscribedEvents(): array
  76.     {
  77.         return [
  78.             KernelEvents::RESPONSE => [
  79.                 ['onKernelResponse', -9999],
  80.             ],
  81.         ];
  82.     }
  84.     /**
  85.      * On kernel response.
  86.      *
  87.      * @param ResponseEvent $event
  88.      *
  89.      * @throws AccessDeniedHttpException
  90.      */
  91.     public function onKernelResponse(ResponseEvent $event)
  92.     {
  93.         if (!$event->isMasterRequest() || !in_array($event->getRequest()->getPathInfo(), $this->encryptedPaths)) {
  94.             return;
  95.         }
  96.         $serial = $event->getResponse()->headers->get('serial');
  97.         $payload = json_decode($event->getResponse()->getContent(), true) ?? [];
  98.         $command = $payload[DeviceCommand::COMMAND_KEY] ?? DeviceCommand::NO_COMMAND;
  99.         $plainContent = $event->getResponse()->getContent();
  101.         if ($serial) {
  102.             $event->getResponse()->headers->remove('serial');
  103.         }
  105.         $encrypted = $this->decoder->encrypt($plainContent, $serial);
  106.         $response = $event->getResponse();
  107.         $response->setContent($encrypted);
  109.         $response->headers->remove('Content-Type');
  110.         $response->headers->add(['Content-Type' => 'text/plain']);
  112.         if (strlen($encrypted) > self::MAX_BUFFER_SIZE) {
  113.             $this->logger->warning('Encrypted device response exceeds modem buffer.', [
  114.                 'path' => $event->getRequest()->getPathInfo(),
  115.                 'serial' => $serial,
  116.                 'command' => $command,
  117.                 'plain_length' => strlen($plainContent),
  118.                 'encrypted_length' => strlen($encrypted),
  119.                 'status' => $response->getStatusCode(),
  120.                 'payload' => $payload,
  121.             ]);
  122.             $response->setStatusCode(Response::HTTP_REQUEST_ENTITY_TOO_LARGE);
  123.             $contentWhereSizeFailed = json_encode(['cmd' => DeviceCommand::NO_COMMAND]);
  124.             $response->setContent($this->decoder->encrypt($contentWhereSizeFailed, $serial));
  125.         } elseif (
  126.             $response->getStatusCode() >= Response::HTTP_OK
  127.             && $response->getStatusCode() < Response::HTTP_MULTIPLE_CHOICES
  128.             && $command === DeviceCommand::SET_RECIPE
  129.             && !empty($serial)
  130.         ) {
  131.             $this->recipeToSyncRepository->findFirstBySerialNumberAndRemove($serial);
  132.         }
  134.         $event->setResponse($response);
  135.     }
  136. }