Chris@0: <?php
Chris@0: 
Chris@0: namespace Drupal\migrate_drupal\Plugin;
Chris@0: 
Chris@0: use Drupal\Component\Plugin\Exception\PluginNotFoundException;
Chris@14: use Drupal\migrate\Plugin\Exception\BadPluginDefinitionException;
Chris@0: use Drupal\migrate\Plugin\MigratePluginManager;
Chris@0: use Drupal\migrate\Plugin\MigrationInterface;
Chris@0: 
Chris@0: /**
Chris@0:  * Plugin manager for migrate field plugins.
Chris@0:  *
Chris@0:  * @see \Drupal\migrate_drupal\Plugin\MigrateFieldInterface
Chris@0:  * @see \Drupal\migrate\Annotation\MigrateField
Chris@0:  * @see plugin_api
Chris@0:  *
Chris@0:  * @ingroup migration
Chris@0:  */
Chris@0: class MigrateFieldPluginManager extends MigratePluginManager implements MigrateFieldPluginManagerInterface {
Chris@0: 
Chris@0:   /**
Chris@0:    * The default version of core to use for field plugins.
Chris@0:    *
Chris@0:    * These plugins were initially only built and used for Drupal 6 fields.
Chris@0:    * Having been extended for Drupal 7 with a "core" annotation, we fall back to
Chris@0:    * Drupal 6 where none exists.
Chris@0:    */
Chris@0:   const DEFAULT_CORE_VERSION = 6;
Chris@0: 
Chris@0:   /**
Chris@0:    * {@inheritdoc}
Chris@0:    */
Chris@0:   public function getPluginIdFromFieldType($field_type, array $configuration = [], MigrationInterface $migration = NULL) {
Chris@0:     $core = static::DEFAULT_CORE_VERSION;
Chris@0:     if (!empty($configuration['core'])) {
Chris@0:       $core = $configuration['core'];
Chris@0:     }
Chris@0:     elseif (!empty($migration->getPluginDefinition()['migration_tags'])) {
Chris@0:       foreach ($migration->getPluginDefinition()['migration_tags'] as $tag) {
Chris@0:         if ($tag == 'Drupal 7') {
Chris@0:           $core = 7;
Chris@0:         }
Chris@0:       }
Chris@0:     }
Chris@0: 
Chris@0:     $definitions = $this->getDefinitions();
Chris@0:     foreach ($definitions as $plugin_id => $definition) {
Chris@0:       if (in_array($core, $definition['core'])) {
Chris@0:         if (array_key_exists($field_type, $definition['type_map']) || $field_type === $plugin_id) {
Chris@0:           return $plugin_id;
Chris@0:         }
Chris@0:       }
Chris@0:     }
Chris@0:     throw new PluginNotFoundException($field_type);
Chris@0:   }
Chris@0: 
Chris@14:   /**
Chris@14:    * {@inheritdoc}
Chris@14:    */
Chris@14:   public function processDefinition(&$definition, $plugin_id) {
Chris@14:     parent::processDefinition($definition, $plugin_id);
Chris@14: 
Chris@14:     foreach (['core', 'source_module', 'destination_module'] as $required_property) {
Chris@14:       if (empty($definition[$required_property])) {
Chris@14:         throw new BadPluginDefinitionException($plugin_id, $required_property);
Chris@14:       }
Chris@14:     }
Chris@14:   }
Chris@14: 
Chris@0: }