vendor/ibexa/segmentation/src/lib/Event/Subscriber/PersonalizationUserSegmentsSubscriber.php line 51

Open in your IDE?
  1. <?php
  3. /**
  4.  * @copyright Copyright (C) Ibexa AS. All rights reserved.
  5.  * @license For full copyright and license information view LICENSE file distributed with this source code.
  6.  */
  7. declare(strict_types=1);
  9. namespace Ibexa\Segmentation\Event\Subscriber;
  11. use Ibexa\Contracts\Core\Repository\Repository;
  12. use Ibexa\Contracts\Segmentation\SegmentationServiceInterface;
  13. use Ibexa\Personalization\Event\PersonalizationSegmentsResolverEvent;
  14. use Ibexa\Personalization\Event\PersonalizationUserTrackingRenderOptionsEvent;
  15. use Ibexa\Segmentation\Exception\Persistence\SegmentNotFoundException;
  16. use Ibexa\Segmentation\Value\Segment;
  17. use Psr\Log\LoggerAwareInterface;
  18. use Psr\Log\LoggerAwareTrait;
  19. use Psr\Log\LoggerInterface;
  20. use Psr\Log\NullLogger;
  21. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  23. final class PersonalizationUserSegmentsSubscriber implements EventSubscriberInterface, LoggerAwareInterface
  24. {
  25.     use LoggerAwareTrait;
  27.     private const SEGMENTS_KEY = 'segments';
  29.     private Repository $repository;
  31.     private SegmentationServiceInterface $segmentationService;
  33.     public function __construct(
  34.         Repository $repository,
  35.         SegmentationServiceInterface $segmentationService,
  36.         ?LoggerInterface $logger = null
  37.     ) {
  38.         $this->repository = $repository;
  39.         $this->segmentationService = $segmentationService;
  40.         $this->logger = $logger ?? new NullLogger();
  41.     }
  43.     public static function getSubscribedEvents(): array
  44.     {
  45.         return [
  46.             PersonalizationUserTrackingRenderOptionsEvent::class => ['onUserTrackingRender', 255],
  47.             PersonalizationSegmentsResolverEvent::class => ['onSegmentsResolver', 255],
  48.         ];
  49.     }
  51.     public function onUserTrackingRender(PersonalizationUserTrackingRenderOptionsEvent $event): void
  52.     {
  53.         $segments = array_column(
  54.             $this->segmentationService->loadSegmentsAssignedToCurrentUser(),
  55.             'id'
  56.         );
  58.         $previousSegments = $event->getOptions()[self::SEGMENTS_KEY] ?? [];
  59.         $event->setOption(self::SEGMENTS_KEY, array_merge($previousSegments, $segments));
  60.     }
  62.     public function onSegmentsResolver(PersonalizationSegmentsResolverEvent $event): void
  63.     {
  64.         $resultMapping = $event->getSegmentsMapping();
  66.         foreach ($event->getSegmentsIds() as $id) {
  67.             try {
  68.                 $resultMapping[$id] = $this->repository->sudo(
  69.                     fn (): Segment => $this->segmentationService->loadSegment($id)
  70.                 );
  71.             } catch (SegmentNotFoundException $e) {
  72.                 $this->logger->debug(sprintf('Segment not found with id: %s', $id));
  73.             }
  74.         }
  76.         $event->setSegmentsMapping($resultMapping);
  77.     }
  78. }