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) {
  75.             $existingPortalUser = PortalUser::getByEmail($user->getEmail())
  76.                     ->addConditionParam('o_id != ? and externalUserId is null', $user->getId())
  77.                     ->count() > 0;
  79.             if ($existingPortalUser) {
  80.                 throw new ValidationException(sprintf('PortalUser with email %s already exists', $user->getEmail()));
  81.             }
  83.             if (empty($user->getPimcoreUser()) && method_exists($user, 'setPimcoreUser')) {
  84.                 $user->setPimcoreUser($this->getFallbackPimcoreUser()->getId());
  85.             }
  86.         }
  87.     }
  89.     /**
  90.      * @param DataObjectEvent $dataObjectEvent
  91.      *
  92.      * @throws \Exception
  93.      */
  94.     public function onPostDelete(DataObjectEvent $dataObjectEvent)
  95.     {
  96.         $user = $dataObjectEvent->getElement();
  97.         if ($user instanceof PortalUserInterface) {
  98.             $this->collectionService->cleanupDeletedUser($user);
  99.             $this->publicShareService->cleanupDeletedUser($user);
  100.         }
  101.     }
  103.     /**
  104.      * @return User
  105.      *
  106.      * @throws \Exception
  107.      */
  108.     protected function getFallbackPimcoreUser(): User
  109.     {
  110.         $user = User::getByName(self::FALLBACK_USER_NAME);
  112.         if (empty($user)) {
  113.             $user = new User();
  114.             $user->setName(self::FALLBACK_USER_NAME);
  115.             $user->setActive(true);
  116.             $user->setParentId(0);
  117.             $user->save();
  118.         }
  120.         return $user;
  121.     }
  122. }