Chris@0: <?php
Chris@0: 
Chris@0: namespace Drupal\migrate_plus\Entity;
Chris@0: 
Chris@0: use Drupal\Core\Cache\Cache;
Chris@0: use Drupal\Core\Config\Entity\ConfigEntityBase;
Chris@0: use Drupal\Core\Entity\EntityTypeInterface;
Chris@0: 
Chris@0: /**
Chris@0:  * Defines the Migration entity.
Chris@0:  *
Chris@0:  * The migration entity stores the information about a single migration, like
Chris@0:  * the source, process and destination plugins.
Chris@0:  *
Chris@0:  * @ConfigEntityType(
Chris@0:  *   id = "migration",
Chris@0:  *   label = @Translation("Migration"),
Chris@0:  *   entity_keys = {
Chris@0:  *     "id" = "id",
Chris@0:  *     "label" = "label",
Chris@0:  *     "weight" = "weight"
Chris@0:  *   }
Chris@0:  * )
Chris@0:  */
Chris@0: class Migration extends ConfigEntityBase implements MigrationInterface {
Chris@0: 
Chris@0:   /**
Chris@0:    * The migration ID (machine name).
Chris@0:    *
Chris@0:    * @var string
Chris@0:    */
Chris@0:   protected $id;
Chris@0: 
Chris@0:   /**
Chris@0:    * The human-readable label for the migration.
Chris@0:    *
Chris@0:    * @var string
Chris@0:    */
Chris@0:   protected $label;
Chris@0: 
Chris@0:   /**
Chris@0:    * {@inheritdoc}
Chris@0:    */
Chris@0:   protected function invalidateTagsOnSave($update) {
Chris@0:     parent::invalidateTagsOnSave($update);
Chris@0:     Cache::invalidateTags(['migration_plugins']);
Chris@0:   }
Chris@0: 
Chris@0:   /**
Chris@0:    * {@inheritdoc}
Chris@0:    */
Chris@0:   protected static function invalidateTagsOnDelete(EntityTypeInterface $entity_type, array $entities) {
Chris@0:     parent::invalidateTagsOnDelete($entity_type, $entities);
Chris@0:     Cache::invalidateTags(['migration_plugins']);
Chris@0:   }
Chris@0: 
Chris@0:   /**
Chris@0:    * Create a configuration entity from a core migration plugin's configuration.
Chris@0:    *
Chris@0:    * @param string $plugin_id
Chris@0:    *   ID of a migration plugin managed by MigrationPluginManager.
Chris@0:    * @param string $new_plugin_id
Chris@0:    *   ID to use for the new configuration entity.
Chris@0:    *
Chris@0:    * @return \Drupal\migrate_plus\Entity\MigrationInterface
Chris@0:    *   A Migration configuration entity (not saved to persistent storage).
Chris@0:    */
Chris@0:   public static function createEntityFromPlugin($plugin_id, $new_plugin_id) {
Chris@0:     /** @var \Drupal\migrate\Plugin\MigrationPluginManagerInterface $plugin_manager */
Chris@0:     $plugin_manager = \Drupal::service('plugin.manager.migration');
Chris@0:     $migration_plugin = $plugin_manager->createInstance($plugin_id);
Chris@0:     $entity_array['id'] = $new_plugin_id;
Chris@0:     $entity_array['migration_tags'] = $migration_plugin->get('migration_tags');
Chris@0:     $entity_array['label'] = $migration_plugin->label();
Chris@0:     $entity_array['source'] = $migration_plugin->getSourceConfiguration();
Chris@0:     $entity_array['destination'] = $migration_plugin->getDestinationConfiguration();
Chris@0:     $entity_array['process'] = $migration_plugin->getProcess();
Chris@0:     $entity_array['migration_dependencies'] = $migration_plugin->getMigrationDependencies();
Chris@0:     $migration_entity = static::create($entity_array);
Chris@0:     return $migration_entity;
Chris@0:   }
Chris@0: 
Chris@0: }