DataNodeLifeCycle.php

Go to the documentation of this file.

<?php
 
namespace Drupal\dkan_data;
 
use Drupal\dkan_common\AbstractDataNodeLifeCycle;
use Drupal\dkan_common\UrlHostTokenResolver;
 
class DataNodeLifeCycle extends AbstractDataNodeLifeCycle {
 
  public function presave() {
 
    if (empty($this->getDataType())) {
      $this->setDataType('dataset');
    }
 
    switch ($this->getDataType()) {
      case 'dataset':
        $this->datasetPresave();
        break;
 
      case 'distribution':
        $this->distributionPresave();
        break;
    }
  }
 
  private function datasetPresave() {
    /* @var $entity \Drupal\node\Entity\Node */
    $entity = $this->node;
 
    $metadata = $this->getMetaData();
 
    $title = isset($metadata->title) ? $metadata->title : $metadata->name;
 
    $entity->setTitle($title);
 
    // If there is no uuid add one.
    if (!isset($metadata->identifier)) {
      $metadata->identifier = $entity->uuid();
    }
    // If one exists in the uuid it should be the same in the table.
    else {
      $entity->set('uuid', $metadata->identifier);
    }
 
    $referencer = \Drupal::service("dkan_data.referencer");
    $metadata = $referencer->reference($this->getMetaData());
    $this->setMetadata($metadata);
 
    // Check for possible orphan property references when updating a dataset.
    if (isset($entity->original)) {
      $orphanChecker = \Drupal::service("dkan_data.orphan_checker");
      $orphanChecker->processReferencesInUpdatedDataset(
        json_decode($entity->referenced_metadata),
        $metadata
      );
    }
  }
 
  private function distributionPresave() {
    $metadata = $this->getMetaData();
    $host = \Drupal::request()->getHost();
    if (isset($metadata->data->downloadURL)) {
      $newUrl = $metadata->data->downloadURL;
      $parsedUrl = parse_url($newUrl);
      if ($parsedUrl['host'] == $host) {
        $parsedUrl['host'] = UrlHostTokenResolver::TOKEN;
        $metadata->data->downloadURL = $this->unparseUrl($parsedUrl);
        $this->setMetadata($metadata);
      }
    }
 
  }
 
  private function unparseUrl($parsedUrl) {
    $url = '';
    $urlParts = [
      'scheme',
      'host',
      'port',
      'user',
      'pass',
      'path',
      'query',
      'fragment',
    ];
 
    foreach ($urlParts as $part) {
      if (!isset($parsedUrl[$part])) {
        continue;
      }
      $url .= ($part == "port") ? ':' : '';
      $url .= ($part == "query") ? '?' : '';
      $url .= ($part == "fragment") ? '#' : '';
      $url .= $parsedUrl[$part];
      $url .= ($part == "scheme") ? '://' : '';
    }
 
    return $url;
  }
 
}