N98\Magento\Command\Integration\CreateCommand

Complexity

Total Complexity

13

Size/Duplication

Total Lines	203
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	4

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	29	1
A	inject()	0	17	1
A	execute()	0	26	1
A	activateToken()	0	16	3
A	saveConsumer()	0	12	3
A	createIntegration()	0	17	2
A	grantPermissions()	0	8	2

<?php

namespace N98\Magento\Command\Integration;

use Magento\Framework\Exception\AlreadyExistsException;
use Magento\Framework\Exception\IntegrationException;
use Magento\Framework\Exception\LocalizedException;
use Magento\Integration\Model\Integration as IntegrationAlias;
use Magento\Integration\Model\Oauth\Consumer as ConsumerModel;
use Magento\Integration\Model\Oauth\Token;
use Magento\Integration\Model\ResourceModel\Oauth\Consumer;
use N98\Magento\Command\AbstractMagentoCommand;
use N98\Magento\Command\Integration\Renderer\TableRenderer as TableRenderer;
use Symfony\Component\Console\Exception\RuntimeException;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;

/**
 * Class CreateCommand
 * @package N98\Magento\Command\Integration
 */
class CreateCommand extends AbstractMagentoCommand
{
    /**
     * @var \Magento\Integration\Model\IntegrationFactory
     */
    private $integrationFactory;

    /**
     * @var \Magento\Integration\Model\OauthService
     */
    private $oauthService;

    /**
     * @var \Magento\Integration\Model\AuthorizationService
     */
    private $authorizationService;

    /**
     * @var \Magento\Integration\Model\Oauth\TokenFactory
     */
    private $tokenFactory;

    /**
     * @var \Magento\Integration\Model\IntegrationService
     */
    private $integrationService;

    /**
     * @var Consumer
     */
    private $consumerResource;

    /**
     * @var \Magento\Integration\Model\ResourceModel\Oauth\Token
     */
    private $tokenResource;

    protected function configure()
    {
        $this
            ->setName('integration:create')
            ->addArgument('name', InputArgument::REQUIRED, 'Name of the integration')
            ->addArgument('email', InputArgument::REQUIRED, 'Email')
            ->addArgument('endpoint', InputArgument::REQUIRED, 'Endpoint URL')
            ->addOption('consumer-key', '', InputOption::VALUE_REQUIRED, 'Consumer Key (length 32 chars)')
            ->addOption('consumer-secret', '', InputOption::VALUE_REQUIRED, 'Consumer Secret (length 32 chars)')
            ->addOption('access-token', '', InputOption::VALUE_REQUIRED, 'Access-Token (length 32 chars)')
            ->addOption('access-token-secret', '', InputOption::VALUE_REQUIRED, 'Access-Token Secret (length 32 chars)')
            ->addOption('resource', 'r', InputOption::VALUE_IS_ARRAY|InputOption::VALUE_REQUIRED, 'Defines a granted ACL resource', [])
            ->setDescription('Create a new integration');

        $help = <<<HELP
Creates a new integration e.g. for 3rd party applications.

<info>Keys and Secets</info>
Keys and secrets are generated by Magento if not defined by specify options.
If key or a secret is defined manually, you must guarantee that this key or secret is at least 32 characters long
and unique in the system.

<info>Permissions</info>
If you do not specify ACL resources by resource option, the new integration will get ALL permissions.
To see a list of all available ACL resources you can run the <comment>config:data:acl</comment> command.

HELP;
        $this->setHelp($help);
    }

    public function inject(
        \Magento\Integration\Model\IntegrationFactory $integrationFactory,
        \Magento\Integration\Model\IntegrationService $integrationService,
        \Magento\Integration\Model\ResourceModel\Oauth\Consumer $consumerResource,
        \Magento\Integration\Model\OauthService $oauthService,
        \Magento\Integration\Model\AuthorizationService $authorizationService,
        \Magento\Integration\Model\Oauth\TokenFactory $tokenFactory,
        \Magento\Integration\Model\ResourceModel\Oauth\Token $tokenResource
    ) {
        $this->integrationFactory = $integrationFactory;
        $this->integrationService = $integrationService;
        $this->oauthService = $oauthService;
        $this->authorizationService = $authorizationService;
        $this->tokenFactory = $tokenFactory;
        $this->consumerResource = $consumerResource;
        $this->tokenResource = $tokenResource;
    }

