ImportRunner::process() - Code Metrics - mathielen/import-engine - Measure and Improve Code Quality continuously with Scrutinizer

ImportRunner::process() B
last analyzed 2021-02-08 13:43 UTC

↳ Parent: ImportRunner

Complexity

Conditions	7
Paths	8

Size

Total Lines

Duplication

Lines	6
Ratio	31.58 %

Code Coverage

Tests	8
CRAP Score	7.9936

Importance

Changes

Metric	Value
dl	6
loc	19
ccs	8
cts	11
cp	0.7272
rs	8.8333
c	0
b	0
f	0
cc	7
nc	8
nop	2
crap	7.9936

<?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 Psr\Log\LoggerInterface;
use Psr\Log\NullLogger;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;

class ImportRunner
{
    /**
     * @var WorkflowFactoryInterface
     */
    private $workflowFactory;

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

    /**
     * @var LoggerInterface
     */
    private $logger;

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

        $this->workflowFactory = $workflowFactory;
        $this->eventDispatcher = $eventDispatcher;
        $this->logger = $logger ? $logger : new NullLogger();
    }

    /**
     * @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->eventDispatcher->dispatch(ImportProcessEvent::AFTER_PREPARE.'.'.$importRun->getConfiguration()->getImporterId(), $e);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        }

        $workflow->process();

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

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

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        }
    }

    /**
     * @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)
    {
        $importRun = $import->getRun();
        $workflow = $this->workflowFactory->buildDryrunWorkflow($import, $importRun);
        $this->process($workflow, $import);

        return $importRun;
    }

    /**
     * @return Import
     */
    public function run(Import $import)
    {
        $this->logger->info('Starting import run.', $import->getRun()->toArray());

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

        $this->logger->info('Import run finished.', $import->getRun()->toArray());

        return $importRun;
    }
}


