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