UniqueFilterStep::finalize() - Code Metrics - jean-pasqualini/import - Measure and Improve Code Quality continuously with Scrutinizer

UniqueFilterStep::finalize() A
last analyzed 2018-09-29 11:52 UTC

↳ Parent: UniqueFilterStep

Complexity

Conditions	1
Paths	1

Size

Total Lines	3
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	2
CRAP Score	1

Importance

Changes

Metric	Value
cc	1
eloc	1
nc	1
nop	1
dl	0
loc	3
ccs	2
cts	2
cp	1
crap	1
rs	10
c	0
b	0
f	0

<?php

declare(strict_types=1);

namespace Darkilliant\ProcessBundle\Step;

use Darkilliant\ProcessBundle\Exception\NonUniqueException;
use Darkilliant\ProcessBundle\State\ProcessState;
use Symfony\Component\OptionsResolver\OptionsResolver;

class UniqueFilterStep extends AbstractConfigurableStep
{
    private $collector;

    public function configureOptionResolver(OptionsResolver $resolver): OptionsResolver
    {
        $resolver->setRequired(['fields', 'data', 'throw_error']);
        $resolver->setDefault('data', null);
        $resolver->setDefault('throw_error', false);

        return parent::configureOptionResolver($resolver);
    }

    public function execute(ProcessState $state)
    {
        $fields = $state->getOptions()['fields'];
        $data = $state->getOptions()['data'] ?: $state->getData();

        if (!is_array($data)) {
            return;
        }

        $collected = '';
        foreach ($fields as $field) {
            $collected .= '|'.$data[$field];
        }

        if (isset($this->collector[$collected])) {
            if ($state->getOption('throw_error')) {
                throw new NonUniqueException(
                    sprintf('skipped, this data is not unique (%s)', $collected)
                );
            }

            $state->warning(
                'skipped, this data is not unique',
                ['collected' => $collected]
            );

            $state->markIgnore();

            return;
        }

        $this->collector[$collected] = 1;
    }

    public function finalize(ProcessState $state)
    {
        $this->collector = [];
    }
}


1		<?php
2
3		declare(strict_types=1);
4
5		namespace Darkilliant\ProcessBundle\Step;
6
7		use Darkilliant\ProcessBundle\Exception\NonUniqueException;
8		use Darkilliant\ProcessBundle\State\ProcessState;
9		use Symfony\Component\OptionsResolver\OptionsResolver;
10
11		class UniqueFilterStep extends AbstractConfigurableStep
12		{
13		private $collector;
14
15	1	public function configureOptionResolver(OptionsResolver $resolver): OptionsResolver
16		{
17	1	$resolver->setRequired(['fields', 'data', 'throw_error']);
18	1	$resolver->setDefault('data', null);
19	1	$resolver->setDefault('throw_error', false);
20
21	1	return parent::configureOptionResolver($resolver);
22		}
23
24	3	public function execute(ProcessState $state)
25		{
26	3	$fields = $state->getOptions()['fields'];
27	3	$data = $state->getOptions()['data'] ?: $state->getData();
28
29	3	if (!is_array($data)) {
30	1	return;
31		}
32
33	2	$collected = '';
34	2	foreach ($fields as $field) {
35	2	$collected .= '\|'.$data[$field];
36		}
37
38	2	if (isset($this->collector[$collected])) {
39	2	if ($state->getOption('throw_error')) {
40	1	throw new NonUniqueException(
41	1	sprintf('skipped, this data is not unique (%s)', $collected)
42		);
43		}
44
45	1	$state->warning(
46	1	'skipped, this data is not unique',
47	1	['collected' => $collected]
48		);
49
50	1	$state->markIgnore();
51
52	1	return;
53		}
54
55	2	$this->collector[$collected] = 1;
56	2	}
57
58	1	public function finalize(ProcessState $state)
59		{
60	1	$this->collector = [];
61	1	}
62		}
63

jean-pasqualini / import

UniqueFilterStep::finalize() A last analyzed 2018-09-29 11:52 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

UniqueFilterStep::finalize() A
last analyzed 2018-09-29 11:52 UTC