Chris@17: <?php
Chris@17: 
Chris@17: namespace Drupal\comment\Plugin\migrate;
Chris@17: 
Chris@17: use Drupal\migrate_drupal\Plugin\migrate\FieldMigration;
Chris@17: 
Chris@17: /**
Chris@17:  * Migration plugin for Drupal 7 comments with fields.
Chris@17:  */
Chris@17: class D7Comment extends FieldMigration {
Chris@17: 
Chris@17:   /**
Chris@17:    * {@inheritdoc}
Chris@17:    */
Chris@17:   public function getProcess() {
Chris@17:     if ($this->init) {
Chris@17:       return parent::getProcess();
Chris@17:     }
Chris@17:     $this->init = TRUE;
Chris@17:     if (!\Drupal::moduleHandler()->moduleExists('field')) {
Chris@17:       return parent::getProcess();
Chris@17:     }
Chris@17:     $definition['source'] = [
Chris@17:       'ignore_map' => TRUE,
Chris@17:     ] + $this->getSourceConfiguration();
Chris@17:     $definition['source']['plugin'] = 'd7_field_instance';
Chris@17:     $definition['destination']['plugin'] = 'null';
Chris@17:     $definition['idMap']['plugin'] = 'null';
Chris@17:     $field_migration = $this->migrationPluginManager->createStubMigration($definition);
Chris@17:     foreach ($field_migration->getSourcePlugin() as $row) {
Chris@17:       $field_name = $row->getSourceProperty('field_name');
Chris@17:       $field_type = $row->getSourceProperty('type');
Chris@17:       if ($this->fieldPluginManager->hasDefinition($field_type)) {
Chris@17:         if (!isset($this->fieldPluginCache[$field_type])) {
Chris@17:           $this->fieldPluginCache[$field_type] = $this->fieldPluginManager->createInstance($field_type, [], $this);
Chris@17:         }
Chris@17:         $info = $row->getSource();
Chris@17:         $this->fieldPluginCache[$field_type]->defineValueProcessPipeline($this, $field_name, $info);
Chris@17:       }
Chris@17:       else {
Chris@17:         $this->setProcessOfProperty($field_name, $field_name);
Chris@17:       }
Chris@17:     }
Chris@17:     return parent::getProcess();
Chris@17:   }
Chris@17: 
Chris@17: }