BetterEmitter::emit() - Code Metrics - kadet1090/nucleus - Measure and Improve Code Quality continuously with Scrutinizer

BetterEmitter::emit() B
last analyzed 2017-03-28 12:48 UTC

↳ Parent: BetterEmitter

Complexity

Conditions	5
Paths	5

Size

Total Lines	17
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	9
CRAP Score	5

Importance

Changes

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

<?php
/**
 * Nucleus - XMPP Library for PHP
 *
 * Copyright (C) 2016, Some rights reserved.
 *
 * @author Kacper "Kadet" Donat <[email protected]>
 *
 * Contact with author:
 * Xmpp: [email protected]
 * E-mail: [email protected]
 *
 * From Kadet with love.
 */

namespace Kadet\Xmpp\Utils;

use Kadet\Xmpp\Utils\filter as with;
use Evenement\EventEmitterTrait;

trait BetterEmitter
{
    /**
     * @var PriorityCollection[]
     */
    protected $listeners;

    use EventEmitterTrait;

    public function on($event, callable $listener, $condition = null, int $priority = 0)
    {
        return $this->addListener($event, $this->getConditionalCallable($listener, $condition), $priority);
    }

    public function once($event, callable $listener, $condition = null, int $priority = 0)
    {
        return $this->on($event, $this->getOnceCallable($this->getConditionalCallable($listener, $condition), $event), null, $priority);
    }

    public function removeListener($event, callable $listener)
    {
        if (!isset($this->listeners[$event])) {
            return false;
        }

        $this->listeners[$event]->remove($listener);

        return true;
    }

    public function emit($event, array $arguments = [])
    {
        foreach ($this->listeners($event) as $listener) {
            try {
                if ($listener(...$arguments) === false) {
                    return false;
                }
            } catch (\Throwable $exception) {
                if($this->emit('exception', [ $exception, $event ])) {
                    throw $exception;
                }
                return false;
            }
        }

        return true;
    }

    public function reference(callable $callable, int $position = 0) : callable
    {
        return \Kadet\Xmpp\Utils\helper\partial($callable, $this, $position);
    }

    private function addListener($event, callable $listener, int $priority = 0)
    {
        if (!isset($this->listeners[$event])) {
            $this->listeners[$event] = new PriorityCollection();
        }

        $this->listeners[$event]->insert($listener, $priority);

        return $listener;
    }

    private function getConditionalCallable(callable $listener, $condition) : callable
    {
        if ($condition === null) {
            return $listener;
        }

        $condition = with\predicate($condition);

        return function (...$arguments) use ($listener, $condition) {
            if ($condition(...$arguments)) {
                return $listener(...$arguments);
            }

            return INF;
        };
    }

    private function getOnceCallable(callable $listener, $event) : callable
    {
        return $onceListener = function (...$arguments) use (&$onceListener, $event, $listener) {
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
            if(($result = $listener(...$arguments)) !== INF) {
                $this->removeListener($event, $onceListener);
                return $result;
            }

            return null;
        };
    }
}


1		<?php
2		/**
3		* Nucleus - XMPP Library for PHP
4		*
5		* Copyright (C) 2016, Some rights reserved.
6		*
7		* @author Kacper "Kadet" Donat <[email protected]>
8		*
9		* Contact with author:
10		* Xmpp: [email protected]
11		* E-mail: [email protected]
12		*
13		* From Kadet with love.
14		*/
15
16		namespace Kadet\Xmpp\Utils;
17
18		use Kadet\Xmpp\Utils\filter as with;
19		use Evenement\EventEmitterTrait;
20
21		trait BetterEmitter
22		{
23		/**
24		* @var PriorityCollection[]
25		*/
26		protected $listeners;
27
28		use EventEmitterTrait;
29
30	17	public function on($event, callable $listener, $condition = null, int $priority = 0)
31		{
32	17	return $this->addListener($event, $this->getConditionalCallable($listener, $condition), $priority);
33		}
34
35	5	public function once($event, callable $listener, $condition = null, int $priority = 0)
36		{
37	5	return $this->on($event, $this->getOnceCallable($this->getConditionalCallable($listener, $condition), $event), null, $priority);
38		}
39
40	4	public function removeListener($event, callable $listener)
41		{
42	4	if (!isset($this->listeners[$event])) {
43		return false;
44		}
45
46	4	$this->listeners[$event]->remove($listener);
47
48	4	return true;
49		}
50
51	14	public function emit($event, array $arguments = [])
52		{
53	14	foreach ($this->listeners($event) as $listener) {
54		try {
55	14	if ($listener(...$arguments) === false) {
56	13	return false;
57		}
58	2	} catch (\Throwable $exception) {
59	2	if($this->emit('exception', [ $exception, $event ])) {
60	1	throw $exception;
61		}
62	13	return false;
63		}
64		}
65
66	13	return true;
67		}
68
69	1	public function reference(callable $callable, int $position = 0) : callable
70		{
71	1	return \Kadet\Xmpp\Utils\helper\partial($callable, $this, $position);
72		}
73
74	17	private function addListener($event, callable $listener, int $priority = 0)
75		{
76	17	if (!isset($this->listeners[$event])) {
77	17	$this->listeners[$event] = new PriorityCollection();
78		}
79
80	17	$this->listeners[$event]->insert($listener, $priority);
81
82	17	return $listener;
83		}
84
85	17	private function getConditionalCallable(callable $listener, $condition) : callable
86		{
87	17	if ($condition === null) {
88	16	return $listener;
89		}
90
91	10	$condition = with\predicate($condition);
92
93		return function (...$arguments) use ($listener, $condition) {
94	7	if ($condition(...$arguments)) {
95	7	return $listener(...$arguments);
96		}
97
98	5	return INF;
99	10	};
100		}
101
102		private function getOnceCallable(callable $listener, $event) : callable
103		{
104	5	return $onceListener = function (...$arguments) use (&$onceListener, $event, $listener) {
		0 ignored issues – show Unused Code introduced 2016-07-25 21:42 UTC by Report Bug Copy Issue Report `$onceListener` is not used, you could remove the assignment. This check looks for variable assignements that are either overwritten by other assignments or where the variable is not used subsequently. $myVar = 'Value'; $higher = false; if (rand(1, 6) > 3) { $higher = true; } else { $higher = false; } Both the `$myVar` assignment in line 1 and the `$higher` assignment in line 2 are dead. The first because `$myVar` is never used and the second because `$higher` is always overwritten for every possible time line. Loading history...
105	2	if(($result = $listener(...$arguments)) !== INF) {
106	2	$this->removeListener($event, $onceListener);
107	2	return $result;
108		}
109
110	1	return null;
111	5	};
112		}
113		}
114

kadet1090 / nucleus

BetterEmitter::emit() B last analyzed 2017-03-28 12:48 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

BetterEmitter::emit() B
last analyzed 2017-03-28 12:48 UTC