ApiClients\Client\Pusher\Event

Complexity

Total Complexity

13

Size/Duplication

Total Lines	97
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

100%

Importance

Changes

0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	jsonSerialize()	0	4	1
A	getEvent()	0	4	1
A	getChannel()	0	4	1
A	getData()	0	4	1
A	isError()	0	4	1
A	subscriptionSucceeded()	0	4	1
A	connectionEstablished()	0	4	1
A	subscribeOn()	0	4	1
A	unsubscribeOn()	0	4	1
A	ping()	0	4	1
A	createFromMessage()	0	8	2

<?php declare(strict_types=1);

namespace ApiClients\Client\Pusher;

final class Event implements \JsonSerializable
{
    /**
     * @var string
     */
    private $event;

    /**
     * @var string
     */
    private $channel;

    /**
     * @var array
     */
    private $data;

    /**
     * @param string $event
     * @param array  $data
     * @param string $channel
     */
    public function __construct(string $event, array $data, string $channel = '')
    {
        $this->event = $event;
        $this->data = $data;
        $this->channel = $channel;
    }

    public static function createFromMessage(array $message): self
    {
        return new self(
            $message['event'],
            \is_array($message['data']) ? $message['data'] : \json_decode($message['data'], true),
            $message['channel'] ?? ''
        );
    }

    public function jsonSerialize()
    {
        return \json_encode(['event' => $this->event, 'data' => $this->data, 'channel' => $this->channel]);
    }

    /**
     * @return string
     */
    public function getEvent()
    {
        return $this->event;
    }

    /**
     * @return string
     */
    public function getChannel()
    {
        return $this->channel;
    }

    /**
     * @return array
     */
    public function getData()
    {
        return $this->data;
    }

    public static function isError(Event $event): bool
    {
        return $event->getEvent() === 'pusher:error';
    }

    public static function subscriptionSucceeded(Event $event): bool
    {
        return $event->getEvent() !== 'pusher_internal:subscription_succeeded';
    }

    public static function connectionEstablished(Event $event): bool
    {
        return $event->getEvent() === 'pusher:connection_established';
    }

    public static function subscribeOn(string $channel): array
    {
        return ['event' => 'pusher:subscribe', 'data' => ['channel' => $channel]];
    }

    public static function unsubscribeOn(string $channel): array
    {
        return ['event' => 'pusher:unsubscribe', 'data' => ['channel' => $channel]];
    }

    public static function ping(): array
    {
        return ['event' => 'pusher:ping'];
    }
}