DataNodeLifeCycle.php

Go to the documentation of this file.

<?php
 
namespace Drupal\dkan_datastore;
 
use Drupal\dkan_common\AbstractDataNodeLifeCycle;
use Drupal\dkan_common\LoggerTrait;
 
class DataNodeLifeCycle extends AbstractDataNodeLifeCycle {
  use LoggerTrait;
 
  public function insert() {
    $entity = $this->node;
    if ($this->getDataType() != 'distribution') {
      return;
    }
 
    if ($this->isDataStorable()) {
      try {
        /* @var $datastoreService \Drupal\dkan_datastore\Service */
        $datastoreService = \Drupal::service('dkan_datastore.service');
        $datastoreService->import($entity->uuid(), TRUE);
      }
      catch (\Exception $e) {
        $this->setLoggerFactory(\Drupal::service('logger.factory'));
        $this->log('dkan_datastore', $e->getMessage());
      }
    }
 
  }
 
  public function predelete() {
    $entity = $this->node;
    if ($this->getDataType() != 'distribution') {
      return;
    }
 
    try {
      /* @var $datastoreService \Drupal\dkan_datastore\Service */
      $datastoreService = \Drupal::service('dkan_datastore.service');
      $datastoreService->drop($entity->uuid());
    }
    catch (\Exception $e) {
      $this->setLoggerFactory(\Drupal::service('logger.factory'));
      $this->log('dkan_datastore', $e->getMessage());
    }
 
    $metadata = $this->getMetaData();
    $data = $metadata->data;
    if (isset($data->downloadURL)) {
      $url = $data->downloadURL;
      $pieces = explode('sites/default/files/', $url);
      $path = "public://" . end($pieces);
      $fileSystemService = \Drupal::service('file_system');
      $fileSystemService->delete($path);
    }
  }
 
  private function isDataStorable() : bool {
    $metadata = $this->getMetaData();
    $data = $metadata->data;
 
    if (isset($data->downloadURL) && isset($data->mediaType)) {
      return in_array($data->mediaType, [
        'text/csv',
        'text/tab-separated-values',
      ]);
    }
 
    return FALSE;
  }
 
}