ControleOnline\Command\WebSocketServerCommand

Complexity

Total Complexity

4

Size/Duplication

Total Lines	42
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	execute()	0	31	3
A	configure()	0	3	1

<?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'
)]
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}...");

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

        $socket->on('connection', function (ConnectionInterface $conn) use ($clients, $output) {
            $clients->attach($conn);
            $output->writeln("Nova conexão! ({$conn->resourceId})");

            $conn->on('data', function ($data) use ($conn, $clients) {
                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!');
        $loop->run();

        return Command::SUCCESS;
    }
}