Handler::handle() - Code Metrics - Inspection of "wip: Progress bar" - gbprod/elasticsearch-dataprovider-bundle - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 3b88e7...c64881 )

by GBProd

created 2016-04-03 19:37 UTC

Handler::handle() A

↳ Parent: Handler

Complexity

Conditions	2
Paths	2

Size

Total Lines	16
Code Lines	9

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	12
CRAP Score	2

Importance

Changes	5
Bugs	1	Features	1

Metric	Value
c	5
b	1
f	1
dl	0
loc	16
ccs	12
cts	12
cp	1
rs	9.4285
cc	2
eloc	9
nc	2
nop	3
crap	2

<?php

namespace GBProd\ElasticsearchDataProviderBundle\DataProvider;

use Elasticsearch\Client;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;

/**
 * Handle data providing
 * 
 * @author gbprod <[email protected]>
 */
class Handler
{
    /**
     * @var Registry
     */
    private $registry;
    
    /**
     * @var EventDispatcherInterface
     */
    private $dispatcher;
    
    /**
     * @param Registry                      $registry
     * @param EventDispatcherInterface|null $dispatcher
     */
    public function __construct(
        Registry $registry, 
        EventDispatcherInterface $dispatcher = null
    ) {
        $this->registry   = $registry;
        $this->dispatcher = $dispatcher;
    }
    
    /**
     * Handle provide command
     */
    public function handle(Client $client, $index, $type)
    {
        $entries = $this->registry->get($index, $type);
        
        $this->dispatchHandlingStartedEvent($entries);
        
        foreach($entries as $entry) {
            $this->dispatchProvidingStartedEvent($entry);
    
            $entry->getProvider()->run(
                $client, 
                $entry->getIndex(), 
                $entry->getType()
            );
        }
    }
    
    private function dispatchHandlingStartedEvent(array $entries)
    {
        if ($this->dispatcher) {
            $this->dispatcher->dispatch(
                'elasticsearch.has_started_handling',
                new HasStartedHandling($entries)
            );
        }
    }
    
    private function dispatchProvidingStartedEvent(RegistryEntry $entry)
    {
        if ($this->dispatcher) {
            $this->dispatcher->dispatch(
                'elasticsearch.has_started_providing',
                new HasStartedProviding($entry)
            );
        }
    }
}


1		<?php
2
3		namespace GBProd\ElasticsearchDataProviderBundle\DataProvider;
4
5		use Elasticsearch\Client;
6		use Symfony\Component\EventDispatcher\EventDispatcherInterface;
7
8		/**
9		* Handle data providing
10		*
11		* @author gbprod <[email protected]>
12		*/
13		class Handler
14		{
15		/**
16		* @var Registry
17		*/
18		private $registry;
19
20		/**
21		* @var EventDispatcherInterface
22		*/
23		private $dispatcher;
24
25		/**
26		* @param Registry $registry
27		* @param EventDispatcherInterface\|null $dispatcher
28		*/
29	2	public function __construct(
30		Registry $registry,
31		EventDispatcherInterface $dispatcher = null
32		) {
33	2	$this->registry = $registry;
34	2	$this->dispatcher = $dispatcher;
35	2	}
36
37		/**
38		* Handle provide command
39		*/
40	1	public function handle(Client $client, $index, $type)
41		{
42	1	$entries = $this->registry->get($index, $type);
43
44	1	$this->dispatchHandlingStartedEvent($entries);
45
46	1	foreach($entries as $entry) {
47	1	$this->dispatchProvidingStartedEvent($entry);
48
49	1	$entry->getProvider()->run(
50	1	$client,
51	1	$entry->getIndex(),
52	1	$entry->getType()
53	1	);
54	1	}
55	1	}
56
57	1	private function dispatchHandlingStartedEvent(array $entries)
58		{
59	1	if ($this->dispatcher) {
60		$this->dispatcher->dispatch(
61		'elasticsearch.has_started_handling',
62		new HasStartedHandling($entries)
63		);
64		}
65	1	}
66
67	1	private function dispatchProvidingStartedEvent(RegistryEntry $entry)
68		{
69	1	if ($this->dispatcher) {
70		$this->dispatcher->dispatch(
71		'elasticsearch.has_started_providing',
72		new HasStartedProviding($entry)
73		);
74		}
75	1	}
76		}
77

gbprod / elasticsearch-dataprovider-bundle

Push — master ( 3b88e7...c64881 )

Handler::handle() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like