laravel-websockets/src/Console/StartWebSocketServer.php

<?php

namespace BeyondCode\LaravelWebSockets\Console;

use BeyondCode\LaravelWebSockets\Facades\WebSocketRouter;
use BeyondCode\LaravelWebSockets\Server\Logger\ConnectionLogger;
use BeyondCode\LaravelWebSockets\Server\Logger\MessageLogger;
use Illuminate\Console\Command;
use BeyondCode\LaravelWebSockets\Server\WebSocketServer;

use React\EventLoop\Factory as LoopFactory;

class StartWebSocketServer extends Command
{
    protected $signature = 'websocket:start {--host=0.0.0.0} {--port=6001} ';

    protected $description = 'Start the Laravel WebSocket Server';

    public function handle()
    {
        $this
            ->configureMessageLogger()
            ->configureConnectionLogger()
            ->registerEchoRoutes()
            ->startWebSocketServer();
    }

    protected function configureMessageLogger()
    {
        app()->singleton(MessageLogger::class, function() {
            return (new MessageLogger($this->output))
                ->enable(config('app.debug'))
                //TODO: use real option
                ->verbose($this->hasOption('vvv'));
        });

        return $this;
    }

    protected function configureConnectionLogger()
    {
        app()->bind(ConnectionLogger::class, function() {
            return (new ConnectionLogger($this->output))
                ->enable(config('app.debug'))
                //TODO: use real option
                ->verbose($this->hasOption('vvv'));
        });

        return $this;
    }

    protected function registerEchoRoutes()
    {
        WebSocketRouter::echo();

        return $this;
    }

    protected function startWebSocketServer()
    {
        $this->info("Starting the WebSocket server on port {$this->option('port')}...");

        $routes = WebSocketRouter::getRoutes();

        /** 🎩 Start the magic 🎩 */
        (new WebSocketServer($routes))
            ->setHost($this->option('host'))
            ->setPort($this->option('port'))
            ->setConsoleOutput($this->output)
            ->run();
    }
}