class MigrationPluginManager

class MigrationPluginManager extends BaseMigrationPluginManager {
    
    /**
     * The Migrate source plugin manager service.
     *
     * @var \Drupal\migrate\Plugin\MigrateSourcePluginManager
     */
    protected $sourceManager;
    
    /**
     * The config factory service.
     *
     * @var \Drupal\Core\Config\ConfigFactoryInterface
     */
    protected $configFactory;
    
    /**
     * The migration tags which will trigger source_module enforcement.
     *
     * @var string[]
     */
    protected $enforcedSourceModuleTags;
    
    /**
     * MigrationPluginManager constructor.
     *
     * @param \Drupal\Core\Extension\ModuleHandlerInterface $module_handler
     *   The module handler service.
     * @param \Drupal\Core\Cache\CacheBackendInterface $cache_backend
     *   The cache backend.
     * @param \Drupal\Core\Language\LanguageManagerInterface $language_manager
     *   The language manager service.
     * @param \Drupal\migrate\Plugin\MigrateSourcePluginManager $source_manager
     *   The Migrate source plugin manager service.
     * @param \Drupal\Core\Config\ConfigFactoryInterface $config_factory
     *   The config factory service.
     */
    public function __construct(ModuleHandlerInterface $module_handler, CacheBackendInterface $cache_backend, LanguageManagerInterface $language_manager, MigrateSourcePluginManager $source_manager, ConfigFactoryInterface $config_factory) {
        parent::__construct($module_handler, $cache_backend, $language_manager);
        $this->sourceManager = $source_manager;
        $this->configFactory = $config_factory;
    }
    
    /**
     * Returns the migration tags that trigger source_module enforcement.
     *
     * @return string[]
     */
    protected function getEnforcedSourceModuleTags() {
        if ($this->enforcedSourceModuleTags === NULL) {
            $this->enforcedSourceModuleTags = $this->configFactory
                ->get('migrate_drupal.settings')
                ->get('enforce_source_module_tags') ?: [];
        }
        return $this->enforcedSourceModuleTags;
    }
    
    /**
     * {@inheritdoc}
     */
    public function processDefinition(&$definition, $plugin_id) {
        parent::processDefinition($definition, $plugin_id);
        // If the migration has no tags, we don't need to enforce the source_module
        // annotation property.
        if (empty($definition['migration_tags'])) {
            return;
        }
        // Check if the migration has any of the tags that trigger source_module
        // enforcement.
        $applied_tags = array_intersect($this->getEnforcedSourceModuleTags(), $definition['migration_tags']);
        if ($applied_tags) {
            // Throw an exception if the source plugin definition does not define a
            // source_module.
            $source_id = $definition['source']['plugin'];
            $source_definition = $this->sourceManager
                ->getDefinition($source_id);
            if (empty($source_definition['source_module'])) {
                throw new BadPluginDefinitionException($source_id, 'source_module');
            }
        }
    }

}