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

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::PRE_ADD => 'onPreUpdate',
  63.             DataObjectEvents::POST_DELETE => 'onPostDelete',
  64.         ];
  65.     }
  67.     /**
  68.      * @param DataObjectEvent $dataObjectEvent
  69.      *
  70.      * @throws \Exception
  71.      */
  72.     public function onPreUpdate(DataObjectEvent $dataObjectEvent)
  73.     {
  74.         $user = $dataObjectEvent->getObject();
  75.         if ($user instanceof PortalUserInterface) {
  76.             $existingPortalUser = PortalUser::getByEmail($user->getEmail())
  77.                     ->addConditionParam('o_id != ? and externalUserId is null', $user->getId())
  78.                     ->count() > 0;
  80.             if ($existingPortalUser) {
  81.                 throw new ValidationException(sprintf('PortalUser with email %s already exists', $user->getEmail()));
  82.             }
  84.             if (empty($user->getPimcoreUser()) && method_exists($user, 'setPimcoreUser')) {
  85.                 $user->setPimcoreUser($this->getFallbackPimcoreUser()->getId());
  86.             }
  87.         }
  88.     }
  90.     /**
  91.      * @param DataObjectEvent $dataObjectEvent
  92.      *
  93.      * @throws \Exception
  94.      */
  95.     public function onPostDelete(DataObjectEvent $dataObjectEvent)
  96.     {
  97.         $user = $dataObjectEvent->getElement();
  98.         if ($user instanceof PortalUserInterface) {
  99.             $this->collectionService->cleanupDeletedUser($user);
  100.             $this->publicShareService->cleanupDeletedUser($user);
  101.         }
  102.     }
  104.     /**
  105.      * @return User
  106.      *
  107.      * @throws \Exception
  108.      */
  109.     protected function getFallbackPimcoreUser(): User
  110.     {
  111.         $user = User::getByName(self::FALLBACK_USER_NAME);
  113.         if (empty($user)) {
  114.             $user = new User();
  115.             $user->setName(self::FALLBACK_USER_NAME);
  116.             $user->setActive(true);
  117.             $user->setParentId(0);
  118.             $user->save();
  119.         }
  121.         return $user;
  122.     }
  123. }