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

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\DataObject\Service;
  22. use Pimcore\Model\Element\ValidationException;
  23. use Pimcore\Model\User;
  24. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  26. /**
  27.  * Class IndexUpdateListener
  28.  *
  29.  * @package Pimcore\Bundle\PortalEngineBundle\EventListener
  30.  */
  31. class SaveUserSubscriber implements EventSubscriberInterface
  32. {
  33.     const FALLBACK_USER_NAME = 'portal-engine-default-user';
  35.     /**
  36.      * @var CollectionService
  37.      */
  38.     protected $collectionService;
  39.     /**
  40.      * @var PublicShareService
  41.      */
  42.     protected $publicShareService;
  44.     /**
  45.      * SaveUserSubscriber constructor.
  46.      *
  47.      * @param CollectionService $collectionService
  48.      * @param PublicShareService $publicShareService
  49.      */
  50.     public function __construct(CollectionService $collectionService, PublicShareService $publicShareService)
  51.     {
  52.         $this->collectionService = $collectionService;
  53.         $this->publicShareService = $publicShareService;
  54.     }
  56.     /**
  57.      * @return array
  58.      */
  59.     public static function getSubscribedEvents()
  60.     {
  61.         return [
  62.             DataObjectEvents::PRE_UPDATE => 'onPreUpdate',
  63.             DataObjectEvents::PRE_ADD => 'onPreUpdate',
  64.             DataObjectEvents::POST_DELETE => 'onPostDelete',
  65.         ];
  66.     }
  68.     /**
  69.      * @param DataObjectEvent $dataObjectEvent
  70.      *
  71.      * @throws \Exception
  72.      */
  73.     public function onPreUpdate(DataObjectEvent $dataObjectEvent)
  74.     {
  75.         $user = $dataObjectEvent->getObject();
  76.         if ($user instanceof PortalUserInterface) {
  77.             $existingPortalUser = PortalUser::getByEmail($user->getEmail())
  78.                     ->addConditionParam(sprintf('%s != ? and externalUserId is null', Service::getVersionDependentDatabaseColumnName('o_id')), $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()) && method_exists($user, 'setPimcoreUser')) {
  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. }