Eole\Websocket\Topic\PartiesTopic

Complexity

Total Complexity

17

Size/Duplication

Total Lines	164
Duplicated Lines	23.78 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	onSubscribe()	0	4	1
A	onPublish()	0	4	1
A	onPartyAvailable()	0	13	2
A	onPartyGone()	13	13	2
A	onSlotJoin()	0	13	2
A	onPartyStarted()	13	13	2
A	onPartyEnded()	13	13	2
A	onUnSubscribe()	0	4	1
A	souldBroadcastForGame()	0	7	2
A	getSubscribedEvents()	0	17	1

<?php

namespace Eole\Websocket\Topic;

use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Ratchet\Wamp\WampConnection;
use Eole\Sandstone\Websocket\Topic;
use Eole\Core\Model\Party;
use Eole\Core\Event\PartyEvent;
use Eole\Core\Event\SlotEvent;

class PartiesTopic extends Topic implements EventSubscriberInterface
{
    /**
     * @var null|string
     */
    private $gameName;

    /**
     * @param string $topicPath
     * @param array $arguments
     */
    public function __construct($topicPath, array $arguments = array())
    {
        parent::__construct($topicPath, $arguments);

        $this->gameName = $arguments['game_name'];
    }

    /**
     * {@InheritDoc}
     */
    public function onSubscribe(WampConnection $conn, $topic)
    {
        parent::onSubscribe($conn, $topic);
    }

    /**
     * {@InheritDoc}
     */
    public function onPublish(WampConnection $conn, $topic, $event)
    {
        // noop
    }

    /**
     * @param PartyEvent $event
     */
    public function onPartyAvailable(PartyEvent $event)
    {
        $party = $event->getParty();

        if (!$this->souldBroadcastForGame($party)) {
            return;
        }

        $this->broadcast([
            'type' => 'created',
            'party' => $party,
        ]);
    }

    /**
     * @param PartyEvent $event
     */
    public function onPartyGone(PartyEvent $event)

This method seems to be duplicated in your project.

    {
        $party = $event->getParty();

        if (!$this->souldBroadcastForGame($party)) {
            return;
        }

        $this->broadcast([
            'type' => 'gone',
            'party' => $party,
        ]);
    }

    /**
     * @param SlotEvent $event
     */
    public function onSlotJoin(SlotEvent $event)
    {
        $party = $event->getParty();

        if (!$this->souldBroadcastForGame($party)) {
            return;
        }

        $this->broadcast([
            'type' => 'slot_join',
            'event' => $event,
        ]);
    }

    /**
     * @param PartyEvent $event
     */
    public function onPartyStarted(PartyEvent $event)

This method seems to be duplicated in your project.

    {
        $party = $event->getParty();

        if (!$this->souldBroadcastForGame($party)) {
            return;
        }

        $this->broadcast([
            'type' => 'party_started',
            'event' => $event,
        ]);
    }

    /**
     * @param PartyEvent $event
     */
    public function onPartyEnded(PartyEvent $event)

This method seems to be duplicated in your project.

    {
        $party = $event->getParty();

        if (!$this->souldBroadcastForGame($party)) {
            return;
        }

        $this->broadcast([
            'type' => 'party_ended',
            'event' => $event,
        ]);
    }

    /**
     * {@InheritDoc}
     */
    public function onUnSubscribe(WampConnection $conn, $topic)
    {
        parent::onUnSubscribe($conn, $topic);
    }

    /**
     * Returns whether it should broadcast event
     * depending on the current game name.
     *
     * @param Party $party
     *
     * @return bool
     */
    private function souldBroadcastForGame(Party $party)
    {
        return
            (null === $this->gameName) ||
            ($party->getGame()->getName() === $this->gameName)
        ;
    }

    /**
     * {@InheritDoc}
     */
    public static function getSubscribedEvents()
    {
        return array(
            PartyEvent::CREATE_AFTER => array(
                array('onPartyAvailable'),
            ),
            SlotEvent::JOIN_AFTER => array(
                array('onSlotJoin'),
            ),
            PartyEvent::STARTED => array(
                array('onPartyStarted'),
            ),
            PartyEvent::ENDED => array(
                array('onPartyEnded'),
            ),
        );
    }
}