vendor/ibexa/migrations/src/bundle/Event/ObjectRelationFieldTypeSubscriber.php line 59

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\Bundle\Migration\Event;
  11. use Ibexa\Contracts\Core\Repository\ContentService;
  12. use Ibexa\Core\FieldType\Relation\Value;
  13. use Ibexa\Migration\Event\FieldValueFromHashEvent;
  14. use Ibexa\Migration\Event\HashFromFieldValueEvent;
  15. use Ibexa\Migration\Event\MigrationEvents;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. final class ObjectRelationFieldTypeSubscriber implements EventSubscriberInterface
  19. {
  20. private ContentService $contentService;
  22. public function __construct(ContentService $contentService)
  23. {
  24. $this->contentService = $contentService;
  25. }
  27. public static function getSubscribedEvents(): array
  28. {
  29. return [
  30. MigrationEvents::AFTER_HASH_FROM_FIELD_VALUE => [
  31. ['addRemoteContentId', -100],
  32. ],
  33. MigrationEvents::BEFORE_FIELD_VALUE_FROM_HASH => [
  34. ['convertRemoteContentId', -100],
  35. ],
  36. ];
  37. }
  39. public function addRemoteContentId(HashFromFieldValueEvent $event): void
  40. {
  41. $value = $event->getSpiFieldTypeValue();
  43. if (!$value instanceof Value) {
  44. return;
  45. }
  47. if ($value->destinationContentId === null) {
  48. return;
  49. }
  51. $hash = $event->getHash();
  53. $content = $this->contentService->loadContent($value->destinationContentId);
  54. $hash['contentRemoteId'] = $content->contentInfo->remoteId;
  56. $event->setHash($hash);
  57. }
  59. public function convertRemoteContentId(FieldValueFromHashEvent $event): void
  60. {
  61. if ($event->getFieldTypeIdentifier() !== 'ezobjectrelation') {
  62. return;
  63. }
  65. $hash = $event->getHash();
  67. if (!isset($hash['contentRemoteId'])) {
  68. return;
  69. }
  71. $content = $this->contentService->loadContentByRemoteId($hash['contentRemoteId']);
  73. $event->setHash(array_merge($hash, [
  74. 'destinationContentId' => $content->id,
  75. ]));
  76. }
  77. }