Service.php

Go to the documentation of this file.

<?php
 
namespace Drupal\dkan_datastore;
 
use Drupal\dkan_datastore\Storage\JobStoreFactory;
use Symfony\Component\DependencyInjection\ContainerInterface;
use Drupal\Core\DependencyInjection\ContainerInjectionInterface;
use Drupal\Core\Queue\QueueFactory;
use Drupal\dkan_datastore\Service\Factory\Resource;
use Drupal\dkan_datastore\Service\Factory\Import;
use Drupal\dkan_datastore\Service\ImporterList\ImporterList;
use Dkan\Datastore\Importer;
 
class Service implements ContainerInjectionInterface {
 
  private $resourceServiceFactory;
  private $importServiceFactory;
  private $queue;
  private $jobStoreFactory;
 
  public static function create(ContainerInterface $container) {
    return new Service(
      $container->get('dkan_datastore.service.factory.resource'),
      $container->get('dkan_datastore.service.factory.import'),
      $container->get('queue'),
      $container->get('dkan_datastore.job_store_factory')
    );
  }
 
  public function __construct(Resource $resourceServiceFactory, Import $importServiceFactory, QueueFactory $queue, JobStoreFactory $jobStoreFactory) {
    $this->queue = $queue->get('dkan_datastore_import');
    $this->resourceServiceFactory = $resourceServiceFactory;
    $this->importServiceFactory = $importServiceFactory;
    $this->jobStoreFactory = $jobStoreFactory;
  }
 
  public function import(string $uuid, bool $deferred = FALSE): array {
 
    $resourceService = $this->resourceServiceFactory->getInstance($uuid);
 
    // If we passed $deferred, immediately add to the queue for later.
    if (!empty($deferred)) {
      // This creates a filefetcher job.
      $resourceService->get(TRUE, FALSE);
      $queueId = $this->queueImport($uuid);
      return [
        'message' => "Resource {$uuid} has been queued to be imported.",
        'queue_id' => $queueId,
      ];
    }
 
    /* @var $resource \Dkan\Datastore\Resource */
    $resource = $resourceService->get(TRUE);
    if (!$resource) {
      $name = substr(strrchr(get_class($resourceService), "\\"), 1);
      return [$name => $resourceService->getResult()];
    }
 
    $importService = $this->importServiceFactory->getInstance($resource->getId(), ['resource' => $resource]);
    $importService->import();
 
    $rname = substr(strrchr(get_class($resourceService), "\\"), 1);
    $iname = substr(strrchr(get_class($importService), "\\"), 1);
 
    return [
      $rname => $resourceService->getResult(),
      $iname => $importService->getResult(),
    ];
  }
 
  public function drop($uuid) {
    $storage = $this->getStorage($uuid);
    if ($storage) {
      $storage->destroy();
    }
 
    /* @var $resourceService \Drupal\dkan_datastore\Service\Resource */
    $resourceService = $this->resourceServiceFactory->getInstance($uuid);
    $resourceService->remove();
 
    /* @var $resource \Dkan\Datastore\Resource */
    $resource = $resourceService->get();
    $this->jobStoreFactory->getInstance(Importer::class)->remove($resource->getId());
 
  }
 
  private function queueImport($uuid) {
    // Attempt to fetch the file in a queue so as to not block user.
    $queueId = $this->queue->createItem(['uuid' => $uuid]);
 
    if ($queueId === FALSE) {
      throw new \RuntimeException("Failed to create file fetcher queue for {$uuid}");
    }
 
    return $queueId;
  }
 
  public function list() {
    return ImporterList::getList($this->jobStoreFactory, $this->resourceServiceFactory, $this->importServiceFactory);
  }
 
  public function getStorage(string $uuid) {
    $resourceService = $this->resourceServiceFactory->getInstance($uuid);
 
    /* @var $resource \Dkan\Datastore\Resource */
    $resource = $resourceService->get();
    if ($resource) {
      $importService = $this->importServiceFactory->getInstance($resource->getId(),
        ['resource' => $resource]);
      return $importService->getStorage();
    }
    return NULL;
  }
 
}