src/App/EventSubscriber/PartialUploadSubscriber.php line 31

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Annotation\PartialUpload;
  6. use App\Model\Upload;
  7. use App\Traits\Autowired\Manager\UploadManagerTrait;
  8. use App\Traits\Autowired\Vendor\RequestStackTrait;
  9. use App\Traits\Autowired\Vendor\SerializerSubscriberTrait;
  10. use GollumSF\RestBundle\Annotation\Serialize;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\HttpFoundation\Response;
  13. use Symfony\Component\HttpKernel\Event\ControllerArgumentsEvent;
  14. use Symfony\Component\HttpKernel\Exception\BadRequestHttpException;
  15. use Symfony\Component\HttpKernel\KernelEvents;
  17. class PartialUploadSubscriber implements EventSubscriberInterface
  18. {
  19.     use UploadManagerTrait;
  20.     use SerializerSubscriberTrait;
  21.     use RequestStackTrait;
  22.     
  23.     public static function getSubscribedEvents() {
  24.         return [
  25.             KernelEvents::CONTROLLER_ARGUMENTS => [
  26.                 ['onKernelControllerArguments', -20],
  27.             ]
  28.         ];
  29.     }
  30.     
  31.     public function onKernelControllerArguments(ControllerArgumentsEvent $event)
  32.     {
  33.         $request = $event->getRequest();
  34.         /** @var PartialUpload $annotation */
  35.         $annotation = $request->attributes->get('_' . PartialUpload::ALIAS_NAME);
  36.         if ($annotation) {
  37.             
  38.             /** @var Upload $upload */
  39.             $upload = $request->attributes->get($annotation->getName());
  40.             if (!$upload) {
  41.                 throw new BadRequestHttpException(sprintf('%s parameter not found', $annotation->getName()));
  42.             }
  43.             $maxSize = null;
  44.             if ($annotation->getMaxSize()) {
  45.                 $maxSize = is_string($annotation->getMaxSize()) ? $this->human2byte($annotation->getMaxSize()) : $annotation->getMaxSize();
  46.             }
  47.             
  48.             if (!$upload->isEndOfFile()) {
  49.                 $upload = $this->uploadManager->partialUpload($upload, $maxSize);
  50.                 $request->attributes->set($annotation->getName(), $upload);
  51.                 $event->setController([ $this, 'partialControllerAction' ]);
  52.             } else {
  53.                 $upload = $this->uploadManager->finalUpload($upload, $maxSize, $annotation->getMimeTypes());
  54.                 $request->attributes->set($annotation->getName(), $upload);
  55.             }
  56.         }
  57.     }
  58.     
  59.     public function partialControllerAction(): Upload {
  60.         $request = $this->requestStack->getCurrentRequest();
  61.         /** @var PartialUpload $annotation */
  62.         /** @var Serialize $serialize */
  63.         $annotation = $request->attributes->get('_' . PartialUpload::ALIAS_NAME);
  64.         $serialize = $request->attributes->get('_' . Serialize::ALIAS_NAME);
  65.         $serialize->setCode(Response::HTTP_OK);
  66.         return $request->attributes->get($annotation->getName());
  67.     }
  69.     protected function human2byte($value) {
  70.         return preg_replace_callback('/^\s*(\d+)\s*(?:([kmgt]?)b?)?\s*$/i', function ($m) {
  71.             switch (strtolower($m[2])) {
  72.                 case 't': $m[1] *= 1024;
  73.                 case 'g': $m[1] *= 1024;
  74.                 case 'm': $m[1] *= 1024;
  75.                 case 'k': $m[1] *= 1024;
  76.             }
  77.             return $m[1];
  78.         }, $value);
  79.     }
  81. }