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. }