Alawar\NginxPushStreamBundle\Connection

Complexity

Total Complexity

17

Size/Duplication

Total Lines	156
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	6
Bugs	1	Features	2

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	addFilter()	0	4	1
A	filter()	0	7	2
A	filterTokens()	0	8	2
A	setIdGenerator()	0	4	1
A	setSender()	0	4	1
A	getSubUrls()	0	10	2
A	getPubUrl()	0	6	1
B	send()	0	36	6

<?php

namespace Alawar\NginxPushStreamBundle;

use Alawar\NginxPushStreamBundle\Filter\FilterInterface;
use Alawar\NginxPushStreamBundle\Http\SenderInterface;
use Alawar\NginxPushStreamBundle\IdGenerator\IdGeneratorInterface;

class Connection
{
    /**
     * @var string
     */
    protected $pubUrl;

    /**
     * @var array
     */
    protected $subUrls;

    /**
     * @var FilterInterface[]
     */
    protected $filters = array();

    /**
     * @var IdGeneratorInterface
     */
    protected $idGenerator = null;

    /**
     * @var SenderInterface
     */
    protected $sender = null;

    /**
     * @param string $pubUrl
     * @param array $subUrls
     */
    public function __construct($pubUrl, $subUrls)
    {
        $this->pubUrl = $pubUrl;
        $this->subUrls = $subUrls;
    }

    /**
     * @param FilterInterface $filter
     */
    public function addFilter(FilterInterface $filter)
    {
        $this->filters[] = $filter;
    }

    /**
     * @param string $data
     * @return string
     */
    public function filter($data)
    {
        foreach ($this->filters as $filter) {
            $data = $filter->filter($data);
        }
        return $data;
    }

    /**
     * @param string[] $tokens
     * @return string[]
     */
    public function filterTokens(array $tokens)
    {
        $res = array();
        foreach ($tokens as $token) {
            $res[] = $this->filter($token);
        }
        return $res;
    }

    /**
     * @param IdGeneratorInterface $idGenerator
     */
    public function setIdGenerator(IdGeneratorInterface $idGenerator)
    {
        $this->idGenerator = $idGenerator;
    }

    /**
     * @param SenderInterface $sender
     */
    public function setSender(SenderInterface $sender)
    {
        $this->sender = $sender;
    }

    /**
     * @param string[] $tokens
     * @return array
     */
    public function getSubUrls(array $tokens)
    {
        $filteredTokens = $this->filterTokens($tokens);
        $tokensString = join('/', $filteredTokens);
        $res = array();
        foreach ($this->subUrls as $type => $subUrl) {
            $res[$type] = str_replace('{tokens}', $tokensString, $subUrl);
        }
        return $res;
    }

    /**
     * @param $token string
     * @return string
     */
    public function getPubUrl($token)
    {
        $filteredToken = $this->filter($token);
        $res = str_replace('{token}', $filteredToken, $this->pubUrl);
        return $res;
    }

    /**
     * @param string $token
     * @param mixed $data
     * @param string $type
     * @param string $id
     * @return bool
     */
    public function send($token, $data, $type = null, $id = null)
    {
        if (!$this->sender) {
            return false;
        }

        $url = $this->getPubUrl($token);

        if ($id === null && $this->idGenerator) {
            $id = $this->idGenerator->generate();
        }

        $msg = array();
        $msg['token'] = $token;

        $headers = array();
        if ($id !== null) {
            $msg['id'] = $id;
            $headers['Event-ID'] = preg_replace('/\\r\\n/', '', $id);
        }

        if ($type !== null) {
            $msg['type'] = $type;
            $headers['Event-Type'] = preg_replace('/\\r\\n/', '', $type);
        }

        $headers['Content-Type'] = 'application/json';

        $msg['data'] = $data;

        $json = json_encode($msg);

        $body = $json . "\r\n";

        return $this->sender->send($url, $body, $headers);
    }
}