src/EventSubscriber/RequestDecryptingSubscriber.php line 76

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\Helpers\TimezoneHelper;
  10. use Psr\Log\LoggerInterface;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\HttpKernel\Event\RequestEvent;
  13. use Symfony\Component\HttpKernel\Exception\AccessDeniedHttpException;
  14. use Symfony\Component\HttpKernel\KernelEvents;
  16. /**
  17.  * Class RequestDecryptingSubscriber.
  18.  */
  19. class RequestDecryptingSubscriber implements EventSubscriberInterface
  20. {
  21.     const MEASUREMENT_TIME = 'measurement_time';
  22.     const START_TIME = 'start_time';
  23.     const SERIAL_NUMBER = 'serial';
  24.     /**
  25.      * Decoder.
  26.      *
  27.      * @var DecoderInterface
  28.      */
  29.     private $decoder;
  31.     /**
  32.      * Device ping path.
  33.      *
  34.      * @var string[]
  35.      */
  36.     private $encryptedPaths;
  38.     /**
  39.      * @var LoggerInterface
  40.      */
  41.     private $logger;
  43.     /**
  44.      * RequestDecryptingSubscriber constructor.
  45.      *
  46.      * @param DecoderInterface $decoder
  47.      * @param string[]         $encryptedPaths Array of encrypted paths.
  48.      */
  49.     public function __construct(DecoderInterface $decoder, array $encryptedPaths, LoggerInterface $logger)
  50.     {
  51.         $this->decoder = $decoder;
  52.         $this->encryptedPaths = $encryptedPaths;
  53.     }
  55.     /**
  56.      * Get subscribed events.
  57.      *
  58.      * @return array
  59.      */
  60.     public static function getSubscribedEvents(): array
  61.     {
  62.         return [
  63.             KernelEvents::REQUEST => [
  64.                 ['onKernelRequest', 9999],
  65.             ],
  66.         ];
  67.     }
  69.     /**
  70.      * On kernel request.
  71.      *
  72.      * @param RequestEvent $event
  73.      *
  74.      * @throws AccessDeniedHttpException
  75.      */
  76.     public function onKernelRequest(RequestEvent $event)
  77.     {
  78.         $request = $event->getRequest();
  79.         if (!$event->isMasterRequest() || !in_array($event->getRequest()->getPathInfo(), $this->encryptedPaths)) {
  80.             return;
  81.         }
  83.         $request->headers->set('accept', 'application/ld+json');
  84.         $request->headers->set('content-type', 'application/ld+json');
  86.         $decrypted = $this->decoder->decrypt($request->getContent())
  87.             ?? $this->decoder->decrypt($request->getContent(), ['non-json' => true]);
  89.         if (null === $decrypted) {
  90.             throw new AccessDeniedHttpException();
  91.         }
  92.         foreach ($decrypted as $key => $value) {
  93.             $request->request->set($key, $value);
  94.         }
  96.         $timezoneHelper = new TimezoneHelper();
  98.         if (!isset($decrypted[self::SERIAL_NUMBER])) {
  99.             $request->request->set(
  100.                 self::SERIAL_NUMBER,
  101.                 $this->decoder->getLastCorrectPassword()
  102.             );
  103.         }
  105.         if (!empty($decrypted[self::MEASUREMENT_TIME])) {
  106.             $request->request->set(
  107.                 self::MEASUREMENT_TIME,
  108.                 $timezoneHelper->getCorrectedTime($decrypted[self::MEASUREMENT_TIME], $decrypted[self::START_TIME])
  109.             );
  110.         }
  112.         if (!empty($decrypted[self::START_TIME])) {
  113.             $request->request->set(
  114.                 self::START_TIME,
  115.                 $timezoneHelper->getCorrectedTime($decrypted[self::START_TIME], $decrypted[self::START_TIME])
  116.             );
  117.         }
  118.     }
  119. }