ControleOnline\Command\WebSocketServerCommand

Complexity

Total Complexity

8

Size/Duplication

Total Lines	61
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
	execute()	0	50	?
A	hp$0 ➔ onClose()	0	4	1
A	hp$0 ➔ execute()	0	50	1
A	hp$0 ➔ __construct()	0	3	1
A	hp$0 ➔ onOpen()	0	4	1
A	hp$0 ➔ onError()	0	4	1
A	hp$0 ➔ onMessage()	0	5	3
A	configure()	0	5	1

<?php

namespace ControleOnline\Command;

use Ratchet\MessageComponentInterface;

The type Ratchet\MessageComponentInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Ratchet\ConnectionInterface;

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

use Ratchet\Server\IoServer;

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

use Ratchet\Http\HttpServer;

The type Ratchet\Http\HttpServer was not found. Maybe you did not declare it correctly or list all dependencies?

use Ratchet\WebSocket\WsServer;

The type Ratchet\WebSocket\WsServer 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\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?

class WebSocketServerCommand extends Command
{
    protected static $defaultName = 'app:websocket-server';

    protected function configure()
    {
        $this
            ->setDescription('Starts the WebSocket server')
            ->setHelp('This command starts a WebSocket server on port 8080');
    }

    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        $output->writeln('Starting WebSocket server on port 8080...');

        $server = IoServer::factory(
            new HttpServer(
                new WsServer(
                    new class implements MessageComponentInterface {
                        protected \SplObjectStorage $clients;

                        public function __construct()
                        {
                            $this->clients = new \SplObjectStorage();
                        }

                        public function onOpen(ConnectionInterface $conn)
                        {
                            $this->clients->attach($conn);
                            echo "New connection! ({$conn->resourceId})\n";
                        }

                        public function onMessage(ConnectionInterface $from, $msg)
                        {
                            foreach ($this->clients as $client) {
                                if ($from !== $client) {
                                    $client->send($msg);
                                }
                            }
                        }

                        public function onClose(ConnectionInterface $conn)
                        {
                            $this->clients->detach($conn);
                            echo "Connection closed! ({$conn->resourceId})\n";
                        }

                        public function onError(ConnectionInterface $conn, \Exception $e)
                        {
                            echo "An error occurred: {$e->getMessage()}\n";
                            $conn->close();
                        }
                    }
                )
            ),
            8080
        );

        $server->run();

        return Command::SUCCESS;
    }
}