FiresCallbacks::fire() - Code Metrics - Inspection of "Merge branch '1.0/develop' of git://github.com/ano..." - anomalylabs/streams-platform - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 489a99...99d7d3 )

by Ryan

created 2016-04-26 20:29 UTC

FiresCallbacks::fire() D

↳ Parent: FiresCallbacks

Complexity

Conditions	14
Paths	300

Size

Total Lines	50
Code Lines	22

Duplication

Lines	20
Ratio	40 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
c	1
b	0
f	0
dl	20
loc	50
rs	4
cc	14
eloc	22
nc	300
nop	2

How to fix Complexity

<?php namespace Anomaly\Streams\Platform\Traits;

use Illuminate\Contracts\Bus\SelfHandling;

/**
 * Class FiresCallbacks
 *
 * @link          http://anomaly.is/streams-platform
 * @author        AnomalyLabs, Inc. <[email protected]>
 * @author        Ryan Thompson <[email protected]>
 * @package       Anomaly\Streams\Platform\Traits
 */
trait FiresCallbacks
{

    /**
     * The local callbacks.
     *
     * @var array
     */
    protected $callbacks = [];

    /**
     * The static callbacks.
     *
     * @var array
     */
    protected static $listeners = [];

    /**
     * Register a new callback.
     *
     * @param $trigger
     * @param $callback
     * @return $this
     */
    public function on($trigger, $callback)
    {
        if (!isset($this->callbacks[$trigger])) {
            $this->callbacks[$trigger] = [];
        }

        $this->callbacks[$trigger][] = $callback;

        return $this;
    }

    /**
     * Register a new listener.
     *
     * @param $trigger
     * @param $callback
     * @return $this
     */
    public function listen($trigger, $callback)
    {
        if (!isset(self::$listeners[$trigger])) {
            self::$listeners[$trigger] = [];
        }

        self::$listeners[$trigger][] = $callback;

        return $this;
    }

    /**
     * Fire a set of closures by trigger.
     *
     * @param       $trigger
     * @param array $parameters
     * @return $this
     */
    public function fire($trigger, array $parameters = [])
    {

        /**
         * Fire listeners first.
         */
        foreach (array_get(self::$listeners, $trigger, []) as $callback) {


            if (is_string($callback) || $callback instanceof \Closure) {
                app()->call($callback, $parameters);
            }

            if ($callback instanceof SelfHandling) {
                app()->call([$callback, 'handle'], $parameters);
            }
        }

        $method = camel_case('on_' . $trigger);

        if (method_exists($this, $method)) {
            app()->call([$this, $method], $parameters);
        }

        $handler = get_class($this) . ucfirst(camel_case('on_' . $trigger));

        if (class_exists($handler)) {
            app()->call($handler . '@handle', $parameters);
        }

        $observer = get_class($this) . 'Callbacks';

        if (class_exists($observer) && $observer = app($observer, $parameters)) {
            if (method_exists($observer, $method)) {
                app()->call([$observer, $method], $parameters);
            }
        }

        foreach (array_get($this->callbacks, $trigger, []) as $callback) {


            if (is_string($callback) || $callback instanceof \Closure) {
                app()->call($callback, $parameters);
            }

            if ($callback instanceof SelfHandling) {
                app()->call([$callback, 'handle'], $parameters);
            }
        }

        return $this;
    }

    /**
     * Return if the callback exists.
     *
     * @param $trigger
     * @return bool
     */
    public function hasCallback($trigger)
    {
        return isset(self::$callbacks[$trigger]);
    }
}


1		<?php namespace Anomaly\Streams\Platform\Traits;
2
3		use Illuminate\Contracts\Bus\SelfHandling;
4
5		/**
6		* Class FiresCallbacks
7		*
8		* @link http://anomaly.is/streams-platform
9		* @author AnomalyLabs, Inc. <[email protected]>
10		* @author Ryan Thompson <[email protected]>
11		* @package Anomaly\Streams\Platform\Traits
12		*/
13		trait FiresCallbacks
14		{
15
16		/**
17		* The local callbacks.
18		*
19		* @var array
20		*/
21		protected $callbacks = [];
22
23		/**
24		* The static callbacks.
25		*
26		* @var array
27		*/
28		protected static $listeners = [];
29
30		/**
31		* Register a new callback.
32		*
33		* @param $trigger
34		* @param $callback
35		* @return $this
36		*/
37		public function on($trigger, $callback)
38		{
39		if (!isset($this->callbacks[$trigger])) {
40		$this->callbacks[$trigger] = [];
41		}
42
43		$this->callbacks[$trigger][] = $callback;
44
45		return $this;
46		}
47
48		/**
49		* Register a new listener.
50		*
51		* @param $trigger
52		* @param $callback
53		* @return $this
54		*/
55		public function listen($trigger, $callback)
56		{
57		if (!isset(self::$listeners[$trigger])) {
58		self::$listeners[$trigger] = [];
59		}
60
61		self::$listeners[$trigger][] = $callback;
62
63		return $this;
64		}
65
66		/**
67		* Fire a set of closures by trigger.
68		*
69		* @param $trigger
70		* @param array $parameters
71		* @return $this
72		*/
73		public function fire($trigger, array $parameters = [])
74		{
75
76		/**
77		* Fire listeners first.
78		*/
79	View Code Duplication	foreach (array_get(self::$listeners, $trigger, []) as $callback) {
		0 ignored issues – show Duplication introduced 2016-04-26 20:36 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...
80
81		if (is_string($callback) \|\| $callback instanceof \Closure) {
82		app()->call($callback, $parameters);
83		}
84
85		if ($callback instanceof SelfHandling) {
86		app()->call([$callback, 'handle'], $parameters);
87		}
88		}
89
90		$method = camel_case('on_' . $trigger);
91
92		if (method_exists($this, $method)) {
93		app()->call([$this, $method], $parameters);
94		}
95
96		$handler = get_class($this) . ucfirst(camel_case('on_' . $trigger));
97
98		if (class_exists($handler)) {
99		app()->call($handler . '@handle', $parameters);
100		}
101
102		$observer = get_class($this) . 'Callbacks';
103
104		if (class_exists($observer) && $observer = app($observer, $parameters)) {
105		if (method_exists($observer, $method)) {
106		app()->call([$observer, $method], $parameters);
107		}
108		}
109
110	View Code Duplication	foreach (array_get($this->callbacks, $trigger, []) as $callback) {
		0 ignored issues – show Duplication introduced 2016-04-26 20:36 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...
111
112		if (is_string($callback) \|\| $callback instanceof \Closure) {
113		app()->call($callback, $parameters);
114		}
115
116		if ($callback instanceof SelfHandling) {
117		app()->call([$callback, 'handle'], $parameters);
118		}
119		}
120
121		return $this;
122		}
123
124		/**
125		* Return if the callback exists.
126		*
127		* @param $trigger
128		* @return bool
129		*/
130		public function hasCallback($trigger)
131		{
132		return isset(self::$callbacks[$trigger]);
133		}
134		}
135

anomalylabs / streams-platform

Push — master ( 489a99...99d7d3 )

FiresCallbacks::fire() D

Complexity

Size

Duplication

Importance

How to fix Complexity

Long Method

Duplication Side-by-Side

Filter issues like