EdwinLuijten\Ekko\Broadcast\Broadcasters\PusherBroadcaster

Complexity

Total Complexity

9

Size/Duplication

Total Lines	77
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	auth()	0	11	3
A	validAuthenticationResponse()	0	13	2
A	broadcast()	0	6	2
A	getPusher()	0	4	1

<?php

namespace EdwinLuijten\Ekko\Broadcast\Broadcasters;

use EdwinLuijten\Ekko\Broadcast\Identity;
use EdwinLuijten\Ekko\Broadcast\StrUtil;
use Pusher;

class PusherBroadcaster extends AbstractBroadcaster implements BroadcasterInterface
{
    /**
     * @var Pusher
     */
    private $pusher;

    /**
     * PusherBroadcaster constructor.
     * @param Pusher $pusher
     */
    public function __construct(Pusher $pusher)
    {
        $this->pusher = $pusher;
    }

    /**
     * @param Identity $identity
     * @return mixed
     * @throws \Exception
     */
    public function auth(Identity $identity)
    {
        if (StrUtil::startsWith($identity->channel, ['private-', 'presence-']) && empty($identity->identifier)) {
            throw new \Exception('Unauthorized', 403);
        }

        return parent::verifyThatIdentityCanAccessChannel(

It seems like you call parent on a different method (verifyThatIdentityCanAccessChannel() instead of auth()). Are you sure this is correct? If so, you might want to change this to $this->verifyThatIdentityCanAccessChannel().

            $identity,
            str_replace(['private-', 'presence-'], '', $identity->channel)
        );
    }

    /**
     * @param Identity $identity
     * @param $response
     * @return string signature
     */
    public function validAuthenticationResponse(Identity $identity, $response)
    {
        if (StrUtil::startsWith($identity->channel, 'private')) {
            return $this->pusher->socket_auth($identity->channel, $identity->socketId);
        } else {
            return $this->pusher->presence_auth(
                $identity->channel,
                $identity->socketId,
                $identity->identifier,
                $response
            );
        }
    }

    /**
     * Broadcast the given event.
     *
     * @param  array $channels
     * @param  string $event
     * @param  array $payload
     * @return void
     */
    public function broadcast(array $channels, $event, array $payload = [])
    {
        $socket = isset($payload['socket']) ? $payload['socket'] : null;

        $this->pusher->trigger($this->formatChannels($channels), $event, $payload, $socket);
    }

    /**
     * Get the Pusher instance.
     *
     * @return Pusher
     */
    public function getPusher()
    {
        return $this->pusher;
    }
}