vendor/ezsystems/ezpublish-kernel/eZ/Bundle/EzPublishIOBundle/EventListener/StreamFileListener.php line 46

Open in your IDE?
  1. <?php
  3. /**
  4.  * @copyright Copyright (C) eZ Systems AS. All rights reserved.
  5.  * @license For full copyright and license information view LICENSE file distributed with this source code.
  6.  */
  7. namespace eZ\Bundle\EzPublishIOBundle\EventListener;
  9. use eZ\Bundle\EzPublishIOBundle\BinaryStreamResponse;
  10. use eZ\Publish\Core\IO\IOServiceInterface;
  11. use eZ\Publish\Core\IO\Values\MissingBinaryFile;
  12. use eZ\Publish\Core\MVC\ConfigResolverInterface;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\HttpKernel\Event\GetResponseEvent;
  15. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
  16. use Symfony\Component\HttpKernel\HttpKernelInterface;
  17. use Symfony\Component\HttpKernel\KernelEvents;
  19. /**
  20.  * Listens for IO files requests, and streams them.
  21.  */
  22. class StreamFileListener implements EventSubscriberInterface
  23. {
  24.     /** @var IOServiceInterface */
  25.     private $ioService;
  27.     /** @var ConfigResolverInterface */
  28.     private $configResolver;
  30.     public function __construct(IOServiceInterface $ioService, ConfigResolverInterface $configResolver)
  31.     {
  32.         $this->ioService = $ioService;
  33.         $this->configResolver = $configResolver;
  34.     }
  36.     public static function getSubscribedEvents()
  37.     {
  38.         return [
  39.             KernelEvents::REQUEST => ['onKernelRequest', 42],
  40.         ];
  41.     }
  43.     /**
  44.      * @param \Symfony\Component\HttpKernel\Event\GetResponseEvent $event
  45.      */
  46.     public function onKernelRequest(GetResponseEvent $event)
  47.     {
  48.         if ($event->getRequestType() !== HttpKernelInterface::MASTER_REQUEST) {
  49.             return;
  50.         }
  52.         $request = $event->getRequest();
  53.         $urlPrefix = $this->configResolver->getParameter('io.url_prefix');
  54.         if (strpos($urlPrefix, '://') !== false) {
  55.             $uri = $request->getSchemeAndHttpHost() . $request->getPathInfo();
  56.         } else {
  57.             $uri = $request->attributes->get('semanticPathinfo');
  58.         }
  60.         if (!$this->isIoUri($uri, $urlPrefix)) {
  61.             return;
  62.         }
  64.         $binaryFile = $this->ioService->loadBinaryFileByUri($uri);
  65.         if ($binaryFile instanceof MissingBinaryFile) {
  66.             throw new NotFoundHttpException("Could not find 'BinaryFile' with identifier '$uri'");
  67.         }
  69.         $event->setResponse(
  70.             new BinaryStreamResponse(
  71.                 $binaryFile,
  72.                 $this->ioService
  73.             )
  74.         );
  75.     }
  77.     /**
  78.      * Tests if $uri is an IO file uri root.
  79.      *
  80.      * @param string $uri
  81.      *
  82.      * @return bool
  83.      */
  84.     private function isIoUri($uri, $urlPrefix)
  85.     {
  86.         return strpos(ltrim($uri, '/'), $this->configResolver->getParameter('io.url_prefix')) === 0;
  87.     }
  88. }