Import.php

Go to the documentation of this file.

<?php
 
namespace Drupal\dkan_datastore\Service;
 
use CsvParser\Parser\Csv;
use Dkan\Datastore\Importer;
use Drupal\dkan_datastore\Storage\DatabaseTable;
use Drupal\dkan_datastore\Storage\JobStoreFactory;
use Procrastinator\Result;
use Dkan\Datastore\Resource;
use Drupal\dkan_datastore\Storage\DatabaseTableFactory;
 
class Import {
  const DEFAULT_TIMELIMIT = 50;
 
  private $resource;
  private $jobStoreFactory;
  private $databaseTableFactory;
 
  public function __construct(Resource $resource, JobStoreFactory $jobStoreFactory, DatabaseTableFactory $databaseTableFactory) {
    $this->resource = $resource;
    $this->jobStoreFactory = $jobStoreFactory;
    $this->databaseTableFactory = $databaseTableFactory;
  }
 
  public function import() {
    $importer = $this->getImporter();
    $importer->run();
  }
 
  public function getResult(): Result {
    $importer = $this->getImporter();
    return $importer->getResult();
  }
 
  public function getImporter(): Importer {
    $delimiter = ",";
    if ($this->resource->getMimeType() == 'text/tab-separated-values') {
      $delimiter = "\t";
    }
 
    $importer = Importer::get($this->resource->getId(),
      $this->jobStoreFactory->getInstance(Importer::class),
      [
        "storage" => $this->getStorage(),
        "parser" => $this->getNonRecordingParser($delimiter),
        "resource" => $this->resource,
      ]
    );
 
    $importer->setTimeLimit(self::DEFAULT_TIMELIMIT);
 
    return $importer;
  }
 
  private function getNonRecordingParser(string $delimiter) : Csv {
    $parser = Csv::getParser($delimiter);
    $parser->machine->stopRecording();
    return $parser;
  }
 
  public function getStorage(): DatabaseTable {
    return $this->databaseTableFactory->getInstance($this->resource->getId(), ['resource' => $this->resource]);
  }
 
}