    /**
     * @param \Symfony\Component\Console\Input\InputInterface $input
     * @param \Symfony\Component\Console\Output\OutputInterface $output
     * @return int|void
     * @throws \Exception
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $integrationName = $input->getArgument('name');
        $integrationEmail = $this->getHelperSet()->get('parameter')->askEmail($input, $output);
        $integrationEndpoint = $input->getArgument('endpoint');

        $consumerKey = $input->getOption('consumer-key');
        $consumerSecret = $input->getOption('consumer-secret');
        $accessToken = $input->getOption('access-token');
        $accessTokenSecret = $input->getOption('access-token-secret');

        $grantedResources = $input->getOption('resource');

        $integrationModel = $this->createIntegration($integrationName, $integrationEmail, $integrationEndpoint);
        $consumerModel = $this->saveConsumer($integrationModel, $consumerKey, $consumerSecret);
        $this->grantPermissions($integrationModel, $grantedResources);
        $tokenModel = $this->activateToken($integrationModel, $accessToken, $accessTokenSecret);

        $table = new TableRenderer(
            $output,
            $integrationModel,
            $consumerModel,
            $tokenModel
        );
        $table->render();
    }

    /**
     * @param IntegrationAlias $integrationModel
     * @param $accessToken
     * @param $accessTokenSecret
     * @return Token
     * @throws AlreadyExistsException
     */
    private function activateToken(IntegrationAlias $integrationModel, $accessToken, $accessTokenSecret): Token
    {
        /** @var Token $tokenModel */
        $tokenModel = $this->tokenFactory->create();
        $tokenModel->createVerifierToken($integrationModel->getConsumerId());
        $tokenModel->setType(Token::TYPE_ACCESS);

        if ($accessToken !== null) {
            $tokenModel->setToken($accessToken);
        }
        if ($accessTokenSecret !== null) {
            $tokenModel->setSecret($accessTokenSecret);
        }
        $this->tokenResource->save($tokenModel);
        return $tokenModel;
    }

    /**
     * @param IntegrationAlias $integrationModel
     * @param $consumerKey
     * @param $consumerSecret
     * @return ConsumerModel
     * @throws AlreadyExistsException
     * @throws LocalizedException
     * @throws \Magento\Framework\Oauth\Exception
     */
    private function saveConsumer(IntegrationAlias $integrationModel, $consumerKey, $consumerSecret): ConsumerModel
    {
        $consumerModel = $this->oauthService->loadConsumer($integrationModel->getConsumerId());
        if ($consumerKey !== null) {
            $consumerModel->setKey($consumerKey);
        }
        if ($consumerSecret !== null) {
            $consumerModel->setSecret($consumerSecret);
        }
        $this->consumerResource->save($consumerModel);
        return $consumerModel;
    }

    /**
     * @param $integrationName
     * @param $integrationEmail
     * @param $integrationEndpoint
     * @return IntegrationAlias
     * @throws IntegrationException
     */
    private function createIntegration($integrationName, $integrationEmail, $integrationEndpoint): IntegrationAlias
    {
        $integrationModel = $this->integrationService->findByName($integrationName);

        if ($integrationModel->getId() > 0) {
            throw new RuntimeException('An integration with that name already exists');
        }

        $integrationModel = $this->integrationService->create([
            'name' => $integrationName,
            'email' => $integrationEmail,
            'status' => IntegrationAlias::STATUS_ACTIVE,
            'endpoint' => $integrationEndpoint,
            'setup_type' => IntegrationAlias::TYPE_MANUAL
        ]);
        return $integrationModel;
    }

    /**
     * @param IntegrationAlias $integrationModel
     * @param array $grantedResources
     * @throws LocalizedException
     */
    private function grantPermissions(IntegrationAlias $integrationModel, array $grantedResources)
    {
        if (empty($grantedResources)) {
            $this->authorizationService->grantAllPermissions($integrationModel->getId());
        } else {
            $this->authorizationService->grantPermissions($integrationModel->getId(), $grantedResources);
        }
    }
}