LaravelSocketCluster\SCBroadcastServiceProvider

Complexity

Total Complexity

6

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	register()	0	4	1
A	boot()	0	10	1
A	makeSocketCluster()	0	12	4

<?php

namespace LaravelSocketCluster;

use Illuminate\Support\ServiceProvider as BaseServiceProvider;
use Illuminate\Broadcasting\BroadcastManager;
use WebSocket\Client as WebSocketClient;

class SCBroadcastServiceProvider extends BaseServiceProvider
{
    /**
     * Register bindings in the container.
     *
     * @return void
     */
    public function register()
    {
        //
    }

    /**
     * Register new BroadcastManager in boot
     *
     * @return void
     */
    public function boot()
    {
        $self = $this;

        $this->app
            ->make(BroadcastManager::class)
            ->extend('socketcluster', function ($app, $config) use ($self) {
                return new SCBroadcaster($self->makeSocketCluster($config));
            });
    }

    /**
     * Register service SocketCluster
     *
     * @return void
     */
    protected function makeSocketCluster($config)
    {
        if (empty($config['uri'])) {
            $scheme = $config['secure']==true ? 'wss' : 'ws';
            $host   = trim($config['host'], "/");
            $port   = !empty($config['port']) ? ":".$config['port'] : '';
            $path   = trim($config['path'], "/");
            $config['uri'] = sprintf("%s://%s%s/%s/", $scheme, $host, $port, $path);
        }
        
        return new SocketCluster(new WebSocketClient($config['uri']));
    }
}