OrphanChecker.php

Go to the documentation of this file.

<?php
 
namespace Drupal\metastore\Reference;
 
use Drupal\Core\Config\ConfigFactoryInterface;
use Drupal\Core\Queue\QueueFactory;
 
class OrphanChecker {
  use HelperTrait;
 
  protected $queueService;
 
  public function __construct(ConfigFactoryInterface $configService, QueueFactory $queueService) {
    $this->queueService = $queueService;
    $this->setConfigService($configService);
  }
 
  public function processReferencesInDeletedDataset($data) {
    if (!is_object($data)) {
      throw new \Exception("data must be an object.");
    }
    // Cycle through the dataset properties we seek to reference.
    foreach ($this->getPropertyList() as $property_id) {
      if (isset($data->{$property_id})) {
        $this->processReferencesInDeletedProperty($property_id, $data->{$property_id});
      }
    }
  }
 
  public function processReferencesInUpdatedDataset($old_dataset, $new_dataset) {
    $this->objectsCheck([$old_dataset, $new_dataset]);
    // Cycle through the dataset properties being referenced, check for orphans.
    foreach ($this->getPropertyList() as $property_id) {
      if (!isset($old_dataset->{$property_id})) {
        // The old dataset had no value for this property, thus no references
        // could be deleted. Safe to skip checking for orphan reference.
        continue;
      }
      $oldProperty = $old_dataset->{$property_id};
      $newProperty = (!isset($new_dataset->{$property_id})) ?
        $this->emptyPropertyOfSameType($oldProperty) :
        $new_dataset->{$property_id};
 
      $this->processReferencesInUpdatedProperty($property_id, $oldProperty, $newProperty);
    }
  }
 
  private function processReferencesInDeletedProperty($property_id, $uuids) {
    // Treat single uuid as an array of one uuid.
    if (!is_array($uuids)) {
      $uuids = [$uuids];
    }
    foreach ($uuids as $uuid) {
      $this->queueReferenceForRemoval($property_id, $uuid);
    }
  }
 
  private function queueReferenceForRemoval($property_id, $uuid) {
    $this->queueService->get('orphan_reference_processor')
      ->createItem([
        $property_id,
        $uuid,
      ]);
  }
 
  private function processReferencesInUpdatedProperty($property_id, $old_value, $new_value) {
    if (!is_array($old_value)) {
      $old_value = [$old_value];
      $new_value = [$new_value];
    }
 
    foreach (array_diff($old_value, $new_value) as $removed_reference) {
      $this->queueReferenceForRemoval($property_id, $removed_reference);
    }
  }
 
  private function objectsCheck($objects) {
    foreach ($objects as $object) {
      if (!is_object($object)) {
        throw new \Exception("data given must be an object.");
      }
    }
  }
 
}