WebSocketsServiceProvider::boot() - Code Metrics - Inspection of "Redis as a replication backend for scalability" - beyondcode/laravel-websockets - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#140)

unknown

created 2019-09-23 19:51 UTC

WebSocketsServiceProvider::boot() A

↳ Parent: WebSocketsServiceProvider

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	25
rs	9.52
c	0
b	0
f	0
cc	2
nc	2
nop	0

<?php

namespace BeyondCode\LaravelWebSockets;

use Pusher\Pusher;
use Psr\Log\LoggerInterface;
use Illuminate\Support\Facades\Gate;
use Illuminate\Support\Facades\Route;
use Illuminate\Support\ServiceProvider;
use Illuminate\Broadcasting\BroadcastManager;
use BeyondCode\LaravelWebSockets\Server\Router;
use BeyondCode\LaravelWebSockets\Apps\AppProvider;
use BeyondCode\LaravelWebSockets\PubSub\Drivers\LocalClient;
use BeyondCode\LaravelWebSockets\PubSub\Drivers\RedisClient;
use BeyondCode\LaravelWebSockets\PubSub\ReplicationInterface;
use BeyondCode\LaravelWebSockets\WebSockets\Channels\ChannelManager;
use BeyondCode\LaravelWebSockets\Dashboard\Http\Controllers\SendMessage;
use BeyondCode\LaravelWebSockets\Dashboard\Http\Controllers\ShowDashboard;
use BeyondCode\LaravelWebSockets\PubSub\Broadcasters\RedisPusherBroadcaster;
use BeyondCode\LaravelWebSockets\Dashboard\Http\Controllers\AuthenticateDashboard;
use BeyondCode\LaravelWebSockets\Dashboard\Http\Controllers\DashboardApiController;
use BeyondCode\LaravelWebSockets\WebSockets\Channels\ChannelManagers\ArrayChannelManager;
use BeyondCode\LaravelWebSockets\Dashboard\Http\Middleware\Authorize as AuthorizeDashboard;
use BeyondCode\LaravelWebSockets\Statistics\Http\Middleware\Authorize as AuthorizeStatistics;
use BeyondCode\LaravelWebSockets\Statistics\Http\Controllers\WebSocketStatisticsEntriesController;

class WebSocketsServiceProvider extends ServiceProvider
{
    public function boot()
    {
        $this->publishes([
            __DIR__.'/../config/websockets.php' => base_path('config/websockets.php'),
        ], 'config');

        if (! class_exists('CreateWebSocketsStatisticsEntries')) {
            $this->publishes([
                __DIR__.'/../database/migrations/create_websockets_statistics_entries_table.php.stub' => database_path('migrations/'.date('Y_m_d_His', time()).'_create_websockets_statistics_entries_table.php'),
            ], 'migrations');
        }

        $this
            ->registerRoutes()
            ->registerDashboardGate();

        $this->loadViewsFrom(__DIR__.'/../resources/views/', 'websockets');

        $this->commands([
            Console\StartWebSocketServer::class,
            Console\CleanStatistics::class,
        ]);

        $this->configurePubSub();
    }