1			<?php
2
3			namespace Mathielen\ImportEngine\Import\Run;
4
5			use Ddeboer\DataImport\Workflow;
6			use Mathielen\DataImport\Event\ImportProcessEvent;
7			use Mathielen\ImportEngine\Import\Import;
8			use Mathielen\ImportEngine\Import\Workflow\DefaultWorkflowFactory;
9			use Mathielen\ImportEngine\Import\Workflow\WorkflowFactoryInterface;
10			use Mathielen\ImportEngine\Exception\ImportRunException;
11			use Psr\Log\LoggerInterface;
12			use Psr\Log\NullLogger;
13			use Symfony\Component\EventDispatcher\EventDispatcherInterface;
14
15			class ImportRunner
16			{
17			/**
18			* @var WorkflowFactoryInterface
19			*/
20			private $workflowFactory;
21
22			/**
23			* @var EventDispatcherInterface
24			*/
25			private $eventDispatcher;
26
27			/**
28			* @var LoggerInterface
29			*/
30			private $logger;
31
32	14		public function __construct(WorkflowFactoryInterface $workflowFactory = null, EventDispatcherInterface $eventDispatcher = null, LoggerInterface $logger = null)
33			{
34	14		if (!$workflowFactory) {
35	8		$workflowFactory = new DefaultWorkflowFactory();
36			}
37
38	14		$this->workflowFactory = $workflowFactory;
39	14		$this->eventDispatcher = $eventDispatcher;
40	14		$this->logger = $logger ? $logger : new NullLogger();
41	14		}
42
43			/**
44			* @return ImportRunner
45			*/
46	2		public static function build(WorkflowFactoryInterface $workflowFactory = null)
47			{
48	2		return new self($workflowFactory);
49			}
50
51	14		private function process(Workflow $workflow, Import $import)
52			{
53	14		$e = null;
54	14		$importRun = null;
55
56	14		if ($this->eventDispatcher && $importRun = $import->getRun()) {
57			$e = new ImportProcessEvent($import);
58			}
59
60	14	View Code Duplication	if ($e && $importRun->getConfiguration()) {
			0 ignored issues – show Duplication introduced 2015-12-08 09:18 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
61			$this->eventDispatcher->dispatch(ImportProcessEvent::AFTER_PREPARE.'.'.$importRun->getConfiguration()->getImporterId(), $e);
			0 ignored issues – show Documentation introduced 2020-11-09 10:22 UTC by Report Bug Copy Issue Report `\Mathielen\DataImport\Ev...tion()->getImporterId()` is of type `string`, but the function expects a `object<Symfony\Contracts\EventDispatcher\object>`. It seems like the type of the argument is not accepted by the function/method which you are calling. In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug. We suggest to add an explicit type cast like in the following example: function acceptsInteger($int) { } $x = '123'; // string "123" // Instead of acceptsInteger($x); // we recommend to use acceptsInteger((integer) $x); Loading history... Documentation introduced 2020-11-09 10:22 UTC by Report Bug Copy Issue Report `$e` is of type `object<Mathielen\DataImp...ent\ImportProcessEvent>`, but the function expects a `null\|string`. It seems like the type of the argument is not accepted by the function/method which you are calling. In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug. We suggest to add an explicit type cast like in the following example: function acceptsInteger($int) { } $x = '123'; // string "123" // Instead of acceptsInteger($x); // we recommend to use acceptsInteger((integer) $x); Loading history...
62			}
63
64	14		$workflow->process();
65
66	14	View Code Duplication	if ($e && $importRun->getConfiguration()) {
			0 ignored issues – show Duplication introduced 2015-12-08 09:18 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
67			$this->eventDispatcher->dispatch(ImportProcessEvent::AFTER_FINISH.'.'.$importRun->getConfiguration()->getImporterId(), $e);
			0 ignored issues – show Documentation introduced 2020-11-09 10:22 UTC by Report Bug Copy Issue Report `\Mathielen\DataImport\Ev...tion()->getImporterId()` is of type `string`, but the function expects a `object<Symfony\Contracts\EventDispatcher\object>`. It seems like the type of the argument is not accepted by the function/method which you are calling. In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug. We suggest to add an explicit type cast like in the following example: function acceptsInteger($int) { } $x = '123'; // string "123" // Instead of acceptsInteger($x); // we recommend to use acceptsInteger((integer) $x); Loading history... Documentation introduced 2020-11-09 10:22 UTC by Report Bug Copy Issue Report `$e` is of type `object<Mathielen\DataImp...ent\ImportProcessEvent>`, but the function expects a `null\|string`. It seems like the type of the argument is not accepted by the function/method which you are calling. In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug. We suggest to add an explicit type cast like in the following example: function acceptsInteger($int) { } $x = '123'; // string "123" // Instead of acceptsInteger($x); // we recommend to use acceptsInteger((integer) $x); Loading history...
68			}
69	14		}
70
71			/**
72			* @return array
73			*/
74	2		public function preview(Import $import, $offset = 0)
75			{
76	2		$importRun = $import->getRun();
77	2		$previewResult = array('from' => array(), 'to' => array());
78
79	2		$workflow = $this->workflowFactory->buildPreviewWorkflow($import, $previewResult, $offset);
80	2		$this->process($workflow, $import);
81
82	2		if (0 == count($previewResult['from'])) {
83			throw new ImportRunException("Unable to preview row with offset '$offset'. EOF?", $importRun);
84			}
85
86			//cleanup from writer
87	2		if (count($previewResult['to']) > 0) {
88	2		$previewResult['to'] = $previewResult['to'][0];
89			} else {
90			$previewResult['to'] = array_fill_keys($import->mappings()->getTargetFields(), null);
91			}
92
93	2		return $previewResult;
94			}
95
96			/**
97			* @return Import
98			*/
99	3		public function dryRun(Import $import)
100			{
101	3		$importRun = $import->getRun();
102	3		$workflow = $this->workflowFactory->buildDryrunWorkflow($import, $importRun);
103	3		$this->process($workflow, $import);
104
105	3		return $importRun;
106			}
107
108			/**
109			* @return Import
110			*/
111	11		public function run(Import $import)
112			{
113	11		$this->logger->info('Starting import run.', $import->getRun()->toArray());
114
115	11		$importRun = $import->getRun();
116	11		$workflow = $this->workflowFactory->buildRunWorkflow($import, $importRun);
117	11		$this->process($workflow, $import);
118
119	11		$this->logger->info('Import run finished.', $import->getRun()->toArray());
120
121	11		return $importRun;
122			}
123			}
124

mathielen / import-engine

ImportRunner::process() B last analyzed 2021-02-08 13:43 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

ImportRunner::process() B
last analyzed 2021-02-08 13:43 UTC