CallQueuedListener::queueEvent() - Code Metrics - bytic/event-dispatcher - Measure and Improve Code Quality continuously with Scrutinizer

CallQueuedListener::queueEvent() A
last analyzed 2022-07-05 14:17 UTC

↳ Parent: CallQueuedListener

Complexity

Conditions	4
Paths	8

Size

Total Lines	16
Code Lines	9

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	20

Importance

Changes	3
Bugs	0	Features	1

Metric	Value
cc	4
eloc	9
nc	8
nop	1
dl	0
loc	16
ccs	0
cts	10
cp	0
crap	20
rs	9.9666
c	3
b	0
f	1

<?php

namespace ByTIC\EventDispatcher\Queue\Listeners;

use ByTIC\EventDispatcher\Events\EventInterface;
use ByTIC\EventDispatcher\Listeners\ListenerInterface;
use ByTIC\Queue\JobQueue\Bus\PendingDispatch;
use ByTIC\Queue\JobQueue\Jobs\Job;
use ReflectionClass;

/**
 * Class CallQueuedListener
 * @package ByTIC\EventDispatcher\Queue\Listeners
 */
class CallQueuedListener implements ListenerInterface
{
    protected $listener;

    protected $listenerObject;

    /**
     * @inheritDoc
     */
    public function handle(EventInterface $event)
    {
        $this->queueEvent($event);
    }

    /**
     * @param mixed $listener
     */
    public function setListener($listener): void
    {
        $this->listener = $listener;
        $class = $listener[0];
        try {
            $this->listenerObject = (new ReflectionClass($class))->newInstanceWithoutConstructor();
        } catch (\ReflectionException $e) {

        }
    }

    /**
     * @param EventInterface $event
     */
    protected function queueEvent(EventInterface $event)
    {
        $job = new Job($this->listener);

        if (isset($this->listenerObject->connection)) {
            $job->onConnection($this->listenerObject->connection);
        }
        if (isset($this->listenerObject->queue)) {
            $job->onQueue($this->listenerObject->queue);
        }
        if (isset($this->listenerObject->delay)) {
            $job->delay($this->listenerObject->delay);
        }
        $job->arguments([$event]);

        (new PendingDispatch($job));
    }
}


1			<?php
2
3			namespace ByTIC\EventDispatcher\Queue\Listeners;
4
5			use ByTIC\EventDispatcher\Events\EventInterface;
6			use ByTIC\EventDispatcher\Listeners\ListenerInterface;
7			use ByTIC\Queue\JobQueue\Bus\PendingDispatch;
8			use ByTIC\Queue\JobQueue\Jobs\Job;
9			use ReflectionClass;
10
11			/**
12			* Class CallQueuedListener
13			* @package ByTIC\EventDispatcher\Queue\Listeners
14			*/
15			class CallQueuedListener implements ListenerInterface
16			{
17			protected $listener;
18
19			protected $listenerObject;
20
21			/**
22			* @inheritDoc
23			*/
24			public function handle(EventInterface $event)
25			{
26			$this->queueEvent($event);
27			}
28
29			/**
30			* @param mixed $listener
31			*/
32			public function setListener($listener): void
33			{
34			$this->listener = $listener;
35			$class = $listener[0];
36			try {
37			$this->listenerObject = (new ReflectionClass($class))->newInstanceWithoutConstructor();
38			} catch (\ReflectionException $e) {
			0 ignored issues – show Coding Style Comprehensibility introduced 2020-06-17 10:05 UTC by Report Bug Copy Issue Report Consider adding a comment why this CATCH block is empty. Loading history...
39			}
40			}
41
42			/**
43			* @param EventInterface $event
44			*/
45			protected function queueEvent(EventInterface $event)
46			{
47			$job = new Job($this->listener);
48
49			if (isset($this->listenerObject->connection)) {
50			$job->onConnection($this->listenerObject->connection);
51			}
52			if (isset($this->listenerObject->queue)) {
53			$job->onQueue($this->listenerObject->queue);
54			}
55			if (isset($this->listenerObject->delay)) {
56			$job->delay($this->listenerObject->delay);
57			}
58			$job->arguments([$event]);
59
60			(new PendingDispatch($job));
61			}
62			}
63

bytic / event-dispatcher

CallQueuedListener::queueEvent() A last analyzed 2022-07-05 14:17 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

CallQueuedListener::queueEvent() A
last analyzed 2022-07-05 14:17 UTC