Referencer.php

Go to the documentation of this file.

<?php
 
namespace Drupal\dkan_data\Reference;
 
use Drupal\Core\Config\ConfigFactoryInterface;
use Drupal\Core\Entity\EntityTypeManager;
use Drupal\dkan_common\LoggerTrait;
use stdClass;
 
class Referencer {
  use HelperTrait;
  use LoggerTrait;
 
  private $entityTypeManager;
 
  public function __construct(ConfigFactoryInterface $configService, EntityTypeManager $entityTypeManager) {
    $this->setConfigService($configService);
    $this->entityTypeManager = $entityTypeManager;
  }
 
  public function reference(stdClass $data) {
    // Cycle through the dataset properties we seek to reference.
    foreach ($this->getPropertyList() as $property_id) {
      if (isset($data->{$property_id})) {
        $data->{$property_id} = $this->referenceProperty($property_id, $data->{$property_id});
      }
    }
    return $data;
  }
 
  private function referenceProperty(string $property_id, $data) {
    if (is_array($data)) {
      return $this->referenceMultiple($property_id, $data);
    }
    else {
      // Case for $data being an object or a string.
      return $this->referenceSingle($property_id, $data);
    }
  }
 
  private function referenceMultiple(string $property_id, array $values) : array {
    $result = [];
    foreach ($values as $value) {
      $data = $this->referenceSingle($property_id, $value);
      if (NULL !== $data) {
        $result[] = $data;
      }
    }
    return $result;
  }
 
  private function referenceSingle(string $property_id, $value) {
    $uuid = $this->checkExistingReference($property_id, $value);
    if (!$uuid) {
      $uuid = $this->createPropertyReference($property_id, $value);
    }
    if ($uuid) {
      return $uuid;
    }
    else {
      if ($this->loggerService) {
        $this->loggerService->get('value_referencer')->error(
          'Neither found an existing nor could create a new reference for property_id: @property_id with value: @value',
          [
            '@property_id' => $property_id,
            '@value' => var_export($value, TRUE),
          ]
        );
      }
      return NULL;
    }
  }
 
  private function checkExistingReference(string $property_id, $data) {
    $nodes = $this->entityTypeManager
      ->getStorage('node')
      ->loadByProperties([
        'field_data_type' => $property_id,
        'title' => md5(json_encode($data)),
      ]);
 
    if ($node = reset($nodes)) {
      return $node->uuid();
    }
    return NULL;
  }
 
  private function createPropertyReference(string $property_id, $value) {
    // Create json metadata for the reference.
    $data = new stdClass();
    $data->identifier = $this->getUuidService()->generate($property_id, $value);
    $data->data = $value;
 
    // Create node to store this reference.
    $node = $this->entityTypeManager
      ->getStorage('node')
      ->create([
        'title' => md5(json_encode($value)),
        'type' => 'data',
        'uuid' => $data->identifier,
        'field_data_type' => $property_id,
        'field_json_metadata' => json_encode($data),
      ]);
    $node->save();
 
    return $node->uuid();
  }
 
}