src/V4/Webhook/EventSubscriber/PostPersistEvent/SendAsyncWebhookHandleMessageEventSubscriber.php line 56

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\V4\Webhook\EventSubscriber\PostPersistEvent;
  7. use App\Model\Product\Product;
  8. use App\Transformer\FQCNToShortNameTransformer;
  9. use App\V4\Event\PostPersistEvent;
  10. use App\V4\Model\Prospect\Prospect;
  11. use App\V4\Model\Quote\Quote;
  12. use App\V4\Model\Task\Task;
  13. use App\V4\Security\AuthenticationManager;
  14. use App\V4\Webhook\Enum\WebhookTriggeredOnEnum;
  15. use App\V4\Webhook\Message\WebhookTriggeredMessage;
  16. use App\V4\Webhook\Repository\WebhookRepository;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Component\Messenger\MessageBusInterface;
  20. class SendAsyncWebhookHandleMessageEventSubscriber implements EventSubscriberInterface
  21. {
  22.     /**
  23.      * @var AuthenticationManager
  24.      */
  25.     private $authenticationManager;
  27.     /**
  28.      * @var MessageBusInterface
  29.      */
  30.     private $messageBus;
  32.     /**
  33.      * @var WebhookRepository
  34.      */
  35.     private $webhookRepository;
  36.     public function __construct(
  37.         AuthenticationManager $authenticationManager,
  38.         MessageBusInterface $messageBus,
  39.         WebhookRepository $webhookRepository
  40.     ) {
  41.         $this->authenticationManager = $authenticationManager;
  42.         $this->messageBus = $messageBus;
  43.         $this->webhookRepository = $webhookRepository;
  44.     }
  46.     public static function getSubscribedEvents(): array
  47.     {
  48.         return [
  49.             PostPersistEvent::NAME => 'onPostPersist',
  50.         ];
  51.     }
  53.     /**
  54.      * @SuppressWarnings(PHPMD.StaticAccess)
  55.      */
  56.     public function onPostPersist(PostPersistEvent $event): void
  57.     {
  58.         $trigger = null === $event->getBefore()
  59.             ? WebhookTriggeredOnEnum::CREATE
  60.             : WebhookTriggeredOnEnum::UPDATE;
  62.         $className = FQCNToShortNameTransformer::transform(get_class($event->getAfter()));
  63.         if (!$className) {
  64.             return;
  65.         }
  67.         $webhooks = $this->webhookRepository->getEnableWebhooksFor($trigger, $className);
  68.         if (0 === count($webhooks)) {
  69.             return;
  70.         }
  72.         //hotfix/2.44.4 : nécessaire pour éviter de sérialiser les fichiers lors du dispatch du message
  73.         $after = $event->getAfter();
  74.         if (in_array(get_class($after), [Prospect::class, Task::class, Quote::class, Product::class], true) && is_array($after->getCustomerFiles())) {
  75.             foreach ($after->getCustomerFiles() as $file) {
  76.                 $file->setCustomerFile(null);
  77.             }
  78.         }
  80.         foreach ($webhooks as $webhook) {
  81.             $message = new WebhookTriggeredMessage(
  82.                 $event,
  83.                 $webhook->getId(),
  84.                 $this->authenticationManager->getLoggedInUser()->getCustomerId()
  85.             );
  87.             $this->messageBus->dispatch($message);
  88.         }
  89.     }
  90. }