nstdio\notymo\GCMNotification

Complexity

Total Complexity

15

Size/Duplication

Total Lines	129
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
A	send()	0	15	3
A	sendMessage()	0	8	1
A	createPayload()	0	17	2
A	getTokens()	0	13	3
A	enqueue()	0	18	4
A	getConnectionParams()	0	9	1

<?php
namespace nstdio\notymo;

/**
 * Class GCMNotificationComponent
 */
class GCMNotification extends AbstractNotification
{
    /**
     *
     */
    const GCM_HOST = 'https://gcm-http.googleapis.com/gcm/send';

    /**
     *
     */
    const MAX_TOKENS = 1000;

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

    /**
     * GCMNotificationComponent constructor.
     *
     * @param $apiKey
     */
    public function __construct($apiKey)
    {
        parent::__construct();

        $this->headers = array(
            'Authorization: key=' . $apiKey,
            'Content-Type: application/json',
        );
    }

    /**
     *
     */
    public function send()
    {
        if ($this->messageQueue->isEmpty()) {
            return;
        }

        $this->openConnection();

        /** @var MessageInterface $message */
        foreach ($this->messageQueue as $message) {
            $this->sendMessage($message);
        }

        $this->stream->close();
    }

    /**
     * @param $message
     */
    private function sendMessage($message)
    {
        $data = $this->createPayload($message);

        $this->stream->write(CURLOPT_POSTFIELDS, json_encode($data));

        return $this->stream->read();
    }

    /**
     * @param MessageInterface $message
     *
     * @return array
     */
    final protected function createPayload(MessageInterface $message)
    {
        $data = array(
            'registration_ids' => $this->getTokens($message),
            'data'             => array(
                'message' => $message->getMessage(),
                'sound'   => $message->getSound(),
                'badge'   => $message->getBadge(),
            ),
        );
        $customData = $message->getCustomData();
        if (!empty($customData)) {
            $data['data'] = array_merge($data['data'], $customData);
        }

        return $data;
    }

    private function getTokens(MessageInterface $message)
    {
        $ret = array();
        if ($message->isMultiple()) {
            foreach ($message->getToken() as $token) {
                $ret[] = $token;
            }
        } else {
            $ret[] = $message->getToken();
        }

        return $ret;
    }

    public function enqueue(MessageInterface $message)
    {
        if ($message->isMultiple() && count($message->getToken()) > self::MAX_TOKENS) {
            $parts = array_chunk($message->getToken(), self::MAX_TOKENS);
            $message->setToken(null);
            $firstElement = array_shift($parts);

            foreach ($parts as $item) {
                $clonedMessage = clone $message;
                $clonedMessage->setToken($item);
                parent::enqueue($clonedMessage);
            }

            $message->setToken($firstElement);
        }

        parent::enqueue($message);
    }

    protected function getConnectionParams()
    {
        return array(
            CURLOPT_URL            => self::GCM_HOST,
            CURLOPT_POST           => true,
            CURLOPT_HTTPHEADER     => $this->headers,
            CURLOPT_RETURNTRANSFER => true,
        );
    }
}