Chris@0: <?php
Chris@0: 
Chris@0: namespace Drupal\node\EventSubscriber;
Chris@0: 
Chris@0: use Drupal\Core\KeyValueStore\KeyValueFactoryInterface;
Chris@0: use Drupal\Core\State\StateInterface;
Chris@0: use Drupal\migrate\Event\EventBase;
Chris@0: use Drupal\migrate\Event\MigrateEvents;
Chris@0: use Drupal\migrate\Event\MigrateImportEvent;
Chris@0: use Drupal\migrate\Event\MigratePostRowSaveEvent;
Chris@0: use Symfony\Component\EventDispatcher\EventSubscriberInterface;
Chris@0: 
Chris@0: /**
Chris@0:  * Creates a key value collection for migrated node translation redirections.
Chris@0:  *
Chris@0:  * If we are migrating node translations from Drupal 6 or 7, these nodes will be
Chris@0:  * combined with their source node. Since there still might be references to the
Chris@0:  * URLs of these now consolidated nodes, this service saves the mapping between
Chris@0:  * the old nids to the new ones to be able to redirect them to the right node in
Chris@0:  * the right language.
Chris@0:  *
Chris@0:  * The mapping is stored in the "node_translation_redirect" key/value collection
Chris@0:  * and the redirection is made by the NodeTranslationExceptionSubscriber class.
Chris@0:  *
Chris@0:  * @see \Drupal\node\NodeServiceProvider
Chris@0:  * @see \Drupal\node\EventSubscriber\NodeTranslationExceptionSubscriber
Chris@0:  */
Chris@0: class NodeTranslationMigrateSubscriber implements EventSubscriberInterface {
Chris@0: 
Chris@0:   /**
Chris@0:    * The key value factory.
Chris@0:    *
Chris@0:    * @var \Drupal\Core\KeyValueStore\KeyValueFactoryInterface
Chris@0:    */
Chris@0:   protected $keyValue;
Chris@0: 
Chris@0:   /**
Chris@0:    * The state service.
Chris@0:    *
Chris@0:    * @var \Drupal\Core\State\StateInterface
Chris@0:    */
Chris@0:   protected $state;
Chris@0: 
Chris@0:   /**
Chris@0:    * Constructs the NodeTranslationMigrateSubscriber.
Chris@0:    *
Chris@0:    * @param \Drupal\Core\KeyValueStore\KeyValueFactoryInterface $key_value
Chris@0:    *   The key value factory.
Chris@0:    * @param \Drupal\Core\State\StateInterface $state
Chris@0:    *   The state service.
Chris@0:    */
Chris@0:   public function __construct(KeyValueFactoryInterface $key_value, StateInterface $state) {
Chris@0:     $this->keyValue = $key_value;
Chris@0:     $this->state = $state;
Chris@0:   }
Chris@0: 
Chris@0:   /**
Chris@0:    * Helper method to check if we are migrating translated nodes.
Chris@0:    *
Chris@0:    * @param \Drupal\migrate\Event\EventBase $event
Chris@0:    *   The migrate event.
Chris@0:    *
Chris@0:    * @return bool
Chris@0:    *   True if we are migrating translated nodes, false otherwise.
Chris@0:    */
Chris@0:   protected function isNodeTranslationsMigration(EventBase $event) {
Chris@0:     $migration = $event->getMigration();
Chris@0:     $source_configuration = $migration->getSourceConfiguration();
Chris@0:     $destination_configuration = $migration->getDestinationConfiguration();
Chris@0:     return !empty($source_configuration['translations']) && $destination_configuration['plugin'] === 'entity:node';
Chris@0:   }
Chris@0: 
Chris@0:   /**
Chris@0:    * Maps the old nid to the new one in the key value collection.
Chris@0:    *
Chris@0:    * @param \Drupal\migrate\Event\MigratePostRowSaveEvent $event
Chris@0:    *   The migrate post row save event.
Chris@0:    */
Chris@0:   public function onPostRowSave(MigratePostRowSaveEvent $event) {
Chris@0:     if ($this->isNodeTranslationsMigration($event)) {
Chris@0:       $row = $event->getRow();
Chris@0:       $source = $row->getSource();
Chris@0:       $destination = $row->getDestination();
Chris@0:       $collection = $this->keyValue->get('node_translation_redirect');
Chris@0:       $collection->set($source['nid'], [$destination['nid'], $destination['langcode']]);
Chris@0:     }
Chris@0:   }
Chris@0: 
Chris@0:   /**
Chris@0:    * Set the node_translation_redirect state to enable the redirections.
Chris@0:    *
Chris@0:    * @param \Drupal\migrate\Event\MigrateImportEvent $event
Chris@0:    *   The migrate import event.
Chris@0:    */
Chris@0:   public function onPostImport(MigrateImportEvent $event) {
Chris@0:     if ($this->isNodeTranslationsMigration($event)) {
Chris@0:       $this->state->set('node_translation_redirect', TRUE);
Chris@0:     }
Chris@0:   }
Chris@0: 
Chris@0:   /**
Chris@0:    * {@inheritdoc}
Chris@0:    */
Chris@0:   public static function getSubscribedEvents() {
Chris@0:     $events = [];
Chris@0: 
Chris@0:     $events[MigrateEvents::POST_ROW_SAVE] = ['onPostRowSave'];
Chris@0:     $events[MigrateEvents::POST_IMPORT] = ['onPostImport'];
Chris@0: 
Chris@0:     return $events;
Chris@0:   }
Chris@0: 
Chris@0: }