custom/plugins/SwagB2bPlatform/components/EasyMode/BridgePlatform/B2bCustomerDataSubscriber.php line 44

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\B2B\EasyMode\BridgePlatform;
  5. use Shopware\B2B\Acl\Framework\AclRepository;
  6. use Shopware\B2B\Common\IdValue;
  7. use Shopware\B2B\Common\Repository\NotFoundException;
  8. use Shopware\B2B\Debtor\Framework\DebtorService;
  9. use Shopware\B2B\Role\Framework\RoleRepository;
  10. use Shopware\B2B\Shop\BridgePlatform\B2bCustomerDataDefinition;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use function array_key_exists;
  15. class B2bCustomerDataSubscriber implements EventSubscriberInterface
  16. {
  17.     private RoleRepository $roleRepository;
  19.     private EasyModeService $easyModeService;
  21.     private AclRepository $aclRoleRepository;
  23.     private DebtorService $debtorService;
  25.     public function __construct(
  26.         RoleRepository $roleRepository,
  27.         EasyModeService $easyModeService,
  28.         AclRepository $aclRoleRepository,
  29.         DebtorService $debtorService
  30.     ) {
  31.         $this->roleRepository = $roleRepository;
  32.         $this->easyModeService = $easyModeService;
  33.         $this->aclRoleRepository = $aclRoleRepository;
  34.         $this->debtorService = $debtorService;
  35.     }
  37.     public static function getSubscribedEvents(): array
  38.     {
  39.         return [
  40.             B2bCustomerDataDefinition::ENTITY_NAME . '.written' => 'updateEasyModeAcl',
  41.         ];
  42.     }
  44.     public function updateEasyModeAcl(EntityWrittenEvent $event): void
  45.     {
  46.         $writtenResults = $event->getPayloads();
  47.         $identities = [];
  49.         foreach ($writtenResults as $customerData) {
  50.             $customerId = IdValue::create($customerData['customerId']);
  51.             $isInEasyMode = array_key_exists('isInEasyMode', $customerData) && $customerData['isInEasyMode'] === true;
  53.             if ($isInEasyMode === false) {
  54.                 continue;
  55.             }
  57.             try {
  58.                 $identity = $this->debtorService->loadIdentityByAuthentication($customerId);
  59.             } catch (NotFoundException $exception) {
  60.                 continue;
  61.             }
  63.             $identities[] = $identity;
  64.         }
  66.         if (!$identities) {
  67.             return;
  68.         }
  70.         foreach ($identities as $identity) {
  71.             $easyModeRole = $this->easyModeService->getEasyModeRole($identity->getOwnershipContext(), $this->roleRepository);
  72.             $this->aclRoleRepository->allow($easyModeRole, $easyModeRole->id);
  73.         }
  74.     }
  75. }