ImporterList.php

Go to the documentation of this file.

<?php
 
namespace Drupal\dkan_datastore\Service\ImporterList;
 
use Drupal\dkan_datastore\Service\Factory\Import;
use Drupal\dkan_datastore\Service\Factory\Resource;
use Drupal\dkan_datastore\Storage\JobStoreFactory;
use FileFetcher\FileFetcher;
 
class ImporterList {
 
  private $jobStoreFactory;
 
  private $resourceServiceFactory;
  private $importServiceFactory;
 
  public function __construct(JobStoreFactory $jobStoreFactory, Resource $resrouceServiceFactory, Import $importServiceFactory) {
    $this->jobStoreFactory = $jobStoreFactory;
    $this->resourceServiceFactory = $resrouceServiceFactory;
    $this->importServiceFactory = $importServiceFactory;
  }
 
  private function buildList() {
    $list = [];
 
    $fileFetchers = [];
    $importers = [];
 
    $store = $this->jobStoreFactory->getInstance(FileFetcher::class);
    foreach ($store->retrieveAll() as $id) {
      try {
        $fileFetchers[$id] = $this->resourceServiceFactory->getInstance($id)
          ->getFileFetcher();
 
        /* @var $resource \Dkan\Datastore\Resource */
        $resource = $this->resourceServiceFactory->getInstance($id)->get();
        $importers[$id] = $this->importServiceFactory->getInstance($resource->getId(),
          ['resource' => $resource])->getImporter();
      }
      catch (\Exception $e) {
        // The file fetcher id is not a resource.
      }
    }
 
    foreach ($fileFetchers as $uuid => $fileFetcher) {
      $importer = isset($importers[$uuid]) ? $importers[$uuid] : NULL;
      $list[$uuid] = ImporterListItem::getItem($fileFetcher, $importer);
    }
 
    return $list;
  }
 
  public static function getList(JobStoreFactory $jobStoreFactory, Resource $resrouceServiceFactory, Import $importServiceFactory): array {
    $importerLister = new ImporterList($jobStoreFactory, $resrouceServiceFactory, $importServiceFactory);
    return $importerLister->buildList();
  }
 
}