Mathielen\ImportEngine\Import\Run\ImportRunner

Complexity

Total Complexity

15

Size/Duplication

Total Lines	101
Duplicated Lines	21.78 %

Coupling/Cohesion

Components	1
Dependencies	8

Test Coverage

Coverage

87.5%

Importance

Changes	11
Bugs	3	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	build()	0	4	1
A	dryRun()	8	8	1
A	run()	8	8	1
A	__construct()	0	9	2
B	process()	6	19	7
A	preview()	0	21	3

<?php
namespace Mathielen\ImportEngine\Import\Run;

use Ddeboer\DataImport\Workflow;
use Mathielen\DataImport\Event\ImportProcessEvent;
use Mathielen\ImportEngine\Import\Import;
use Mathielen\ImportEngine\Import\Workflow\DefaultWorkflowFactory;
use Mathielen\ImportEngine\Import\Workflow\WorkflowFactoryInterface;
use Mathielen\ImportEngine\Exception\ImportRunException;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;

class ImportRunner
{

    /**
     * @var WorkflowFactoryInterface
     */
    private $workflowFactory;

    /**
     * @var EventDispatcherInterface
     */
    private $eventDispatcher;

    public function __construct(WorkflowFactoryInterface $workflowFactory=null, EventDispatcherInterface $eventDispatcher=null)
    {
        if (!$workflowFactory) {
            $workflowFactory = new DefaultWorkflowFactory();
        }

        $this->workflowFactory = $workflowFactory;
        $this->eventDispatcher = $eventDispatcher;
    }

    /**
     * @return ImportRunner
     */
    public static function build(WorkflowFactoryInterface $workflowFactory=null)
    {
        return new self($workflowFactory);
    }

    private function process(Workflow $workflow, Import $import)
    {
        $e = null;
        $importRun = null;

        if ($this->eventDispatcher && $importRun = $import->getRun()) {
            $e = new ImportProcessEvent($import);
        }

        if ($e && $importRun->getConfiguration()) {

This code seems to be duplicated across your project.

            $this->eventDispatcher->dispatch(ImportProcessEvent::AFTER_PREPARE.'.'.$importRun->getConfiguration()->getImporterId(), $e);
        }

        $workflow->process();

        if ($e && $importRun->getConfiguration()) {

This code seems to be duplicated across your project.

            $this->eventDispatcher->dispatch(ImportProcessEvent::AFTER_FINISH.'.'.$importRun->getConfiguration()->getImporterId(), $e);
        }
    }

    /**
     * @return array
     */
    public function preview(Import $import, $offset = 0)
    {
        $importRun = $import->getRun();
        $previewResult = array('from'=>array(), 'to'=>array());

        $workflow = $this->workflowFactory->buildPreviewWorkflow($import, $previewResult, $offset);
        $this->process($workflow, $import);

        if (0 == count($previewResult['from'])) {
            throw new ImportRunException("Unable to preview row with offset '$offset'. EOF?", $importRun);
        }

        //cleanup from writer
        if (count($previewResult['to']) > 0) {
            $previewResult['to'] = $previewResult['to'][0];
        } else {
            $previewResult['to'] = array_fill_keys($import->mappings()->getTargetFields(), null);
        }

        return $previewResult;
    }

    /**
     * @return Import
     */
    public function dryRun(Import $import)

This method seems to be duplicated in your project.

    {
        $importRun = $import->getRun();
        $workflow = $this->workflowFactory->buildDryrunWorkflow($import, $importRun);
        $this->process($workflow, $import);

        return $importRun;
    }

    /**
     * @return Import
     */
    public function run(Import $import)

This method seems to be duplicated in your project.

    {
        $importRun = $import->getRun();
        $workflow = $this->workflowFactory->buildRunWorkflow($import, $importRun);
        $this->process($workflow, $import);

        return $importRun;
    }

}