Gockets\Client

Complexity

Total Complexity

13

Size/Duplication

Total Lines	109
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	showAll()	0	5	1
A	edit()	0	12	1
A	show()	0	9	2
A	prepare()	0	23	4
A	publish()	0	11	2
A	close()	0	9	2

<?php declare(strict_types=1);

namespace Gockets;

use Gockets\Adapter\ChannelAdapter;
use Gockets\Adapter\ResponseAdapter;
use Gockets\Contract\AdapterInterface;
use Gockets\Contract\GocketsInterface;
use Gockets\Exception\ChannelNotFoundException;
use Gockets\Factory\HttpFactory;
use Gockets\Model\Channel;
use Gockets\Model\ChannelOptions;
use Gockets\Model\Params;
use Gockets\Model\Response;

/**
 * Gockets Client
 *
 * Implements available Gockets methods.
 *
 * @package Gockets
 */
class Client implements GocketsInterface
{
    /**
     * Help to convert json into defined Channel objects.
     *
     * @var AdapterInterface
     */
    private $channelAdapter;

    /**
     * Help to convert json into defined Response objects.
     *
     * @var AdapterInterface
     */
    private $responseAdapter;

    /**
     * HTTP client to communicate with daemon.
     *
     * @var \GuzzleHttp\Client
     */
    private static $http;

    public function __construct(Params $params)
    {
        $this->channelAdapter = new ChannelAdapter();
        $this->responseAdapter = new ResponseAdapter();
        self::$http = HttpFactory::createHttpClient($params);
    }

    public function prepare(?ChannelOptions $channelOptions = null): Channel
    {
        if (is_null($channelOptions)) {
            $options = [];
        } else {
            $body = [];

            if (!empty($channelOptions->getHookUrl())) {
                $body['subscriber_message_hook_url'] = $channelOptions->getHookUrl();
            }

            if (!empty($channelOptions->getTag())) {
                $body['tag'] = $channelOptions->getTag();
            }

            $options = [
                \GuzzleHttp\RequestOptions::JSON => $body,
            ];
        }

        $result = self::$http->post('channel/prepare', $options);

        return $this->channelAdapter->convertJson($result->getBody()->getContents());
    }

    public function show(string $publisherToken): Channel
    {
        $result = self::$http->get("channel/show/{$publisherToken}");

        if ($result->getStatusCode() === 404) {
            throw new ChannelNotFoundException($result->getBody()->getContents());
        }

        return $this->channelAdapter->convertJson($result->getBody()->getContents());
    }

    public function showAll(): array
    {
        $result = self::$http->get('channel/show');

        return $this->channelAdapter->convertJsonArray($result->getBody()->getContents());
    }

    public function edit(string $publisherToken, ChannelOptions $channelOptions): Channel
    {
        $options = [
            \GuzzleHttp\RequestOptions::JSON => [
                'subscriber_message_hook_url' => $channelOptions->getHookUrl(),
                'tag' => $channelOptions->getTag(),
            ],
        ];

        $result = self::$http->patch("channel/edit/{$publisherToken}", $options);

        return $this->channelAdapter->convertJson($result->getBody()->getContents());
    }

    public function publish($data, string $publisherToken): Response
    {
        $result = self::$http->post("channel/publish/{$publisherToken}", [
            \GuzzleHttp\RequestOptions::JSON => $data,
        ]);

        if ($result->getStatusCode() === 404) {
            throw new ChannelNotFoundException($result->getBody()->getContents());
        }

        return $this->responseAdapter->convertJson($result->getBody()->getContents());
    }

    public function close(string $publisherToken): Response
    {
        $result = self::$http->delete("channel/publish/{$publisherToken}");

        if ($result->getStatusCode() === 404) {
            throw new ChannelNotFoundException($result->getBody()->getContents());
        }

        return $this->responseAdapter->convertJson($result->getBody()->getContents());
    }
}