ImporterListItem.php

Go to the documentation of this file.

<?php
 
namespace Drupal\dkan_datastore\Service\ImporterList;
 
use Dkan\Datastore\Importer;
use FileFetcher\FileFetcher;
use Procrastinator\Job\Job;
 
class ImporterListItem {
 
  public $fileFetcher;
 
  public $importer;
 
  public $fileFetcherStatus;
 
  public $fileFetcherPercentDone;
 
  public $fileFetcherBytes;
 
  public $fileName;
 
  public $importerStatus;
 
  public $importerBytes;
 
 
  public $importerPercentDone;
 
  public function __construct(FileFetcher $fileFetcher, $importer = NULL) {
    $this->fileFetcher = $fileFetcher;
    $this->importer = $importer;
  }
 
  public static function getItem(FileFetcher $fileFetcher, $importer = NULL) {
    $item = new ImporterListItem($fileFetcher, $importer);
    $item->buildItem();
    return $item;
  }
 
  private function buildItem() {
    $this->fileName = $this->getFileName();
    $this->fileFetcherStatus = $this->fileFetcher->getResult()->getStatus();
    $this->fileFetcherBytes = $this->getBytesProcessed($this->fileFetcher);
    $this->fileFetcherPercentDone = $this->getPercentDone($this->fileFetcher);
    $this->importerStatus = 'waiting';
    $this->importerBytes = 0;
    $this->importerPercentDone = 0;
 
    if (isset($this->importer)) {
      $this->importerStatus = $this->importer->getResult()->getStatus();
      $this->importerBytes = $this->getBytesProcessed($this->importer);
      $this->importerPercentDone = $this->getPercentDone($this->importer);
    }
  }
 
  private function getFileName(): string {
    $fileLocation = $this->fileFetcher->getStateProperty('source');
    $locationParts = explode('/', $fileLocation);
    return end($locationParts);
  }
 
  private function getPercentDone(Job $job): float {
    $bytes = $this->getBytesProcessed($job);
    $filesize = $this->getFileSize();
    return ($filesize > 0) ? round($bytes / $filesize * 100) : 0;
  }
 
  private function getFileSize(): int {
    return $this->fileFetcher->getStateProperty('total_bytes');
  }
 
  private function getBytesProcessed(Job $job): int {
    $className = get_class($job);
    switch ($className) {
      // For Importer, avoid going above total size due to chunk multiplication.
      case Importer::class:
        $chunksSize = $job->getStateProperty('chunksProcessed') * Importer::BYTES_PER_CHUNK;
        $fileSize = $this->getFileSize();
        return ($chunksSize > $fileSize) ? $fileSize : $chunksSize;
 
      case FileFetcher::class:
        return $job->getStateProperty('total_bytes_copied');
 
      default:
        return 0;
    }
  }
 
}