Consolidation\SiteProcess\Transport\SshTransport

Complexity

Total Complexity

7

Size/Duplication

Total Lines	76
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	configure()	0	4	1
A	wrap()	0	12	1
A	addChdir()	0	11	1
A	getTransportOptions()	0	11	2
A	getCommandToExecute()	0	7	1

<?php

namespace Consolidation\SiteProcess\Transport;

use Drush\Drush;
use Psr\Log\LoggerInterface;
use Robo\Common\IO;
use Symfony\Component\Console\Style\OutputStyle;
use Symfony\Component\Process\Process;
use Consolidation\SiteProcess\Util\RealtimeOutputHandler;
use Symfony\Component\Console\Output\ConsoleOutputInterface;
use Consolidation\SiteAlias\AliasRecord;

/**
 * SshTransport knows how to wrap a command such that it runs on a remote
 * system via the ssh cli.
 */
class SshTransport implements TransportInterface
{
    protected $tty;

    public function __construct(AliasRecord $siteAlias)
    {
        $this->siteAlias = $siteAlias;

The property siteAlias does not exist. Did you maybe forget to declare it?

    }

    /**
     * inheritdoc
     */
    public function configure(Process $process)
    {
        $this->tty = $process->isTty();
    }

    /**
     * inheritdoc
     */
    public function wrap($args)
    {
        $transport = ['ssh'];
        $transportOptions = $this->getTransportOptions();
        $commandToExecute = $this->getCommandToExecute($args);

        return array_merge(
            $transport,
            $transportOptions,
            $commandToExecute
        );
    }

    /**
     * @inheritdoc
     */
    public function addChdir($cd, $args)
    {
        return array_merge(
            [
                'cd',
                $cd,
                '&&',
            ],
            $args
        );
    }

    /**
     * getTransportOptions returns the transport options for the tranport
     * mechanism itself
     */
    protected function getTransportOptions()
    {
        $transportOptions = [
            $this->siteAlias->get('ssh.options', '-o PasswordAuthentication=no'),
            $this->siteAlias->remoteHostWithUser(),
        ];
        if ($this->tty) {
            array_unshift($transportOptions, '-t');
        }
        return $transportOptions;
    }

    /**
     * getCommandToExecute processes the arguments for the command to
     * be executed such that they are appropriate for the transport mechanism.
     */
    protected function getCommandToExecute($args)
    {
        // @TODO: Methinks this needs to be escaped for the target system.
        $commandToExecute = implode(' ', $args);

        return [$commandToExecute];
    }
}