Ozean12\GooglePubSubBundle\Service\Subscriber\PushSubscriberManager

Complexity

Total Complexity

4

Size/Duplication

Total Lines	68
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	2
Bugs	2	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
B	processMessage()	0	30	2
A	addSubscriber()	0	4	1

<?php

namespace Ozean12\GooglePubSubBundle\Service\Subscriber;

use Ozean12\GooglePubSubBundle\DTO\PushMessageRequestDTO;
use Ozean12\GooglePubSubBundle\Service\LoggerTrait;

/**
 * Class PushSubscriberManager
 */
class PushSubscriberManager
{
    use LoggerTrait;

    /**
     * @var string
     */
    private $projectId;

    /**
     * @var PushSubscriberInterface[]
     */
    private $subscribers;

    /**
     * PushSubscriberManager constructor.
     *
     * @param string $projectId
     */
    public function __construct($projectId)
    {
        $this->projectId = $projectId;
    }

    /**
     * @param PushMessageRequestDTO $messageRequest
     * @return bool
     */
    public function processMessage(PushMessageRequestDTO $messageRequest)
    {
        $subscription = str_replace(
            sprintf('projects/%s/subscriptions/', $this->projectId),
            '',
            $messageRequest->getSubscription()
        );

        $message = $messageRequest->getMessage();

        if (isset($this->subscribers[$subscription])) {
            $subscriber = $this->subscribers[$subscription];
            $subscriber->process($message);

            $this->logInfo('Received message : {subscription}[{message}]; Processed with {subscriberClass} subscriber', [
                'message' => $message->getMessageId(),
                'subscription' => $subscription,
                'subscriberClass' => get_class($subscriber),
            ]);

            return true;
        }

        $this->logInfo('Received message : {subscription}[{message}]; Subscriber not found', [
            'message' => $message->getMessageId(),
            'subscription' => $subscription,
        ]);

        return false;
    }

    /**
     * @param string                  $subscriptionName
     * @param PushSubscriberInterface $subscriber
     */
    public function addSubscriber($subscriptionName, PushSubscriberInterface $subscriber)
    {
        $this->subscribers[$subscriptionName] = $subscriber;
    }
}