    protected function configurePubSub()
    {
        if (config('websockets.replication.enabled') !== true || config('websockets.replication.driver') !== 'redis') {
            $this->app->singleton(ReplicationInterface::class, function () {
                return new LocalClient();
            });

            return;
        }

        $this->app->singleton(ReplicationInterface::class, function () {
            return (new RedisClient())->boot($this->loop);
class MyClass { }

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

        $this->app->get(BroadcastManager::class)->extend('redis-pusher', function ($app, array $config) {
            $pusher = new Pusher(
                $config['key'], $config['secret'],
                $config['app_id'], $config['options'] ?? []
            );

            if ($config['log'] ?? false) {
                $pusher->setLogger($this->app->make(LoggerInterface::class));
            }

            return new RedisPusherBroadcaster(
                $pusher,
                $config['app_id'],
                $this->app->make('redis'),
                $config['connection'] ?? null
            );
        });
    }

    public function register()
    {
        $this->mergeConfigFrom(__DIR__.'/../config/websockets.php', 'websockets');

        $this->app->singleton('websockets.router', function () {
            return new Router();
        });

        $this->app->singleton(ChannelManager::class, function () {
            return config('websockets.channel_manager') !== null && class_exists(config('websockets.channel_manager'))
                ? $this->app->make(config('websockets.channel_manager')) : new ArrayChannelManager();
        });

        $this->app->singleton(AppProvider::class, function () {
            return $this->app->make(config('websockets.app_provider'));
        });
    }

    protected function registerRoutes()
    {
        Route::prefix(config('websockets.path'))->group(function () {
            Route::middleware(config('websockets.middleware', [AuthorizeDashboard::class]))->group(function () {
                Route::get('/', ShowDashboard::class);
                Route::get('/api/{appId}/statistics', [DashboardApiController::class, 'getStatistics']);
                Route::post('auth', AuthenticateDashboard::class);
                Route::post('event', SendMessage::class);
            });

            Route::middleware(AuthorizeStatistics::class)->group(function () {
                Route::post('statistics', [WebSocketStatisticsEntriesController::class, 'store']);
            });
        });

        return $this;
    }

    protected function registerDashboardGate()
    {
        Gate::define('viewWebSocketsDashboard', function ($user = null) {

            return $this->app->environment('local');
        });

        return $this;
    }
}


1			<?php
2
3			namespace BeyondCode\LaravelWebSockets;
4
5			use Pusher\Pusher;
6			use Psr\Log\LoggerInterface;
7			use Illuminate\Support\Facades\Gate;
8			use Illuminate\Support\Facades\Route;
9			use Illuminate\Support\ServiceProvider;
10			use Illuminate\Broadcasting\BroadcastManager;
11			use BeyondCode\LaravelWebSockets\Server\Router;
12			use BeyondCode\LaravelWebSockets\Apps\AppProvider;
13			use BeyondCode\LaravelWebSockets\PubSub\Drivers\LocalClient;
14			use BeyondCode\LaravelWebSockets\PubSub\Drivers\RedisClient;
15			use BeyondCode\LaravelWebSockets\PubSub\ReplicationInterface;
16			use BeyondCode\LaravelWebSockets\WebSockets\Channels\ChannelManager;
17			use BeyondCode\LaravelWebSockets\Dashboard\Http\Controllers\SendMessage;
18			use BeyondCode\LaravelWebSockets\Dashboard\Http\Controllers\ShowDashboard;
19			use BeyondCode\LaravelWebSockets\PubSub\Broadcasters\RedisPusherBroadcaster;
20			use BeyondCode\LaravelWebSockets\Dashboard\Http\Controllers\AuthenticateDashboard;
21			use BeyondCode\LaravelWebSockets\Dashboard\Http\Controllers\DashboardApiController;
22			use BeyondCode\LaravelWebSockets\WebSockets\Channels\ChannelManagers\ArrayChannelManager;
23			use BeyondCode\LaravelWebSockets\Dashboard\Http\Middleware\Authorize as AuthorizeDashboard;
24			use BeyondCode\LaravelWebSockets\Statistics\Http\Middleware\Authorize as AuthorizeStatistics;
25			use BeyondCode\LaravelWebSockets\Statistics\Http\Controllers\WebSocketStatisticsEntriesController;
26
27			class WebSocketsServiceProvider extends ServiceProvider
28			{
29			public function boot()
30			{
31			$this->publishes([
32			__DIR__.'/../config/websockets.php' => base_path('config/websockets.php'),
33			], 'config');
34
35			if (! class_exists('CreateWebSocketsStatisticsEntries')) {
36			$this->publishes([
37			__DIR__.'/../database/migrations/create_websockets_statistics_entries_table.php.stub' => database_path('migrations/'.date('Y_m_d_His', time()).'_create_websockets_statistics_entries_table.php'),
38			], 'migrations');
39			}
40
41			$this
42			->registerRoutes()
43			->registerDashboardGate();
44
45			$this->loadViewsFrom(__DIR__.'/../resources/views/', 'websockets');
46
47			$this->commands([
48			Console\StartWebSocketServer::class,
49			Console\CleanStatistics::class,
50			]);
51
52			$this->configurePubSub();
53			}
54
55			protected function configurePubSub()
56			{
57			if (config('websockets.replication.enabled') !== true \|\| config('websockets.replication.driver') !== 'redis') {
58			$this->app->singleton(ReplicationInterface::class, function () {
59			return new LocalClient();
60			});
61
62			return;
63			}
64
65			$this->app->singleton(ReplicationInterface::class, function () {
66			return (new RedisClient())->boot($this->loop);
			0 ignored issues – show Bug introduced 2019-09-03 15:52 UTC by Report Bug Copy Issue Report The property `loop` 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...
67			});
68
69			$this->app->get(BroadcastManager::class)->extend('redis-pusher', function ($app, array $config) {
70			$pusher = new Pusher(
71			$config['key'], $config['secret'],
72			$config['app_id'], $config['options'] ?? []
73			);
74
75			if ($config['log'] ?? false) {
76			$pusher->setLogger($this->app->make(LoggerInterface::class));
77			}
78
79			return new RedisPusherBroadcaster(
80			$pusher,
81			$config['app_id'],
82			$this->app->make('redis'),
83			$config['connection'] ?? null
84			);
85			});
86			}
87
88			public function register()
89			{
90			$this->mergeConfigFrom(__DIR__.'/../config/websockets.php', 'websockets');
91
92			$this->app->singleton('websockets.router', function () {
93			return new Router();
94			});
95
96			$this->app->singleton(ChannelManager::class, function () {
97			return config('websockets.channel_manager') !== null && class_exists(config('websockets.channel_manager'))
98			? $this->app->make(config('websockets.channel_manager')) : new ArrayChannelManager();
99			});
100
101			$this->app->singleton(AppProvider::class, function () {
102			return $this->app->make(config('websockets.app_provider'));
103			});
104			}
105
106			protected function registerRoutes()
107			{
108			Route::prefix(config('websockets.path'))->group(function () {
109			Route::middleware(config('websockets.middleware', [AuthorizeDashboard::class]))->group(function () {
110			Route::get('/', ShowDashboard::class);
111			Route::get('/api/{appId}/statistics', [DashboardApiController::class, 'getStatistics']);
112			Route::post('auth', AuthenticateDashboard::class);
113			Route::post('event', SendMessage::class);
114			});
115
116			Route::middleware(AuthorizeStatistics::class)->group(function () {
117			Route::post('statistics', [WebSocketStatisticsEntriesController::class, 'store']);
118			});
119			});
120
121			return $this;
122			}
123
124			protected function registerDashboardGate()
125			{
126			Gate::define('viewWebSocketsDashboard', function ($user = null) {
			0 ignored issues – show Unused Code introduced 2018-12-04 21:28 UTC by Report Bug Copy Issue Report The parameter `$user` is not used and could be removed. This check looks from parameters that have been defined for a function or method, but which are not used in the method body. Loading history...
127			return $this->app->environment('local');
128			});
129
130			return $this;
131			}
132			}
133

beyondcode / laravel-websockets

Pull Request — master (#140)

WebSocketsServiceProvider::boot() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like