class Importer in Default Content for D8 8
Same name and namespace in other branches
- 2.0.x src/Importer.php \Drupal\default_content\Importer
A service for handling import of default content.
@todo throw useful exceptions
Hierarchy
- class \Drupal\default_content\Importer implements ImporterInterface
Expanded class hierarchy of Importer
1 string reference to 'Importer'
1 service uses Importer
File
- src/
Importer.php, line 21
Namespace
Drupal\default_contentView source
class Importer implements ImporterInterface {
/**
* Defines relation domain URI for entity links.
*
* @var string
*/
protected $linkDomain;
/**
* The serializer service.
*
* @var \Symfony\Component\Serializer\Serializer
*/
protected $serializer;
/**
* The entity type manager.
*
* @var \Drupal\Core\Entity\EntityTypeManagerInterface
*/
protected $entityTypeManager;
/**
* A list of vertex objects keyed by their link.
*
* @var array
*/
protected $vertexes = [];
/**
* The graph entries.
*
* @var array
*/
protected $graph = [];
/**
* The link manager service.
*
* @var \Drupal\hal\LinkManager\LinkManagerInterface
*/
protected $linkManager;
/**
* The event dispatcher.
*
* @var \Symfony\Component\EventDispatcher\EventDispatcherInterface
*/
protected $eventDispatcher;
/**
* The file system scanner.
*
* @var \Drupal\default_content\ScannerInterface
*/
protected $scanner;
/**
* The account switcher.
*
* @var \Drupal\Core\Session\AccountSwitcherInterface
*/
protected $accountSwitcher;
/**
* Constructs the default content manager.
*
* @param \Symfony\Component\Serializer\Serializer $serializer
* The serializer service.
* @param \Drupal\Core\Entity\EntityTypeManagerInterface $entity_type_manager
* The entity type manager service.
* @param \Drupal\hal\LinkManager\LinkManagerInterface $link_manager
* The link manager service.
* @param \Symfony\Component\EventDispatcher\EventDispatcherInterface $event_dispatcher
* The event dispatcher.
* @param \Drupal\default_content\ScannerInterface $scanner
* The file scanner.
* @param string $link_domain
* Defines relation domain URI for entity links.
* @param \Drupal\Core\Session\AccountSwitcherInterface $account_switcher
* The account switcher.
*/
public function __construct(Serializer $serializer, EntityTypeManagerInterface $entity_type_manager, LinkManagerInterface $link_manager, EventDispatcherInterface $event_dispatcher, ScannerInterface $scanner, $link_domain, AccountSwitcherInterface $account_switcher) {
$this->serializer = $serializer;
$this->entityTypeManager = $entity_type_manager;
$this->linkManager = $link_manager;
$this->eventDispatcher = $event_dispatcher;
$this->scanner = $scanner;
$this->linkDomain = $link_domain;
$this->accountSwitcher = $account_switcher;
}
/**
* {@inheritdoc}
*/
public function importContent($module) {
$created = [];
$folder = drupal_get_path('module', $module) . "/content";
if (file_exists($folder)) {
$root_user = $this->entityTypeManager
->getStorage('user')
->load(1);
$this->accountSwitcher
->switchTo($root_user);
$file_map = [];
foreach ($this->entityTypeManager
->getDefinitions() as $entity_type_id => $entity_type) {
$reflection = new \ReflectionClass($entity_type
->getClass());
// We are only interested in importing content entities.
if ($reflection
->implementsInterface(ConfigEntityInterface::class)) {
continue;
}
if (!file_exists($folder . '/' . $entity_type_id)) {
continue;
}
$files = $this->scanner
->scan($folder . '/' . $entity_type_id);
// Default content uses drupal.org as domain.
// @todo Make this use a uri like default-content:.
$this->linkManager
->setLinkDomain($this->linkDomain);
// Parse all of the files and sort them in order of dependency.
foreach ($files as $file) {
$contents = $this
->parseFile($file);
// Decode the file contents.
$decoded = $this->serializer
->decode($contents, 'hal_json');
// Get the link to this entity.
$item_uuid = $decoded['uuid'][0]['value'];
// Throw an exception when this UUID already exists.
if (isset($file_map[$item_uuid])) {
// Reset link domain.
$this->linkManager
->setLinkDomain(FALSE);
throw new \Exception(sprintf('Default content with uuid "%s" exists twice: "%s" "%s"', $item_uuid, $file_map[$item_uuid]->uri, $file->uri));
}
// Store the entity type with the file.
$file->entity_type_id = $entity_type_id;
// Store the file in the file map.
$file_map[$item_uuid] = $file;
// Create a vertex for the graph.
$vertex = $this
->getVertex($item_uuid);
$this->graph[$vertex->id]['edges'] = [];
if (empty($decoded['_embedded'])) {
// No dependencies to resolve.
continue;
}
// Here we need to resolve our dependencies:
foreach ($decoded['_embedded'] as $embedded) {
foreach ($embedded as $item) {
$uuid = $item['uuid'][0]['value'];
$edge = $this
->getVertex($uuid);
$this->graph[$vertex->id]['edges'][$edge->id] = TRUE;
}
}
}
}
// @todo what if no dependencies?
$sorted = $this
->sortTree($this->graph);
foreach ($sorted as $link => $details) {
if (!empty($file_map[$link])) {
$file = $file_map[$link];
$entity_type_id = $file->entity_type_id;
$class = $this->entityTypeManager
->getDefinition($entity_type_id)
->getClass();
$contents = $this
->parseFile($file);
$entity = $this->serializer
->deserialize($contents, $class, 'hal_json', [
'request_method' => 'POST',
]);
$entity
->enforceIsNew(TRUE);
// Ensure that the entity is not owned by the anonymous user.
if ($entity instanceof EntityOwnerInterface && empty($entity
->getOwnerId())) {
$entity
->setOwner($root_user);
}
$entity
->save();
$created[$entity
->uuid()] = $entity;
}
}
$this->eventDispatcher
->dispatch(DefaultContentEvents::IMPORT, new ImportEvent($created, $module));
$this->accountSwitcher
->switchBack();
}
// Reset the tree.
$this
->resetTree();
// Reset link domain.
$this->linkManager
->setLinkDomain(FALSE);
return $created;
}
/**
* Parses content files.
*
* @param object $file
* The scanned file.
*
* @return string
* Contents of the file.
*/
protected function parseFile($file) {
return file_get_contents($file->uri);
}
/**
* Resets tree properties.
*/
protected function resetTree() {
$this->graph = [];
$this->vertexes = [];
}
/**
* Sorts dependencies tree.
*
* @param array $graph
* Array of dependencies.
*
* @return array
* Array of sorted dependencies.
*/
protected function sortTree(array $graph) {
$graph_object = new Graph($graph);
$sorted = $graph_object
->searchAndSort();
uasort($sorted, 'Drupal\\Component\\Utility\\SortArray::sortByWeightElement');
return array_reverse($sorted);
}
/**
* Returns a vertex object for a given item link.
*
* Ensures that the same object is returned for the same item link.
*
* @param string $item_link
* The item link as a string.
*
* @return object
* The vertex object.
*/
protected function getVertex($item_link) {
if (!isset($this->vertexes[$item_link])) {
$this->vertexes[$item_link] = (object) [
'id' => $item_link,
];
}
return $this->vertexes[$item_link];
}
}
Members
Name | Modifiers | Type | Description | Overrides |
---|---|---|---|---|
Importer:: |
protected | property | The account switcher. | |
Importer:: |
protected | property | The entity type manager. | |
Importer:: |
protected | property | The event dispatcher. | |
Importer:: |
protected | property | The graph entries. | |
Importer:: |
protected | property | Defines relation domain URI for entity links. | |
Importer:: |
protected | property | The link manager service. | |
Importer:: |
protected | property | The file system scanner. | |
Importer:: |
protected | property | The serializer service. | |
Importer:: |
protected | property | A list of vertex objects keyed by their link. | |
Importer:: |
protected | function | Returns a vertex object for a given item link. | |
Importer:: |
public | function |
Imports default content from a given module. Overrides ImporterInterface:: |
|
Importer:: |
protected | function | Parses content files. | |
Importer:: |
protected | function | Resets tree properties. | |
Importer:: |
protected | function | Sorts dependencies tree. | |
Importer:: |
public | function | Constructs the default content manager. |