LibSSH2\Sessions\Shell

Complexity

Total Complexity

11

Size/Duplication

Total Lines	95
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	shell()	0	8	2
A	output()	0	15	3
A	__destruct()	0	3	1
A	__construct()	0	5	1
A	write()	0	16	4

<?php
namespace LibSSH2\Sessions;

use LibSSH2\Authentication\Authentication;
use LibSSH2\Configuration;
use LibSSH2\Connection;

/**
 * Shell class.
 *
 * Shell interface.
 *
 * @package LibSSH2\Sessions
 */
class Shell extends Connection
{

    /**
     * SSH interactive shell resource.
     *
     * @var resource
     */
    private $stream;
    private $command;

The private property $command is not used, and could be removed.

    /**
     * Constructor.
     *
     * @param  object $configuration  Configuration class object
     * @param  object $authentication Authentication class object
     * @return void
     */
    public function __construct(Configuration $configuration, Authentication $authentication)
    {
        parent::__construct($configuration, $authentication);

        $this->shell();
    }
	
    /**
     * Destructor.
     *
     * @return void
     */
    public function __destruct()
    {
        fclose($this->stream);
    }

    /**
     * Returns SSH interactive shell.
     *
     * @return resouce SSH interactive shell

The type LibSSH2\Sessions\resouce was not found. Maybe you did not declare it correctly or list all dependencies?

     */
    final public function shell()
    {
        if (($this->stream = @ssh2_shell($this->connection)) === false)

The condition $this->stream = @ssh2_shell($this->connection) === false can never be true.

        {
            throw new \RuntimeException($this->get_error_message());
        }
        sleep(1);
        return $this;

The expression return $this returns the type LibSSH2\Sessions\Shell which is incompatible with the documented return type LibSSH2\Sessions\resouce.

    }

    /**
     * Retrieves shell command output.
     *
     * @return void
     */
    final public function output()
    {
        $stdout = [];
        while (!preg_match('/RETURN_CODE:\[([0-9]+)\]/', implode(PHP_EOL, $stdout), $retval))
        {
            $buffer = fgets($this->stream);
            if (!empty($buffer))
            {
                $stdout[] = trim($buffer);
                //print $buffer;
            }
        }
        $stdout = preg_replace('/RETURN_CODE:\[([0-9]+)\]/', '', $stdout);
        $this->set_output(implode(PHP_EOL, $stdout));
        $this->set_exitstatus($retval[1]);
    }

    /**
     * Execute remote command via SSH (shell).
     *
     * @param  string   $command  command being executed
     * @param  instance $terminal Terminal instance
     * @return object
     */
    final public function write($command, $returncode = FALSE)
    {
        $command = ($returncode == FALSE) ? $command : $command.'; echo "RETURN_CODE:[$?]";';
        $write_count = 0;
        $string_len = strlen($command.PHP_EOL);
        while ($write_count < $string_len)
        {
            $fwrite_count = fwrite($this->stream, substr($command.PHP_EOL, $write_count), 1024);
            if ($fwrite_count === FALSE)
            {
                throw new \RuntimeException('failed to write command to stream');
            }
            $write_count += $fwrite_count;
        }
        sleep(1);
        return $this;
    }
	
}