PHPDaemon\PubSub\PubSub

Complexity

Total Complexity

11

Size/Duplication

Total Lines	97
Duplicated Lines	14.43 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	eventExists()	0	4	1
A	sub()	0	7	2
A	addEvent()	0	4	1
A	removeEvent()	0	4	1
A	unsub()	7	7	2
A	pub()	7	7	2
A	unsubFromAll()	0	7	2

<?php
namespace PHPDaemon\PubSub;

/**
 * PubSub
 * @package PHPDaemon\PubSub
 * @author  Vasily Zorin <maintainer@daemon.io>
 */
class PubSub
{
    use \PHPDaemon\Traits\ClassWatchdog;
    use \PHPDaemon\Traits\StaticObjectWatchdog;

    /**
     * @var PubSubEvent[] Storage of events
     */
    protected $events = [];

    /**
     * Is event exists?
     * @param  string $id Event ID
     * @return boolean
     */
    public function eventExists($id)
    {
        return isset($this->events[$id]);
    }

    /**
     * Subcribe to event
     * @param  string $id Event ID
     * @param  object $obj Subscriber
     * @param  callable $cb Callback
     * @return boolean       Success

Should the return type not be false|PubSubEvent?

     */
    public function sub($id, $obj, $cb)
    {
        if (!isset($this->events[$id])) {
            return false;
        }
        return $this->events[$id]->sub($obj, $cb);
    }

    /**
     * Adds event
     * @param  string $id Event ID
     * @param  PubSubEvent $obj
     * @return void
     */
    public function addEvent($id, PubSubEvent $obj)
    {
        $this->events[$id] = $obj;
    }

    /**
     * Removes event
     * @param  string $id Event ID
     * @return void
     */
    public function removeEvent($id)
    {
        unset($this->events[$id]);
    }

    /**
     * Unsubscribe object from event
     * @param  string $id Event ID
     * @param  object $obj Subscriber
     * @return boolean      Success

Should the return type not be false|PubSubEvent?

     */
    public function unsub($id, $obj)

This method seems to be duplicated in your project.

    {
        if (!isset($this->events[$id])) {
            return false;
        }
        return $this->events[$id]->unsub($obj);
    }

    /**
     * Publish
     * @param  string $id Event ID
     * @param  mixed $data Data
     * @return boolean       Success

Should the return type not be false|PubSubEvent?

     */
    public function pub($id, $data)

This method seems to be duplicated in your project.

    {
        if (!isset($this->events[$id])) {
            return false;
        }
        return $this->events[$id]->pub($data);
    }

    /**
     * Unsubscribe object from all events
     * @param  object $obj Subscriber
     * @return boolean      Success
     */
    public function unsubFromAll($obj)
    {
        foreach ($this->events as $event) {
            $event->unsub($obj);
        }
        return true;
    }
}