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');