Telegram\Bot\Conversations\ConversationBus

Complexity

Total Complexity

15

Size/Duplication

Total Lines	140
Duplicated Lines	11.43 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

6.38%

Importance

Changes	2
Bugs	0	Features	1

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getConversations()	0	4	1
A	addConversations()	0	8	2
B	addConversation()	16	37	5
A	handler()	0	6	1
A	execute()	0	8	2
A	removeConversations()	0	8	2
A	removeConversation()	0	6	1

<?php

namespace Telegram\Bot\Conversations;

use Telegram\Bot\Answers\AnswerBus;
use Telegram\Bot\Api;
use Telegram\Bot\Exceptions\TelegramSDKException;
use Telegram\Bot\Objects\Update;

/**
 * Class ConversationBus
 */
class ConversationBus extends AnswerBus
{
    /**
     * @var Conversation[]
     */
    private $conversations;

    /**
     * ConversationBus constructor.
     *
     * @param Api $telegram
     */
    public function __construct(Api $telegram)
    {
        $this->telegram = $telegram;
    }

    /**
     * @return Conversation[]
     */
    public function getConversations()
    {
        return $this->conversations;
    }

    /**
     * @param array $conversations
     * @return $this
     * @throws TelegramSDKException
     */
    public function addConversations(array $conversations)
    {
        foreach ($conversations as $conversation) {
            $this->addConversation($conversation);
        }

        return $this;
    }

    /**
     * @param $conversation
     * @return $this
     * @throws TelegramSDKException
     */
    public function addConversation($conversation)
    {
        if (!is_object($conversation)) {

This code seems to be duplicated across your project.

            if (!class_exists($conversation)) {
                throw new TelegramSDKException(
                    sprintf(
                        'Conversation class "%s" not found! Please make sure the class exists.',
                        $conversation
                    )
                );
            }

            if ($this->telegram->hasContainer()) {
                $conversation = $this->buildDependencyInjectedAnswer($conversation);
            } else {
                $conversation = new $conversation();
            }
        }

        if ($conversation instanceof ConversationInterface) {
            /*
             * At this stage we definitely have a proper conversation to use.
             *
             * @var Conversation $conversation
            */
            $this->conversations[get_class($conversation)] = $conversation;

            return $this;
        }

        throw new TelegramSDKException(
            sprintf(
                'Conversation class "%s" should be an instance of "Telegram\Bot\Conversations\ConversationInterface"',
                get_class($conversation)
            )
        );
    }

    /**
     * @param array $names
     * @return $this
     */
    public function removeConversations(array $names)
    {
        foreach ($names as $name) {
            $this->removeConversation($name);
        }

        return $this;
    }

    /**
     * @param $name
     * @return $this
     */
    public function removeConversation($name)
    {
        unset($this->conversations[$name]);

        return $this;
    }

    /**
     * Handles Inbound Messages and Executes Appropriate Command.
     *
     * @param $message
     * @param $update
     *
     * @throws TelegramSDKException
     *
     * @return Update
     */
    protected function handler($message, Update $update)

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

    {
        $this->execute($update->getMessage()->getFrom()->getCurrentConversation(), $update);

        return $update;
    }

    /**
     * Execute the command.
     *
     * @param $name
     * @param $message
     *
     * @return mixed
     */
    protected function execute($name, $update)
    {
        if (array_key_exists($name, $this->conversations)) {
            return $this->conversations[$name]->make($this->telegram, $update);
        }

        return 'Ok';
    }
}