Payever\ExternalIntegration\Plugins\Command\PluginCommandManager

Complexity

Total Complexity

5

Size/Duplication

Total Lines	53
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	executePluginCommands()	0	11	3
A	isCommandSupported()	0	3	1
A	__construct()	0	10	1

<?php
/**
 * PHP version 5.4 and 7
 *
 * @package   Payever\Plugins
 * @author    Hennadii.Shymanskyi <gendosua@gmail.com>
 * @copyright 2017-2019 payever GmbH
 * @license   MIT <https://opensource.org/licenses/MIT>
 */

namespace Payever\ExternalIntegration\Plugins\Command;

use Payever\ExternalIntegration\Plugins\Base\PluginRegistryInfoProviderInterface;
use Payever\ExternalIntegration\Plugins\Base\PluginsApiClientInterface;
use Payever\ExternalIntegration\Plugins\Http\ResponseEntity\CommandsResponseEntity;

class PluginCommandManager
{
    /** @var int|null */
    private $lastCommandTimestamp;

    /** @var PluginsApiClientInterface */
    private $pluginsApiClient;

    /** @var PluginCommandExecutorInterface */
    private $commandExecutor;

    /** @var PluginRegistryInfoProviderInterface */
    private $registryInfoProvider;

    public function __construct(
        PluginsApiClientInterface $pluginsApiClient,
        PluginCommandExecutorInterface $commandExecutor,
        PluginRegistryInfoProviderInterface $registryInfoProvider,
        $lastCommandTimestamp = null
    ) {
        $this->pluginsApiClient = $pluginsApiClient;
        $this->commandExecutor = $commandExecutor;
        $this->registryInfoProvider = $registryInfoProvider;
        $this->lastCommandTimestamp = $lastCommandTimestamp;
    }

    /**
     * Gets up to date commands and executes them
     *
     * @throws \Exception - bubbles up anything thrown by API or CommandExecutor
     */
    public function executePluginCommands()
    {
        $commandsResponse = $this->pluginsApiClient->getCommands($this->lastCommandTimestamp);
        /** @var CommandsResponseEntity $commandsResponseEntity */
        $commandsResponseEntity = $commandsResponse->getResponseEntity();
        $commandsList = $commandsResponseEntity->getCommands();

        foreach ($commandsList as $commandEntity) {
            if ($this->isCommandSupported($commandEntity->getName())) {
                $this->commandExecutor->executeCommand($commandEntity->getName(), $commandEntity->getValue());
                $this->pluginsApiClient->acknowledgePluginCommand($commandEntity->getId());
            }
        }
    }

    /**
     * @param string $commandName
     * @return bool
     */
    private function isCommandSupported($commandName)
    {
        return in_array($commandName, $this->registryInfoProvider->getSupportedCommands());
    }
}