Eole\Sandstone\Websocket\Topic

Complexity

Total Complexity

6

Size/Duplication

Total Lines	73
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	setNormalizer()	0	6	1
A	broadcast()	0	4	1
A	onSubscribe()	0	4	1
A	onPublish()	0	4	1
A	onUnSubscribe()	0	4	1

<?php

namespace Eole\Sandstone\Websocket;

use JMS\Serializer\ArrayTransformerInterface;
use Ratchet\Wamp\WampConnection;
use Ratchet\Wamp\Topic as BaseTopic;

class Topic extends BaseTopic
{
    /**
     * @var array
     */
    protected $arguments;

    /**
     * @var ArrayTransformerInterface
     */
    protected $normalizer;

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

        $this->arguments = $arguments;
    }

    /**
     * @param ArrayTransformerInterface $normalizer
     *
     * @return self
     */
    public function setNormalizer(ArrayTransformerInterface $normalizer)
    {
        $this->normalizer = $normalizer;

        return $this;
    }

    /**
     * {@InheritDoc}
     *
     * And normalize message using the serializer before send.
     */
    public function broadcast($msg, array $exclude = array(), array $eligible = array())
    {
        parent::broadcast($this->normalizer->toArray($msg), $exclude, $eligible);
    }

    /**
     * @param WampConnection $conn
     * @param string $topic
     */
    public function onSubscribe(WampConnection $conn, $topic)

The parameter $topic is not used and could be removed.

    {
        $this->add($conn);
    }

    /**
     * @param WampConnection $conn
     * @param string $topic
     * @param string $event
     */
    public function onPublish(WampConnection $conn, $topic, $event)

The parameter $conn is not used and could be removed.

The parameter $topic is not used and could be removed.

The parameter $event is not used and could be removed.

    {
        // noop
    }

    /**
     * @param WampConnection $conn
     * @param string $topic
     */
    public function onUnSubscribe(WampConnection $conn, $topic)

The parameter $topic is not used and could be removed.

    {
        $this->remove($conn);
    }
}