src/EventSubscriber/ActionSubscriber.php line 63

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Event\ActionErrorEvent;
  6. use App\Event\ActionFormEvent;
  7. use App\Message\ProcessFormActionsMessage;
  8. use App\Service\FormActionSetManager;
  9. use Exception;
  10. use Psr\Log\LoggerInterface;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\Messenger\MessageBusInterface;
  14. class ActionSubscriber implements EventSubscriberInterface
  15. {
  16.     /** @var FormActionSetManager $formActionSetManager */
  17.     private $formActionSetManager;
  18.     /** @var MessageBusInterface $messageBus */
  19.     private $messageBus;
  20.     /** @var LoggerInterface $logger */
  21.     private $logger;
  22.     /** @var bool $asyncFormActions */
  23.     private $asyncFormActions;
  25.     /**
  26.      * @param FormActionSetManager $formActionSetManager
  27.      * @param MessageBusInterface $messageBus
  28.      * @param LoggerInterface $logger
  29.      * @param bool $asyncFormActions
  30.      */
  31.     public function __construct(
  32.         FormActionSetManager $formActionSetManager,
  33.         MessageBusInterface $messageBus,
  34.         LoggerInterface $logger,
  35.         bool $asyncFormActions
  36.     ) {
  37.         $this->formActionSetManager = $formActionSetManager;
  38.         $this->messageBus = $messageBus;
  39.         $this->logger = $logger;
  40.         $this->asyncFormActions = $asyncFormActions;
  41.     }
  43.     /**
  44.      * @return string[]
  45.      */
  46.     public static function getSubscribedEvents(): array
  47.     {
  48.         return [
  49.             ActionErrorEvent::KEY => 'onActionError',
  50.             ActionFormEvent::KEY => 'onAppEventsForm'
  51.         ];
  52.     }
  54.     /**
  55.      * Una acción que no ha podido completarse (hoy: un email sin destinatarios resolubles).
  56.      *
  57.      * Se registra con nivel error para que llegue a Sentry. Sin esto, un formulario cuyo
  58.      * email de confirmación no encuentra destinatario falla de forma completamente silenciosa.
  59.      *
  60.      * @param ActionErrorEvent $event
  61.      * @return void
  62.      */
  63.     public function onActionError(ActionErrorEvent $event)
  64.     {
  65.         $action = $event->getAction();
  67.         $this->logger->error('La acción del formulario no ha podido completarse', [
  68.             'action' => $action->getId(),
  69.             'action_name' => $action->getName(),
  70.             'command' => $action->getCommand(),
  71.             'form' => $event->getForm()->getId(),
  72.             'form_lead' => $event->getFormLead()->getId(),
  73.         ]);
  74.     }
  76.     /**
  77.      * Las acciones post-envío generan PDFs con Dompdf, calculan los promedios del anexo de
  78.      * indicadores sobre toda la campaña y envían por SMTP. Con ASYNC_FORM_ACTIONS=1 todo eso
  79.      * sale del request y lo procesa un worker de Messenger.
  80.      *
  81.      * El interruptor viene por variable de entorno y por defecto está apagado: así el código
  82.      * se puede desplegar sin activar el asíncrono, validar el worker en un entorno y activarlo
  83.      * después sin necesidad de otra release. Si no hay worker consumiendo la cola, los emails
  84.      * no llegan a salir, y eso tiene que ser una decisión explícita.
  85.      *
  86.      * @param ActionFormEvent $event
  87.      * @return void
  88.      * @throws Exception
  89.      */
  90.     public function onAppEventsForm(ActionFormEvent $event)
  91.     {
  92.         if ($this->asyncFormActions) {
  93.             $this->messageBus->dispatch(new ProcessFormActionsMessage(
  94.                 $event->getForm()->getId(),
  95.                 $event->getFormLead()->getId(),
  96.                 $event->getName()
  97.             ));
  99.             return;
  100.         }
  102.         $this->formActionSetManager
  103.             ->setForm($event->getForm())
  104.             ->setLead($event->getFormLead())
  105.             ->executeActionSets($event->getName())
  106.         ;
  107.     }
  108. }