Facile\CrossbarHTTPPublisherBundle\Publisher\Publisher

Complexity

Total Complexity

9

Size/Duplication

Total Lines	105
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	publish()	0	18	2
A	prepareBody()	0	16	3
B	prepareSignature()	0	28	3

<?php

namespace Facile\CrossbarHTTPPublisherBundle\Publisher;

use Facile\CrossbarHTTPPublisherBundle\Exception\PublishRequestException;
use GuzzleHttp\Client;

/**
 * Class Publisher
 * @package Facile\CrossbarHTTPPublisherBundle\Publisher
 */
class Publisher
{
    /** @var Client */
    private $client;

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

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

    /**
     * @param Client $client
     * @param $key
     * @param $secret
     */
    public function __construct(Client $client, $key, $secret)
    {
        $this->client = $client;
        $this->key = $key;
        $this->secret = $secret;
    }

    /**
     * @param $topic string
     * @param $args array|null
     * @param $kwargs array|null
     * @return array JSON decoded response
     * @throws \Exception
     */
    public function publish($topic, array $args = null, array $kwargs = null)
    {
        $jsonBody = $this->prepareBody($topic, $args, $kwargs);

        try {
            $response = $this->client->post(
                '',
                [
                    'json' => $jsonBody,
                    'query' => $this->prepareSignature($jsonBody)
                ]
            );
        } catch (\Exception $e) {
            throw new PublishRequestException($e->getMessage(), 500, $e);
        }

        return json_decode($response->getBody(), true);
    }

    /**
     * @param $topic
     * @param $args
     * @param $kwargs
     * @return array
     */
    private function prepareBody($topic, $args, $kwargs)
    {
        $body = [];

        $body['topic'] = $topic;

        if (null !== $args) {
            $body['args'] = $args;
        }

        if (null !== $kwargs) {
            $body['kwargs'] = $kwargs;
        }

        return $body;
    }

    /**
     * @param array $body
     * @return array
     */
    private function prepareSignature($body)
    {
        $query = [];

        $seq = mt_rand(0, pow(2, 12));
        $now = new \DateTime('now', new \DateTimeZone('UTC'));
        $timestamp = $now->format("Y-m-d\TH:i:s.u\Z");

        $query['seq'] = $seq;
        $query['timestamp'] = $timestamp;

        if (null !== $this->key && null !== $this->secret) {

            $nonce = mt_rand(0, pow(2, 53));
            $signature = hash_hmac(
                'sha256',
                $this->key . $timestamp . $seq . $nonce . json_encode($body),
                $this->secret,
                true
            );

            $query['key'] = $this->key;
            $query['nonce'] = $nonce;
            $query['signature'] = strtr(base64_encode($signature), '+/', '-_');
        }

        return $query;
    }
}