PEIP\Dispatcher\ClassDispatcher

Complexity

Total Complexity

14

Size/Duplication

Total Lines	91
Duplicated Lines	23.08 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	4
Bugs	4	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	connect()	0	9	3
A	notify()	11	12	3
A	notifyUntil()	10	11	4
A	notifyOfInstance()	0	4	1
A	hasListeners()	0	10	3

<?php

namespace PEIP\Dispatcher;

use PEIP\Util\Reflection;
use PEIP\Util\Test;

class ClassDispatcher extends \PEIP\ABS\Dispatcher\MapDispatcher
{
    /**
     * Connects a listener to a given event-name.
     *
     * @param string                            $name     name of the class
     * @param callable|PEIP\INF\Handler\Handler $listener listener to connect
     *
     * @return
     */
    public function connect($name, $listener)
    {
        $name = is_object($name) ? get_class($name) : (string) $name;
        if (Test::assertClassOrInterfaceExists($name)) {
            parent::connect($name, $listener);
        } else {
            throw new \InvalidArgumentException($name.' is not an Class nor Interface');
        }
    }

    /**
     * notifies all listeners on a event on a subject.
     *
     * @param string $name    name of the class
     * @param mixed  $subject the subject
     *
     * @return
     */
    public function notify($name, $subject)

This method seems to be duplicated in your project.

    {
        $res = false;
        foreach (Reflection::getImplementedClassesAndInterfaces($name) as $cls) {
            if (parent::hasListeners($cls)) {

It seems like you call parent on a different method (hasListeners() instead of notify()). Are you sure this is correct? If so, you might want to change this to $this->hasListeners().

                self::doNotify($this->getListeners($cls), $subject);
                $res = true;
            }
        }

        return $res;
    }

    /**
     * notifies all listeners on a event on a subject until one returns a boolean true value.
     *
     * @param string $name    name of the event
     * @param mixed  $subject the subject
     *
     * @return \PEIP\INF\Handler\Handler listener which returned a boolean true value
     */
    public function notifyUntil($name, $subject)

This method seems to be duplicated in your project.

    {
        $res = null;
        foreach (Reflection::getImplementedClassesAndInterfaces($name) as $cls) {
            if (!$res && parent::hasListeners($cls)) {

It seems like you call parent on a different method (hasListeners() instead of notifyUntil()). Are you sure this is correct? If so, you might want to change this to $this->hasListeners().

                $res = self::doNotifyUntil($this->getListeners($cls), $subject);
            }
        }

        return $res;
    }

    /**
     * notifies all listeners on a event on a subject.
     *
     * @param mixed $subject the subject
     *
     * @return
     */
    public function notifyOfInstance($subject)
    {
        return $this->notify(get_class($subject), $subject);
    }

    /**
     * Checks wether any listener is registered for a given event-name.
     *
     * @param string $name name of the event
     *
     * @return bool wether any listener is registered for event-name
     */
    public function hasListeners($name)
    {
        foreach (Reflection::getImplementedClassesAndInterfaces($name) as $cls) {
            if (parent::hasListeners($cls)) {
                return true;
            }
        }

        return false;
    }
}