src/PortoContainers/Zapier/EventSubscriber/OrderSubscriber.php line 49

  1. <?php
  3. namespace App\PortoContainers\Zapier\EventSubscriber;
  5. use App\Event\OrderCreatedEvent;
  6. use App\Event\OrderRemovedEvent;
  7. use App\Event\OrderStatusChangedEvent;
  8. use App\PortoContainers\Global\DTO\OrderData;
  9. use App\PortoContainers\Zapier\Actions\RemoveOrderFromTriggersAction;
  10. use App\PortoContainers\Zapier\DTO\RemoveOrderFromTriggersData;
  11. use App\PortoContainers\Zapier\DTO\ZapierTriggerData;
  12. use App\PortoContainers\Zapier\Entities\ZapierTrigger;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use App\PortoContainers\Zapier\Actions\AddTriggerAction;
  15. use App\PortoContainers\Zapier\Actions\IsOrderAcceptableForZapierAction;
  17. class OrderSubscriber implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @param AddTriggerAction $addTriggerAction
  21.      * @param IsOrderAcceptableForZapierAction $isOrderAcceptableForZapierAction
  22.      * @param RemoveOrderFromTriggersAction $removeOrderFromTriggersAction
  23.      */
  24.     public function __construct(
  25.         private readonly AddTriggerAction                 $addTriggerAction,
  26.         private readonly IsOrderAcceptableForZapierAction $isOrderAcceptableForZapierAction,
  27.         private readonly RemoveOrderFromTriggersAction    $removeOrderFromTriggersAction
  28.     )
  29.     {
  30.     }
  32.     /**
  33.      * @return array
  34.      */
  35.     public static function getSubscribedEvents(): array
  36.     {
  37.         return [
  38.             OrderCreatedEvent::class => ['orderCreatedAction', -100],
  39.             OrderStatusChangedEvent::class => ['orderStatusChangedAction', -100],
  40.             OrderRemovedEvent::class => ['orderRemovedAction', -100]
  41.         ];
  42.     }
  44.     /**
  45.      * @param OrderCreatedEvent $event
  46.      * @return void
  47.      * @throws \Exception
  48.      */
  49.     public function orderCreatedAction(OrderCreatedEvent $event): void
  50.     {
  51.         $this->addTriggerAction->run(
  52.             new ZapierTriggerData(
  53.                 ZapierTrigger::TRIGGER_ORDER_CREATED,
  54.                 $event->getOrder()->getId()
  55.             )
  56.         );
  57.     }
  59.     /**
  60.      * @param OrderStatusChangedEvent $event
  61.      * @return void
  62.      * @throws \Exception
  63.      */
  64.     public function orderStatusChangedAction(OrderStatusChangedEvent $event): void
  65.     {
  66.         if ($this->isOrderAcceptableForZapierAction->run(
  67.             new OrderData($event->getOrder())
  68.         )) {
  69.             $this->addTriggerAction->run(
  70.                 new ZapierTriggerData(
  71.                     ZapierTrigger::TRIGGER_ORDER_STATUS_UPDATED,
  72.                     $event->getOrder()->getId()
  73.                 )
  74.             );
  75.         }
  76.     }
  78.     /**
  79.      * @param OrderRemovedEvent $event
  80.      * @return void
  81.      * @throws \Exception
  82.      */
  83.     public function orderRemovedAction(OrderRemovedEvent $event): void
  84.     {
  85.         $this->removeOrderFromTriggersAction->run(
  86.             new RemoveOrderFromTriggersData($event->getOrder())
  87.         );
  88.     }
  89. }