src/Listener/AttachmentPostedSubscriber.php line 61

Open in your IDE?
  1. <?php
  3. namespace App\Listener;
  5. use App\Event\NewDocumentEvent;
  6. use App\Manager\NotificationManager;
  7. use App\Manager\UserRightsManagerInterface;
  8. use App\Model\UserRequest\RequestModel;
  9. use Psr\Log\LoggerInterface;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class AttachmentPostedSubscriber implements EventSubscriberInterface
  13. {
  14.     public const ATTACHMENT_POSTED_DONE = 'attachement.posted.done';
  16.     public const STATUS_BLOCKING_NOTIF = [
  17.         RequestModel::STATUS_DRAFT,
  18.         RequestModel::STATUS_TO_QUALIFY,
  19.         RequestModel::STATUS_TO_SPECIFY,
  20.     ];
  22.     /**
  23.      * @var NotificationManager
  24.      */
  25.     protected $notificationManager;
  27.     /**
  28.      * @var LoggerInterface
  29.      */
  30.     protected $logger;
  32.     /**
  33.      * AttachmentPostedSubscriber constructor.
  34.      *
  35.      * @param NotificationManager $notificationManager
  36.      * @param LoggerInterface     $logger
  37.      */
  38.     public function __construct(NotificationManager $notificationManager, LoggerInterface $logger)
  39.     {
  40.         $this->notificationManager = $notificationManager;
  41.         $this->logger              = $logger;
  42.     }
  44.     /**
  45.      * @return array
  46.      */
  47.     public static function getSubscribedEvents(): array
  48.     {
  49.         return [
  50.             static::ATTACHMENT_POSTED_DONE => 'onAttachmentPostedDone',
  51.         ];
  52.     }
  54.     /**
  55.      * Bootstraps status change hooks.
  56.      *
  57.      * @param NewDocumentEvent $event
  58.      *
  59.      * @return void
  60.      */
  61.     public function onAttachmentPostedDone(NewDocumentEvent $event): void
  62.     {
  63.         $request      = $event->getSubject();
  64.         $targetStatus = $event->getArgument('targetStatus');
  66.         if (!in_array($targetStatus, static::STATUS_BLOCKING_NOTIF, true)) {
  67.             $notification = $this->notificationManager->getNewDocumentNotification($request);
  68.             $this->notificationManager->notify($notification);
  70.             // if the user isn't from Suez organisation, a notification should be sent to Suez to let them know the action took place
  71.             $userRoles = $event->getArgument('userRoles');
  73.             if (!in_array(UserRightsManagerInterface::ROLE_SUEZ, $userRoles, true)) {
  74.                 $this->notifySuezNewStatus($event);
  75.             }
  76.         }
  77.     }
  79.     public function notifySuezNewStatus(NewDocumentEvent $event): void
  80.     {
  81.         $request      = $event->getSubject();
  82.         $notification = $this->notificationManager->getNewDocumentNotification($request);
  84.         $this->logger->info('New attachment from client user. Pushing notification to Asteo');
  86.         // Original email will be replaced by the consumer dedicated to pushing notifications to Suez.
  88.         // and we push
  89.         $this->notificationManager->notifyPce($notification);
  90.     }
  91. }