Notimatica\Driver\Providers\Chrome

Complexity

Total Complexity

18

Size/Duplication

Total Lines	160
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	9

Test Coverage

Coverage

83.33%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	initBrowser()	0	13	4
A	batch()	0	4	1
A	prepareRequests()	0	12	2
A	calculateChunkSize()	0	17	3
A	getRequestContent()	0	13	2
A	manifest()	0	7	1
B	send()	0	31	5

<?php

namespace Notimatica\Driver\Providers;

use GuzzleHttp\Client;
use GuzzleHttp\Psr7\Request;
use GuzzleHttp\Psr7\Response;
use Notimatica\Driver\Contracts\Notification;
use Notimatica\Driver\Contracts\Subscriber;
use Notimatica\Driver\Driver;
use Notimatica\Driver\Events\NotificationFailed;
use Notimatica\Driver\Events\NotificationSent;

class Chrome extends AbstractProvider
{
    const NAME            = 'chrome';
    const DEFAULT_TTL     = 2419200;
    const DEFAULT_TIMEOUT = 30;

    /**
     * @var array
     */
    protected static $headers = [
        'Content-Type' => 'application/json',
    ];

    /**
     * Init Browser.
     *
     * @param array $config
     */
    protected static function initBrowser(array $config)
    {
        if (static::$browser) {
            return;
        }

        static::$browser = new Client([
            'timeout' => isset($config['timeout']) ? $config['timeout'] : static::DEFAULT_TIMEOUT,
        ]);

        static::$headers['TTL'] = isset($config['ttl']) ? $config['ttl'] : static::DEFAULT_TTL;
        static::$headers['Authorization'] = 'key=' . $config['api_key'];
    }

    /**
     * Split endpoints for batch requests.
     *
     * @param  array $endpoints
     * @return array
     */
    protected function batch(array $endpoints)
    {
        return array_chunk($endpoints, (int) $this->config['batch_chunk_size']);
    }

    /**
     * Send notification.
     *
     * @param  Notification $notification
     * @param  Subscriber[] $subscribers
     */
    public function send(Notification $notification, array $subscribers)
    {
        static::initBrowser($this->config);
        $total = count($subscribers);

        $this->flush(
            $subscribers,
            function (Response $response, $index) use ($notification, $total) {
                try {
                    $response = json_decode($response->getBody());

                    if (json_last_error() !== JSON_ERROR_NONE) {
                        throw new \Exception();
                    }

                    if ($response->success > 0) {
                        Driver::emit(new NotificationSent($notification, (int) $response->success));
                    }

                    if ($response->failure > 0) {
                        Driver::emit(new NotificationFailed($notification, (int) $response->failure));
                    }
                } catch (\Exception $e) {
                    Driver::emit(new NotificationFailed($notification, $this->calculateChunkSize($index, $total)));
                }
            },
            function ($reason, $index) use ($notification, $total) {
                Driver::emit(new NotificationFailed($notification, $this->calculateChunkSize($index, $total)));
            }
        );
    }

    /**
     * Send request.
     *
     * @param  array $subscribers
     * @param  null $payload
     * @return \Generator
     */
    protected function prepareRequests($subscribers, $payload = null)
    {
        $url = $this->config['url'];
        $headers = static::$headers;

        foreach ($this->batch($subscribers) as $index => $chunk) {
            $content = $this->getRequestContent($chunk);
            $headers['Content-Length'] = strlen($content);

            yield new Request('POST', $url, $headers, $content);
        }
    }

    /**
     * Calculate chunk size.
     * Problem is, we don't know the latter chunk size.
     *
     * @param  int $index
     * @param  int $total
     * @return int
     */
    protected function calculateChunkSize($index, $total)
    {
        $chunkSize = (int) $this->config['batch_chunk_size'];

        $offset = ($index + 1) * $chunkSize;
        $chunks = ceil($total / $chunkSize);

        if ($offset <= $total) {
            $return = $chunkSize;
        } elseif ($offset > $total + $chunkSize) {
            $return = 0;
        } else {
            $return = $total - ($chunks - 1) * $chunkSize;
        }

        return (int) $return;
    }

    /**
     * Send notification to endpoints.
     *
     * @param  Subscriber[] $subscribers
     * @return array
     */
    protected function getRequestContent(array $subscribers)
    {
        $tokens = [];

        /** @var Subscriber $subscriber */
        foreach ($subscribers as $subscriber) {
            $tokens[] = $subscriber->getToken();
        }

        return json_encode([
            'registration_ids' => $tokens,
        ]);
    }

    /**
     * Generate manifest file text.
     *
     * @return string
     */
    public function manifest()
    {
        return json_encode([
            'name' => $this->project->name,
            'gcm_sender_id' => $this->config['sender_id'],
        ], JSON_PRETTY_PRINT);
    }
}