OrphanReferenceProcessor.php

Go to the documentation of this file.

<?php
 
declare(strict_types = 1);
 
namespace Drupal\dkan_data\Plugin\QueueWorker;
 
use Drupal\Core\Entity\EntityTypeManagerInterface;
use Drupal\Core\Plugin\ContainerFactoryPluginInterface;
use Drupal\Core\Queue\QueueWorkerBase;
use Symfony\Component\DependencyInjection\ContainerInterface;
 
class OrphanReferenceProcessor extends QueueWorkerBase implements ContainerFactoryPluginInterface {
 
  protected $entityTypeManager;
 
  public function __construct(array $configuration, $plugin_id, $plugin_definition, EntityTypeManagerInterface $entity_type_manager) {
    parent::__construct($configuration, $plugin_id, $plugin_definition);
    $this->entityTypeManager = $entity_type_manager;
  }
 
  public static function create(ContainerInterface $container, array $configuration, $plugin_id, $plugin_definition) {
    return new static(
          $configuration,
          $plugin_id,
          $plugin_definition,
          $container->get('entity_type.manager')
      );
  }
 
  public function processItem($data) {
    $property_id = $data[0];
    $uuid = $data[1];
 
    // Search datasets using this uuid for this property id.
    $datasets = $this->entityTypeManager->getStorage('node')
      ->loadByProperties(
              [
                'field_data_type' => 'dataset',
              ]
          );
    foreach ($datasets as $dataset) {
      $data = json_decode($dataset->referenced_metadata);
      $value = $data->{$property_id};
      // Check if uuid is found either directly or in an array.
      $uuid_is_value = $uuid == $value;
      $uuid_found_in_array = is_array($value) && in_array($uuid, $value);
      if ($uuid_is_value || $uuid_found_in_array) {
        // Uuid found in use, abort.
        return;
      }
    }
 
    // Value reference uuid not found in any dataset, therefore safe to delete.
    $this->deleteReference($property_id, $uuid);
  }
 
  protected function deleteReference(string $property_id, string $uuid) {
    $references = $this->entityTypeManager->getStorage('node')
      ->loadByProperties(
              [
                'field_data_type' => $property_id,
                'uuid' => $uuid,
              ]
          );
    if (FALSE !== ($reference = reset($references))) {
      $reference->delete();
    }
  }
 
}