vendor/ibexa/personalization/src/lib/Event/Subscriber/UserCollectionGeneratorEventSubscriber.php line 43

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\Personalization\Event\Subscriber;
  11. use Ibexa\Bundle\Personalization\Serializer\Normalizer\AttributeNormalizer;
  12. use Ibexa\Bundle\Personalization\Serializer\Normalizer\UserCollectionNormalizer;
  13. use Ibexa\Bundle\Personalization\Serializer\Normalizer\UserNormalizer;
  14. use Ibexa\Personalization\Event\GenerateUserCollectionDataEvent;
  15. use Ibexa\Personalization\Event\UpdateUserAPIEvent;
  16. use Ibexa\Personalization\Value\Output\UserCollection;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Component\Serializer\Encoder\XmlEncoder;
  19. use Symfony\Component\Serializer\Normalizer\ArrayDenormalizer;
  20. use Symfony\Component\Serializer\Serializer;
  21. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  23. final class UserCollectionGeneratorEventSubscriber implements EventSubscriberInterface
  24. {
  25.     /** @var \Symfony\Component\EventDispatcher\EventDispatcher */
  26.     private $eventDispatcher;
  28.     public function __construct(EventDispatcherInterface $eventDispatcher)
  29.     {
  30.         $this->eventDispatcher = $eventDispatcher;
  31.     }
  33.     /**
  34.      * {@inheritdoc}
  35.      */
  36.     public static function getSubscribedEvents(): array
  37.     {
  38.         return [
  39.             UpdateUserAPIEvent::class => ['onRecommendationUpdateUserCollection', 128],
  40.         ];
  41.     }
  43.     public function onRecommendationUpdateUserCollection(UpdateUserAPIEvent $userAPIEvent): void
  44.     {
  45.         $event = new GenerateUserCollectionDataEvent();
  46.         $this->eventDispatcher->dispatch($event);
  48.         $userCollection = $event->getUserCollection();
  50.         if ($userCollection->isEmpty()) {
  51.             return;
  52.         }
  54.         $userApiRequest = $userAPIEvent->getUserAPIRequest();
  56.         if ($event->hasUserCollectionName()) {
  57.             $userApiRequest->source = $event->getUserCollectionName();
  58.         }
  60.         $userApiRequest->xmlBody = $this->generateXml($userCollection);
  61.     }
  63.     /**
  64.      * Generates xml string based on UserCollection object.
  65.      */
  66.     private function generateXml(UserCollection $userCollection): string
  67.     {
  68.         $encoders = [new XmlEncoder()];
  69.         $normalizers = [
  70.             new UserCollectionNormalizer(),
  71.             new UserNormalizer(),
  72.             new AttributeNormalizer(),
  73.             new ArrayDenormalizer(),
  74.         ];
  76.         $serializer = new Serializer($normalizers, $encoders);
  78.         return $serializer->serialize(
  79.             $userCollection,
  80.             'xml',
  81.             [
  82.             'xml_root_node_name' => 'users',
  83.             ]
  84.         );
  85.     }
  86. }
  88. class_alias(UserCollectionGeneratorEventSubscriber::class, 'EzSystems\EzRecommendationClient\Event\Subscriber\UserCollectionGeneratorEventSubscriber');