StartServer::configureLoggers() - Code Metrics - Inspection of "[2.x] Major refactoring" - beyondcode/laravel-websockets - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#447)

by Alexandru

created 2020-09-10 20:22 UTC

StartServer::configureLoggers() A

↳ Parent: StartServer

Complexity

Conditions	1
Paths	1

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	6
rs	10
c	0
b	0
f	0
cc	1
nc	1
nop	0

<?php

namespace BeyondCode\LaravelWebSockets\Console\Commands;

use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
use BeyondCode\LaravelWebSockets\Contracts\StatisticsCollector;
use BeyondCode\LaravelWebSockets\Facades\StatisticsCollector as StatisticsCollectorFacade;
use BeyondCode\LaravelWebSockets\Facades\WebSocketRouter;
use BeyondCode\LaravelWebSockets\Server\Loggers\ConnectionLogger;
use BeyondCode\LaravelWebSockets\Server\Loggers\HttpLogger;
use BeyondCode\LaravelWebSockets\Server\Loggers\WebSocketsLogger;
use BeyondCode\LaravelWebSockets\ServerFactory;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\Cache;
use React\EventLoop\Factory as LoopFactory;

class StartServer extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'websockets:serve
        {--host=0.0.0.0}
        {--port=6001}
        {--disable-statistics : Disable the statistics tracking.}
        {--statistics-interval= : The amount of seconds to tick between statistics saving.}
        {--debug : Forces the loggers to be enabled and thereby overriding the APP_DEBUG setting.}
        {--test : Prepare the server, but do not start it.}
    ';

    /**
     * The console command description.
     *
     * @var string|null
     */
    protected $description = 'Start the LaravelWebSockets server.';

    /**
     * Get the loop instance.
     *
     * @var \React\EventLoop\LoopInterface
     */
    protected $loop;

    /**
     * The Pusher server instance.
     *
     * @var \Ratchet\Server\IoServer
     */
    public $server;

    /**
     * Initialize the command.
     *
     * @return void

     */
    public function __construct()
    {
        parent::__construct();

        $this->loop = LoopFactory::create();
    }

    /**
     * Run the command.
     *
     * @return void
     */
    public function handle()
    {
        $this->configureLoggers();

        $this->configureManagers();

        $this->configureStatistics();

        $this->configureRestartTimer();

        $this->startServer();
    }

    /**
     * Configure the loggers used for the console.
     *
     * @return void
     */
    protected function configureLoggers()
    {
        $this->configureHttpLogger();
        $this->configureMessageLogger();
        $this->configureConnectionLogger();
    }

    /**
     * Register the managers that are not resolved
     * in the package service provider.
     *
     * @return void
     */
    protected function configureManagers()
    {
        $this->laravel->singleton(ChannelManager::class, function () {

            $mode = config('websockets.replication.mode', 'local');

            $class = config("websockets.replication.modes.{$mode}.channel_manager");

            return new $class($this->loop);
        });
    }

    /**
     * Register the Statistics Collectors that
     * are not resolved in the package service provider.
     *
     * @return void
     */
    protected function configureStatistics()
    {
        $this->laravel->singleton(StatisticsCollector::class, function () {

            $replicationMode = config('websockets.replication.mode', 'local');

            $class = config("websockets.replication.modes.{$replicationMode}.collector");

            return new $class;
        });

        $this->laravel->singleton(StatisticsStore::class, function () {
            $class = config('websockets.statistics.store');

            return new $class;
        });

        if (! $this->option('disable-statistics')) {
            $intervalInSeconds = $this->option('statistics-interval') ?: config('websockets.statistics.interval_in_seconds', 3600);

            $this->loop->addPeriodicTimer($intervalInSeconds, function () {
                $this->line('Saving statistics...');

                StatisticsCollectorFacade::save();
            });
        }
    }

    /**
     * Configure the restart timer.
     *
     * @return void
     */
    public function configureRestartTimer()
    {
        $this->lastRestart = $this->getLastRestart();
class MyClass { }

$x = new MyClass();
$x->foo = true;

        $this->loop->addPeriodicTimer(10, function () {
            if ($this->getLastRestart() !== $this->lastRestart) {
                $this->loop->stop();
            }
        });
    }

    /**
     * Configure the HTTP logger class.
     *
     * @return void
     */
    protected function configureHttpLogger()

    {
        $this->laravel->singleton(HttpLogger::class, function () {
            return (new HttpLogger($this->output))
                ->enable($this->option('debug') ?: config('app.debug'))
                ->verbose($this->output->isVerbose());
        });
    }

    /**
     * Configure the logger for messages.
     *
     * @return void
     */
    protected function configureMessageLogger()

    {
        $this->laravel->singleton(WebSocketsLogger::class, function () {
            return (new WebSocketsLogger($this->output))
                ->enable($this->option('debug') ?: config('app.debug'))
                ->verbose($this->output->isVerbose());
        });
    }

    /**
     * Configure the connection logger.
     *
     * @return void
     */
    protected function configureConnectionLogger()
    {
        $this->laravel->bind(ConnectionLogger::class, function () {
            return (new ConnectionLogger($this->output))
                ->enable(config('app.debug'))
                ->verbose($this->output->isVerbose());
        });
    }

    /**
     * Start the server.
     *
     * @return void
     */
    protected function startServer()
    {
        $this->info("Starting the WebSocket server on port {$this->option('port')}...");

        $this->buildServer();

        // For testing, just boot up the server, run it
        // but exit after the next tick.
        if ($this->option('test')) {
            $this->loop->futureTick(function () {
                $this->loop->stop();
            });
        }

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

    /**
     * Build the server instance.
     *
     * @return void
     */
    protected function buildServer()
    {
        $this->server = new ServerFactory(

            $this->option('host'), $this->option('port')
        );

        $this->server = $this->server
            ->setLoop($this->loop)
            ->withRoutes(WebSocketRouter::getRoutes())
            ->setConsoleOutput($this->output)
            ->createServer();
    }

    /**
     * Get the last time the server restarted.
     *
     * @return int
     */
    protected function getLastRestart()
    {
        return Cache::get(
            'beyondcode:websockets:restart', 0
        );
    }
}


