content_deploy-1.0.1/src/Normalizer/ContentEntityNormalizer.php
src/Normalizer/ContentEntityNormalizer.php
<?php
namespace Drupal\content_deploy\Normalizer;
use Drupal\content_deploy\ContentSyncManager;
use Drupal\content_deploy\Plugin\SyncNormalizerDecoratorManager;
use Drupal\content_deploy\Plugin\SyncNormalizerDecoratorTrait;
use Drupal\Core\Entity\ContentEntityInterface;
use Drupal\Core\Entity\EntityTypeManagerInterface;
use Drupal\Core\Entity\EntityTypeRepositoryInterface;
use Drupal\Core\Entity\EntityFieldManagerInterface;
use Drupal\Core\Entity\EntityRepositoryInterface;
use Drupal\Core\Entity\EntityTypeBundleInfoInterface;
use Drupal\Core\Entity\RevisionableInterface;
use Drupal\Core\Url;
use Drupal\menu_link_content\Entity\MenuLinkContent;
use Drupal\path_alias\Entity\PathAlias;
use Drupal\serialization\Normalizer\ContentEntityNormalizer as BaseContentEntityNormalizer;
/**
* Adds the file URI to embedded file entities.
*/
class ContentEntityNormalizer extends BaseContentEntityNormalizer {
use SyncNormalizerDecoratorTrait;
/**
* @var SyncNormalizerDecoratorManager
*/
protected $decoratorManager;
/**
* The entity bundle info.
*
* @var \Drupal\Core\Entity\EntityTypeBundleInfoInterface
*/
protected $entityTypeBundleInfo;
/**
* The entity repository.
*
* @var \Drupal\Core\Entity\EntityRepositoryInterface
*/
protected $entityRepository;
/**
* Constructs an EntityNormalizer object.
*
* @param \Drupal\Core\Entity\EntityTypeManagerInterface $entity_type_manager
* The entity type manager.
* @param \Drupal\Core\Entity\EntityTypeRepositoryInterface $entity_type_repository
* The entity type repository.
* @param \Drupal\Core\Entity\EntityFieldManagerInterface $entity_field_manager
* The entity field manager.
* @param \Drupal\Core\Entity\EntityTypeBundleInfoInterface $entity_type_bundle_info
* The entity bundle info.
* @param \Drupal\Core\Entity\EntityRepositoryInterface $entity_repository
* The entity repository.
* @param SyncNormalizerDecoratorManager $decorator_manager
*/
public function __construct(EntityTypeManagerInterface $entity_type_manager, EntityTypeRepositoryInterface $entity_type_repository, EntityFieldManagerInterface $entity_field_manager, EntityTypeBundleInfoInterface $entity_type_bundle_info, EntityRepositoryInterface $entity_repository, SyncNormalizerDecoratorManager $decorator_manager) {
parent::__construct($entity_type_manager, $entity_type_repository, $entity_field_manager, $entity_type_bundle_info, $entity_repository, $decorator_manager);
// echo "construct called?";die;
$this->decoratorManager = $decorator_manager;
$this->entityRepository = $entity_repository;
$this->entityTypeBundleInfo = $entity_type_bundle_info;
}
/**
* {@inheritdoc}
*/
public function denormalize($data, $class, $format = NULL, array $context = []) {
if (is_null($data)) {
return NULL;
}
$original_data = $data;
// Get the entity type ID while letting context override the $class param.
// $entity_type_id = !empty($context['entity_type']) ? $context['entity_type'] : $this->entityTypeManager->getEntityTypeFromClass($class);
$entity_type_id = !empty($context['entity_type']) ? $context['entity_type'] : \Drupal::service('entity_type.repository')->getEntityTypeFromClass($class);
$bundle = FALSE;
/** @var \Drupal\Core\Entity\EntityTypeInterface $entity_type_definition */
// Get the entity type definition.
$entity_type_definition = $this->entityTypeManager->getDefinition($entity_type_id, FALSE);
if ($entity_type_definition->hasKey('bundle')) {
$bundle_key = $entity_type_definition->getKey('bundle');
// Get the base field definitions for this entity type.
$base_field_definitions = $this->entityFieldManager->getBaseFieldDefinitions($entity_type_id);
// Get the ID key from the base field definition for the bundle key or
// default to 'value'.
$key_id = isset($base_field_definitions[$bundle_key]) ? $base_field_definitions[$bundle_key]->getFieldStorageDefinition()
->getMainPropertyName() : 'value';
// Normalize the bundle if it is not explicitly set.
$bundle = isset($data[$bundle_key][0][$key_id]) ? $data[$bundle_key][0][$key_id] : (isset($data[$bundle_key]) ? $data[$bundle_key] : NULL);
}
// Decorate data before denormalizing it.
$this->decorateDenormalization($data, $entity_type_id, $format, $context);
// Resolve references
$this->fixReferences($data, $entity_type_id, $bundle);
// Remove invalid fields
$this->cleanupData($data, $entity_type_id, $bundle);
// Data to Entity
$entity = parent::denormalize($data, $class, $format, $context);
// Decorate denormalized entity before retuning it.
$this->decorateDenormalizedEntity($entity, $original_data, $format, $context);
return $entity;
}
/**
* {@inheritdoc}
*/
public function normalize($object, $format = NULL, array $context = []) {
/* @var ContentEntityInterface $object */
$normalized_data = parent::normalize($object, $format, $context);
$normalized_data['_content_deploy'] = $this->getContentSyncMetadata($object, $context);
/**
* @var \Drupal\Core\Entity\ContentEntityBase $object
*/
$referenced_entities = $object->referencedEntities();
// Add node uuid for menu link if any.
if ($object->getEntityTypeId() == 'menu_link_content') {
if ($entity = $this->getMenuLinkNodeAttached($object)) {
$normalized_data['_content_deploy']['menu_entity_link'][$entity->getEntityTypeId()] = $entity->uuid();
$referenced_entities[] = $entity;
}
}
if (!empty($referenced_entities)) {
$dependencies = [];
foreach ($referenced_entities as $entity) {
$reflection = new \ReflectionClass($entity);
if ($reflection->implementsInterface(ContentEntityInterface::class)) {
$ids = [
$entity->getEntityTypeId(),
$entity->bundle(),
$entity->uuid(),
];
$dependency = implode(ContentSyncManager::DELIMITER, $ids);
if (!$this->inDependencies($dependency, $dependencies)) {
$dependencies[$entity->getEntityTypeId()][] = $dependency;
}
}
}
$normalized_data['_content_deploy']['entity_dependencies'] = $dependencies;
}
// Decorate normalized entity before retuning it.
if (is_a($object, ContentEntityInterface::class, TRUE)) {
$this->decorateNormalization($normalized_data, $object, $format, $context);
}
return $normalized_data;
}
/**
* Checks if a dependency is in a dependencies nested array.
*
* @param string $dependency
* An entity identifier.
* @param $dependencies
* A nested array of dependencies.
*
* @return bool
*/
protected function inDependencies($dependency, $dependencies) {
list($entity_type_id, $bundle, $uuid) = explode('.', $dependency);
if (isset($dependencies[$entity_type_id])) {
if (in_array($dependency, $dependencies[$entity_type_id])) return TRUE;
}
return FALSE;
}
/**
* Gets a node attached to a menu link. The node has already been imported.
*
* @param \Drupal\menu_link_content\Entity\MenuLinkContent $object
* Menu Link Entity.
*
* @return \Drupal\Core\Entity\EntityInterface|null
* Node Entity.
*
*/
protected function getMenuLinkNodeAttached(MenuLinkContent $object) {
$uri = $object->get('link')->getString();
$url = Url::fromUri($uri);
try {
$route_parameters = $url->getRouteParameters();
if (count($route_parameters) == 1) {
$entity_id = reset($route_parameters);
$entity_type = key($route_parameters);
return \Drupal::entityTypeManager()->getStorage($entity_type)->load($entity_id);
}
}
catch (\Exception $e) {
// If menu link is linked to a non-node page - just do nothing.
}
}
/**
* @inheritdoc
*/
public function supportsNormalization($data, $format = NULL) {
return parent::supportsNormalization($data, $format) && !empty($data->is_content_deploy);
}
/**
* @inheritdoc
*/
public function supportsDenormalization($data, $type, $format = NULL) {
return parent::supportsDenormalization($data, $type, $format);
}
/**
* @param $object
* @param array $context
*
* @return array
*/
protected function getContentSyncMetadata($object, $context = []) {
$metadata = [
'entity_type' => $object->getEntityTypeId(),
];
return $metadata;
}
/**
* @inheritdoc
*/
protected function getDecoratorManager() {
return $this->decoratorManager;
}
/**
* @param array $data
* @param $entity_type_id
*
* @return array
*/
protected function fixReferences(&$data, $entity_type_id, $bundle = FALSE) {
if ($bundle) {
$field_definitions = $this->entityFieldManager->getFieldDefinitions($entity_type_id, $bundle);
}
else {
$bundles = array_keys($this->entityTypeBundleInfo->getBundleInfo($entity_type_id));
$field_definitions = [];
foreach ($bundles as $bundle) {
$field_definitions_bundle = $this->entityFieldManager->getFieldDefinitions($entity_type_id, $bundle);
if (is_array($field_definitions_bundle)) {
$field_definitions += $field_definitions_bundle;
}
}
}
foreach ($field_definitions as $field_name => $field_definition) {
// We are only interested in importing content entities.
if (!is_a($field_definition->getClass(), '\Drupal\Core\Field\EntityReferenceFieldItemList', TRUE)) {
continue;
}
if (!empty($data[$field_name]) && is_array($data[$field_name])) {
$key = $field_definition->getFieldStorageDefinition()
->getMainPropertyName();
foreach ($data[$field_name] as $i => &$item) {
if (!empty($item['target_uuid'])) {
$reference = $this->entityRepository->loadEntityByUuid($item['target_type'], $item['target_uuid']);
if ($reference) {
$item[$key] = $reference->id();
if (is_a($reference, RevisionableInterface::class, TRUE)) {
$item['target_revision_id'] = $reference->getRevisionId();
}
}
else {
$reflection = new \ReflectionClass($this->entityTypeManager->getStorage($item['target_type'])->getEntityType()->getClass());
if ($reflection->implementsInterface(ContentEntityInterface::class)) {
unset($data[$field_name][$i]);
}
}
}
}
}
}
return $data;
}
/**
* @param $data
* @param $entity_type_id
*/
protected function cleanupData(&$data, $entity_type_id, $bundle = FALSE) {
if ($bundle) {
$field_definitions = $this->entityFieldManager->getFieldDefinitions($entity_type_id, $bundle);
}
else {
$bundles = array_keys($this->entityTypeBundleInfo->getBundleInfo($entity_type_id));
$field_definitions = [];
foreach ($bundles as $bundle) {
$field_definitions_bundle = $this->entityFieldManager->getFieldDefinitions($entity_type_id, $bundle);
if (is_array($field_definitions_bundle)) {
$field_definitions += $field_definitions_bundle;
}
}
}
$field_names = array_keys($field_definitions);
foreach ($data as $field_name => $field_data) {
if (!in_array($field_name, $field_names)) {
unset($data[$field_name]);
}
}
}
}
