vendor/pimcore/portal-engine/src/EventSubscriber/SaveUserSubscriber.php line 71

Open in your IDE?
  1. <?php
  3. /**
  4.  * Pimcore
  5.  *
  6.  * This source file is available under following license:
  7.  * - Pimcore Commercial License (PCL)
  8.  *
  9.  *  @copyright  Copyright (c) Pimcore GmbH (http://www.pimcore.org)
  10.  *  @license    http://www.pimcore.org/license     PCL
  11.  */
  13. namespace Pimcore\Bundle\PortalEngineBundle\EventSubscriber;
  15. use Pimcore\Bundle\PortalEngineBundle\Model\DataObject\PortalUserInterface;
  16. use Pimcore\Bundle\PortalEngineBundle\Service\Collection\CollectionService;
  17. use Pimcore\Bundle\PortalEngineBundle\Service\PublicShare\PublicShareService;
  18. use Pimcore\Event\DataObjectEvents;
  19. use Pimcore\Event\Model\DataObjectEvent;
  20. use Pimcore\Model\DataObject\PortalUser;
  21. use Pimcore\Model\Element\ValidationException;
  22. use Pimcore\Model\User;
  23. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  25. /**
  26.  * Class IndexUpdateListener
  27.  *
  28.  * @package Pimcore\Bundle\PortalEngineBundle\EventListener
  29.  */
  30. class SaveUserSubscriber implements EventSubscriberInterface
  31. {
  32.     const FALLBACK_USER_NAME = 'portal-engine-default-user';
  34.     /**
  35.      * @var CollectionService
  36.      */
  37.     protected $collectionService;
  38.     /**
  39.      * @var PublicShareService
  40.      */
  41.     protected $publicShareService;
  43.     /**
  44.      * SaveUserSubscriber constructor.
  45.      *
  46.      * @param CollectionService $collectionService
  47.      * @param PublicShareService $publicShareService
  48.      */
  49.     public function __construct(CollectionService $collectionService, PublicShareService $publicShareService)
  50.     {
  51.         $this->collectionService = $collectionService;
  52.         $this->publicShareService = $publicShareService;
  53.     }
  55.     /**
  56.      * @return array
  57.      */
  58.     public static function getSubscribedEvents()
  59.     {
  60.         return [
  61.             DataObjectEvents::PRE_UPDATE => 'onPreUpdate',
  62.             DataObjectEvents::POST_DELETE => 'onPostDelete',
  63.         ];
  64.     }
  66.     /**
  67.      * @param DataObjectEvent $dataObjectEvent
  68.      *
  69.      * @throws \Exception
  70.      */
  71.     public function onPreUpdate(DataObjectEvent $dataObjectEvent)
  72.     {
  73.         $user = $dataObjectEvent->getObject();
  74.         if ($user instanceof PortalUserInterface) {
  76.             /** @var bool $existingPortalUser */
  77.             $existingPortalUser = PortalUser::getByEmail($user->getEmail())
  78.                     ->addConditionParam('o_id != ? and externalUserId is null', $user->getId())
  79.                     ->count() > 0;
  81.             if ($existingPortalUser) {
  82.                 throw new ValidationException(sprintf('PortalUser with email %s already exists', $user->getEmail()));
  83.             }
  85.             if (empty($user->getPimcoreUser())) {
  86.                 $user->setPimcoreUser($this->getFallbackPimcoreUser()->getId());
  87.             }
  88.         }
  89.     }
  91.     /**
  92.      * @param DataObjectEvent $dataObjectEvent
  93.      *
  94.      * @throws \Exception
  95.      */
  96.     public function onPostDelete(DataObjectEvent $dataObjectEvent)
  97.     {
  98.         $user = $dataObjectEvent->getElement();
  99.         if ($user instanceof PortalUserInterface) {
  100.             $this->collectionService->cleanupDeletedUser($user);
  101.             $this->publicShareService->cleanupDeletedUser($user);
  102.         }
  103.     }
  105.     /**
  106.      * @return User
  107.      *
  108.      * @throws \Exception
  109.      */
  110.     protected function getFallbackPimcoreUser(): User
  111.     {
  112.         $user = User::getByName(self::FALLBACK_USER_NAME);
  114.         if (empty($user)) {
  115.             $user = new User();
  116.             $user->setName(self::FALLBACK_USER_NAME);
  117.             $user->setActive(true);
  118.             $user->setParentId(0);
  119.             $user->save();
  120.         }
  122.         return $user;
  123.     }
  124. }