Api.php

Go to the documentation of this file.

<?php
 
namespace Drupal\dkan_harvest\Controller;
 
use Drupal\Core\DependencyInjection\ContainerInjectionInterface;
use Symfony\Component\DependencyInjection\ContainerInterface;
use Symfony\Component\HttpFoundation\JsonResponse;
 
class Api implements ContainerInjectionInterface {
 
  private $requestStack;
 
  private $harvester;
 
  public static function create(ContainerInterface $container) {
    return new Api($container);
  }
 
  public function __construct(ContainerInterface $container) {
    $this->requestStack = $container->get('request_stack');
    $this->harvester = $container->get('dkan_harvest.service');
  }
 
  public function index() {
 
    try {
 
      $rows = $this->harvester
        ->getAllHarvestIds();
 
      return new JsonResponse(
            $rows,
            200,
            ["Access-Control-Allow-Origin" => "*"]
      );
    }
    catch (\Exception $e) {
      return $this->exceptionJsonResponse($e);
    }
  }
 
  public function getPlan($identifier) {
    try {
      $plan = $this->harvester
        ->getHarvestPlan($identifier);
 
      return new JsonResponse(
        json_decode($plan),
        200,
        ["Access-Control-Allow-Origin" => "*"]
      );
    }
    catch (\Exception $e) {
      return $this->exceptionJsonResponse($e);
    }
  }
 
  public function register() {
    try {
      $harvest_plan = $this->requestStack->getCurrentRequest()->getContent();
      $plan = json_decode($harvest_plan);
      $identifier = $this->harvester
        ->registerHarvest($plan);
 
      return new JsonResponse(
            (object) [
              "identifier" => $identifier,
            ],
            200,
            [
              "Access-Control-Allow-Origin" => "*",
            ]
      );
    }
    catch (\Exception $e) {
      return $this->exceptionJsonResponse($e);
    }
  }
 
  public function deregister($identifier) {
 
    try {
 
      $this->harvester
        ->deregisterHarvest($identifier);
 
      return new JsonResponse(
            (object) [
              "identifier" => $identifier,
            ],
            200,
            ["Access-Control-Allow-Origin" => "*"]
      );
    }
    catch (\Exception $e) {
      return $this->exceptionJsonResponse($e);
    }
  }
 
  public function run() {
    try {
      $payloadJson = $this->requestStack->getCurrentRequest()->getContent();
      $payload = json_decode($payloadJson);
      if (!isset($payload->plan_id)) {
        $return = [
          "message" => "Invalid payload.",
          "documentation" => "/api/1/harvest",
        ];
        return $this->jsonResponse($return, 422);
      }
 
      $id = $payload->plan_id;
      $result = $this->harvester
        ->runHarvest($id);
 
      return new JsonResponse(
            (object) [
              "identifier" => $id,
              "result"     => $result,
            ],
            200,
            ["Access-Control-Allow-Origin" => "*"]
      );
    }
    catch (\Exception $e) {
      return $this->exceptionJsonResponse($e);
    }
  }
 
  public function info() {
 
    try {
      $id = $this->requestStack->getCurrentRequest()->get('plan');
      if (empty($id)) {
        return new JsonResponse(
          ["message" => "Missing 'plan' query parameter value"],
          400,
          ["Access-Control-Allow-Origin" => "*"]
        );
      }
 
      $response = $this->harvester
        ->getAllHarvestRunInfo($id);
 
      return new JsonResponse(
            $response,
            200,
            ["Access-Control-Allow-Origin" => "*"]
      );
    }
    catch (\Exception $e) {
      return $this->exceptionJsonResponse($e);
    }
  }
 
  public function infoRun($identifier) {
 
    $id = $this->requestStack->getCurrentRequest()->get('plan');
    if (empty($id)) {
      return new JsonResponse(
        ["message" => "Missing 'plan' query parameter value"],
        400,
        ["Access-Control-Allow-Origin" => "*"]
      );
    }
 
    try {
      $response = $this->harvester
        ->getHarvestRunInfo($id, $identifier);
 
      return new JsonResponse(
            json_decode($response),
            200,
            ["Access-Control-Allow-Origin" => "*"]
      );
    }
    catch (\Exception $e) {
      return $this->exceptionJsonResponse($e);
    }
  }
 
  public function revert() {
    try {
 
      $id = $this->requestStack->getCurrentRequest()->get('plan');
      if (empty($id)) {
        return new JsonResponse(
          ["message" => "Missing 'plan' query parameter value"],
          400,
          ["Access-Control-Allow-Origin" => "*"]
        );
      }
 
      $result = $this->harvester
        ->revertHarvest($id);
 
      return new JsonResponse(
            (object) [
              "identifier" => $id,
              'result'     => $result,
            ],
            200,
            [
              "Access-Control-Allow-Origin" => "*",
            ]
      );
    }
    catch (\Exception $e) {
      return $this->exceptionJsonResponse($e);
    }
  }
 
  private function exceptionJsonResponse(\Exception $e, int $code = 400) {
    return $this->jsonResponse(['message' => $e->getMessage()], $code);
  }
 
  private function jsonResponse(array $return, int $code = 400) {
    return new JsonResponse(
      (object) $return,
      $code
    );
  }
 
}