LaravelSocketCluster\SocketCluster

Complexity

Total Complexity

6

Size/Duplication

Total Lines	92
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	publish()	0	9	1
A	emit()	0	21	2
A	receive()	0	4	1
A	error()	0	4	1

<?php

namespace LaravelSocketCluster;

use WebSocket\Client;
use Closure;
use Exception;

class SocketCluster
{
    /**
     * @var WebSocket\Client
     */
    protected $websocket;

    /**
     * @var string
     */
    protected $error;

    /**
     * Construct
     *
     * @param Client $websocket Websocket
     */
    public function __construct(Client $websocket)
    {
        $this->websocket = $websocket;

It seems like $websocket of type object<WebSocket\Client> is incompatible with the declared type object<LaravelSocketCluster\WebSocket\Client> of property $websocket.

    }

    /**
     * Publish Channel
     *
     * @param string       $channel
     * @param mixed        $data
     * @param Closure|null $callback
     *
     * @return void
     */
    public function publish($channel, $data, Closure $callback = null)
    {
        $pubData = [
            'channel' => $channel,
            'data' => $data,
        ];
        
        return $this->emit('#publish', $pubData, $callback);
    }

    /**
     * Emit Event
     *
     * @param string       $event
     * @param array        $data
     * @param Closure|null $callback
     *
     * @return void
     */
    public function emit($event, array $data, Closure $callback = null)

The parameter $callback is not used and could be removed.

    {
        try {
            $eventData = [
                'event' => $event,
                'data' => $data,
            ];

            $sendData = (string) @json_encode($eventData);

            $this->websocket->send($sendData);

            $this->error = null;

            return true;

        } catch (Exception $e) {
            $this->error = $e->getMessage();
            return false;
        }
    }

    /**
     * Receive
     *
     * @return string
     */
    public function receive()
    {
        return $this->websocket->receive();
    }

    /**
     * Get Error
     *
     * @return string|null
     */
    public function error()
    {
        return $this->error;
    }
}