WebServiceApi.php

Go to the documentation of this file.

<?php
 
namespace Drupal\dkan_datastore;
 
use Symfony\Component\DependencyInjection\ContainerInterface;
use Symfony\Component\HttpFoundation\RequestStack;
use Drupal\Core\DependencyInjection\ContainerInjectionInterface;
use Drupal\dkan_common\JsonResponseTrait;
 
class WebServiceApi implements ContainerInjectionInterface {
  use JsonResponseTrait;
 
  protected $datastoreService;
 
  private $requestStack;
 
  public function __construct(Service $datastoreService, RequestStack $requestStack) {
    $this->datastoreService = $datastoreService;
    $this->requestStack = $requestStack;
  }
 
  public static function create(ContainerInterface $container) {
    $datastoreService = $container->get('dkan_datastore.service');
    $requestStack = $container->get('request_stack');
    return new WebServiceApi($datastoreService, $requestStack);
  }
 
  public function summary($identifier) {
    try {
      $storage = $this->datastoreService->getStorage($identifier);
      if ($storage) {
        $data = $storage->getSummary();
        return $this->getResponse($data);
      }
      throw new \Exception("no storage");
    }
    catch (\Exception $e) {
      $exception = new \Exception("A datastore for resource {$identifier} does not exist.");
      return $this->getResponseFromException($exception, 404);
    }
  }
 
  public function import() {
 
    $payloadJson = $this->requestStack->getCurrentRequest()->getContent();
    $payload = json_decode($payloadJson);
 
    if (isset($payload->resource_ids)) {
      return $this->importMultiple($payload->resource_ids);
    }
 
    if (!isset($payload->resource_id)) {
      return $this->getResponseFromException(new \Exception("Invalid payload."));
    }
 
    try {
      $results = $this->datastoreService->import($payload->resource_id, FALSE);
      return $this->getResponse($results);
    }
    catch (\Exception $e) {
      return $this->getResponseFromException($e);
    }
  }
 
  private function importMultiple(array $resourceIds) {
 
    $responses = [];
    foreach ($resourceIds as $identifier) {
      try {
        $results = $this->datastoreService->import($identifier, TRUE);
        $responses[$identifier] = $results;
      }
      catch (\Exception $e) {
        $responses[$identifier] = $e->getMessage();
      }
    }
 
    return $this->getResponse($responses);
  }
 
  public function delete($identifier) {
    try {
      $this->datastoreService->drop($identifier);
      return $this->getResponse(
        [
          "identifier" => $identifier,
          "message" => "The datastore for resource {$identifier} was succesfully dropped.",
        ]
      );
    }
    catch (\Exception $e) {
      return $this->getResponseFromException($e);
    }
  }
 
  public function deleteMultiple() {
    $payloadJson = $this->requestStack->getCurrentRequest()->getContent();
    $payload = json_decode($payloadJson);
 
    if (!isset($payload->resource_ids)) {
      return $this->getResponseFromException(new \Exception("Invalid payload."));
    }
 
    $identifiers = $payload->resource_ids;
 
    $responses = [];
    foreach ($identifiers as $identifier) {
      $responses[$identifier] = json_decode($this->delete($identifier)->getContent());
    }
 
    return $this->getResponse($responses);
  }
 
  public function list() {
    try {
      $data = $this->datastoreService->list();
      return $this->getResponse($data);
    }
    catch (\Exception $e) {
      return $this->getResponseFromException(
        new \Exception("No importer data was returned. {$e->getMessage()}"),
        404
      );
    }
  }
 
}