View source
<?php
namespace Drupal\media_migration;
use Drupal\Component\Plugin\Exception\PluginException;
use Drupal\Core\Cache\CacheBackendInterface;
use Drupal\Core\Extension\ModuleHandlerInterface;
use Drupal\Core\Plugin\DefaultPluginManager;
use Drupal\media_migration\Annotation\FileDealer;
class FileDealerManager extends DefaultPluginManager implements FileDealerManagerInterface {
protected $logger;
public function __construct(\Traversable $namespaces, CacheBackendInterface $cache_backend, ModuleHandlerInterface $module_handler) {
parent::__construct('Plugin/media_migration/file', $namespaces, $module_handler, FileDealerPluginInterface::class, FileDealer::class);
$this
->alterInfo('media_migration_file_dealer_info');
$this
->setCacheBackend($cache_backend, 'file_dealer_plugins');
}
protected function getDefinitionsByFieldTypeAndScheme(string $scheme, string $mime) {
$definitions = $this
->getDefinitions();
$strict_list = array_filter($definitions, function ($definition) use ($scheme, $mime) {
return in_array($scheme, $definition['schemes'], TRUE) && in_array($mime, $definition['mimes'], TRUE);
});
if (!empty($strict_list)) {
return $strict_list;
}
$only_mime_list = array_filter($definitions, function ($definition) use ($mime) {
return empty($definition['schemes']) && in_array($mime, $definition['mimes'], TRUE);
});
if (!empty($only_mime_list)) {
return $only_mime_list;
}
$only_scheme_list = array_filter($definitions, function ($definition) use ($scheme) {
return in_array($scheme, $definition['schemes'], TRUE) && empty($definition['mimes']);
});
if (!empty($only_scheme_list)) {
return $only_scheme_list;
}
if (array_key_exists('fallback', $definitions)) {
return [
'fallback' => $definitions['fallback'],
];
}
return [];
}
public function createInstanceFromSchemeAndMime(string $scheme, string $mime) {
$filtered_definitions = $this
->getDefinitionsByFieldTypeAndScheme($scheme, $mime);
if (!empty($filtered_definitions)) {
try {
$configuration = [
'scheme' => $scheme,
'mime' => $mime,
];
$plugin_id = array_keys($filtered_definitions)[0];
return $this
->createInstance($plugin_id, $configuration);
} catch (PluginException $e) {
return NULL;
}
}
return NULL;
}
}