unreal4u\MQTT\Application\Topic

Complexity

Total Complexity

6

Size/Duplication

Total Lines	81
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	setQoSLevel()	0	5	1
A	getTopicName()	0	3	1
A	setTopicName()	0	4	1
A	__construct()	0	9	2
A	getTopicQoSLevel()	0	3	1

<?php

declare(strict_types=1);

namespace unreal4u\MQTT\Application;

use unreal4u\MQTT\DataTypes\QoSLevel;
use unreal4u\MQTT\DataTypes\TopicName;

/**
 * When the client wants to subscribe to a topic, this is done by adding a topic filter.
 */
final class Topic
{
    /**
     * The Topic Name identifies the information channel to which payload data is published.
     *
     * @see http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/os/mqtt-v3.1.1-os.html#_Toc398718106
     * @var TopicName
     */
    private $topicName;

    /**
     * The QoS lvl of this topic
     *
     * NOTE: Setting a QoS level where it is not needed (basically anything apart from a subscription) will have no
     * effect at all, as the QoS level is set not on a Topic level, but on a Message level instead.
     *
     * @var QoSLevel
     */
    private $qosLevel = 0;

    /**
     * Topic constructor.
     * @param string $topicName
     * @param QoSLevel $qosLevel
     * @throws \OutOfBoundsException
     * @throws \unreal4u\MQTT\Exceptions\InvalidQoSLevel
     * @throws \InvalidArgumentException
     */
    public function __construct(TopicName $topicName, QoSLevel $qosLevel = null)
    {
        if ($qosLevel === null) {
            $qosLevel = new QoSLevel(0);
        }

        $this
            ->setTopicName($topicName)
            ->setQoSLevel($qosLevel);
    }

    /**
     * Contains the name of the Topic Filter
     *
     * @param string $topicName
     * @return Topic
     * @throws \OutOfBoundsException
     * @throws \InvalidArgumentException
     */
    private function setTopicName(TopicName $topicName): self
    {
        $this->topicName = $topicName;
        return $this;
    }

    /**
     * Requested QoS level is the maximum QoS level at which the Server can send Application Messages to the Client
     *
     * @param int $qosLevel
     * @return Topic
     * @throws \unreal4u\MQTT\Exceptions\InvalidQoSLevel
     */
    private function setQoSLevel(QoSLevel $qosLevel): self
    {
        $this->qosLevel = $qosLevel;

        return $this;
    }

    /**
     * @return string
     */
    public function getTopicName(): string
    {
        return $this->topicName->getTopicName();
    }

    /**
     * @return int
     */
    public function getTopicQoSLevel(): int
    {
        return $this->qosLevel->getQoSLevel();
    }
}