Commands.php

Go to the documentation of this file.

<?php
 
namespace Drupal\dkan_harvest\Drush;
 
use Symfony\Component\Console\Helper\Table;
use Symfony\Component\Console\Output\ConsoleOutput;
 
use Drush\Commands\DrushCommands;
 
class Commands extends DrushCommands {
  use Helper;
 
  protected $harvestFactory;
 
  protected $harvestService;
 
  protected $logger;
 
  public function __construct() {
    // @todo passing via arguments doesn't seem play well with drush.services.yml
    $this->harvestService = \Drupal::service('dkan_harvest.service');
    $this->logger = \Drupal::service('dkan_harvest.logger_channel');
  }
 
  public function index() {
    // Each row needs to be an array for display.
    $rows = array_map(
      function ($id) {
        return [$id];
      },
      $this->harvestService->getAllHarvestIds()
      );
    (new Table(new ConsoleOutput()))->setHeaders(['plan id'])->setRows($rows)->render();
  }
 
  public function register($harvest_plan) {
    try {
      $plan       = json_decode($harvest_plan);
      $identifier = $this->harvestService
        ->registerHarvest($plan);
      $this->logger->notice("Successfully registered the {$identifier} harvest.");
    }
    catch (\Exception $e) {
      $this->logger->error($e->getMessage());
      $this->logger->debug($e->getTraceAsString());
    }
  }
 
  public function deregister($id) {
    try {
      if ($this->harvestService->deregisterHarvest($id)) {
        $message = "Successfully deregistered the {$id} harvest.";
      }
    }
    catch (\Exception $e) {
      $message = $e->getMessage();
    }
 
    (new ConsoleOutput())->write($message . PHP_EOL);
  }
 
  public function run($id) {
    $result = $this->harvestService
      ->runHarvest($id);
 
    $this->renderResult($result);
  }
 
  public function runAll() {
 
    $ids = $this->harvestService
      ->getAllHarvestIds();;
 
    foreach ($ids as $id) {
      $this->run($id);
    }
  }
 
  public function info($id, $run_id = NULL) {
 
    if (!isset($run_id)) {
      $runs = $this->harvestService
        ->getAllHarvestRunInfo($id);
      $table = new Table(new ConsoleOutput());
      $table->setHeaders(["{$id} runs"]);
      foreach (array_keys($runs) as $run_id) {
        $table->addRow([$run_id]);
      }
      $table->render();
    }
    else {
      $run = $this->harvestService
        ->getHarvestRunInfo($id, $run_id);
      $result = json_decode($run);
      print_r($result);
    }
 
  }
 
  public function revert($id) {
 
    $result = $this->harvestService
      ->revertHarvest($id);
 
    (new ConsoleOutput())->write("{$result} items reverted for the '{$id}' harvest plan." . PHP_EOL);
  }
 
}