vendor/sulu/automation-bundle/EventSubscriber/PHPTaskEventSubscriber.php line 53

  1. <?php
  3. /*
  4.  * This file is part of Sulu.
  5.  *
  6.  * (c) Sulu GmbH
  7.  *
  8.  * This source file is subject to the MIT license that is bundled
  9.  * with this source code in the file LICENSE.
  10.  */
  12. namespace Sulu\Bundle\AutomationBundle\EventSubscriber;
  14. use Sulu\Bundle\AutomationBundle\Tasks\Model\TaskRepositoryInterface;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Symfony\Component\HttpFoundation\Request;
  17. use Symfony\Component\HttpFoundation\RequestStack;
  18. use Task\Event\Events;
  19. use Task\Event\TaskEvent;
  21. /**
  22.  * Fake-Request handling for tasks.
  23.  */
  24. class PHPTaskEventSubscriber implements EventSubscriberInterface
  25. {
  26.     /**
  27.      * @var RequestStack
  28.      */
  29.     private $requestStack;
  31.     /**
  32.      * @var TaskRepositoryInterface
  33.      */
  34.     private $taskRepository;
  36.     public function __construct(RequestStack $requestStack, TaskRepositoryInterface $taskRepository)
  37.     {
  38.         $this->requestStack = $requestStack;
  39.         $this->taskRepository = $taskRepository;
  40.     }
  42.     public static function getSubscribedEvents(): array
  43.     {
  44.         return [
  45.             Events::TASK_BEFORE => ['pushRequest'],
  46.             Events::TASK_AFTER => ['popRequest'],
  47.         ];
  48.     }
  50.     /**
  51.      * Create and push new request to requests-stack.
  52.      */
  53.     public function pushRequest(TaskEvent $event): void
  54.     {
  55.         $task = $this->taskRepository->findByTaskId($event->getTask()->getUuid());
  56.         if (!$task) {
  57.             // current task is not managed by this bundle
  59.             return;
  60.         }
  62.         $request = new Request(
  63.             [],
  64.             [],
  65.             ['_task_id' => $event->getTask()->getUuid()],
  66.             [],
  67.             [],
  68.             ['SERVER_NAME' => $task->getHost(), 'HTTPS' => 'http' === $task->getScheme() ? 'off' : 'on']
  69.         );
  71.         $this->requestStack->push($request);
  72.     }
  74.     /**
  75.      * Pop request from request stack.
  76.      */
  77.     public function popRequest(TaskEvent $event): void
  78.     {
  79.         $request = $this->requestStack->getCurrentRequest();
  80.         if (!$request || $request->attributes->get('_task_id') !== $event->getTask()->getUuid()) {
  81.             // current request was not created for current task
  83.             return;
  84.         }
  86.         $this->requestStack->pop();
  87.     }
  88. }