src/EventSubscriber/SiteSubscriber.php line 55

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\ClientProfile;
  6. use App\Entity\SiteStatus;
  7. use App\Event\SiteCreatedEvent;
  8. use App\Event\TrackerInstalledEvent;
  9. use App\Repository\SiteStatusRepository;
  10. use App\Service\SiteNotificationSender;
  11. use Doctrine\ORM\EntityManagerInterface;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Symfony\Contracts\Translation\TranslatorInterface;
  15. class SiteSubscriber implements EventSubscriberInterface
  16. {
  17.     /**
  18.      * @var SiteStatusRepository
  19.      */
  20.     private $siteStatusRepository;
  21.     /**
  22.      * @var EntityManagerInterface
  23.      */
  24.     private $entityManager;
  25.     /**
  26.      * @var TranslatorInterface
  27.      */
  28.     private $translator;
  29.     /**
  30.      * @var SiteNotificationSender
  31.      */
  32.     private $notificationSender;
  34.     public function __construct(
  35.         SiteStatusRepository $siteStatusRepository,
  36.         EntityManagerInterface $entityManager,
  37.         TranslatorInterface $translator,
  38.         SiteNotificationSender $notificationSender
  39.     )
  40.     {
  41.         $this->siteStatusRepository = $siteStatusRepository;
  42.         $this->entityManager = $entityManager;
  43.         $this->translator = $translator;
  44.         $this->notificationSender = $notificationSender;
  45.     }
  47.     public static function getSubscribedEvents()
  48.     {
  49.         return [
  50.             SiteCreatedEvent::class => 'onSiteCreated',
  51.             TrackerInstalledEvent::class => 'onTrackerInstalled',
  52.         ];
  53.     }
  55.     public function onSiteCreated(SiteCreatedEvent $event)
  56.     {
  57.         $site = $event->getSite();
  59.         $siteStatuses = [];
  60.         foreach (SiteStatus::TYPES as $type) {
  61.             $siteStatus = $this->siteStatusRepository->findByTypeAndSiteId($type, $site->getId());
  63.             if (null === $siteStatus) {
  64.                 $siteStatuses[] = SiteStatus::create(
  65.                     $site,
  66.                     $this->translator->trans('site_status.name.'.$type),
  67.                     $type
  68.                 );
  69.             }
  70.         }
  72.         if (!empty($siteStatuses)) {
  73.             foreach ($siteStatuses as $siteStatus) {
  74.                 $this->entityManager->persist($siteStatus);
  75.             }
  77.             $this->entityManager->flush();
  78.         }
  79.     }
  81.     public function onTrackerInstalled(TrackerInstalledEvent $event)
  82.     {
  83.         $site = $event->getSite();
  85.         $this->notificationSender->sendTrackerInstalledEmail($site);
  87.         $clientProfiles = $this->profileRepository->findAllBySitePermissions($site);
  89.         /** @var ClientProfile $clientProfile */
  90.         foreach ($clientProfiles as $clientProfile) {
  91.             $clientProfile->setOnboard(false);
  92.         }
  94.         $this->entityManager->flush();
  95.     }
  96. }