Deployer\Ssh\SshClient::run()

Complexity

Conditions	12
Paths	96

Size

Total Lines	76
Code Lines	46

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function run(Host $host, string $command, RunParams $params): string
    {
        $shellId = 'id$' . bin2hex(random_bytes(10));
        $shellCommand = $host->getShell();
        if ($host->has('become') && !empty($host->get('become'))) {
            $shellCommand = "sudo -H -u {$host->get('become')} " . $shellCommand;
        }

        $ssh = array_merge(['ssh'], $host->connectionOptionsArray(), [$host->connectionString(), ": $shellId; $shellCommand"]);

        // -vvv for ssh command
        if ($this->output->isDebug()) {
            $sshString = $ssh[0];
            for ($i = 1; $i < count($ssh); $i++) {

It seems like you are calling the size function count() as part of the test condition. You might want to compute the size beforehand, and not on each iteration.

                $sshString .= ' ' . escapeshellarg((string) $ssh[$i]);
            }
            $this->output->writeln("[$host] $sshString");
        }

        if (!empty($params->cwd)) {
            $command = "cd $params->cwd && ($command)";
        }

        if (!empty($params->env)) {
            $env = env_stringify($params->env);
            $command = "export $env; $command";
        }

        if (!empty($params->secrets)) {
            foreach ($params->secrets as $key => $value) {
                $command = str_replace('%' . $key . '%', strval($value), $command);
            }
        }

        $this->pop->command($host, 'run', $command);
        $this->logger->log("[{$host->getAlias()}] run $command");


        $process = new Process($ssh);
        $process
            ->setInput($command)
            ->setTimeout($params->timeout)
            ->setIdleTimeout($params->idleTimeout);

        $callback = function ($type, $buffer) use ($params, $host) {
            $this->logger->printBuffer($host, $type, $buffer);
            $this->pop->callback($host, $params->forceOutput)($type, $buffer);
        };

        try {
            $process->run($callback);
        } catch (ProcessTimedOutException $exception) {
            // Let's try to kill all processes started by this command.
            $pid = $this->run($host, "ps x | grep $shellId | grep -v grep | awk '{print \$1}'", $params->with(timeout: 10));
            // Minus before pid means all processes in this group.
            $this->run($host, "kill -9 -$pid", $params->with(timeout: 20));
            throw new TimeoutException(
                $command,
                $exception->getExceededTimeout(),
            );
        }

        $output = $process->getOutput();
        $exitCode = $process->getExitCode();

        if ($exitCode !== 0 && !$params->nothrow) {
            throw new RunException(
                $host,
                $command,
                $exitCode,

It seems like $exitCode can also be of type null; however, parameter $exitCode of Deployer\Exception\RunException::__construct() does only seem to accept integer, maybe add an additional type check?

                $output,
                $process->getErrorOutput(),
            );
        }

        return $output;
    }