NotificationChannels\Fcm\FcmChannel

Complexity

Total Complexity

11

Size/Duplication

Total Lines	89
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	sendToFcm()	0	11	2
A	getClientHeaders()	0	14	2
A	__construct()	0	4	1
B	send()	0	32	6

<?php

namespace NotificationChannels\Fcm;

use GuzzleHttp\Client;
use GuzzleHttp\Exception\RequestException;
use Illuminate\Notifications\Notification;
use NotificationChannels\Fcm\Exceptions\CouldNotSendNotification;

class FcmChannel
{
    const DEFAULT_API_URL = 'https://fcm.googleapis.com';
    const MAX_TOKEN_PER_REQUEST = 1000;

    /**
     * @var Client
     */
    protected $client;

    public function __construct(Client $client)
    {
        $this->client = $client;
    }

    /**
     * Send the given notification.
     *
     * @param mixed $notifiable
     * @param \Illuminate\Notifications\Notification $notification
     *
     * @throws \NotificationChannels\Fcm\Exceptions\CouldNotSendNotification
     */
    public function send($notifiable, Notification $notification)
    {
        // Get the token/s from the model
        if (! $notifiable->routeNotificationFor('fcm')) {
            return;
        }
        $tokens = (array) $notifiable->routeNotificationFor('fcm');

        if (empty($tokens)) {
            return;
        }

        // Get the message from the notification class
        $fcmMessage = $notification->toFcm($notifiable);

The method toFcm() does not seem to exist on object<Illuminate\Notifications\Notification>.

        if (empty($fcmMessage)) {
            return;
        }

        if (count($tokens) == 1) {
            // Do not use multicast if there is only one recipient
            $fcmMessage->setTo($tokens[0]);
            $this->sendToFcm($fcmMessage);
        } else {
            // Use multicast because there are multiple recipients
            $partialTokens = array_chunk($tokens, self::MAX_TOKEN_PER_REQUEST, false);
            foreach ($partialTokens as $tokens) {
                $fcmMessage->setRegistrationIds($tokens);
                $this->sendToFcm($fcmMessage);
            }
        }
    }

    protected function sendToFcm($fcmMessage)
    {
        try {
            $this->client->request('POST', '/fcm/send', [
                'headers' => $this->getClientHeaders($fcmMessage),
                'body' => $fcmMessage->toJson(),
            ]);
        } catch (RequestException $requestException) {
            throw CouldNotSendNotification::serviceRespondedWithAnError($requestException);
        }
    }

    /**
     * This is used to get the headers for the FCM request. We can add customization to the headers here.
     *
     * @param FcmMessage $fcmMessage
     * @return array
     */
    protected function getClientHeaders(FcmMessage $fcmMessage)
    {
        $headers = [
            'Authorization' => sprintf('key=%s', config('broadcasting.connections.fcm.key')),
            'Content-Type' => 'application/json',
        ];

        // Override the FCM key from the config
        if (! empty($fcmMessage->getFcmKey())) {
            $headers['Authorization'] = sprintf('key=%s', $fcmMessage->getFcmKey());
        }

        return $headers;
    }
}