Helper.php

Go to the documentation of this file.

<?php
 
namespace Drupal\dkan_harvest\Drush;
 
use Drupal\dkan_harvest\Storage\DatabaseTable;
use Harvest\ETL\Factory;
use Harvest\Harvester;
use Harvest\ResultInterpreter;
use Symfony\Component\Console\Helper\Table;
use Symfony\Component\Console\Output\ConsoleOutput;
 
trait Helper {
 
  private function getHarvester($id) {
 
    if (!method_exists($this, 'getHarvestPlan')) {
      throw new \Exception("Drupal\dkan_harvest\Drush\Helper requires the host to implement the getHarvestPlan method.");
    }
 
    return new Harvester(new Factory($this->getHarvestPlan($id),
      $this->getStorage($id, "item"),
      $this->getStorage($id, "hash")));
  }
 
  private function getPlanStorage() {
    $connection = \Drupal::service('database');
    return new DatabaseTable($connection, "harvest_plans");
  }
 
  private function getStorage($id, $type) {
    $connection = \Drupal::service('database');
    return new DatabaseTable($connection, "harvest_{$id}_{$type}");
  }
 
  private function renderResult($result) {
    $interpreter = new ResultInterpreter($result);
 
    $table = new Table(new ConsoleOutput());
    $table->setHeaders(['processed', 'created', 'updated', 'errors']);
    $table->addRow([
      $interpreter->countProcessed(),
      $interpreter->countCreated(),
      $interpreter->countUpdated(),
      $interpreter->countFailed(),
    ]);
    $table->render();
  }
 
}