BeyondCode\LaravelTinkerServer\Server

Complexity

Total Complexity

5

Size/Duplication

Total Lines	89
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	10

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
A	start()	0	8	1
A	createSocketServer()	0	24	1
A	createStdio()	0	20	1
A	executeCode()	0	4	1

<?php

namespace BeyondCode\LaravelTinkerServer;

use BeyondCode\LaravelTinkerServer\Shell\ExecutionClosure;
use Clue\React\Stdio\Stdio;
use Psy\Shell;
use React\EventLoop\Factory;
use React\EventLoop\LoopInterface;
use React\Socket\ConnectionInterface;
use React\Socket\Server as SocketServer;
use Symfony\Component\Console\Output\BufferedOutput;

class Server
{
    protected $host;

    /** @var LoopInterface */
    protected $loop;

    /** @var BufferedOutput */
    protected $shellOutput;

    /** @var Shell */
    protected $shell;

    /** @var BufferedOutput */
    protected $output;

    /** @var Stdio */
    protected $stdio;

    public function __construct($host, Shell $shell, BufferedOutput $output, LoopInterface $loop = null, Stdio $stdio = null)
    {
        $this->host = $host;
        $this->loop = $loop ?? Factory::create();
        $this->shell = $shell;
        $this->output = $output;
        $this->shellOutput = new BufferedOutput();
        $this->stdio = $stdio ?? $this->createStdio();
    }

    public function start()
    {
        $this->shell->setOutput($this->shellOutput);

        $this->createSocketServer();

        $this->loop->run();
    }

    protected function createSocketServer()
    {
        $socket = new SocketServer($this->host, $this->loop);

        $socket->on('connection', function (ConnectionInterface $connection) {
            $connection->on('data', function ($data) use ($connection) {
                $unserializedData = unserialize(base64_decode($data));

                $this->shell->setScopeVariables(array_merge($unserializedData, $this->shell->getScopeVariables()));

                $this->stdio->write(PHP_EOL);

                collect($unserializedData)->keys()->map(function ($variableName) {
                    $this->output->writeln('>> $'.$variableName);

                    $this->executeCode('$'.$variableName);

                    $this->output->write($this->shellOutput->fetch());

                    $this->stdio->write($this->output->fetch());
                });
            });
        });
    }

    protected function createStdio(): Stdio
    {
        $stdio = new Stdio($this->loop);

        $stdio->getReadline()->setPrompt('>> ');

The method Clue\React\Stdio\Stdio::getReadline() has been deprecated.

The method Clue\React\Stdio\Readline::setPrompt() has been deprecated with message: use Stdio::setPrompt() instead

        $stdio->on('data', function ($line) use ($stdio) {
            $line = rtrim($line, "\r\n");

            $stdio->getReadline()->addHistory($line);

The method Clue\React\Stdio\Stdio::getReadline() has been deprecated.

The method Clue\React\Stdio\Readline::addHistory() has been deprecated with message: use Stdio::addHistory() instead

            $this->executeCode($line);

            $this->output->write(PHP_EOL.$this->shellOutput->fetch());

            $this->stdio->write($this->output->fetch());
        });

        return $stdio;
    }

    protected function executeCode($code)
    {
        (new ExecutionClosure($this->shell, $code))->execute();
    }
}