nstdio\notymo\AbstractNotification

Complexity

Total Complexity

6

Size/Duplication

Total Lines	55
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	3

Test Coverage

Coverage

88.89%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
	send()	0	1	?
	createPayload()	0	1	?
	getConnectionParams()	0	1	?
A	__construct()	0	4	1
A	enqueue()	0	4	1
A	setStreamWrapper()	0	4	1
A	openConnection()	0	8	1
A	lazyInitStream()	0	6	2

<?php
namespace nstdio\notymo;

/**
 * Class AbstractNotification
 *
 * @package nstdio\notymo
 * @author  Edgar Asatryan <nstdio@gmail.com>
 */
abstract class AbstractNotification implements PushNotificationInterface
{
    /**
     * @var MessageQueue
     */
    protected $messageQueue;

    /**
     * @var Connection
     */
    protected $stream;

    public function __construct()
    {
        $this->messageQueue = new MessageQueue();
    }

    abstract public function send();

    public function enqueue(MessageInterface $message)
    {
        $this->messageQueue->enqueue($message);
    }

    /**
     * @param Connection $wrapper
     */
    public function setStreamWrapper(Connection $wrapper)
    {
        $this->stream = $wrapper;
    }

    abstract protected function createPayload(MessageInterface $message);

    final protected function openConnection()
    {
        $this->lazyInitStream();

        $this->stream->open($this->getConnectionParams(), null);

        return $this;
    }

    private function lazyInitStream()
    {
        if ($this->stream === null) {
            $this->stream = new CurlWrapper();
        }
    }

    /**
     * @return array
     */
    abstract protected function getConnectionParams();
}