ControleOnline\Command\WebSocketServerCommand

Complexity

Total Complexity

15

Size/Duplication

Total Lines	88
Duplicated Lines	0 %

Importance

Changes	3
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	3	1
C	execute()	0	77	14

<?php

namespace ControleOnline\Command;

use React\EventLoop\Loop;

The type React\EventLoop\Loop was not found. Maybe you did not declare it correctly or list all dependencies?

use React\Socket\Server;

The type React\Socket\Server was not found. Maybe you did not declare it correctly or list all dependencies?

use React\Socket\ConnectionInterface;

The type React\Socket\ConnectionInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Console\Attribute\AsCommand;

The type Symfony\Component\Console\Attribute\AsCommand was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Console\Command\Command;

The type Symfony\Component\Console\Command\Command was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Console\Input\InputArgument;

The type Symfony\Component\Console\Input\InputArgument was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Console\Input\InputInterface;

The type Symfony\Component\Console\Input\InputInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Console\Output\OutputInterface;

The type Symfony\Component\Console\Output\OutputInterface was not found. Maybe you did not declare it correctly or list all dependencies?

#[AsCommand(
    name: 'websocket:start',
    description: 'Inicia o servidor WebSocket com ReactPHP (com tentativa de handshake)'
)]
class WebSocketServerCommand extends Command
{
    protected function configure(): void
    {
        $this->addArgument('port', InputArgument::OPTIONAL, 'Porta para o servidor WebSocket', 8080);
    }

    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        $port = $input->getArgument('port');
        $output->writeln("Iniciando servidor WebSocket ReactPHP na porta {$port} (com tentativa de handshake)...");

        $loop = Loop::get();
        $socket = new Server("0.0.0.0:{$port}", $loop);
        $clients = new \SplObjectStorage();

        $socket->on('connection', function (ConnectionInterface $conn) use ($clients, $output) {
            $handshakeDone = false;
            $buffer = '';

            $conn->on('data', function ($data) use ($conn, $clients, $output, &$handshakeDone, &$buffer) {
                $buffer .= $data;

                if (!$handshakeDone) {
                    // Tenta encontrar o final dos headers HTTP (\r\n\r\n)
                    if (strpos($buffer, "\r\n\r\n") !== false) {
                        $headers = [];
                        $headerLines = explode("\r\n", substr($buffer, 0, strpos($buffer, "\r\n\r\n")));

                        // Analisa os headers
                        foreach ($headerLines as $line) {
                            if (strpos($line, ':') !== false) {
                                [$key, $value] = explode(':', $line, 2);
                                $headers[trim(strtolower($key))] = trim($value);
                            }
                        }

                        // Verifica se é uma requisição de upgrade WebSocket
                        if (isset($headers['upgrade']) && strtolower($headers['upgrade']) === 'websocket' &&
                            isset($headers['connection']) && strtolower($headers['connection']) === 'upgrade' &&
                            isset($headers['sec-websocket-key']) && isset($headers['sec-websocket-version']) && $headers['sec-websocket-version'] === '13') {

                            $secWebSocketKey = $headers['sec-websocket-key'];
                            $magicString = '258EAFA5-E914-47DA-95CA-C5AB0DC85B11';
                            $hash = base64_encode(sha1($secWebSocketKey . $magicString, true));
                            $response = "HTTP/1.1 101 Switching Protocols\r\n";
                            $response .= "Upgrade: websocket\r\n";
                            $response .= "Connection: Upgrade\r\n";
                            $response .= "Sec-WebSocket-Accept: " . $hash . "\r\n\r\n";

                            $conn->write($response);
                            $handshakeDone = true;
                            $clients->attach($conn);
                            $output->writeln("Nova conexão WebSocket estabelecida! ({$conn->resourceId})");

                            // Remove os headers do buffer para processar dados WebSocket futuros
                            $buffer = substr($buffer, strpos($buffer, "\r\n\r\n") + 4);

                        } else {
                            $output->writeln("Requisição de handshake inválida. Fechando conexão.");
                            $conn->close();
                        }
                    }
                } else {
                    // Lógica para lidar com dados WebSocket (decodificação de frames, etc.) virá aqui
                    // Por enquanto, apenas reenvia os dados para outros clientes
                    foreach ($clients as $client) {
                        if ($client !== $conn) {
                            $client->write($data);
                        }
                    }
                }
            });

            $conn->on('close', function () use ($conn, $clients, $output) {
                $clients->detach($conn);
                $output->writeln("Conexão fechada! ({$conn->resourceId})");
            });
        });

        $output->writeln('Servidor WebSocket ReactPHP iniciado (com tentativa de handshake)!');
        $loop->run();

        return Command::SUCCESS;
    }
}