vendor/dachcom-digital/formbuilder/src/FormBuilderBundle/EventSubscriber/SignalSubscribeHandler.php line 46

Open in your IDE?
  1. <?php
  3. namespace FormBuilderBundle\EventSubscriber;
  5. use FormBuilderBundle\Configuration\Configuration;
  6. use FormBuilderBundle\Event\OutputWorkflow\OutputWorkflowSignalEvent;
  7. use FormBuilderBundle\Event\OutputWorkflow\OutputWorkflowSignalsEvent;
  8. use FormBuilderBundle\EventSubscriber\SignalStorage\ArraySignalStorage;
  9. use FormBuilderBundle\EventSubscriber\SignalStorage\ProviderAwareStorageInterface;
  10. use FormBuilderBundle\EventSubscriber\SignalStorage\SignalStorageInterface;
  11. use FormBuilderBundle\FormBuilderEvents;
  12. use FormBuilderBundle\Registry\StorageProviderRegistry;
  13. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class SignalSubscribeHandler implements EventSubscriberInterface
  17. {
  18.     public const CHANNEL_FUNNEL_INITIATE = 'funnel.initiate';
  19.     public const CHANNEL_FUNNEL_PROCESS = 'funnel.process';
  20.     public const CHANNEL_OUTPUT_WORKFLOW = 'output_workflow';
  22.     protected Configuration $configuration;
  23.     protected StorageProviderRegistry $storageProviderRegistry;
  24.     protected EventDispatcherInterface $eventDispatcher;
  25.     protected SignalStorageInterface $signalStorage;
  27.     protected ?string $channel = null;
  29.     public function __construct(
  30.         Configuration $configuration,
  31.         StorageProviderRegistry $storageProviderRegistry,
  32.         EventDispatcherInterface $eventDispatcher
  33.     ) {
  34.         $this->configuration = $configuration;
  35.         $this->storageProviderRegistry = $storageProviderRegistry;
  36.         $this->eventDispatcher = $eventDispatcher;
  37.     }
  39.     public static function getSubscribedEvents(): array
  40.     {
  41.         return [
  42.             OutputWorkflowSignalEvent::NAME => 'addSignal',
  43.         ];
  44.     }
  46.     public function addSignal(OutputWorkflowSignalEvent $signalEvent): void
  47.     {
  48.         if ($this->channel === null) {
  49.             throw new \Exception('Cannot add signal, no channel has been defined.');
  50.         }
  52.         $this->signalStorage->storeSignal($signalEvent);
  53.     }
  55.     public function listen(string $channel, array $context = []): void
  56.     {
  57.         if ($this->channel !== null) {
  58.             return;
  59.         }
  61.         $this->channel = $channel;
  62.         $this->signalStorage = $this->buildSignalStorage($channel, $context);
  63.         $this->eventDispatcher->addSubscriber($this);
  64.     }
  66.     public function broadcast(array $context = []): void
  67.     {
  68.         $channelName = $this->channel;
  70.         if ($channelName === null) {
  71.             return;
  72.         }
  74.         $this->channel = null;
  75.         $this->eventDispatcher->removeSubscriber($this);
  77.         $this->eventDispatcher->dispatch(
  78.             new OutputWorkflowSignalsEvent(
  79.                 $channelName,
  80.                 $this->signalStorage->getSignals(),
  81.                 $context
  82.             ),
  83.             FormBuilderEvents::OUTPUT_WORKFLOW_SIGNALS
  84.         );
  85.     }
  87.     private function buildSignalStorage(string $channel, array $context): SignalStorageInterface
  88.     {
  89.         if ($channel === self::CHANNEL_OUTPUT_WORKFLOW) {
  90.             return new ArraySignalStorage();
  91.         }
  93.         if ($channel === self::CHANNEL_FUNNEL_INITIATE) {
  94.             return new ArraySignalStorage();
  95.         }
  97.         if ($channel === self::CHANNEL_FUNNEL_PROCESS) {
  99.             $funnelConfiguration = $this->configuration->getConfig('funnel');
  101.             $signalStorageClass = $funnelConfiguration['signal_storage_class'];
  102.             $signalStorageProvider = $funnelConfiguration['storage_provider'];
  104.             /** @var SignalStorageInterface $signalStorageClass */
  105.             $signalStorage = new $signalStorageClass($context);
  107.             if ($signalStorage instanceof ProviderAwareStorageInterface) {
  108.                 $signalStorage->setStorageProvider($this->storageProviderRegistry->get($signalStorageProvider));
  109.             }
  111.             return $signalStorage;
  112.         }
  114.         throw new \Exception(sprintf('Cannot determinate signal storage for channel "%s"', $channel));
  115.     }
  116. }