1		<?php
2
3		namespace BeyondCode\LaravelWebSockets\Console\Commands;
4
5		use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
6		use BeyondCode\LaravelWebSockets\Contracts\StatisticsCollector;
7		use BeyondCode\LaravelWebSockets\Facades\StatisticsCollector as StatisticsCollectorFacade;
8		use BeyondCode\LaravelWebSockets\Facades\WebSocketRouter;
9		use BeyondCode\LaravelWebSockets\Server\Loggers\ConnectionLogger;
10		use BeyondCode\LaravelWebSockets\Server\Loggers\HttpLogger;
11		use BeyondCode\LaravelWebSockets\Server\Loggers\WebSocketsLogger;
12		use BeyondCode\LaravelWebSockets\ServerFactory;
13		use Illuminate\Console\Command;
14		use Illuminate\Support\Facades\Cache;
15		use React\EventLoop\Factory as LoopFactory;
16
17		class StartServer extends Command
18		{
19		/**
20		* The name and signature of the console command.
21		*
22		* @var string
23		*/
24		protected $signature = 'websockets:serve
25		{--host=0.0.0.0}
26		{--port=6001}
27		{--disable-statistics : Disable the statistics tracking.}
28		{--statistics-interval= : The amount of seconds to tick between statistics saving.}
29		{--debug : Forces the loggers to be enabled and thereby overriding the APP_DEBUG setting.}
30		{--test : Prepare the server, but do not start it.}
31		';
32
33		/**
34		* The console command description.
35		*
36		* @var string\|null
37		*/
38		protected $description = 'Start the LaravelWebSockets server.';
39
40		/**
41		* Get the loop instance.
42		*
43		* @var \React\EventLoop\LoopInterface
44		*/
45		protected $loop;
46
47		/**
48		* The Pusher server instance.
49		*
50		* @var \Ratchet\Server\IoServer
51		*/
52		public $server;
53
54		/**
55		* Initialize the command.
56		*
57		* @return void
		0 ignored issues – show Comprehensibility Best Practice introduced 2020-08-24 06:54 UTC by Report Bug Copy Issue Report Adding a `@return` annotation to constructors is generally not recommended as a constructor does not have a meaningful return value. Adding a `@return` annotation to a constructor is not recommended, since a constructor does not have a meaningful return value. Please refer to the PHP core documentation on constructors. Loading history...
58		*/
59		public function __construct()
60		{
61		parent::__construct();
62
63		$this->loop = LoopFactory::create();
64		}
65
66		/**
67		* Run the command.
68		*
69		* @return void
70		*/
71		public function handle()
72		{
73		$this->configureLoggers();
74
75		$this->configureManagers();
76
77		$this->configureStatistics();
78
79		$this->configureRestartTimer();
80
81		$this->startServer();
82		}
83
84		/**
85		* Configure the loggers used for the console.
86		*
87		* @return void
88		*/
89		protected function configureLoggers()
90		{
91		$this->configureHttpLogger();
92		$this->configureMessageLogger();
93		$this->configureConnectionLogger();
94		}
95
96		/**
97		* Register the managers that are not resolved
98		* in the package service provider.
99		*
100		* @return void
101		*/
102		protected function configureManagers()
103		{
104	View Code Duplication	$this->laravel->singleton(ChannelManager::class, function () {
		0 ignored issues – show Duplication introduced 2020-09-10 20:15 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
105		$mode = config('websockets.replication.mode', 'local');
106
107		$class = config("websockets.replication.modes.{$mode}.channel_manager");
108
109		return new $class($this->loop);
110		});
111		}
112
113		/**
114		* Register the Statistics Collectors that
115		* are not resolved in the package service provider.
116		*
117		* @return void
118		*/
119		protected function configureStatistics()
120		{
121	View Code Duplication	$this->laravel->singleton(StatisticsCollector::class, function () {
		0 ignored issues – show Duplication introduced 2020-09-10 20:15 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
122		$replicationMode = config('websockets.replication.mode', 'local');
123
124		$class = config("websockets.replication.modes.{$replicationMode}.collector");
125
126		return new $class;
127		});
128
129		$this->laravel->singleton(StatisticsStore::class, function () {
130		$class = config('websockets.statistics.store');
131
132		return new $class;
133		});
134
135		if (! $this->option('disable-statistics')) {
136		$intervalInSeconds = $this->option('statistics-interval') ?: config('websockets.statistics.interval_in_seconds', 3600);
137
138		$this->loop->addPeriodicTimer($intervalInSeconds, function () {
139		$this->line('Saving statistics...');
140
141		StatisticsCollectorFacade::save();
142		});
143		}
144		}
145
146		/**
147		* Configure the restart timer.
148		*
149		* @return void
150		*/
151		public function configureRestartTimer()
152		{
153		$this->lastRestart = $this->getLastRestart();
		0 ignored issues – show Bug introduced 2020-09-10 20:15 UTC by Report Bug Copy Issue Report The property `lastRestart` does not exist. Did you maybe forget to declare it? In PHP it is possible to write to properties without declaring them. For example, the following is perfectly valid PHP code: class MyClass { } $x = new MyClass(); $x->foo = true; Generally, it is a good practice to explictly declare properties to avoid accidental typos and provide IDE auto-completion: class MyClass { public $foo; } $x = new MyClass(); $x->foo = true; Loading history...
154
155		$this->loop->addPeriodicTimer(10, function () {
156		if ($this->getLastRestart() !== $this->lastRestart) {
157		$this->loop->stop();
158		}
159		});
160		}
161
162		/**
163		* Configure the HTTP logger class.
164		*
165		* @return void
166		*/
167	View Code Duplication	protected function configureHttpLogger()
		0 ignored issues – show Duplication introduced 2018-12-04 21:28 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
168		{
169		$this->laravel->singleton(HttpLogger::class, function () {
170		return (new HttpLogger($this->output))
171		->enable($this->option('debug') ?: config('app.debug'))
172		->verbose($this->output->isVerbose());
173		});
174		}
175
176		/**
177		* Configure the logger for messages.
178		*
179		* @return void
180		*/
181	View Code Duplication	protected function configureMessageLogger()
		0 ignored issues – show Duplication introduced 2018-12-04 21:28 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
182		{
183		$this->laravel->singleton(WebSocketsLogger::class, function () {
184		return (new WebSocketsLogger($this->output))
185		->enable($this->option('debug') ?: config('app.debug'))
186		->verbose($this->output->isVerbose());
187		});
188		}
189
190		/**
191		* Configure the connection logger.
192		*
193		* @return void
194		*/
195		protected function configureConnectionLogger()
196		{
197		$this->laravel->bind(ConnectionLogger::class, function () {
198		return (new ConnectionLogger($this->output))
199		->enable(config('app.debug'))
200		->verbose($this->output->isVerbose());
201		});
202		}
203
204		/**
205		* Start the server.
206		*
207		* @return void
208		*/
209		protected function startServer()
210		{
211		$this->info("Starting the WebSocket server on port {$this->option('port')}...");
212
213		$this->buildServer();
214
215		// For testing, just boot up the server, run it
216		// but exit after the next tick.
217		if ($this->option('test')) {
218		$this->loop->futureTick(function () {
219		$this->loop->stop();
220		});
221		}
222
223		$this->server->run();
224		}
225
226		/**
227		* Build the server instance.
228		*
229		* @return void
230		*/
231		protected function buildServer()
232		{
233		$this->server = new ServerFactory(
		0 ignored issues – show Documentation Bug introduced 2020-09-10 20:15 UTC by Report Bug Copy Issue Report It seems like `new \BeyondCode\LaravelW... $this->option('port'))` of type `object<BeyondCode\Larave...bSockets\ServerFactory>` is incompatible with the declared type `object<Ratchet\Server\IoServer>` of property `$server`. Our type inference engine has found an assignment to a property that is incompatible with the declared type of that property. Either this assignment is in error or the assigned type should be added to the documentation/type hint for that property.. Loading history...
234		$this->option('host'), $this->option('port')
235		);
236
237		$this->server = $this->server
238		->setLoop($this->loop)
239		->withRoutes(WebSocketRouter::getRoutes())
240		->setConsoleOutput($this->output)
241		->createServer();
242		}
243
244		/**
245		* Get the last time the server restarted.
246		*
247		* @return int
248		*/
249		protected function getLastRestart()
250		{
251		return Cache::get(
252		'beyondcode:websockets:restart', 0
253		);
254		}
255		}
256

beyondcode / laravel-websockets

Pull Request — master (#447)

StartServer::configureLoggers() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like