WebServiceApi.php

Go to the documentation of this file.

<?php
 
namespace Drupal\dkan_metastore;
 
use Drupal\dkan_metastore\Exception\CannotChangeUuidException;
use Drupal\dkan_metastore\Exception\InvalidJsonException;
use Drupal\dkan_metastore\Exception\MetastoreException;
use Drupal\dkan_metastore\Exception\MissingPayloadException;
use Symfony\Component\HttpFoundation\JsonResponse;
use Symfony\Component\HttpFoundation\RequestStack;
use Symfony\Component\DependencyInjection\ContainerInterface;
use Drupal\Core\DependencyInjection\ContainerInjectionInterface;
use Drupal\dkan_common\JsonResponseTrait;
 
class WebServiceApi implements ContainerInjectionInterface {
  use JsonResponseTrait;
 
  private $requestStack;
 
  private $service;
 
  public static function create(ContainerInterface $container) {
    return new WebServiceApi(
      $container->get('request_stack'),
      $container->get('dkan_metastore.service')
    );
  }
 
  public function __construct(RequestStack $requestStack, Service $service) {
    $this->requestStack = $requestStack;
    $this->service = $service;
  }
 
  public function getSchemas() {
    return $this->getResponse($this->service->getSchemas());
  }
 
  public function getSchema(string $identifier) {
    return $this->getResponse($this->service->getSchema($identifier));
  }
 
  public function getAll(string $schema_id) {
    return $this->getResponse($this->service->getAll($schema_id));
  }
 
  public function get(string $schema_id, string $identifier) {
    try {
      $object = json_decode($this->service->get($schema_id, $identifier));
      return $this->getResponse($object);
    }
    catch (\Exception $e) {
      return $this->getResponseFromException($e, 404);
    }
  }
 
  public function getResources(string $schema_id, string $identifier) {
    try {
      return $this->getResponse($this->service->getResources($schema_id, $identifier));
    }
    catch (\Exception $e) {
      return $this->getResponseFromException($e, 404);
    }
  }
 
  public function post(string $schema_id) {
    try {
      $data = $this->getRequestContent();
      $this->checkData($data);
      $identifier = $this->service->post($schema_id, $data);
      return $this->getResponse([
        "endpoint" => "{$this->getRequestUri()}/{$identifier}",
        "identifier" => $identifier,
      ], 201);
    }
    catch (MetastoreException $e) {
      return $this->getResponseFromException($e, $e->httpCode());
    }
    catch (\Exception $e) {
      return $this->getResponseFromException($e, 400);
    }
  }
 
  public function put($schema_id, string $identifier) {
    try {
      $data = $this->getRequestContent();
      $this->checkData($data, $identifier);
      $info = $this->service->put($schema_id, $identifier, $data);
      $code = ($info['new'] == TRUE) ? 201 : 200;
      return $this->getResponse(["endpoint" => $this->getRequestUri(), "identifier" => $info['identifier']], $code);
    }
    catch (MetastoreException $e) {
      return $this->getResponseFromException($e, $e->httpCode());
    }
    catch (\Exception $e) {
      return $this->getResponseFromException($e, 400);
    }
  }
 
  public function patch($schema_id, $identifier) {
 
    try {
      $data = $this->getRequestContent();
      $this->checkData($data, $identifier);
      $this->service->patch($schema_id, $identifier, $data);
      return $this->getResponse((object) ["endpoint" => $this->getRequestUri(), "identifier" => $identifier]);
    }
    catch (MetastoreException $e) {
      return $this->getResponseFromException($e, $e->httpCode());
    }
    catch (\Exception $e) {
      return $this->getResponseFromException($e, 400);
    }
  }
 
  public function delete($schema_id, $identifier) {
    try {
      $this->service->delete($schema_id, $identifier);
      return $this->getResponse((object) ["message" => "Dataset {$identifier} has been deleted."]);
    }
    catch (\Exception $e) {
      return $this->getResponseFromException($e);
    }
  }
 
  public function getCatalog() : JsonResponse {
    try {
      return $this->getResponse($this->service->getCatalog());
    }
    catch (\Exception $e) {
      return $this->getResponseFromException($e);
    }
  }
 
  private function checkData($data, $identifier = NULL) {
 
    if (empty($data)) {
      throw new MissingPayloadException("Empty body");
    }
 
    $obj = json_decode($data);
 
    if (!$obj) {
      throw new InvalidJsonException("Invalid JSON");
    }
 
    if (isset($identifier) && isset($obj->identifier) && $obj->identifier != $identifier) {
      throw new CannotChangeUuidException("Identifier cannot be modified");
    }
  }
 
  private function getRequestUri(): string {
    return $this->requestStack->getCurrentRequest()->getRequestUri();
  }
 
  private function getRequestContent(): string {
    return $this->requestStack->getCurrentRequest()->getContent();
  }
 
}