vendor/shopware/core/Content/Flow/Dispatching/FlowExecutor.php line 40

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Flow\Dispatching;
  5. use Shopware\Core\Content\Flow\Dispatching\Struct\ActionSequence;
  6. use Shopware\Core\Content\Flow\Dispatching\Struct\Flow;
  7. use Shopware\Core\Content\Flow\Dispatching\Struct\IfSequence;
  8. use Shopware\Core\Content\Flow\Dispatching\Struct\Sequence;
  9. use Shopware\Core\Content\Flow\Exception\ExecuteSequenceException;
  10. use Shopware\Core\Framework\App\Event\AppFlowActionEvent;
  11. use Shopware\Core\Framework\App\FlowAction\AppFlowActionProvider;
  12. use Shopware\Core\Framework\Event\FlowEvent;
  13. use Shopware\Core\Framework\Event\FlowEventAware;
  14. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  16. /**
  17.  * @internal not intended for decoration or replacement
  18.  */
  19. class FlowExecutor
  20. {
  21.     private EventDispatcherInterface $dispatcher;
  23.     private AppFlowActionProvider $appFlowActionProvider;
  25.     public function __construct(EventDispatcherInterface $dispatcher, AppFlowActionProvider $appFlowActionProvider)
  26.     {
  27.         $this->dispatcher = $dispatcher;
  28.         $this->appFlowActionProvider = $appFlowActionProvider;
  29.     }
  31.     public function execute(Flow $flow, FlowEventAware $event): void
  32.     {
  33.         $state = new FlowState($event);
  34.         $state->flowId = $flow->getId();
  35.         foreach ($flow->getSequences() as $sequence) {
  36.             $state->sequenceId = $sequence->sequenceId;
  37.             $state->delayed = false;
  39.             try {
  40.                 $this->executeSequence($sequence, $state);
  41.             } catch (\Exception $e) {
  42.                 throw new ExecuteSequenceException($sequence->flowId, $sequence->sequenceId, $e->getMessage(), $e->getCode(), $e);
  43.             }
  45.             if ($state->stop) {
  46.                 return;
  47.             }
  48.         }
  49.     }
  51.     public function executeSequence(?Sequence $sequence, FlowState $state): void
  52.     {
  53.         if ($sequence === null) {
  54.             return;
  55.         }
  57.         $state->currentSequence = $sequence;
  59.         if ($sequence instanceof IfSequence) {
  60.             $this->executeIf($sequence, $state);
  62.             return;
  63.         }
  65.         if ($sequence instanceof ActionSequence) {
  66.             $this->executeAction($sequence, $state);
  67.         }
  68.     }
  70.     public function executeAction(ActionSequence $sequence, FlowState $state): void
  71.     {
  72.         $actionName = $sequence->action;
  73.         if (!$actionName) {
  74.             return;
  75.         }
  77.         if ($state->stop) {
  78.             return;
  79.         }
  81.         $globalEvent = new FlowEvent($actionName, $state, $sequence->config);
  83.         if ($sequence->appFlowActionId) {
  84.             $eventData = $this->appFlowActionProvider->getWebhookData($globalEvent, $sequence->appFlowActionId);
  86.             $globalEvent = new AppFlowActionEvent(
  87.                 $actionName,
  88.                 $eventData['headers'],
  89.                 $eventData['payload']
  90.             );
  91.         }
  93.         $this->dispatcher->dispatch($globalEvent, $actionName);
  95.         if ($state->delayed) {
  96.             return;
  97.         }
  99.         $state->currentSequence = $sequence;
  101.         /** @var ActionSequence $nextAction */
  102.         $nextAction = $sequence->nextAction;
  103.         if ($nextAction !== null) {
  104.             $this->executeAction($nextAction, $state);
  105.         }
  106.     }
  108.     public function executeIf(IfSequence $sequence, FlowState $state): void
  109.     {
  110.         if (\in_array($sequence->ruleId, $state->event->getContext()->getRuleIds(), true)) {
  111.             $this->executeSequence($sequence->trueCase, $state);
  113.             return;
  114.         }
  116.         $this->executeSequence($sequence->falseCase, $state);
  117.     }
  118. }