Fresh\FirebaseCloudMessagingBundle\Client\FirebaseClient

Complexity

Total Complexity

4

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	sendMessage()	0	14	1
A	dispatchEvent()	0	14	2

<?php
/*
 * This file is part of the FirebaseCloudMessagingBundle
 *
 * (c) Artem Henvald <genvaldartem@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Fresh\FirebaseCloudMessagingBundle\Client;

use Fresh\FirebaseCloudMessagingBundle\Event\FirebaseEvents;
use Fresh\FirebaseCloudMessagingBundle\Event\MulticastMessageResponseEvent;
use Fresh\FirebaseCloudMessagingBundle\Message\Builder\MessageBuilder;
use Fresh\FirebaseCloudMessagingBundle\Message\Type\AbstractMessage;
use Fresh\FirebaseCloudMessagingBundle\Response\FirebaseResponseInterface;
use Fresh\FirebaseCloudMessagingBundle\Response\MulticastMessageResponse;
use Fresh\FirebaseCloudMessagingBundle\Response\ResponseProcessor;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;

/**
 * FirebaseClient.
 *
 * @author Artem Henvald <genvaldartem@gmail.com>
 */
class FirebaseClient
{
    /** @var HttpClient */
    private $httpClient;

    /** @var MessageBuilder */
    private $messageBuilder;

    /** @var ResponseProcessor */
    private $responseProcessor;

    /** @var EventDispatcherInterface */
    private $eventDispatcher;

    /**
     * @param HttpClient               $httpClient
     * @param MessageBuilder           $messageBuilder
     * @param ResponseProcessor        $responseProcessor
     * @param EventDispatcherInterface $eventDispatcher
     */
    public function __construct(HttpClient $httpClient, MessageBuilder $messageBuilder, ResponseProcessor $responseProcessor, EventDispatcherInterface $eventDispatcher)
    {
        $this->messageBuilder = $messageBuilder;
        $this->responseProcessor = $responseProcessor;
        $this->httpClient = $httpClient;
        $this->eventDispatcher = $eventDispatcher;
    }

    /**
     * @param AbstractMessage $message
     *
     * @return FirebaseResponseInterface
     */
    public function sendMessage(AbstractMessage $message): FirebaseResponseInterface
    {
        $this->messageBuilder->setMessage($message);

        $response = $this->httpClient->post(
            '',
            ['body' => $this->messageBuilder->getMessageAsJson()]
        );

        $processedResponse = $this->responseProcessor->processResponse($message, $response);
        $this->dispatchEvent($processedResponse);

        return $processedResponse;
    }

    /**
     * @param FirebaseResponseInterface $response
     */
    private function dispatchEvent(FirebaseResponseInterface $response): void
    {
        if ($response instanceof MulticastMessageResponse) {
            $this->eventDispatcher->dispatch(
                FirebaseEvents::MULTICAST_MESSAGE_RESPONSE_EVENT,
                new MulticastMessageResponseEvent(
                    $response->getMulticastId(),
                    $response->getSuccessfulMessageResults(),

It seems like $response->getSuccessfulMessageResults() targeting Fresh\FirebaseCloudMessagingBundle\Response\MulticastMessageResponseTrait::getSuccessfulMessageResults() can also be of type array<integer,object<Fresh\FirebaseCloudMessagingBundle\Response\MessageResult\SuccessfulMessageResult>>; however, Fresh\FirebaseCloudMessagingBundle\Event\MulticastMessageResponseEvent::__construct() does only seem to accept object<Fresh\FirebaseCloudMessagingBundle\Response\MessageResult\Collection\SuccessfulMessageResultCollection>, maybe add an additional type check?

                    $response->getFailedMessageResults(),

It seems like $response->getFailedMessageResults() targeting Fresh\FirebaseCloudMessagingBundle\Response\MulticastMessageResponseTrait::getFailedMessageResults() can also be of type array<integer,object<Fresh\FirebaseCloudMessagingBundle\Response\MessageResult\FailedMessageResult>>; however, Fresh\FirebaseCloudMessagingBundle\Event\MulticastMessageResponseEvent::__construct() does only seem to accept object<Fresh\FirebaseCloudMessagingBundle\Response\MessageResult\Collection\FailedMessageResultCollection>, maybe add an additional type check?

                    $response->getCanonicalTokenMessageResults()

It seems like $response->getCanonicalTokenMessageResults() targeting Fresh\FirebaseCloudMessagingBundle\Response\MulticastMessageResponseTrait::getCanonicalTokenMessageResults() can also be of type array<integer,object<Fresh\FirebaseCloudMessagingBundle\Response\MessageResult\CanonicalTokenMessageResult>>; however, Fresh\FirebaseCloudMessagingBundle\Event\MulticastMessageResponseEvent::__construct() does only seem to accept object<Fresh\FirebaseCloudMessagingBundle\Response\MessageResult\Collection\CanonicalTokenMessageResultCollection>, maybe add an additional type check?

                )
            );
        }
    }
}